Merge pull request #95 from mattn/accept-req

add ReqAccepter to handle request filters

handlers.go

@@ -180,8 +180,15 @@ func (s *Server) doReq(ctx context.Context, ws *WebSocket, request []json.RawMes
 		); err != nil {
 			return "failed to decode filter"
 		}
+	}
 
-		filter := &filters[i]
+	if accepter, ok := s.relay.(ReqAccepter); ok {
+		if !accepter.AcceptReq(ctx, id, filters) {
+			return "REQ fitlers are not accepted"
+		}
+	}
+
+	for _, filter := range filters {
 
 		// prevent kind-4 events from being returned to unauthed users,
 		//   only when authentication is a thing
@@ -206,7 +213,7 @@ func (s *Server) doReq(ctx context.Context, ws *WebSocket, request []json.RawMes
 			}
 		}
 
-		events, err := store.QueryEvents(ctx, filter)
+		events, err := store.QueryEvents(ctx, &filter)
 		if err != nil {
 			s.Log.Errorf("store: %v", err)
 			continue

interface.go

@@ -26,6 +26,14 @@ type Relay interface {
 	Storage(context.Context) Storage
 }
 
+// ReqAccepter is the main interface for implementing a nostr relay.
+type ReqAccepter interface {
+	// AcceptReq is called for every nostr request filters received by the
+	// server. If the returned value is true, the filtres is passed on to
+	// [Storage.QueryEvent].
+	AcceptReq(context.Context, string, nostr.Filters) bool
+}
+
 // Auther is the interface for implementing NIP-42.
 // ServiceURL() returns the URL used to verify the "AUTH" event from clients.
 type Auther interface {