Adding a handle_info callback to LiveComponents

Lately I’ve been thinking about how to organize components as a LiveView application grows. One of the pain points I’ve found (for myself and beginners) is communicating over PubSub with LiveComponents. The only way to do so is through the parent LiveView, which works well but introduces boilerplate and some indirection, as the LiveView is required to maintain the PubSub subscriptions, and communicate state changes via component assigns or send_update/2.

It would be nice if LiveComponents could implement a handle_info/2 callback, and had a way to manage their own PubSub subscriptions. Well, I was able to implement just that. This is how the “connected” component itself looks:

defmodule CounterComponent do
  use AppWeb, :connected_component

  def render(assigns) do
    ~H"""
    <div {@connected_attrs}>{@count}</div>
    """
  end

  def on_mount(socket) do
    process_setup = fn ->
      Phoenix.PubSub.subscribe(App.PubSub, "inc_channel")
    end

    {:ok, assign(socket, :count, 0), process_setup}
  end

  def handle_info(:inc, socket) do
    {:noreply, update(socket, :count, &(&1 + 1))}
  end
end

I’ve called it “connected” because the component has its own process, which is connected to it via the parent LiveView process. In the on_mount/1 callback, the component returns an anonymous function which is called in a new process and creates any interprocess connections needed by the component (generally, PubSub subscriptions).

In this example, the component receives :inc messages via inc_channel, which when received increments the :count assign on the component. The advantage of this is that the LiveComponent is now fully encapsulated, including its interactions with PubSub.

You can find a complete example and demo video here: GitHub - jtormey/connected_component_demo: Phoenix LiveView project demoing the ConnectedComponent concept

The implementation itself is here (not extensively tested, there may be bugs).

Using these components is transparent to the parent LiveView and even allows for deeply nested components to have their own handle_info/2 callbacks. It just requires an on_mount/1 handler to be called in the parent LiveView, which can be applied for all LiveViews globally by calling it in the live_view/1 macro in your web module (you can see how this works in the demo application).

There is a slight performance cost: an additional process for each component that uses this pattern, and each message that is received is copied one more time than would normally be necessary. Though I think these can be justified.

I’m curious if anyone would find this useful in their own applications. Personally I like the convenience and the API, and wonder if something like this might be a worthwhile addition to LiveView itself.

4 Likes

You can achieve the same goal by creating nested LiveViews.

In my opinion, the primary reason to use components is to save resources by avoiding the need to spawn a new process. I don’t see a compelling reason to use a “connected component” since LiveView already provides that functionality.

Did you explore adding handlers in on_mount for the components without the extra process? If so, what made you go this route?

A major difference is that passing props to a nested liveview and updating it on-page (outside of messages) is much more clunky.

That said I am not convinced the upside is bigger than the added downside/complexity.

1 Like

Nested LiveViews are similar, but they are clunkier and even more expensive:

  • They also spawn a new process, which is even heavier than my connected component process (it holds the state of the LiveView, instead of just passing along messages).
  • The nested LiveView can’t receive assigns directly from its parent, so it has to re-mount all of the state it needs, including I believe your whole auth pipeline.
  • It’s more isolated from the parent LiveView than a LiveComponent, making it more difficult to relay information and making the dev experience more difficult in my experience.

assign_new is meant to take care of inheriting assigns from a parent LV. No need to query data already available again.

Yes, but then as the developer you have to be very careful about how data coming from other processes is routed to the right components, which is what I’m trying to solve.

Could you elaborate on this? From what I can tell, you can’t actually pass assigns from a parent LiveView to a LiveView rendered with live_render/3. The only data you can pass is via the :session option, which you would then use to fetch the data needed by the LiveView, including session/user data that already existed in the parent.

Also, it’s not that I think nested LiveViews don’t have a purpose. For example, live_render/3 with sticky: true when a persistent, isolated LiveView is needed in the app (helpful for uploads that don’t interrupt on page navigation).

The advantages I believe my solution has over nested LiveViews are: it’s easier to pass data up or down the component tree (any Elixir term can be an assign), it’s less expensive (spawns a new process, but it does less, and there’s no re-fetching data), it still has the familiar LiveComponent API for receiving updated assigns from the parent (update/2).

Only half of that is true. Yes you can only pass session data around (just like with the static render → connected render). But assign_new will look up assigns like :current_user in the parent LV and only query for it if that assign doesn’t exist in the parent. So if you run your auth pipeline in the parent a nested LV will just get to use the results of it, not query all the information again.

1 Like

Ah, that’s a neat feature. I didn’t know that.

Still, it’s not as explicit as assigns. And in the solution I presented, you can have a connected component deeply nested within other LiveComponents, and it will be able to receive messages from PubSub to its handle_info/3 callback. I think you lose that level of composition with live_render/3.

Name spacing the events breaks down at what point? Deeply nested components?

Name spaces can conflict between sibling components. And that aside, this is more about avoiding the indirection of: handle_info/2 -> send_update/2 -> update/2.

The ability to add handle_info/2 to any LiveComponent and have it manage its own PubSub subscriptions, no manual routing required, is incredibly convenient.

I get that, but it does come with a cost - extra process plus an extra library with slightly different semantics. You don’t explain the original problem and what it looks like so I’m really just trying to understand how you got here.

To put those costs in perspective, an extra process isn’t expensive in elixir, and the library is a thin wrapper around Phoenix.LiveComponent, which you would only use if the new semantics prove valuable for you.

The original problem is in the first paragraph of the post if that helps :slightly_smiling_face:

I implemented the example app using both approaches in case you’d like to compare: Connected vs. Disconnected (vanilla LiveView). If it’s not worth the cost to you, totally get that, I shared in case anyone else was in search of better abstractions/patterns around LiveView.

1 Like

I’m not sure if I agree with that statement because the LiveComponent state will also need to be stored, though not in a lightweight process, but in the parent LiveView. However, I don’t think that’s the main point of the discussion.

I understand that the initial problem you’re trying to solve is the communication between LiveComponents and PubSub. Since the discussion has shifted towards efficiency, I believe it would be beneficial to avoid creating a separate process to accommodate this feature. Instead, a “message broker” within the LiveView itself could handle this task, eliminating the need to spawn additional processes. This approach is more efficient and avoids introducing extra complexity to the LiveComponents.

1 Like

I agree, it would be best if the extra process wasn’t necessary. However I wasn’t able to come up with a solution for automatically brokering messages in a single process, there are too many complications and you end up back where we started with manual message routing.

The extra process removes this complexity entirely, when it receives a message you know exactly the component its meant for, then it’s tagged as such and relayed to it. And this is opt-in, you wouldn’t use this for the majority of your components.

If you have specific ideas on implementing a single-process message broker I would love to hear them!

2 Likes