Impl email.Sender

Author: gedorinku

.env.ci

@@ -30,3 +30,8 @@ DEBUG_LOG=true
 JOB_INTERVAL_SEC=120
 
 HYDRA_ADMIN_URL=http://hydra:4445
+
+CLIENT_REGISTRATION_URL=http://localhost:8080/registration
+
+SMTP_ADDR=smtp:1025
+EMAIL_FROM=[email protected]

.env.sample

@@ -31,3 +31,8 @@ DEBUG_LOG=true
 JOB_INTERVAL_SEC=120
 
 HYDRA_ADMIN_URL=http://hydra:4445
+
+CLIENT_REGISTRATION_URL=http://localhost:8080/registration
+
+SMTP_ADDR=smtp:1025
+EMAIL_FROM=[email protected]

app/config/config.go

@@ -8,17 +8,20 @@ import (
 
 // Config represents app config
 type Config struct {
-	DataBaseURL     string `envconfig:"database_url" required:"true"`
-	TestDataBaseURL string `envconfig:"test_database_url" required:"true"`
-	RedisAddr       string `envconfig:"redis_addr" required:"true"`
-	DebugLog        bool   `envconfig:"debug_log"`
-	JobIntervalSec  int    `envconfig:"job_interval_sec" required:"true"`
-	HydraAdminURL   string `envconfig:"hydra_admin_url" required:"true"`
-	MinioPublicURL  string `envconfig:"minio_public_url" required:"true"`
-	MinioEndpoint   string `envconfig:"minio_endpoint" required:"true"`
-	MinioAccessKey  string `envconfig:"minio_access_key" required:"true"`
-	MinioSecretKey  string `envconfig:"minio_secret_key" required:"true"`
-	MinioBucketName string `envconfig:"minio_bucket_name" required:"true"`
+	DataBaseURL           string `envconfig:"database_url" required:"true"`
+	TestDataBaseURL       string `envconfig:"test_database_url" required:"true"`
+	RedisAddr             string `envconfig:"redis_addr" required:"true"`
+	DebugLog              bool   `envconfig:"debug_log"`
+	JobIntervalSec        int    `envconfig:"job_interval_sec" required:"true"`
+	HydraAdminURL         string `envconfig:"hydra_admin_url" required:"true"`
+	MinioPublicURL        string `envconfig:"minio_public_url" required:"true"`
+	MinioEndpoint         string `envconfig:"minio_endpoint" required:"true"`
+	MinioAccessKey        string `envconfig:"minio_access_key" required:"true"`
+	MinioSecretKey        string `envconfig:"minio_secret_key" required:"true"`
+	MinioBucketName       string `envconfig:"minio_bucket_name" required:"true"`
+	ClientRegistrationURL string `envconfig:"client_registration_url" required:"true"`
+	SMTPAddr              string `envconfig:"smtp_addr" required:"true"`
+	EmailFrom             string `envconfig:"email_from" required:"true"`
 }
 
 // LoadConfig loads config

docker-compose.yml

@@ -12,6 +12,7 @@ services:
       - pg
       - redis
       - hydra
+      - mailhog
     ports:
       - "127.0.0.1:3000:3000"
 
@@ -111,6 +112,14 @@ services:
     ports:
       - "127.0.0.1:9100:9000"
 
+  mailhog:
+    image: mailhog/mailhog
+    hostname: smtp
+    restart: always
+    ports:
+      - "127.0.0.1:1025:1025"
+      - "127.0.0.1:8025:8025"
+
 volumes:
   pg-data:
     driver: local

infra/email/email.go

@@ -1,17 +1,20 @@
 package email
 
 import (
+	"bytes"
 	"context"
 
-	"github.com/ProgrammingLab/prolab-accounts/static"
+	"github.com/jordan-wright/email"
+	"github.com/pkg/errors"
 
 	"github.com/ProgrammingLab/prolab-accounts/app/config"
 	"github.com/ProgrammingLab/prolab-accounts/infra/record"
+	"github.com/ProgrammingLab/prolab-accounts/static"
 )
 
 // Sender represents interface of email sender
 type Sender interface {
-	SendInvitationEmail(email string, req *record.Invitation) error
+	SendInvitationEmail(req *record.Invitation) error
 }
 
 // NewSender creates new sender
@@ -29,7 +32,38 @@ type senderImpl struct {
 	asset *static.EmailAsset
 }
 
+type invitationEmailData struct {
+	RegistrationURL string
+}
+
+const (
+	subjectPrefix = "[プロラボアカウント]"
+)
+
 // SendInvitationEmail sends invitation email
-func (s *senderImpl) SendInvitationEmail(email string, inv *record.Invitation) error {
+func (s *senderImpl) SendInvitationEmail(inv *record.Invitation) error {
+	tmpl, err := s.asset.GetTemplate("invitation.tmpl")
+	if err != nil {
+		return err
+	}
+
+	d := invitationEmailData{
+		RegistrationURL: s.cfg.ClientRegistrationURL + "/" + inv.Code,
+	}
+	buf := &bytes.Buffer{}
+	err = tmpl.Execute(buf, d)
+	if err != nil {
+		return errors.WithStack(err)
+	}
+
+	e := email.NewEmail()
+	e.From = s.cfg.EmailFrom
+	e.To = []string{inv.Email}
+	e.Subject = subjectPrefix + "ユーザー登録"
+	e.Text = buf.Bytes()
+	err = e.Send(s.cfg.SMTPAddr, nil)
+	if err != nil {
+		return errors.WithStack(err)
+	}
 	return nil
 }

static/asset.go

@@ -1,6 +1,7 @@
 package static
 
 import (
+	"fmt"
 	"text/template"
 
 	"github.com/gobuffalo/packr/v2"
@@ -15,9 +16,12 @@ type EmailAsset struct {
 }
 
 // GetTemplate returns email template
-func (a *EmailAsset) GetTemplate(name string) (tmpl *template.Template, ok bool) {
-	tmpl, ok = a.templates[name]
-	return
+func (a *EmailAsset) GetTemplate(name string) (*template.Template, error) {
+	tmpl, ok := a.templates[name]
+	if !ok {
+		return nil, errors.WithStack(fmt.Errorf("template %v not found", name))
+	}
+	return tmpl, nil
 }
 
 func (a *EmailAsset) addTemplate(name string, tmpl *template.Template) {