hailey.at
this repo has no description
1package indexer
2
3import (
4 "context"
5
6 vyletkafka "github.com/vylet-app/go/bus/proto"
7)
8
9func (s *Server) handleEvent(ctx context.Context, evt *vyletkafka.FirehoseEvent) error {
10 if evt.Commit != nil {
11 return s.handleCommit(ctx, evt)
12 }
13
14 return nil
15}
16
17func (s *Server) handleCommit(ctx context.Context, evt *vyletkafka.FirehoseEvent) error {
18 switch evt.Commit.Collection {
19 case "app.vylet.actor.profile":
20 return s.handleActorProfile(ctx, evt)
21 case "app.vylet.feed.post":
22 return s.handleFeedPost(ctx, evt)
23 case "app.vylet.feed.like":
24 return s.handleFeedLike(ctx, evt)
25 case "app.vylet.graph.follow":
26 return s.handleGraphFollow(ctx, evt)
27 }
28
29 return nil
30}