rayrayzayzay

defmodule ChannelHandler do
  def process_plugs(plugs, socket, payload, bindings \\ %{}) do
    result =
			Enum.reduce_while(plugs, {socket, payload, bindings},
				fn plug, {socket, payload, bindings} ->
	        case process_plug(plug, socket, payload, bindings) do
	          {:cont, socket, payload, bindings} -> {:cont, {:cont, socket, payload, bindings}}
	          {:halt, socket, status, reason} -> {:halt, {:halt, socket, status, reason}}
	        end
	    end)

rayrayzayzay

@spec call(Phoenix.Socket.t, payload :: any, bindings :: any, opts :: any) ::
		{:cont, Phoenix.Socket.t, payload :: any, bindings :: any}
		| {:halt, status :: atom, reason :: any}

rayrayzayzay

@spec call(socket :: Phoenix.Socket.t, opts :: any) :: Phoenix.Socket.t

rayrayzayzay

defmodule Felt.Channel.ElementHandler do
  def handle_event(event, payload, socket) when event in ["create", "update", "delete"] do
    with :ok <- ensure_map_editable(socket) do
      do_handle_event(event, payload, socket)
    else
      {:error, reason} ->
        {:reply, {:error, reason}, socket}
    end
  end

rayrayzayzay

defmodule Felt.Channel.ElementHandler do
  def handle_event("create", payload, socket) do
    with :ok <- ensure_map_editable(socket) do
      # Create the element
    end
  end

  def handle_event("update", payload, socket) do
    with :ok <- ensure_map_editable(socket) do
      # Update the element

rayrayzayzay

plug MyAppWeb.Plugs.EnsureAuthenticated

rayrayzayzay

def handle_call("element:" <> event, payload, socket) do
  FeltWeb.Channels.ElementHandler.handle_event(event, payload, socket)
end

def handle_call("layer:" <> event, payload, socket) do
  FeltWeb.Channels.LayerHandler.handle_event(event, payload, socket)
end

def handle_event("sync:" <> event, payload, socket) do
  FeltWeb.Channels.SyncHandler.handle_event(event, payload, socket)

rayrayzayzay

## Element handling

def handle_event("element:create", payload, socket) do
  # ...
end

def handle_event("element:update", payload, socket) do
  # ...
end

rayrayzayzay

plug MyAppWeb.Plugs.CheckFeatureFlag,
  :upload_anything when action in [:import_layer, :import_elements]

def import_layer(conn, params) do
  # Will run if feature flag is enabled, fail otherwise
end

rayrayzayzay

public generateExpression(): MapLibreExpression {
    return [
      "interpolate",
      ["exponential", this.base],
      ["zoom"],
      ...this.stops.map((stop) => [stop[0] - 1, stop[1]]).flat(),
    ];
  }