Add support for creating associated conversations with message

- Fix DataToAttributes plug's parse_included fn
- Add conversation parts to view and controller
- Add conversation channel

Author: begedin

config/dev.exs

@@ -43,7 +43,7 @@ config :code_corps, CodeCorps.Repo,
   pool_size: 10
 
 # CORS allowed origins
-config :code_corps, allowed_origins: ["http://localhost:4200"]
+config :code_corps, allowed_origins: ["http://localhost:4200", "chrome-extension://pfdhoblngboilpfeibdedpjgfnlcodoo"]
 
 config :code_corps, CodeCorps.Guardian,
   secret_key: "e62fb6e2746f6b1bf8b5b735ba816c2eae1d5d76e64f18f3fc647e308b0c159e"

lib/code_corps/messages/conversation_parts.ex

@@ -10,17 +10,21 @@ defmodule CodeCorps.Messages.ConversationParts do
     ConversationPart,
     Repo
   }
+  alias CodeCorpsWeb.ConversationChannel
 
   @spec create(map) :: ConversationPart.t | Ecto.Changeset.t
   def create(attrs) do
-    %ConversationPart{} |> create_changeset(attrs) |> Repo.insert()
+    with {:ok, %ConversationPart{} = conversation_part} <- %ConversationPart{} |> create_changeset(attrs) |> Repo.insert() do
+      ConversationChannel.broadcast_new_conversation_part(conversation_part)
+      {:ok, conversation_part}
+    end
   end
 
   @doc false
   @spec create_changeset(ConversationPart.t, map) :: Ecto.Changeset.t
   def create_changeset(%ConversationPart{} = conversation_part, attrs) do
     conversation_part
-    |> cast(attrs, [:author_id, :body, :conversation_id, :read_at])
+    |> cast(attrs, [:author_id, :body, :conversation_id])
     |> validate_required([:author_id, :body, :conversation_id])
     |> assoc_constraint(:author)
     |> assoc_constraint(:conversation)

lib/code_corps/messages/conversations.ex

@@ -0,0 +1,19 @@
+defmodule CodeCorps.Messages.Conversations do
+  @moduledoc ~S"""
+  Subcontext aimed at managing `CodeCorps.Conversation` records aimed at a
+  specific user belonging to a `CodeCorps.Message`.
+  """
+
+  alias Ecto.Changeset
+
+  alias CodeCorps.{Conversation}
+
+  @doc false
+  @spec create_changeset(Conversation.t, map) :: Ecto.Changeset.t
+  def create_changeset(%Conversation{} = conversation, %{} = attrs) do
+    conversation
+    |> Changeset.cast(attrs, [:user_id])
+    |> Changeset.validate_required([:user_id])
+    |> Changeset.assoc_constraint(:user)
+  end
+end

lib/code_corps/messages/messages.ex

@@ -67,6 +67,11 @@ defmodule CodeCorps.Messages do
   def create(%{} = params) do
     %Message{}
     |> Message.changeset(params)
+    |> Changeset.cast(params, [:author_id, :project_id])
+    |> Changeset.validate_required([:author_id, :project_id])
+    |> Changeset.assoc_constraint(:author)
+    |> Changeset.assoc_constraint(:project)
+    |> Changeset.cast_assoc(:conversations, with: &Messages.Conversations.create_changeset/2)
     |> Repo.insert()
   end
 

lib/code_corps_web/channels/conversation_channel.ex

