a195d3797a421ad4479bb5c41a7ae5e311bb8ad8

Committed 18 Jun 2024 08:00PM UTC coverage: 54.947% (-0.6%) from 55.59%

Build # a195d3797a421ad4479bb5c41a7ae5e311bb8ad8

Build Type

push

github

Committed by

web-flow

Commit Message

Update Elixir to 1.12.3-otp-23 (#444)

* deps: Update Elixir to 1.12.3-otp-23

* chore: Run mix.format

Run Details

0 of 2 new or added lines in 2 files covered. (0.0%)

44 existing lines in 22 files now uncovered.

1094 of 1991 relevant lines covered (54.95%)

15.13 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

60.0

/apps/cf/lib/notifications/notifications.ex

defmodule CF.Notifications do
  @moduledoc """
  Functions to create, fetch, and manipulate notifications.
  """

  import Ecto.Query

  alias DB.Repo
  alias DB.Schema.User
  alias DB.Schema.UserAction
  alias DB.Schema.Notification

  @doc """
  Get all notifications for user, last inserted first.
  Paginated with `page` + `limit`.
  """
  @spec all(User.t(), integer(), integer(), :all | :seen | :unseen) :: Scrivener.Page.t()
  def all(%User{id: user_id}, page \\ 1, page_size \\ 10, filter \\ :all) do
    Notification
    |> where([n], n.user_id == ^user_id)
    |> add_filter(filter)
    |> order_by(desc: :inserted_at)
    |> Repo.paginate(page: page, page_size: page_size)
  end

  @doc """
  Insert a new notification in DB.
  """
  @spec create!(User.t(), UserAction.t(), atom()) ::
          {:ok, Notification.t()} | {:error, Ecto.Changeset.t()}
  def create!(%User{id: user_id}, %UserAction{id: action_id}, type) do
    %Notification{}
    |> Notification.changeset(%{user_id: user_id, action_id: action_id, type: type})
    |> Repo.insert()
  end

  @doc """
  Mark the given notification as seen or unseed.
  seen.
  """
  @spec mark_as_seen(Notification.t(), boolean()) :: Notification.t()
  def mark_as_seen(notification = %Notification{seen_at: nil}, true) do
    notification
    |> Notification.changeset(%{seen_at: DateTime.utc_now()})
    |> Repo.update()
  end

  def mark_as_seen(notification = %Notification{seen_at: seen_at}, false)
      when not is_nil(seen_at) do
    notification
    |> Notification.changeset(%{seen_at: nil})
    |> Repo.update()
  end

  def mark_as_seen(notification, _),
    do: {:ok, notification}

  defp add_filter(query, :seen), do: where(query, [n], not is_nil(n.seen_at))
  defp add_filter(query, :unseen), do: where(query, [n], is_nil(n.seen_at))
  defp add_filter(query, :all), do: query
end

1	defmodule CF.Notifications do
2	@moduledoc """
3	Functions to create, fetch, and manipulate notifications.
4	"""
5
6	import Ecto.Query
7
8	alias DB.Repo
9	alias DB.Schema.User
10	alias DB.Schema.UserAction
11	alias DB.Schema.Notification
12
13	@doc """
14	Get all notifications for user, last inserted first.
15	Paginated with `page` + `limit`.
16	"""
17	@spec all(User.t(), integer(), integer(), :all \| :seen \| :unseen) :: Scrivener.Page.t()
18	def all(%User{id: user_id}, page \\ 1, page_size \\ 10, filter \\ :all) do
19	Notification
20	\|> where([n], n.user_id == ^user_id)	2✔
21	\|> add_filter(filter)
22	\|> order_by(desc: :inserted_at)	2✔
23	\|> Repo.paginate(page: page, page_size: page_size)	2✔
24	end
25
26	@doc """
27	Insert a new notification in DB.
28	"""
29	@spec create!(User.t(), UserAction.t(), atom()) ::
30	{:ok, Notification.t()} \| {:error, Ecto.Changeset.t()}
31	def create!(%User{id: user_id}, %UserAction{id: action_id}, type) do
32	%Notification{}
33	\|> Notification.changeset(%{user_id: user_id, action_id: action_id, type: type})
34	\|> Repo.insert()	×
35	end
36
37	@doc """
38	Mark the given notification as seen or unseed.
39	seen.
40	"""
41	@spec mark_as_seen(Notification.t(), boolean()) :: Notification.t()
42	def mark_as_seen(notification = %Notification{seen_at: nil}, true) do
43	notification
44	\|> Notification.changeset(%{seen_at: DateTime.utc_now()})
45	\|> Repo.update()	2✔
46	end
47
48	def mark_as_seen(notification = %Notification{seen_at: seen_at}, false)
49	when not is_nil(seen_at) do
50	notification
51	\|> Notification.changeset(%{seen_at: nil})
52	\|> Repo.update()	2✔
53	end
54
55	def mark_as_seen(notification, _),
UNCOV 56	do: {:ok, notification}	×
57
58	defp add_filter(query, :seen), do: where(query, [n], not is_nil(n.seen_at))	×
59	defp add_filter(query, :unseen), do: where(query, [n], is_nil(n.seen_at))	×
60	defp add_filter(query, :all), do: query	2✔
61	end

CaptainFact / captain-fact-api / a195d3797a421ad4479bb5c41a7ae5e311bb8ad8

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous