From 5649e567fefe1d67ddeeb0930d1c68273fba8c62 Mon Sep 17 00:00:00 2001 From: Asim Aslam Date: Sun, 27 Feb 2022 21:42:01 +0000 Subject: [PATCH] add debugging to events handler --- event/handler/event.go | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/event/handler/event.go b/event/handler/event.go index a752607..a824ab8 100644 --- a/event/handler/event.go +++ b/event/handler/event.go @@ -103,7 +103,6 @@ func (s *Event) Read(ctx context.Context, req *pb.ReadRequest, rsp *pb.ReadRespo // create tenant based topics topic := path.Join("event", id, req.Topic) - log.Infof("Tenant %v reading %v\n", id, req.Topic) limit := uint(25) offset := uint(0) @@ -115,11 +114,15 @@ func (s *Event) Read(ctx context.Context, req *pb.ReadRequest, rsp *pb.ReadRespo offset = uint(req.Offset) } + log.Infof("Tenant %v reading %v limit: %v offset: %v\n", id, req.Topic, req.Limit, req.Offset) + events, err := events.Read(topic, events.ReadLimit(limit), events.ReadOffset(offset)) if err != nil { return err } + log.Infof("Events read %v", len(events)) + for _, ev := range events { // unmarshal the message into a struct d := &structpb.Struct{}