Publish selected event kinds to relay.nos.social

The idea is to make it work like https://purplepag.es/what.

service/app/app.go

@@ -5,6 +5,7 @@ import (
 
 	"github.com/boreq/errors"
 	"github.com/planetary-social/nos-event-service/service/domain"
+	"github.com/planetary-social/nos-event-service/service/domain/relays"
 )
 
 var (
@@ -121,3 +122,8 @@ type ContactsExtractor interface {
 type Subscriber interface {
 	EventSavedQueueLength(ctx context.Context) (int, error)
 }
+
+type RelayConnections interface {
+	GetEvents(ctx context.Context, relayAddress domain.RelayAddress, filter domain.Filter) (<-chan relays.EventOrEndOfSavedEvents, error)
+	SendEvent(ctx context.Context, relayAddress domain.RelayAddress, event domain.Event) error
+}

service/app/downloader.go

@@ -10,7 +10,6 @@ import (
 	"github.com/planetary-social/nos-event-service/internal"
 	"github.com/planetary-social/nos-event-service/internal/logging"
 	"github.com/planetary-social/nos-event-service/service/domain"
-	"github.com/planetary-social/nos-event-service/service/domain/relays"
 )
 
 const (
@@ -42,10 +41,6 @@ type RelaySource interface {
 	GetRelays(ctx context.Context) ([]domain.RelayAddress, error)
 }
 
-type RelayConnections interface {
-	GetEvents(ctx context.Context, relayAddress domain.RelayAddress, filter domain.Filter) (<-chan relays.EventOrEndOfSavedEvents, error)
-}
-
 type PublicKeySource interface {
 	GetPublicKeys(ctx context.Context) ([]domain.PublicKey, error)
 }

service/app/handler_process_saved_event.go

@@ -4,10 +4,20 @@ import (
 	"context"
 
 	"github.com/boreq/errors"
+	"github.com/planetary-social/nos-event-service/internal"
 	"github.com/planetary-social/nos-event-service/internal/logging"
 	"github.com/planetary-social/nos-event-service/service/domain"
 )
 
+var (
+	nosRelayAddress                    = domain.MustNewRelayAddress("wss://relay.nos.social")
+	eventKindsWhichShouldBeSentToRelay = internal.NewSetVariadic(
+		domain.EventKindMetadata,
+		domain.EventKindContacts,
+		domain.EventKindRelayListMetadata,
+	)
+)
+
 type ProcessSavedEvent struct {
 	id domain.EventId
 }
@@ -21,6 +31,7 @@ type ProcessSavedEventHandler struct {
 	relaysExtractor        RelaysExtractor
 	contactsExtractor      ContactsExtractor
 	externalEventPublisher ExternalEventPublisher
+	relayConnections       RelayConnections
 	logger                 logging.Logger
 	metrics                Metrics
 }
@@ -30,6 +41,7 @@ func NewProcessSavedEventHandler(
 	relaysExtractor RelaysExtractor,
 	contactsExtractor ContactsExtractor,
 	externalEventPublisher ExternalEventPublisher,
+	relayConnections RelayConnections,
 	logger logging.Logger,
 	metrics Metrics,
 ) *ProcessSavedEventHandler {
@@ -38,6 +50,7 @@ func NewProcessSavedEventHandler(
 		relaysExtractor:        relaysExtractor,
 		contactsExtractor:      contactsExtractor,
 		externalEventPublisher: externalEventPublisher,
+		relayConnections:       relayConnections,
 		logger:                 logger.New("processSavedEventHandler"),
 		metrics:                metrics,
 	}
@@ -59,6 +72,10 @@ func (h *ProcessSavedEventHandler) Handle(ctx context.Context, cmd ProcessSavedE
 		return errors.Wrap(err, "error publishing the external event")
 	}
 
+	if err := h.maybeSendEventToRelay(ctx, event); err != nil {
+		return errors.Wrap(err, "error sending the event to relay")
+	}
+
 	return nil
 }
 
@@ -138,3 +155,10 @@ func (h *ProcessSavedEventHandler) shouldReplaceContacts(ctx context.Context, ad
 
 	return domain.ShouldReplaceContactsEvent(oldEvent, newEvent)
 }
+
+func (h *ProcessSavedEventHandler) maybeSendEventToRelay(ctx context.Context, event domain.Event) error {
+	if !eventKindsWhichShouldBeSentToRelay.Contains(event.Kind()) {
+		return nil
+	}
+	return h.relayConnections.SendEvent(ctx, nosRelayAddress, event)
+}