diff options
| author | Maksim Pechnikov <parallel588@gmail.com> | 2019-11-02 21:19:01 +0300 | 
|---|---|---|
| committer | Maksim Pechnikov <parallel588@gmail.com> | 2019-11-03 20:44:59 +0300 | 
| commit | 57995fa8cf26c9d5cd31969b59dbafb9f8c8fdc7 (patch) | |
| tree | 64a44b6f0389ccc7af28890d80e34ad10435125c /lib/mix | |
| parent | fd8099fb680c87e2f589d33ca9923f625f9dc47c (diff) | |
| download | pleroma-57995fa8cf26c9d5cd31969b59dbafb9f8c8fdc7.tar.gz pleroma-57995fa8cf26c9d5cd31969b59dbafb9f8c8fdc7.zip | |
fix migrate
update migrate
Diffstat (limited to 'lib/mix')
| -rw-r--r-- | lib/mix/tasks/pleroma/marker.ex | 36 | 
1 files changed, 0 insertions, 36 deletions
| diff --git a/lib/mix/tasks/pleroma/marker.ex b/lib/mix/tasks/pleroma/marker.ex deleted file mode 100644 index bebef0d6a..000000000 --- a/lib/mix/tasks/pleroma/marker.ex +++ /dev/null @@ -1,36 +0,0 @@ -defmodule Mix.Tasks.Pleroma.Marker do -  use Mix.Task -  import Mix.Pleroma -  import Ecto.Query - -  alias Pleroma.Notification -  alias Pleroma.Repo - -  def run(["update_markers"]) do -    start_pleroma() - -    from(q in Notification, -      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.each(fn attrs -> -      Pleroma.Marker -      |> struct(attrs) -      |> Ecto.Changeset.change() -      |> Pleroma.Repo.insert( -        returning: true, -        on_conflict: {:replace, [:last_read_id, :unread_count]}, -        conflict_target: [:user_id, :timeline] -      ) -    end) - -    shell_info("Done") -  end -end | 
