feat(service): Add Gotify

service/gotify/gotify.go

@@ -0,0 +1,74 @@
+package gotify
+
+import (
+	"bytes"
+	"context"
+	"encoding/json"
+	"fmt"
+	"net/http"
+
+	"github.com/pkg/errors"
+)
+
+//go:generate mockery --name=gotifyService --output=. --case=underscore --inpackage
+type gotifyService interface {
+	Send(ctx context.Context, subject, message string) error
+}
+
+var _ gotifyService = &Gotify{}
+
+// Gotify struct holds necessary data to communicate with Gotify API
+type Gotify struct {
+	httpClient *http.Client
+	baseURL    string
+	appToken   string
+}
+
+func New(appToken, baseURL string) *Gotify {
+	g := &Gotify{
+		httpClient: http.DefaultClient,
+		baseURL:    baseURL,
+		appToken:   appToken,
+	}
+
+	return g
+}
+
+type newMessageRequestBody struct {
+	Title    string
+	Message  string
+	Priority int
+}
+
+func (g *Gotify) Send(ctx context.Context, subject, message string) error {
+	select {
+	case <-ctx.Done():
+		return ctx.Err()
+	default:
+		reqBody := &newMessageRequestBody{
+			Title:    subject,
+			Message:  message,
+			Priority: 1,
+		}
+
+		body, err := json.Marshal(reqBody)
+		if err != nil {
+			return err
+		}
+
+		req, err := http.NewRequestWithContext(context.Background(), "POST", fmt.Sprintf("%s/message", g.baseURL), bytes.NewReader(body))
+		if err != nil {
+			return err
+		}
+
+		req.Header.Add("Authorization", fmt.Sprintf("Bearer %s", g.appToken))
+
+		b, err := g.httpClient.Do(req)
+		b.Body.Close()
+		if err != nil {
+			return errors.Wrapf(err, "failed to send message to gotify server")
+		}
+
+		return nil
+	}
+}

service/gotify/gotify_test.go

@@ -0,0 +1,47 @@
+package gotify
+
+import (
+	"context"
+	"errors"
+	"testing"
+
+	"github.com/stretchr/testify/require"
+)
+
+func TestGotify_New(t *testing.T) {
+	t.Parallel()
+
+	assert := require.New(t)
+	assert.NotNil(New(
+		"testingAppToken",
+		"baseUrl",
+	))
+}
+
+func TestGotify_SendSuccess(t *testing.T) {
+	t.Parallel()
+
+	assert := require.New(t)
+
+	mock := newMockGotifyService(t)
+	mock.On("Send", context.Background(), "testing", "hello world!").Return(nil)
+
+	err := mock.Send(context.Background(), "testing", "hello world!")
+	assert.Nil(err)
+
+	mock.AssertCalled(t, "Send", context.Background(), "testing", "hello world!")
+}
+
+func TestGotify_SendFailure(t *testing.T) {
+	t.Parallel()
+
+	assert := require.New(t)
+
+	mock := newMockGotifyService(t)
+	mock.On("Send", context.Background(), "testing", "hello world!").Return(errors.New("failed to send message"))
+
+	err := mock.Send(context.Background(), "testing", "hello world!")
+	assert.NotNil(err)
+
+	mock.AssertCalled(t, "Send", context.Background(), "testing", "hello world!")
+}