@@ -0,0 +1,34 @@
+defmodule CodeCorpsWeb.ConversationChannel do
+  use Phoenix.Channel
+
+  alias CodeCorps.{Conversation, Policy, Repo, User}
+  alias Phoenix.Socket
+
+  @spec join(String.t, map, Socket.t) :: {:ok, Socket.t} | {:error, map}
+  def join("conversation:" <> id, %{}, %Socket{} = socket) do
+    with %Conversation{} = conversation <- Conversation |> Repo.get(id),
+         %User{} = current_user <- socket.assigns[:current_user],
+         {:ok, :authorized} <- current_user |> Policy.authorize(:show, conversation, %{}) do
+
+        {:ok, socket}
+    else
+      nil -> {:error, %{reason: "unauthenticated"}}
+      {:error, :not_authorized} -> {:error, %{reason: "unauthorized"}}
+    end
+  end
+
+  def event("new:conversation-part", socket, message) do
+    broadcast socket, "new:conversation-part", message
+    {:ok, socket}
+  end
+
+  def broadcast_new_conversation_part(conversation_part) do
+    channel = "conversation:#{conversation_part.conversation_id}"
+    event = "new:conversation-part"
+    payload = %{
+      id: conversation_part.id
+    }
+
+    CodeCorpsWeb.Endpoint.broadcast(channel, event, payload)
+  end
+end

lib/code_corps_web/channels/user_socket.ex

@@ -2,7 +2,7 @@ defmodule CodeCorpsWeb.UserSocket do
   use Phoenix.Socket
 
   ## Channels
-  # channel "room:*", CodeCorps.RoomChannel
+  channel "conversation:*", CodeCorpsWeb.ConversationChannel
 
   ## Transports
   transport :websocket, Phoenix.Transports.WebSocket,
@@ -20,8 +20,13 @@ defmodule CodeCorpsWeb.UserSocket do
   #
   # See `Phoenix.Token` documentation for examples in
   # performing token verification on connect.
-  def connect(_params, socket) do
-    {:ok, socket}
+  def connect(%{"token" => token}, socket) do
+    with {:ok, claims} <- CodeCorps.Guardian.decode_and_verify(token),
+         {:ok, user} <- CodeCorps.Guardian.resource_from_claims(claims) do
+      {:ok, assign(socket, :current_user, user)}
+    else
+      _ -> {:ok, socket}
+    end
   end
 
   # Socket id's are topics that allow you to identify all sockets for a given user:

lib/code_corps_web/controllers/conversation_controller.ex

@@ -15,17 +15,23 @@ defmodule CodeCorpsWeb.ConversationController do
   @spec index(Conn.t, map) :: Conn.t
   def index(%Conn{} = conn, %{} = params) do
     with %User{} = current_user <- conn |> CodeCorps.Guardian.Plug.current_resource,
-         conversations <- Conversation |> Policy.scope(current_user) |> Messages.list_conversations(params) do
+         conversations <- Conversation |> Policy.scope(current_user) |> Messages.list_conversations(params) |> preload() do
       conn |> render("index.json-api", data: conversations)
     end
   end
 
   @spec show(Conn.t, map) :: Conn.t
   def show(%Conn{} = conn, %{"id" => id}) do
     with %User{} = current_user <- conn |> CodeCorps.Guardian.Plug.current_resource,
-      %Conversation{} = conversation <- Messages.get_conversation(id),
+      %Conversation{} = conversation <- Messages.get_conversation(id) |> preload(),
       {:ok, :authorized} <- current_user |> Policy.authorize(:show, conversation, %{}) do
       conn |> render("show.json-api", data: conversation)
     end
   end
+
+  @preloads [:conversation_parts, :message, :user]
+
+  def preload(data) do
+    Repo.preload(data, @preloads)
+  end
 end

lib/code_corps_web/controllers/message_controller.ex

@@ -9,21 +9,21 @@ defmodule CodeCorpsWeb.MessageController do
   }
 
   action_fallback CodeCorpsWeb.FallbackController
-  plug CodeCorpsWeb.Plug.DataToAttributes
+  plug CodeCorpsWeb.Plug.DataToAttributes, [includes_many: ~w(conversation)]
   plug CodeCorpsWeb.Plug.IdsToIntegers
 
   @spec index(Conn.t, map) :: Conn.t
   def index(%Conn{} = conn, %{} = params) do
     with %User{} = current_user <- conn |> CodeCorps.Guardian.Plug.current_resource,
