add blossom after routes

main.go

@@ -1,6 +1,7 @@
 package main
 
 import (
+	"bytes"
 	"context"
 	"flag"
 	"fmt"
@@ -10,6 +11,7 @@ import (
 	"text/template"
 
 	"github.com/fiatjaf/khatru"
+	"github.com/fiatjaf/khatru/blossom"
 	"github.com/nbd-wtf/go-nostr"
 	"github.com/puzpuzpuz/xsync/v3"
 	"github.com/spf13/afero"
@@ -285,6 +287,32 @@ func makeNewRelay(relayType string, w http.ResponseWriter, r *http.Request) *kha
 			}
 		})
 
+		addr := fmt.Sprintf("%s:%d", config.RelayBindAddress, config.RelayPort)
+
+		bl := blossom.New(outboxRelay, addr)
+		bl.Store = blossom.EventStoreBlobIndexWrapper{Store: outboxDB, ServiceURL: bl.ServiceURL}
+		bl.StoreBlob = append(bl.StoreBlob, func(ctx context.Context, sha256 string, body []byte) error {
+			if khatru.GetAuthed(ctx) != nPubToPubkey(config.OwnerNpub) {
+				return fmt.Errorf("auth-required: only the relay owner can store media")
+			}
+
+			file, err := fs.Create(config.BlossomPath + sha256)
+			if err != nil {
+				return err
+			}
+			if _, err := io.Copy(file, bytes.NewReader(body)); err != nil {
+				return err
+			}
+			return nil
+		})
+		bl.LoadBlob = append(bl.LoadBlob, func(ctx context.Context, sha256 string) (io.Reader, error) {
+			return fs.Open(config.BlossomPath + sha256)
+		})
+		bl.DeleteBlob = append(bl.DeleteBlob, func(ctx context.Context, sha256 string) error {
+			return fs.Remove(config.BlossomPath + sha256)
+		})
+
 		return outboxRelay
 	}
+
 }