add tag parameter to send to sendgrid

Author: pthieu

.openapi-generator/FILES

@@ -8,6 +8,7 @@ internal/server/api_notification.go
 internal/server/api_notification_service.go
 internal/server/api_sms.go
 internal/server/api_sms_service.go
+internal/server/error.go
 internal/server/helpers.go
 internal/server/impl.go
 internal/server/model_email_recipient.go
@@ -16,8 +17,8 @@ internal/server/model_error.go
 internal/server/model_mail_message.go
 internal/server/model_send_bulk_mail_request.go
 internal/server/model_send_bulk_mail_response.go
-internal/server/model_send_bulk_mail_response_failed.go
-internal/server/model_send_bulk_mail_response_successful.go
+internal/server/model_send_bulk_mail_response_failed_inner.go
+internal/server/model_send_bulk_mail_response_successful_inner.go
 internal/server/model_send_mail_request.go
 internal/server/model_send_mail_response.go
 internal/server/model_send_slack_message_request.go

.openapi-generator/VERSION

@@ -1 +1 @@
-5.0.0-beta3
+6.6.0

api/notification-service.yaml

@@ -264,6 +264,10 @@ components:
           $ref: '#/components/schemas/MailMessage'
         headers:
           $ref: '#/components/schemas/MailHeaders'
+        tags:
+          type: array
+          items:
+            type: string
 
     SendBulkMailRequest:
       type: object

internal/mail/mail.go

@@ -29,7 +29,7 @@ func SendBulkMail(toList []server.EmailRecipient, from server.EmailSender, cc []
 	// Create goroutines for each send
 	for _, to := range toList {
 		go func(to server.EmailRecipient) {
-			response, err := SendIndividualMail([]server.EmailRecipient{to}, from, cc, bcc, headers, message, client)
+			response, err := SendIndividualMail([]server.EmailRecipient{to}, from, cc, bcc, headers, message, client, []string{})
 			responseChannel <- BulkSendAttempt{to.Address, response, err}
 			wg.Done()
 		}(to)
@@ -42,7 +42,7 @@ func SendBulkMail(toList []server.EmailRecipient, from server.EmailSender, cc []
 }
 
 // SendIndividualMail sends an email message
-func SendIndividualMail(to []server.EmailRecipient, from server.EmailSender, cc []server.EmailRecipient, bcc []server.EmailRecipient, headers map[string]string, message server.MailMessage, client Client) (*rest.Response, error) {
+func SendIndividualMail(to []server.EmailRecipient, from server.EmailSender, cc []server.EmailRecipient, bcc []server.EmailRecipient, headers map[string]string, message server.MailMessage, client Client, tags []string) (*rest.Response, error) {
 	sendMessage := sendgridMail.NewV3Mail()
 
 	sendMessage.SetFrom(sendgridMail.NewEmail(from.Name, from.Address))
@@ -78,6 +78,10 @@ func SendIndividualMail(to []server.EmailRecipient, from server.EmailSender, cc
 		}
 	}
 
+	if len(tags) > 0 {
+		sendMessage.AddCategories(tags...)
+	}
+
 	return client.Send(sendMessage)
 }
 

internal/mail/mail_test.go

@@ -39,7 +39,7 @@ func TestSendMail(t *testing.T) {
 		return m.Headers["X-Test-Header"] == headers["X-Test-Header"]
 	})
 	client.On("Send", headersMatcher).Return(nil, nil)
-	mail.SendIndividualMail(toList, from, cc, bcc, headers, message, &client)
+	mail.SendIndividualMail(toList, from, cc, bcc, headers, message, &client, []string{})
 	client.AssertNumberOfCalls(t, "Send", 1)
 }
 

internal/service/api_email_service.go

@@ -43,7 +43,7 @@ func (s *EmailApiService) SendEmail(ctx context.Context, sendMailRequest server.
 
 	client := sendgrid.NewSendClient(s.config.SendgridAPIKey)
 
-	response, err := mail.SendIndividualMail(sendMailRequest.ToAddresses, sendMailRequest.FromAddress, sendMailRequest.CcAddresses, sendMailRequest.BccAddresses, sendMailRequest.Headers, sendMailRequest.Message, client)
+	response, err := mail.SendIndividualMail(sendMailRequest.ToAddresses, sendMailRequest.FromAddress, sendMailRequest.CcAddresses, sendMailRequest.BccAddresses, sendMailRequest.Headers, sendMailRequest.Message, client, sendMailRequest.Tags)
 
 	if err != nil {
 		zap.S().Errorf("Error sending mail: %v", response)