summaryrefslogtreecommitdiff
path: root/priv
diff options
context:
space:
mode:
authorHaelwenn <contact+git.pleroma.social@hacktivis.me>2020-04-14 06:38:56 +0000
committerHaelwenn <contact+git.pleroma.social@hacktivis.me>2020-04-14 06:38:56 +0000
commit60cc7d6c9a2ec60c3a98f0fe51d68d3dbd5d21c2 (patch)
treef037060e2d82eb69c3eca0151ce78ca53c7962b9 /priv
parente3db1c471e2f52a5bbdc854b594fa08342edf181 (diff)
parenta16b3dbcbf19d584eaefbecbfb4ff34fa7b3743a (diff)
downloadpleroma-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.exs39
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