Add new feature to count messages by date

lib/chat_api/reporting.ex

@@ -31,6 +31,20 @@ defmodule ChatApi.Reporting do
     |> Repo.all()
   end
 
+  def count_sent_messages_by_date() do
+    Message
+    |> where([message], not is_nil(message.user_id))
+    |> count_grouped_by_date()
+    |> Repo.all()
+  end
+
+  def count_received_messages_by_date() do
+    Message
+    |> where([message], not is_nil(message.customer_id))
+    |> count_grouped_by_date()
+    |> Repo.all()
+  end
+
   def count_grouped_by_date(query, field \\ :inserted_at) do
     query
     |> group_by([r], fragment("date(?)", field(r, ^field)))

test/chat_api/reporting_test.exs

@@ -115,5 +115,84 @@ defmodule ChatApi.ReportingTest do
                %{date: ~D[2020-09-03], count: 1}
              ] = Reporting.conversations_by_date(account.id)
     end
+
+    test "count_sent_messages_by_date/0 groups by date correctly", %{
+      account: account,
+      customer: customer
+    } do
+      user_2 = user_fixture(account)
+      user_3 = user_fixture(account)
+      conversation = conversation_fixture(account, customer)
+
+      message_fixture(account, conversation, %{
+        inserted_at: ~N[2020-09-01 12:00:00],
+        user_id: user_2.id
+      })
+
+      message_fixture(account, conversation, %{
+        inserted_at: ~N[2020-09-02 12:00:00],
+        user_id: user_2.id
+      })
+
+      message_fixture(account, conversation, %{
+        inserted_at: ~N[2020-09-03 12:00:00],
+        user_id: user_3.id
+      })
+
+      message_fixture(account, conversation, %{
+        inserted_at: ~N[2020-09-03 12:00:00],
+        user_id: user_3.id
+      })
+
+      message_fixture(account, conversation, %{
+        inserted_at: ~N[2020-09-03 12:00:00],
+        customer_id: customer.id
+      })
+
+      assert [
+               %{date: ~D[2020-09-01], count: 1},
+               %{date: ~D[2020-09-02], count: 1},
+               %{date: ~D[2020-09-03], count: 2}
+             ] = Reporting.count_sent_messages_by_date()
+    end
+
+    test "count_received_messages_by_date/0 groups by date correctly", %{
+      account: account,
+      customer: customer
+    } do
+      user_2 = user_fixture(account)
+      conversation = conversation_fixture(account, customer)
+
+      message_fixture(account, conversation, %{
+        inserted_at: ~N[2020-09-01 12:00:00],
+        customer_id: customer.id
+      })
+
+      message_fixture(account, conversation, %{
+        inserted_at: ~N[2020-09-02 12:00:00],
+        customer_id: customer.id
+      })
+
+      message_fixture(account, conversation, %{
+        inserted_at: ~N[2020-09-03 12:00:00],
+        customer_id: customer.id
+      })
+
+      message_fixture(account, conversation, %{
+        inserted_at: ~N[2020-09-03 12:00:00],
+        user_id: user_2.id
+      })
+
+      message_fixture(account, conversation, %{
+        inserted_at: ~N[2020-09-03 12:00:00],
+        user_id: user_2.id
+      })
+
+      assert [
+               %{date: ~D[2020-09-01], count: 1},
+               %{date: ~D[2020-09-02], count: 1},
+               %{date: ~D[2020-09-03], count: 1}
+             ] = Reporting.count_received_messages_by_date()
+    end
   end
 end