+4

automod/engine.go

reviewed

··· 63 63 func (e *Engine) ProcessCommit(ctx context.Context, commit *comatproto.SyncSubscribeRepos_Commit) error { 64 64 65 65 // similar to an HTTP server, we want to recover any panics from rule execution 66 66 + /* 66 67 defer func() { 67 68 if r := recover(); r != nil { 68 69 slog.Error("automod event execution exception", "err", r) ··· 70 71 // TODO: circuit-break on repeated panics? 71 72 } 72 73 }() 74 74 + */ 73 75 74 76 r, err := repo.ReadRepoFromCar(ctx, bytes.NewReader(commit.Blocks)) 75 77 if err != nil { ··· 140 142 } 141 143 142 144 func (e *Engine) CallIdentityRules(evt *IdentityEvent) error { 145 145 + slog.Info("calling rules on identity event") 143 146 return nil 144 147 } 145 148 146 149 func (e *Engine) CallRecordRules(evt *RecordEvent) error { 150 150 + slog.Info("calling rules on record event") 147 151 return nil 148 152 } 149 153

+5

cmd/hepa/firehose.go

reviewed

··· 145 145 } 146 146 147 147 func (s *Server) discoverRepos() { 148 148 + if s.skipBackfill { 149 149 + s.logger.Info("skipping repo discovery") 150 150 + return 151 151 + } 152 152 + 148 153 ctx := context.Background() 149 154 log := s.logger.With("func", "discoverRepos") 150 155 log.Info("starting repo discovery")

+1 -1

cmd/hepa/main.go

reviewed

··· 43 43 &cli.StringFlag{ 44 44 Name: "atp-bgs-host", 45 45 Usage: "hostname and port of BGS to subscribe to", 46 46 - Value: "wss://bsky.social", 46 46 + Value: "wss://bsky.network", 47 47 EnvVars: []string{"ATP_BGS_HOST"}, 48 48 }, 49 49 &cli.StringFlag{

+3 -1

cmd/hepa/server.go

reviewed

··· 63 63 Host: bgshttp, 64 64 } 65 65 66 66 - engine := automod.Engine{} 66 66 + engine := automod.Engine{ 67 67 + Directory: dir, 68 68 + } 67 69 68 70 s := &Server{ 69 71 db: db,