feat: sns (#255)

Author: totalimmersion

app.go

@@ -28,6 +28,9 @@ type AppSettings struct {
 	SqsURL                   *string                `json:"sqs_url,omitempty"`
 	SqsKey                   *string                `json:"sqs_key,omitempty"`
 	SqsSecret                *string                `json:"sqs_secret,omitempty"`
+	SnsTopicArn              *string                `json:"sns_topic_arn,omitempty"`
+	SnsKey                   *string                `json:"sns_key,omitempty"`
+	SnsSecret                *string                `json:"sns_secret,omitempty"`
 	BeforeMessageSendHookURL *string                `json:"before_message_send_hook_url,omitempty"`
 	CustomActionHandlerURL   *string                `json:"custom_action_handler_url,omitempty"`
 
@@ -225,6 +228,25 @@ func (c *Client) CheckSqs(ctx context.Context, req *CheckSQSRequest) (*CheckSQSR
 	return &resp, err
 }
 
+type CheckSNSRequest struct {
+	SnsTopicARN string `json:"sns_topic_arn"`
+	SnsKey      string `json:"sns_key"`
+	SnsSecret   string `json:"sns_secret"`
+}
+
+type CheckSNSResponse struct {
+	Status string                 `json:"status"`
+	Error  string                 `json:"error"`
+	Data   map[string]interface{} `json:"data"`
+	Response
+}
+
+func (c *Client) CheckSns(ctx context.Context, req *CheckSNSRequest) (*CheckSNSResponse, error) {
+	var resp CheckSNSResponse
+	err := c.makeRequest(ctx, http.MethodPost, "check_sns", nil, req, &resp)
+	return &resp, err
+}
+
 type CheckPushRequest struct {
 	MessageID            string `json:"message_id,omitempty"`
 	ApnTemplate          string `json:"apn_template,omitempty"`

app_test.go

@@ -85,6 +85,19 @@ func TestClient_CheckSqs(t *testing.T) {
 	require.NotNil(t, resp.Data)
 }
 
+func TestClient_CheckSns(t *testing.T) {
+	c := initClient(t)
+	ctx := context.Background()
+
+	req := &CheckSNSRequest{SnsTopicARN: "arn:aws:sns:us-east-1:123456789012:sns-topic", SnsKey: "key", SnsSecret: "secret"}
+	resp, err := c.CheckSns(ctx, req)
+
+	require.NoError(t, err)
+	require.NotEmpty(t, resp.Error)
+	require.Equal(t, "error", resp.Status)
+	require.NotNil(t, resp.Data)
+}
+
 func TestClient_CheckPush(t *testing.T) {
 	c := initClient(t)
 	ch := initChannel(t, c)