feat: add Publisher and messaging types

Signed-off-by: Fabrizio Sestito <[email protected]>

internal/messaging/publisher.go

@@ -0,0 +1,46 @@
+package messaging
+
+import (
+	"encoding/json"
+	"fmt"
+
+	"github.com/nats-io/nats.go"
+)
+
+const MessageTypeHeader = "MessageType"
+
+type Publisher interface {
+	Publish(message Message) error
+}
+
+type publisher struct {
+	js nats.JetStreamContext
+}
+
+func NewPublisher(js nats.JetStreamContext) Publisher {
+	return &publisher{
+		js: js,
+	}
+}
+
+func (p *publisher) Publish(message Message) error {
+	data, err := json.Marshal(message)
+	if err != nil {
+		return fmt.Errorf("failed to marshal message to JSON: %w", err)
+	}
+
+	header := make(nats.Header)
+	header.Add(MessageTypeHeader, message.GetType())
+
+	msg := &nats.Msg{
+		Subject: SbombasticSubject,
+		Data:    data,
+		Header:  header,
+	}
+
+	if _, err := p.js.PublishMsg(msg); err != nil {
+		return fmt.Errorf("failed to publish message: %w", err)
+	}
+
+	return nil
+}

internal/messaging/types.go

@@ -0,0 +1,22 @@
+package messaging
+
+type Message interface {
+	GetType() string
+}
+
+type BaseMessage struct {
+	Type string `json:"type"`
+}
+
+type CreateCatalog struct {
+	BaseMessage
+	Name         string   `json:"name"`
+	URL          string   `json:"url"`
+	Repositories []string `json:"repositories"`
+	CABundle     string   `json:"caBundle"`
+	Insecure     bool     `json:"insecure"`
+}
+
+func (m *CreateCatalog) GetType() string {
+	return "CreateRegistryCatalog"
+}