From cd040691bd28fea1437b8f1c39bb914465e1ff46 Mon Sep 17 00:00:00 2001
From: Maksim Pechnikov <parallel588@gmail.com>
Date: Mon, 10 Feb 2020 09:01:45 +0300
Subject: maked `unread_count` as virtual field

---
 .../20191030202008_add_unread_to_marker.exs        | 48 ----------------------
 .../migrations/20200210050658_update_markers.exs   | 39 ++++++++++++++++++
 2 files changed, 39 insertions(+), 48 deletions(-)
 delete mode 100644 priv/repo/migrations/20191030202008_add_unread_to_marker.exs
 create mode 100644 priv/repo/migrations/20200210050658_update_markers.exs

(limited to 'priv')

diff --git a/priv/repo/migrations/20191030202008_add_unread_to_marker.exs b/priv/repo/migrations/20191030202008_add_unread_to_marker.exs
deleted file mode 100644
index 2b3abc682..000000000
--- a/priv/repo/migrations/20191030202008_add_unread_to_marker.exs
+++ /dev/null
@@ -1,48 +0,0 @@
-defmodule Pleroma.Repo.Migrations.AddUnreadToMarker do
-  use Ecto.Migration
-  import Ecto.Query
-  alias Pleroma.Repo
-
-  def up do
-    alter table(:markers) do
-      add_if_not_exists(:unread_count, :integer, default: 0)
-    end
-
-    flush()
-
-    update_markers()
-  end
-
-  def down do
-    alter table(:markers) do
-      remove_if_exists(:unread_count, :integer)
-    end
-  end
-
-  def update_markers do
-    now = NaiveDateTime.utc_now()
-
-    markers_attrs =
-      from(q in "notifications",
-        select: %{
-          timeline: "notifications",
-          user_id: q.user_id,
-          unread_count: fragment("SUM( CASE WHEN seen = false THEN 1 ELSE 0 END )"),
-          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
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
-- 
cgit v1.2.3