ash notifier pubsub question

def mount(_params, session, socket) do
    Phoenix.PubSub.subscribe(App.PubSub, "budget:#{budget_id}")
end

def handle_info(
        %Phoenix.Socket.Broadcast{
          topic: "budget:" <> budget_id,
          event: _event,
          payload: _data
        },
        socket
      ) do
end

pub_sub do
    module AppWeb.Endpoint
    prefix "budget"

    publish_all :create, [:budget_id] do
      transform & &1.data
    end

    publish_all :update, [:budget_id] do
      transform & &1.data
    end
  end

publish_all :create, [:budget_id] do
      transform fn notification ->
        transfer = notification.data
       
        case App.Finance.get_account(transfer.from_account_id, tenant: transfer.organization_id, authorize?: false) do
          {:ok, account} -> 
            %{notification | data: Map.put(transfer, :budget_id, account.budget_id)}
          {:error, error} -> 
            notification
        end
      end
    end