summaryrefslogtreecommitdiff
path: root/priv
diff options
context:
space:
mode:
Diffstat (limited to 'priv')
-rw-r--r--priv/repo/migrations/20200210050658_update_markers.exs (renamed from priv/repo/migrations/20191030202008_add_unread_to_marker.exs)15
1 files changed, 3 insertions, 12 deletions
diff --git a/priv/repo/migrations/20191030202008_add_unread_to_marker.exs b/priv/repo/migrations/20200210050658_update_markers.exs
index 2b3abc682..b280e156c 100644
--- a/priv/repo/migrations/20191030202008_add_unread_to_marker.exs
+++ b/priv/repo/migrations/20200210050658_update_markers.exs
@@ -1,25 +1,17 @@
-defmodule Pleroma.Repo.Migrations.AddUnreadToMarker do
+defmodule Pleroma.Repo.Migrations.UpdateMarkers 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
+ :ok
end
- def update_markers do
+ defp update_markers do
now = NaiveDateTime.utc_now()
markers_attrs =
@@ -27,7 +19,6 @@ defmodule Pleroma.Repo.Migrations.AddUnreadToMarker do
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)
},