3 files changed, 84 insertions, 0 deletions

diff --git a/internal/handler/grpc/server.go b/internal/handler/grpc/server.go
index b65b527..b1ffd96 100644
--- a/internal/handler/grpc/server.go
+++ b/internal/handler/grpc/server.go
@@ -13,6 +13,7 @@ import (
 type EventStore interface {
         StoreEvent(context.Context, *storage.EventData) error
         QueryEvents(context.Context, []*pb.Filter, *storage.QueryOptions) ([]*pb.Event, error)
+        ProcessDeletion(context.Context, *pb.Event) error
 }
 
 type Server struct {
@@ -75,6 +76,16 @@ func (s *Server) PublishEvent(ctx context.Context, req *pb.PublishEventRequest)
                 return nil, fmt.Errorf("failed to store event: %w", err)
         }
 
+        if req.Event.Kind == 5 {
+                if err := s.store.ProcessDeletion(ctx, req.Event); err != nil {
+                        return &pb.PublishEventResponse{
+                                Accepted:      false,
+                                Message:       fmt.Sprintf("deletion processing failed: %v", err),
+                                CanonicalJson: canonicalJSON,
+                        }, nil
+                }
+        }
+
         s.subs.MatchAndFan(req.Event)
 
         return &pb.PublishEventResponse{
diff --git a/internal/handler/websocket/handler.go b/internal/handler/websocket/handler.go
index cef83dd..4a7db0d 100644
--- a/internal/handler/websocket/handler.go
+++ b/internal/handler/websocket/handler.go
@@ -17,6 +17,7 @@ import (
 type EventStore interface {
         StoreEvent(context.Context, *storage.EventData) error
         QueryEvents(context.Context, []*pb.Filter, *storage.QueryOptions) ([]*pb.Event, error)
+        ProcessDeletion(context.Context, *pb.Event) error
 }
 
 type Handler struct {
@@ -32,6 +33,11 @@ func NewHandler(store EventStore, subs *subscription.Manager) *Handler {
 }
 
 func (h *Handler) ServeHTTP(w http.ResponseWriter, r *http.Request) {
+        if r.Method == "GET" && r.Header.Get("Accept") == "application/nostr+json" {
+                h.ServeNIP11(w, r)
+                return
+        }
+
         conn, err := websocket.Accept(w, r)
         if err != nil {
                 log.Printf("WebSocket accept failed: %v", err)
@@ -125,6 +131,13 @@ func (h *Handler) handleEvent(ctx context.Context, conn *websocket.Conn, raw []j
                 return nil
         }
 
+        if pbEvent.Kind == 5 {
+                if err := h.store.ProcessDeletion(ctx, pbEvent); err != nil {
+                        h.sendOK(ctx, conn, event.ID, false, fmt.Sprintf("deletion failed: %v", err))
+                        return nil
+                }
+        }
+
         h.subs.MatchAndFan(pbEvent)
 
         h.sendOK(ctx, conn, event.ID, true, "")
diff --git a/internal/handler/websocket/nip11.go b/internal/handler/websocket/nip11.go
new file mode 100644
index 0000000..a5bb9ca
--- /dev/null
+++ b/internal/handler/websocket/nip11.go
@@ -0,0 +1,60 @@
+package websocket
+
+import (
+        "encoding/json"
+        "net/http"
+)
+
+type RelayInfo struct {
+        Name          string   `json:"name"`
+        Description   string   `json:"description"`
+        Pubkey        string   `json:"pubkey,omitempty"`
+        Contact       string   `json:"contact,omitempty"`
+        SupportedNIPs []int    `json:"supported_nips"`
+        Software      string   `json:"software"`
+        Version       string   `json:"version"`
+        Limitation    *Limits  `json:"limitation,omitempty"`
+}
+
+type Limits struct {
+        MaxMessageLength    int  `json:"max_message_length,omitempty"`
+        MaxSubscriptions    int  `json:"max_subscriptions,omitempty"`
+        MaxFilters          int  `json:"max_filters,omitempty"`
+        MaxLimit            int  `json:"max_limit,omitempty"`
+        MaxSubidLength      int  `json:"max_subid_length,omitempty"`
+        MaxEventTags        int  `json:"max_event_tags,omitempty"`
+        MaxContentLength    int  `json:"max_content_length,omitempty"`
+        MinPowDifficulty    int  `json:"min_pow_difficulty,omitempty"`
+        AuthRequired        bool `json:"auth_required"`
+        PaymentRequired     bool `json:"payment_required"`
+        RestrictedWrites    bool `json:"restricted_writes"`
+}
+
+func (h *Handler) ServeNIP11(w http.ResponseWriter, r *http.Request) {
+        info := RelayInfo{
+                Name:          "nostr-grpc relay",
+                Description:   "High-performance Nostr relay with gRPC, Connect, and WebSocket support",
+                SupportedNIPs: []int{1, 9, 11},
+                Software:      "northwest.io/nostr-grpc",
+                Version:       "0.1.0",
+                Limitation: &Limits{
+                        MaxMessageLength: 65536,
+                        MaxSubscriptions: 20,
+                        MaxFilters:       10,
+                        MaxLimit:         5000,
+                        MaxSubidLength:   64,
+                        MaxEventTags:     2000,
+                        MaxContentLength: 65536,
+                        AuthRequired:     false,
+                        PaymentRequired:  false,
+                        RestrictedWrites: false,
+                },
+        }
+
+        w.Header().Set("Content-Type", "application/nostr+json")
+        w.Header().Set("Access-Control-Allow-Origin", "*")
+        w.Header().Set("Access-Control-Allow-Headers", "Content-Type, Accept")
+        w.Header().Set("Access-Control-Allow-Methods", "GET")
+
+        json.NewEncoder(w).Encode(info)
+}