onasty: mailer/service.go (35d2b54766347ebbc4d3f1e3f1cccf535c140659)

Smirnov Oleksandr feat: reset password (#110)..., 1 year ago

package main

import (
	"context"
	"log/slog"
)

type Service struct {
	appURL string
	mg     *Mailgun
}

func NewService(appURL string, mg *Mailgun) *Service {
	return &Service{
		appURL: appURL,
		mg:     mg,
	}
}

func (s Service) Send(
	ctx context.Context,
	cancel context.CancelFunc,
	receiver, templateName string,
	templateOpts map[string]string,
) error {
	tmpl, err := getTemplate(s.appURL, templateName)
	if err != nil {
		return err
	}

	t := tmpl(templateOpts)

	go func() {
		select {
		case <-ctx.Done():
			slog.ErrorContext(ctx, "failed to send email",
				"template_name", templateName,
				"err", ctx.Err())
			return
		default:
			if err := s.mg.Send(ctx, receiver, t.Subject, t.Body); err != nil {
				slog.ErrorContext(ctx, "failed to send email",
					"template_name", templateName,
					"err", err)
			}
			cancel()
		}
	}()

	return nil
}

1	package main
2
3	import (
4	"context"
5	"log/slog"
6	)
7
8	type Service struct {
9	appURL string
10	mg *Mailgun
11	}
12
13	func NewService(appURL string, mg Mailgun) Service {
14	return &Service{
15	appURL: appURL,
16	mg: mg,
17	}
18	}
19
20	func (s Service) Send(
21	ctx context.Context,
22	cancel context.CancelFunc,
23	receiver, templateName string,
24	templateOpts map[string]string,
25	) error {
26	tmpl, err := getTemplate(s.appURL, templateName)
27	if err != nil {
28	return err
29	}
30
31	t := tmpl(templateOpts)
32
33	go func() {
34	select {
35	case <-ctx.Done():
36	slog.ErrorContext(ctx, "failed to send email",
37	"template_name", templateName,
38	"err", ctx.Err())
39	return
40	default:
41	if err := s.mg.Send(ctx, receiver, t.Subject, t.Body); err != nil {
42	slog.ErrorContext(ctx, "failed to send email",
43	"template_name", templateName,
44	"err", err)
45	}
46	cancel()
47	}
48	}()
49
50	return nil
51	}