Initial commit

Signed-off-by: Alek Ratzloff <alekratz@gmail.com>

lib/anonbb_web/channels/room_channel.ex

@@ -0,0 +1,29 @@
+defmodule AnonbbWeb.RoomChannel do
+  use Phoenix.Channel
+  alias Anonbb.{Repo, Room, Message}
+  import Ecto.Query
+
+  def join("room:" <> room, _message, socket) do
+    # Make sure the room exists
+    room_name = Repo.one(from r in Room, where: r.name == ^room, select: r.name)
+    if !room_name do
+      Repo.insert(%Room{name: room})
+      room_name = room
+    end
+    {:ok, socket
+    |> assign(:room, room_name)}
+  end
+
+  def handle_in("new_msg", %{"body" => body}, socket) do
+    room = socket.assigns.room
+    body = String.slice(body, 0..1000)
+    insert_message(room, body)
+    broadcast!(socket, "new_msg", %{body: body})
+    {:noreply, socket}
+  end
+
+  defp insert_message(room_name, message) do
+    room_id = Repo.one(from r in Room, where: r.name == ^room_name, select: r.id)
+    Repo.insert(%Message{text: message, room_id: room_id})
+  end
+end

lib/anonbb_web/channels/user_socket.ex

@@ -0,0 +1,33 @@
+defmodule AnonbbWeb.UserSocket do
+  use Phoenix.Socket
+
+  ## Channels
+  channel "room:*", AnonbbWeb.RoomChannel
+
+  # Socket params are passed from the client and can
+  # be used to verify and authenticate a user. After
+  # verification, you can put default assigns into
+  # the socket that will be set for all channels, ie
+  #
+  #     {:ok, assign(socket, :user_id, verified_user_id)}
+  #
+  # To deny connection, return `:error`.
+  #
+  # See `Phoenix.Token` documentation for examples in
+  # performing token verification on connect.
+  def connect(_params, socket, _connect_info) do
+    {:ok, socket}
+  end
+
+  # Socket id's are topics that allow you to identify all sockets for a given user:
+  #
+  #     def id(socket), do: "user_socket:#{socket.assigns.user_id}"
+  #
+  # Would allow you to broadcast a "disconnect" event and terminate
+  # all active sockets and channels for a given user:
+  #
+  #     AnonbbWeb.Endpoint.broadcast("user_socket:#{user.id}", "disconnect", %{})
+  #
+  # Returning `nil` makes this socket anonymous.
+  def id(_socket), do: nil
+end