1 files changed, 11 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{