Add a client

Author: toddkazakov

client/client.go

@@ -0,0 +1,42 @@
+package client
+
+import (
+	"context"
+	"github.com/go-playground/validator/v10"
+	"github.com/tidepool-org/go-common/events"
+)
+
+const Topic = "emails"
+
+type Client interface {
+	Send(ctx context.Context, email events.SendEmailTemplateEvent) error
+}
+
+type client struct {
+	producer *events.KafkaCloudEventsProducer
+	validate *validator.Validate
+}
+
+var _ Client = &client{}
+
+func NewClient(config *events.CloudEventsConfig) (Client, error) {
+	producer, err := events.NewKafkaCloudEventsProducer(config)
+	if err != nil {
+		return nil, err
+	}
+
+	return &client{
+		producer: producer,
+		validate : validator.New(),
+	}, nil
+}
+
+func (c *client) Send(ctx context.Context, email events.SendEmailTemplateEvent) error {
+	if err := c.validate.Var(email.Recipient, "email"); err != nil {
+		return err
+	}
+	if err := c.validate.Var(email.Template, "required,min=1"); err != nil {
+		return err
+	}
+	return c.producer.Send(ctx, email)
+}

client/go.mod

@@ -0,0 +1,10 @@
+module github.com/tidepool-org/mailer/client
+
+go 1.16
+
+require (
+	github.com/go-playground/validator/v10 v10.9.0
+	github.com/tidepool-org/go-common v0.8.3-0.20210910112449-5937a193bc79
+	go.uber.org/zap v1.16.0 // indirect
+	golang.org/x/tools v0.0.0-20191108193012-7d206e10da11 // indirect
+)