this repo has no description
add more bugsnag errors
+6
-3
+3
-3
consumer.go
+3
-3
consumer.go
···
4
4
"context"
5
5
"encoding/json"
6
6
"fmt"
7
-
"log"
8
7
"log/slog"
9
8
"strings"
10
9
"sync"
···
42
41
}
43
42
44
43
scheduler := sequential.NewScheduler("jetstream_localdev", logger, h.HandleEvent)
44
+
defer scheduler.Shutdown()
45
45
46
46
// TODO: logger
47
47
c, err := client.NewClient(con.cfg, slog.Default(), scheduler)
48
48
if err != nil {
49
-
log.Fatalf("failed to create client: %v", err)
49
+
return fmt.Errorf("failed to create client: %w", err)
50
50
}
51
51
52
52
cursor := time.Now().Add(5 * -time.Minute).UnixMicro()
···
115
115
subscribedDids, ok := h.parentsToLookFor[parentURI]
116
116
if !ok {
117
117
h.parentsToLookFor[parentURI] = map[string]struct{}{
118
-
did: struct{}{},
118
+
did: {},
119
119
}
120
120
return
121
121
}
+3
server.go
+3
server.go
···
7
7
"log/slog"
8
8
"net/http"
9
9
"strconv"
10
+
11
+
"github.com/bugsnag/bugsnag-go/v2"
10
12
)
11
13
12
14
type Feeder interface {
···
46
48
func (s *Server) Run() {
47
49
err := s.httpsrv.ListenAndServe()
48
50
if err != nil {
51
+
bugsnag.Notify(fmt.Errorf("http server: %w", err))
49
52
slog.Error("listen and serve", "error", err)
50
53
}
51
54
}