Differential D443 Diff 1049 lib/kolab_chat/web/channels/room_channel.ex

Changeset View

Standalone View

lib/kolab_chat/web/channels/room_channel.ex

	defmodule KolabChat.Web.RoomChannel do			defmodule KolabChat.Web.RoomChannel do
	use KolabChat.Web, :channel			use KolabChat.Web, :channel

	alias KolabChat.Web.Endpoint			alias KolabChat.Web.Endpoint
				alias KolabChat.Rooms

	@spec join(topic :: binary(), args :: map(), socket :: pid()) :: {:ok, socket :: pid()}			@spec join(topic :: binary(), args :: map(), socket :: pid()) :: {:ok, socket :: pid()}
	def join("room:" <> room_name, _, socket) do			def join("room:" <> room_name, args, socket) do
				room = Rooms.find(%{:id => room_name, :name => room_name})
				socket = socket
				\|> assign(:room, room)
				\|> assign(:context, get_context(args))

				send self(), :after_join
	{:ok, socket}			{:ok, socket}
	end			end

	@spec handle_in(topic :: binary, args :: map(), socket :: pid()) :: {:noreply, socket :: pid()}			@spec handle_in(topic :: binary, args :: map(), socket :: pid()) :: {:noreply, socket :: pid()}
	def handle_in("new:message", message, socket) do			def handle_in("new:message", message, socket) do
	broadcast! socket, "new:message", %{user: socket.assigns.user.username, body: message["body"]}			broadcast! socket, "new:message", %{user: socket.assigns.user.username, body: message["body"]}
	{:noreply, socket}			{:noreply, socket}
	end			end

	def handle_in("ctl:invite", %{"users" => invitee}, socket) when is_bitstring(invitee) do			def handle_in("ctl:invite", %{"users" => invitee}, socket) when is_bitstring(invitee) do
	Endpoint.broadcast!("user:" <> invitee, "notify:invite", %{ user: socket.assigns.user.username, room: socket.topic})			Endpoint.broadcast!("user:" <> invitee, "notify:invite", %{ user: socket.assigns.user.username, room: socket.topic})
	{:noreply, socket}			{:noreply, socket}
	end			end

	def handle_in("ctl:invite", %{"users" => invitees}, socket) when is_list(invitees) do			def handle_in("ctl:invite", %{"users" => invitees}, socket) when is_list(invitees) do
	Enum.each(invitees, fn(invitee) -> Endpoint.broadcast!("user:" <> invitee, "notify:invite", %{ user: socket.assigns.user.username, room: socket.topic}) end)			Enum.each(invitees, fn(invitee) -> Endpoint.broadcast!("user:" <> invitee, "notify:invite", %{ user: socket.assigns.user.username, room: socket.topic}) end)
	{:noreply, socket}			{:noreply, socket}
	end			end

	def handle_in("ctl:invite", params, socket) do			def handle_in("ctl:invite", params, socket) do
	{:noreply, socket}			{:noreply, socket}
	end			end

				@spec handle_info(:after_join, socket :: pid()) :: {:noreply, socket :: pid()}
				def handle_info(:after_join, socket) do
				push socket, "info", socket.assigns.room
				seigoUnsubmitted Not Done Inline Actions this should perhaps already be a map (JSON object on the client side) because we'll definitely want to add more info over time here such as channel name, icon, etc. seigo: this should perhaps already be a map (JSON object on the client side) because we'll definitely…
				# Presence.track_presence(socket)
				{:noreply, socket}
				end

				defp get_context(args) do
				case args do
				%{:context => context} -> context
				_ -> "default"
				end
				end

	end			end