diff options
author | Haelwenn <contact+git.pleroma.social@hacktivis.me> | 2020-04-14 06:38:56 +0000 |
---|---|---|
committer | Haelwenn <contact+git.pleroma.social@hacktivis.me> | 2020-04-14 06:38:56 +0000 |
commit | 60cc7d6c9a2ec60c3a98f0fe51d68d3dbd5d21c2 (patch) | |
tree | f037060e2d82eb69c3eca0151ce78ca53c7962b9 /priv | |
parent | e3db1c471e2f52a5bbdc854b594fa08342edf181 (diff) | |
parent | a16b3dbcbf19d584eaefbecbfb4ff34fa7b3743a (diff) | |
download | pleroma-60cc7d6c9a2ec60c3a98f0fe51d68d3dbd5d21c2.tar.gz pleroma-60cc7d6c9a2ec60c3a98f0fe51d68d3dbd5d21c2.zip |
Merge branch 'issue/1276' into 'develop'
[#1276] An endpoint for getting unread notification count
Closes #1276
See merge request pleroma/pleroma!1877
Diffstat (limited to 'priv')
-rw-r--r-- | priv/repo/migrations/20200210050658_update_markers.exs | 39 |
1 files changed, 39 insertions, 0 deletions
diff --git a/priv/repo/migrations/20200210050658_update_markers.exs b/priv/repo/migrations/20200210050658_update_markers.exs new file mode 100644 index 000000000..b280e156c --- /dev/null +++ b/priv/repo/migrations/20200210050658_update_markers.exs @@ -0,0 +1,39 @@ +defmodule Pleroma.Repo.Migrations.UpdateMarkers do + use Ecto.Migration + import Ecto.Query + alias Pleroma.Repo + + def up do + update_markers() + end + + def down do + :ok + end + + defp update_markers do + now = NaiveDateTime.utc_now() + + markers_attrs = + from(q in "notifications", + select: %{ + timeline: "notifications", + user_id: q.user_id, + last_read_id: + type(fragment("MAX( CASE WHEN seen = true THEN id ELSE null END )"), :string) + }, + group_by: [q.user_id] + ) + |> Repo.all() + |> Enum.map(fn attrs -> + attrs + |> Map.put_new(:inserted_at, now) + |> Map.put_new(:updated_at, now) + end) + + Repo.insert_all("markers", markers_attrs, + on_conflict: {:replace, [:last_read_id, :unread_count]}, + conflict_target: [:user_id, :timeline] + ) + end +end |