+1 -1

consumer.go

reviewed

··· 127 127 if event.Did != "did:plc:dadhhalkfcq3gucaq25hjqon" { 128 128 return nil 129 129 } 130 130 - slog.Info("delete event received") 130 130 + slog.Info("delete event received", "did", event.Did, "rkey", event.Commit.RKey) 131 131 132 132 parentURI, err := getSubscribingPostParentURI(h.db, event.Did, event.Commit.RKey) 133 133 if err != nil {

+3

database.go

reviewed

··· 195 195 if err := rows.Scan(&subscription.ID, &subscription.ParentURI); err != nil { 196 196 return "", fmt.Errorf("scan row: %w", err) 197 197 } 198 198 + 199 199 + slog.Info("record", "val", subscription) 200 200 + 198 201 parentURI = subscription.ParentURI 199 202 break 200 203 }