feat: add publish handler

cmd/server/main.go

@@ -33,6 +33,7 @@ func main() {
 
 	e.POST("/nip47/info", svc.InfoHandler)
 	e.POST("/nip47", svc.NIP47Handler)
+	e.POST("/publish", svc.PublishHandler)
 	e.POST("/subscriptions", svc.SubscriptionHandler)
 	e.DELETE("/subscriptions/:id", svc.StopSubscriptionHandler)
 	e.Use(echologrus.Middleware())

internal/nostr/models.go

@@ -153,6 +153,11 @@ type NIP47Request struct {
 	SignedEvent  *nostr.Event `json:"event"`
 }
 
+type PublishRequest struct {
+	Relays      []string     `json:"relays"`
+	SignedEvent *nostr.Event `json:"event"`
+}
+
 type SubscriptionRequest struct {
 	RelayUrl     string        `json:"relayUrl"`
 	WebhookUrl   string        `json:"webhookUrl"`

internal/nostr/nostr.go

@@ -10,6 +10,7 @@ import (
 	"net/http"
 	"os"
 	"os/signal"
+	"strings"
 	"sync"
 	"time"
 
@@ -203,6 +204,67 @@ func (svc *Service) InfoHandler(c echo.Context) error {
 	}
 }
 
+func (svc *Service) PublishHandler(c echo.Context) error {
+	var requestData PublishRequest
+	if err := c.Bind(&requestData); err != nil {
+		return c.JSON(http.StatusBadRequest, ErrorResponse{
+			Message: fmt.Sprintf("error decoding publish request: %s", err.Error()),
+		})
+	}
+
+	if len(requestData.Relays) == 0 {
+		return c.JSON(http.StatusBadRequest, ErrorResponse{
+			Message: "relay(s) not specified",
+		})
+	}
+
+	if (requestData.SignedEvent == nil) {
+		return c.JSON(http.StatusBadRequest, ErrorResponse{
+			Message: "signed event is empty",
+		})
+	}
+
+	var wg sync.WaitGroup
+	errorCh := make(chan error, len(requestData.Relays))
+
+	for _, relayUrl := range requestData.Relays {
+		wg.Add(1)
+		go func(relayUrl string) {
+			defer wg.Done()
+			ctx, cancel := context.WithTimeout(svc.Ctx, 30*time.Second)
+			defer cancel()
+
+			relay, isCustomRelay, err := svc.getRelayConnection(ctx, relayUrl)
+			if err != nil {
+				errorCh <- fmt.Errorf("error connecting to relay %s: %v", relayUrl, err)
+				return
+			}
+			if isCustomRelay {
+				defer relay.Close()
+			}
+			err = relay.Publish(ctx, *requestData.SignedEvent)
+			if err != nil {
+				errorCh <- fmt.Errorf("error publishing to relay %s: %v", relayUrl, err)
+			}
+		}(relayUrl)
+	}
+
+	wg.Wait()
+	close(errorCh)
+	var errors []string
+	for err := range errorCh {
+		errors = append(errors, err.Error())
+	}
+
+	if len(errors) > 0 {
+		return c.JSON(http.StatusInternalServerError, ErrorResponse{
+			Message: "errors occurred while publishing to relays: " + strings.Join(errors, "; "),
+		})
+	}
+
+	return c.JSON(http.StatusOK, "published")
+}
+
 func (svc *Service) NIP47Handler(c echo.Context) error {
 	var requestData NIP47Request
 	if err := c.Bind(&requestData); err != nil {