-         messages <- Message |> Policy.scope(current_user) |> Messages.list(params) do
+         messages <- Message |> Policy.scope(current_user) |> Messages.list(params) |> preload() do
       conn |> render("index.json-api", data: messages)
     end
   end
 
   @spec show(Conn.t, map) :: Conn.t
   def show(%Conn{} = conn, %{"id" => id}) do
     with %User{} = current_user <- conn |> CodeCorps.Guardian.Plug.current_resource,
-      %Message{} = message <- Message |> Repo.get(id),
+      %Message{} = message <- Message |> Repo.get(id) |> preload(),
       {:ok, :authorized} <- current_user |> Policy.authorize(:show, message, %{}) do
       conn |> render("show.json-api", data: message)
     end
@@ -40,7 +40,7 @@ defmodule CodeCorpsWeb.MessageController do
     end
   end
 
-  @preloads [:author, :project]
+  @preloads [:author, :project, :conversations]
 
   def preload(data) do
     Repo.preload(data, @preloads)

lib/code_corps_web/plugs/data_to_attributes.ex

@@ -1,9 +1,11 @@
 defmodule CodeCorpsWeb.Plug.DataToAttributes do
   @moduledoc ~S"""
-  Converts params in the JSON api "data" format into flat params convient for
+  Converts params in the JSON api format into flat params convient for
   changeset casting.
 
-  This is done using `JaSerializer.Params.to_attributes/1`
+  For base parameters, this is done using `JaSerializer.Params.to_attributes/1`
+
+  For included records, this is done using custom code.
   """
 
   alias Plug.Conn
@@ -12,13 +14,38 @@ defmodule CodeCorpsWeb.Plug.DataToAttributes do
   def init(opts), do: opts
 
   @spec call(Conn.t, Keyword.t) :: Plug.Conn.t
-  def call(%Conn{params: %{"data" => data} = params} = conn, _opts) do
+  def call(%Conn{params: %{} = params} = conn, opts \\ []) do
     attributes =
       params
       |> Map.delete("data")
-      |> Map.merge(data |> JaSerializer.Params.to_attributes)
+      |> Map.delete("included")
+      |> Map.merge(params |> parse_data())
+      |> Map.merge(params |> parse_included(opts))
 
     conn |> Map.put(:params, attributes)
   end
-  def call(%Conn{} = conn, _opts), do: conn
+
+  @spec parse_data(map) :: map
+  defp parse_data(%{"data" => data}), do: data |> JaSerializer.Params.to_attributes
+  defp parse_data(%{}), do: %{}
+
+  @spec parse_included(map, Keyword.t) :: map
+  defp parse_included(%{"included" => included}, opts) do
+    included |> Enum.reduce(%{}, fn (%{"data" => %{"type" => type}} = params, parsed) ->
+      attributes = params |> parse_data()
+
+      if opts |> Keyword.get(:includes_many, []) |> Enum.member?(type) do
+        # this is an explicitly specified has_many,
+        # update existing data by adding new record
+        pluralized_type = type |> Inflex.pluralize
+        parsed |> Map.update(pluralized_type, [attributes], fn data ->
+          data ++ [attributes]
+        end)
+      else
+        # this is a belongs to, put a new submap into payload
+        parsed |> Map.put(type, attributes)
+      end
+    end)
+  end
+  defp parse_included(%{}, _opts), do: %{}
 end

lib/code_corps_web/views/conversation_view.ex

@@ -7,4 +7,6 @@ defmodule CodeCorpsWeb.ConversationView do
 
   has_one :user, type: "user", field: :user_id
   has_one :message, type: "message", field: :message_id
+
+  has_many :conversation_parts, serializer: CodeCorpsWeb.ConversationPartView, identifiers: :always
 end