summaryrefslogtreecommitdiffstats
path: root/internal/handler/grpc/server.go
diff options
context:
space:
mode:
authorbndw <ben@bdw.to>2026-02-13 20:36:12 -0800
committerbndw <ben@bdw.to>2026-02-13 20:36:12 -0800
commit89b8948195f24df127b7ae656ab3f60bd1b49ac7 (patch)
tree2c6fc91e053039e4ad53ee0a72038b1b99f8c50c /internal/handler/grpc/server.go
parent656748ea286ff7eac6cbe1b241ad31212892ba61 (diff)
refactor: simplify deletion handling (remove NIP-09 processing)
Remove deletion processing logic in favor of simpler approach: - Remove deletions table from schema - Delete deletions.go and deletions_test.go - Remove ProcessDeletion from EventStore interface - Kind 5 events now stored like any other event (no special handling) - Update storage test to expect 2 tables instead of 3 - All 41 tests passing
Diffstat (limited to 'internal/handler/grpc/server.go')
-rw-r--r--internal/handler/grpc/server.go11
1 files changed, 0 insertions, 11 deletions
diff --git a/internal/handler/grpc/server.go b/internal/handler/grpc/server.go
index b1ffd96..b65b527 100644
--- a/internal/handler/grpc/server.go
+++ b/internal/handler/grpc/server.go
@@ -13,7 +13,6 @@ import (
13type EventStore interface { 13type EventStore interface {
14 StoreEvent(context.Context, *storage.EventData) error 14 StoreEvent(context.Context, *storage.EventData) error
15 QueryEvents(context.Context, []*pb.Filter, *storage.QueryOptions) ([]*pb.Event, error) 15 QueryEvents(context.Context, []*pb.Filter, *storage.QueryOptions) ([]*pb.Event, error)
16 ProcessDeletion(context.Context, *pb.Event) error
17} 16}
18 17
19type Server struct { 18type Server struct {
@@ -76,16 +75,6 @@ func (s *Server) PublishEvent(ctx context.Context, req *pb.PublishEventRequest)
76 return nil, fmt.Errorf("failed to store event: %w", err) 75 return nil, fmt.Errorf("failed to store event: %w", err)
77 } 76 }
78 77
79 if req.Event.Kind == 5 {
80 if err := s.store.ProcessDeletion(ctx, req.Event); err != nil {
81 return &pb.PublishEventResponse{
82 Accepted: false,
83 Message: fmt.Sprintf("deletion processing failed: %v", err),
84 CanonicalJson: canonicalJSON,
85 }, nil
86 }
87 }
88
89 s.subs.MatchAndFan(req.Event) 78 s.subs.MatchAndFan(req.Event)
90 79
91 return &pb.PublishEventResponse{ 80 return &pb.PublishEventResponse{