# Update server state from browser events
defmodule MyAppWeb.CounterLive do
  use MyAppWeb, :live_view

  def mount(_params, _session, socket) do
    {:ok, assign(socket, count: 0)}
  end

  def handle_event("increment", _, socket) do
    {:noreply, update(socket, :count, &(&1 + 1))}
  end
end

# Control hardware from a supervised process
def handle_info(:toggle_led, %{led: led} = state) do
  next_level = 1 - state.level

  :ok = Circuits.GPIO.write(led, next_level)
  Process.send_after(self(), :toggle_led, 500)

  {:noreply, %{state | level: next_level}}
end

# Run a pre-trained model with Nx acceleration
{:ok, model} =
  Bumblebee.load_model({:hf, "google/vit"})
{:ok, featurizer} =
  Bumblebee.load_featurizer({:hf, "google/vit"})

serving =
  Bumblebee.Vision.image_classification(model, featurizer,
    compile: [batch_size: 1],
    defn_options: [compiler: EXLA]
  )

Nx.Serving.run(serving, image)

# Broadway controls demand and applies backpressure
Broadway.start_link(MyPipeline,
  producer: [
    module: BroadwaySQS.Producer
  ],
  processors: [
    default: [concurrency: 50]
  ],
  batchers: [
    storage: [batch_size: 100, batch_timeout: 1_000]
  ]
)

# Connect nodes through Erlang distribution
edge_nodes = [:"edge@factory-1", :"edge@factory-2"]

Enum.each(edge_nodes, &Node.connect/1)

# Execute concurrently across every connected node
:erpc.multicall(
  edge_nodes,
  Sensor, :read_temperature, []
)