diff --git a/db/streams.go b/db/streams.go index 5b689f9..44dfea7 100644 --- a/db/streams.go +++ b/db/streams.go @@ -12,7 +12,15 @@ import ( // JetStream server. It lives here, next to the code that publishes, on purpose: // the streams used to be created only by an external Python script // (Birock/doormile-bookings/setup_jetstream.py) on another machine, and the two -// drifted. Four of the eight subjects this app published were bound to no stream +// drifted. +// +// That script has since been reduced to a read-only inspector, because it +// updated streams with the subject list replaced wholesale. Re-running it would +// have stripped every subject added here — including booking.assignment_requested, +// which carries the assignment retry loop itself, so bookings would have stopped +// reaching riders entirely with nothing logged anywhere. This map is now the only +// place streams are defined; adding a js.Publish without adding its subject here +// means the event goes nowhere. Four of the eight subjects this app published were bound to no stream // at all — booking.cancelled, booking.outcome, booking.assignment_failed, and // chat.room.closed. (CHAT declared the literal "chat.room.closed", which does // not match a subject with an extra token). Every publish site is best-effort