persist chats

src/chatservice/config/test.exs

@@ -20,12 +20,6 @@ config :chatservice, ChatServiceWeb.Endpoint,
   secret_key_base: "cfHSrMhdqQLdzdAiLRZazXjUBlnd12ZuG3ilwKigBsbA58cOWzW0Rm2cUa5oF8ts",
   server: false
 
-# In test we don't send emails.
-config :chatservice, ChatService.Mailer, adapter: Swoosh.Adapters.Test
-
-# Disable swoosh api client as it is only required for production adapters.
-config :swoosh, :api_client, false
-
 # Print only warnings and errors during test
 config :logger, level: :warning
 

src/chatservice/lib/chatservice.ex

@@ -1,9 +1,6 @@
 defmodule ChatService do
   @moduledoc """
-  ChatService keeps the contexts that define your domain
-  and business logic.
+  The ChatService supervision tree is in chatservice/application.ex
 
-  Contexts are also responsible for managing your data, regardless
-  if it comes from the database, an external API or others.
   """
 end

src/chatservice/lib/chatservice/application.ex

@@ -14,7 +14,6 @@ defmodule ChatService.Application do
     children = [
       ChatServiceWeb.Telemetry,
       ChatService.Repo,
-      # {DNSCluster, query: Application.get_env(:chatservice, :dns_cluster_query) || :ignore},
       {Phoenix.PubSub, name: ChatService.PubSub},
       {Registry, keys: :unique, name: ChatService.Registry},
       ChatServiceWeb.Endpoint

src/chatservice/lib/chatservice/chat_context.ex

@@ -0,0 +1,22 @@
+defmodule ChatService.ChatContext do
+  @moduledoc """
+  The database/persistence context
+  """
+
+  import Ecto.Query, warn: false
+  alias ChatService.Repo
+
+  alias ChatService.ChatContext.Message
+
+  def list_messages(topic) do
+    Message
+    |> where(topic: ^topic)
+    |> Repo.all()
+  end
+
+  def create_message(attrs \\ %{}) do
+    %Message{}
+    |> Message.changeset(attrs)
+    |> Repo.insert()
+  end
+end

src/chatservice/lib/chatservice/chat_context/message.ex

@@ -0,0 +1,20 @@
+defmodule ChatService.ChatContext.Message do
+  @derive {Jason.Encoder, only: [:name, :message, :inserted_at, :topic]}
+  use Ecto.Schema
+  import Ecto.Changeset
+
+  schema "messages" do
+    field :topic, :string
+    field :name, :string
+    field :message, :string
+
+    timestamps(type: :utc_datetime)
+  end
+
+  @doc false
+  def changeset(message, attrs) do
+    message
+    |> cast(attrs, [:topic, :name, :message])
+    |> validate_required([:topic, :name, :message])
+  end
+end

src/chatservice/lib/chatservice/chat_server.ex

@@ -1,5 +1,6 @@
 defmodule ChatService.ChatServer do
-  require OpenTelemetry.Tracer
+  use GenServer
+  alias ChatService.ChatContext
 
   def start_chat(topic) do
     case Registry.lookup(ChatService.Registry, topic) do
@@ -8,34 +9,37 @@ defmodule ChatService.ChatServer do
     end
   end
 
-  def start_link(topic) do
-    GenServer.start_link(__MODULE__, %{}, name: via_tuple(topic))
-  end
-
   def list_topics() do
     ChatService.Registry
     |> Registry.select([{{:"$1", :_, :_}, [], [{{:"$1"}}]}])
     |> Enum.map(fn {key} -> key end)
   end
 
   def send_message(topic, message) do
-    OpenTelemetry.Tracer.with_span :send_message do
-      GenServer.call(via_tuple(topic), {:send_message, message})
-    end
+    GenServer.call(via_tuple(topic), {:send_message, Map.put(message, "topic", topic)})
   end
 
   def get_messages(topic) do
     GenServer.call(via_tuple(topic), :get_messages)
   end
 
-  def init(_) do
-    {:ok, []}
+  def start_link(topic) do
+    GenServer.start_link(__MODULE__, topic, name: via_tuple(topic))
+  end
+
+  @impl true
+  def init(topic) do
+    messages = ChatContext.list_messages(topic)
+    {:ok, messages}
   end
 
+  @impl true
   def handle_call({:send_message, message}, _from, state) do
-    {:reply, :ok, [message | state]}
+    saved = ChatContext.create_message(message)
+    {:reply, saved, [saved | state]}
   end
 
+  @impl true
   def handle_call(:get_messages, _from, state) do
     {:reply, Enum.reverse(state), state}
   end

src/chatservice/lib/chatservice_web.ex

@@ -43,7 +43,6 @@ defmodule ChatServiceWeb do
         layouts: [html: ChatServiceWeb.Layouts]
 
       import Plug.Conn
-      import ChatServiceWeb.Gettext
 
       unquote(verified_routes())
     end