Tips for troubleshooting PubSub messages not received?

First thing I would check is if a generic handle_info(msg, socket) catch something in the msg.

Subscribing in handle_params could prove to be problematic. It’s hard to see without more context—is your LiveView handling both “index” and “show” pages? If not, then you can still get the id from def mount(%{"id" => id}, _session, socket). If they are sharing a LiveView, then as you have it you aren’t unsubscribing from the previous trip before subscribing to the new one which means they would pile up. handle_params get called any time there is a patch event. This applies to things like query params or subroutes that may potentially point to the same LiveView. This means that on any patch to the same trip it will unsubscribe and resubscribe. I’m not actually sure what effect that would have, but I wouldn’t say it’s the best place to put it. Possibly there is a sane way to do so but it’s not something I’ve ever seen before and I feel like it could lead to confusing bugs.

Yeah, I have a catch-all at the end that will alert if it ever gets hit. But it’s not being triggered either.

I wondered about that since every example seems to use mount. I tried listening in mount by hard-coding the id since I didn’t see a way to get at the params there, but no change.

Also agreed, unsubscribing and immediately subscribing feels really ugly. I wasn’t sure how to both access the id and prevent having multiple subscriptions.

This is a show LiveView so I don’t have to worry about an index and the id changing.

Ah, so is your problem that you are patching when switching between trips and that’s why you need handle_params? Otherwise, params is the first parameter given to mount so you should definitely be able to get the id from there.

You could also subscribe to a general trips channel and see if it’s the current one or not:

handle_info({:trip_updated, trip}, socket)
    when trip.id == socket.assigns.trip.id do
  # ...
  {:noreply, socket}
end

As a quick sanity check to check if your Ido.PubSub is working, could you try the following in an interactive Elixir session with a running Phoenix server i.e. iex -S mix phx.server?

Phoenix.PubSub.subscribe(Ido.PubSub, "trip:foo")
:ok
Process.info(self(), :messages)
{:messages, []}
Phoenix.PubSub.broadcast(Ido.PubSub, "trip:foo", "bar")
:ok
Process.info(self(), :messages)
{:messages, ["bar"]}

Ok, I just tried that and have the exact same output as you.

Ha, yeah- great point. My eyes completely glazed right over that fact. I’ve moved my subscribe into mount/3.

Hmm, how’s broadcast_email_processed being called?

Any chance the trip_id might be mismatched somehow and the PubSub message gets broadcasted to another topic that the LiveView is not subscribed to? It might be worth throwing an IO.inspect(msg) in there and then verifying that msg.element.trip_id is set as expected.

Ooof, I’m an idiot. So I was testing by running mix phx.server in one shell, and iex -S mix, and I somehow thought those would be the same app.

I just ran an iex -S mix phx.server, and then in that same REPL triggered some broadcasts and it worked perfectly.

Thank you all so much!