summaryrefslogtreecommitdiffstats
path: root/internal/handler/websocket
diff options
context:
space:
mode:
Diffstat (limited to 'internal/handler/websocket')
-rw-r--r--internal/handler/websocket/handler.go8
1 files changed, 0 insertions, 8 deletions
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 (
17type EventStore interface { 17type EventStore interface {
18 StoreEvent(context.Context, *storage.EventData) error 18 StoreEvent(context.Context, *storage.EventData) error
19 QueryEvents(context.Context, []*pb.Filter, *storage.QueryOptions) ([]*pb.Event, error) 19 QueryEvents(context.Context, []*pb.Filter, *storage.QueryOptions) ([]*pb.Event, error)
20 ProcessDeletion(context.Context, *pb.Event) error
21} 20}
22 21
23type Handler struct { 22type Handler struct {
@@ -131,13 +130,6 @@ func (h *Handler) handleEvent(ctx context.Context, conn *websocket.Conn, raw []j
131 return nil 130 return nil
132 } 131 }
133 132
134 if pbEvent.Kind == 5 {
135 if err := h.store.ProcessDeletion(ctx, pbEvent); err != nil {
136 h.sendOK(ctx, conn, event.ID, false, fmt.Sprintf("deletion failed: %v", err))
137 return nil
138 }
139 }
140
141 h.subs.MatchAndFan(pbEvent) 133 h.subs.MatchAndFan(pbEvent)
142 134
143 h.sendOK(ctx, conn, event.ID, true, "") 135 h.sendOK(ctx, conn, event.ID, true, "")