apicodegen/api/mail/adapter_aws_ses.go

package mail

import (
	"fmt"

	"git.eugeniocarvalho.dev/eugeniucarvalho/apicodegen/api/errs"
	"git.eugeniocarvalho.dev/eugeniucarvalho/apicodegen/api/types"

	//go get -u github.com/aws/aws-sdk-go
	"github.com/aws/aws-sdk-go/aws"
	"github.com/aws/aws-sdk-go/aws/awserr"
	"github.com/aws/aws-sdk-go/aws/session"
	"github.com/aws/aws-sdk-go/service/ses"
)

const (
	// The character encoding for the email.
	AwsCharSet = "UTF-8"
)

var (
	AwsErrorCodeMap = map[string]string{
		ses.ErrCodeMessageRejected: ses.ErrCodeMessageRejected,
		ses.ErrCodeMailFromDomainNotVerifiedException: ses.ErrCodeMailFromDomainNotVerifiedException,
		ses.ErrCodeConfigurationSetDoesNotExistException: ses.ErrCodeConfigurationSetDoesNotExistException,
	}
)


type AwsSESAdapter struct {
}

func (adapter *AwsSESAdapter) Send(mail *Mail, options *SendMailOptions) (err *errs.Error) {
	var (
		sendError error
		result *ses.SendEmailOutput
		sess *session.Session
	)
	sess, sendError = session.NewSession(&aws.Config{
		Region: aws.String("us-east-1")},
	)

	// Create an SES session.
	svc := ses.New(sess)
	destination := mail.Destination
	body := mail.Body
	// Assemble the email.
	input := &ses.SendEmailInput{
		Destination: &ses.Destination{
			CcAddresses: destination.CcAddresses,
			ToAddresses: destination.ToAddresses,
		},
		Source: mail.Sender,
		Message: &ses.Message{
			Subject: &ses.Content{
				Charset: aws.String(AwsCharSet),
				Data:    mail.Subject,
			},
			Body: &ses.Body{
				Html: &ses.Content{
					Charset: aws.String(AwsCharSet),
					Data:    body.Html,
				},
				Text: &ses.Content{
					Charset: aws.String(AwsCharSet),
					Data:    body.Text,
				},
			},
		},
		// Uncomment to use a configuration set
		// ConfigurationSetName: aws.String(ConfigurationSet),
	}

	// Attempt to send the email.
	if result, sendError = svc.SendEmail(input); sendError != nil {
		err = adapter.handlerError(sendError)
		return
	}

	fmt.Println("Email Sent to address: ")
	fmt.Println(result)

	return
}

func (adapter *AwsSESAdapter) SendTemplateEmail(mail *Mail, options *SendMailOptions) (err *errs.Error) {
	var (
		sendError error
		jsonData string
		sess *session.Session
		result *ses.SendTemplatedEmailOutput
	)

	sess, sendError = session.NewSession(&aws.Config{
		Region: aws.String("us-east-1")},
	)

	// Create an SES session.
	svc := ses.New(sess)

	if mail.TemplateData == nil {
		mail.TemplateData = &types.Map{}
	}
	
	if jsonData, err = types.JSON(mail.TemplateData); err != nil {
		return
	}


	destination := mail.Destination
	// Assemble the email.
	// input := &ses.SendEmailInput{
	input := &ses.SendTemplatedEmailInput{
		Template:     mail.Template,
		TemplateData: aws.String(jsonData),
		Destination: &ses.Destination{
			CcAddresses: destination.CcAddresses,
			ToAddresses: destination.ToAddresses,
		},
		Source: mail.Sender,
		// Uncomment to use a configuration set
		// ConfigurationSetName: aws.String(ConfigurationSet),
	}

	// Attempt to send the email.
	// Display error messages if they occur.
	if result, sendError = svc.SendTemplatedEmail(input); sendError != nil {
		err = adapter.handlerError(sendError)
		return
	}

	fmt.Println("Email Sent to address:")
	fmt.Println(result)

	return
}


func (adapter *AwsSESAdapter) handlerError(sendError error) (err *errs.Error)  {
	var (
		message string
		reason string
		found bool
	)
	if aerr, ok := sendError.(awserr.Error); ok {
		if reason, found = AwsErrorCodeMap[aerr.Code()]; !found {
			reason = ""
		}
		message = aerr.Error()
	} else {
		message = err.Error()
	}
	err = errs.Internal().Details(&errs.Detail{
		Reason : reason,
		Message: message,
	})
	return
}