2 files changed, 0 insertions, 19 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 (
 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 {
@@ -76,16 +75,6 @@ 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 4a7db0d..38d4fa6 100644
--- a/internal/handler/websocket/handler.go
+++ b/internal/handler/websocket/handler.go
@@ -17,7 +17,6 @@ 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 {
@@ -131,13 +130,6 @@ 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, "")