+3 -1

server/internal/atplistener/jetstream.go

reviewed

··· 24 24 25 25 type handler struct { 26 26 db *db.Store 27 27 + l *log.Logger 27 28 } 28 29 29 30 func NewConsumer(jsAddr string, l *log.Logger, db *db.Store) *Consumer { ··· 41 42 return &Consumer{ 42 43 cfg: cfg, 43 44 logger: l, 44 44 - handler: &handler{db: db}, 45 45 + handler: &handler{db: db, l: l}, 45 46 } 46 47 } 47 48 ··· 75 76 } 76 77 77 78 func (h *handler) handleProfile(ctx context.Context, event *models.Event) error { 79 79 + h.l.Deprintln("handling profile") 78 80 var pr lex.ProfileRecord 79 81 err := json.Unmarshal(event.Commit.Record, &pr) 80 82 if err != nil {

+1 -1

server/internal/log/log.go

reviewed

··· 19 19 if verbose { 20 20 l.debugLogger = log.New(w, "[debug]", log.Ldate|log.Ltime) 21 21 } 22 22 - slog.New(slog.NewTextHandler(w, nil)) 22 22 + l.Slog = slog.New(slog.NewTextHandler(w, nil)) 23 23 return l 24 24 } 25 25