git.squeep.com Git - akkoma/blob - test/web/mastodon_api/controllers/scheduled_activity_controller_test.exs

   1 # Pleroma: A lightweight social networking server
   2 # Copyright © 2017-2019 Pleroma Authors <https://pleroma.social/>
   3 # SPDX-License-Identifier: AGPL-3.0-only
   4
   5 defmodule Pleroma.Web.MastodonAPI.ScheduledActivityControllerTest do
   6   use Pleroma.Web.ConnCase
   7
   8   alias Pleroma.Repo
   9   alias Pleroma.ScheduledActivity
  10
  11   import Pleroma.Factory
  12   import Ecto.Query
  13
  14   clear_config([ScheduledActivity, :enabled])
  15
  16   test "shows scheduled activities", %{conn: conn} do
  17     user = insert(:user)
  18     scheduled_activity_id1 = insert(:scheduled_activity, user: user).id |> to_string()
  19     scheduled_activity_id2 = insert(:scheduled_activity, user: user).id |> to_string()
  20     scheduled_activity_id3 = insert(:scheduled_activity, user: user).id |> to_string()
  21     scheduled_activity_id4 = insert(:scheduled_activity, user: user).id |> to_string()
  22
  23     conn =
  24       conn
  25       |> assign(:user, user)
  26
  27     # min_id
  28     conn_res =
  29       conn
  30       |> get("/api/v1/scheduled_statuses?limit=2&min_id=#{scheduled_activity_id1}")
  31
  32     result = json_response(conn_res, 200)
  33     assert [%{"id" => ^scheduled_activity_id3}, %{"id" => ^scheduled_activity_id2}] = result
  34
  35     # since_id
  36     conn_res =
  37       conn
  38       |> get("/api/v1/scheduled_statuses?limit=2&since_id=#{scheduled_activity_id1}")
  39
  40     result = json_response(conn_res, 200)
  41     assert [%{"id" => ^scheduled_activity_id4}, %{"id" => ^scheduled_activity_id3}] = result
  42
  43     # max_id
  44     conn_res =
  45       conn
  46       |> get("/api/v1/scheduled_statuses?limit=2&max_id=#{scheduled_activity_id4}")
  47
  48     result = json_response(conn_res, 200)
  49     assert [%{"id" => ^scheduled_activity_id3}, %{"id" => ^scheduled_activity_id2}] = result
  50   end
  51
  52   test "shows a scheduled activity", %{conn: conn} do
  53     user = insert(:user)
  54     scheduled_activity = insert(:scheduled_activity, user: user)
  55
  56     res_conn =
  57       conn
  58       |> assign(:user, user)
  59       |> get("/api/v1/scheduled_statuses/#{scheduled_activity.id}")
  60
  61     assert %{"id" => scheduled_activity_id} = json_response(res_conn, 200)
  62     assert scheduled_activity_id == scheduled_activity.id |> to_string()
  63
  64     res_conn =
  65       conn
  66       |> assign(:user, user)
  67       |> get("/api/v1/scheduled_statuses/404")
  68
  69     assert %{"error" => "Record not found"} = json_response(res_conn, 404)
  70   end
  71
  72   test "updates a scheduled activity", %{conn: conn} do
  73     Pleroma.Config.put([ScheduledActivity, :enabled], true)
  74     user = insert(:user)
  75
  76     scheduled_at =
  77       NaiveDateTime.add(
  78         NaiveDateTime.utc_now(),
  79         :timer.minutes(60),
  80         :millisecond
  81       )
  82
  83     {:ok, scheduled_activity} =
  84       ScheduledActivity.create(
  85         user,
  86         %{
  87           scheduled_at: scheduled_at,
  88           params: build(:note).data
  89         }
  90       )
  91
  92     scheduled_activity_job =
  93       Repo.one(from(j in Oban.Job, where: j.queue == "scheduled_activities"))
  94
  95     assert scheduled_activity_job.args == %{"activity_id" => scheduled_activity.id}
  96
  97     assert DateTime.truncate(scheduled_activity_job.scheduled_at, :second) ==
  98              to_datetime(scheduled_at)
  99
 100     new_scheduled_at =
 101       NaiveDateTime.add(NaiveDateTime.utc_now(), :timer.minutes(120), :millisecond)
 102
 103     res_conn =
 104       conn
 105       |> assign(:user, user)
 106       |> put("/api/v1/scheduled_statuses/#{scheduled_activity.id}", %{
 107         scheduled_at: new_scheduled_at
 108       })
 109
 110     assert %{"scheduled_at" => expected_scheduled_at} = json_response(res_conn, 200)
 111     assert expected_scheduled_at == Pleroma.Web.CommonAPI.Utils.to_masto_date(new_scheduled_at)
 112     scheduled_activity_job = refresh_record(scheduled_activity_job)
 113
 114     assert DateTime.truncate(scheduled_activity_job.scheduled_at, :second) ==
 115              to_datetime(new_scheduled_at)
 116
 117     res_conn =
 118       conn
 119       |> assign(:user, user)
 120       |> put("/api/v1/scheduled_statuses/404", %{scheduled_at: new_scheduled_at})
 121
 122     assert %{"error" => "Record not found"} = json_response(res_conn, 404)
 123   end
 124
 125   test "deletes a scheduled activity", %{conn: conn} do
 126     Pleroma.Config.put([ScheduledActivity, :enabled], true)
 127     user = insert(:user)
 128
 129     {:ok, scheduled_activity} =
 130       ScheduledActivity.create(
 131         user,
 132         %{
 133           scheduled_at:
 134             NaiveDateTime.add(
 135               NaiveDateTime.utc_now(),
 136               :timer.minutes(60),
 137               :millisecond
 138             ),
 139           params: build(:note).data
 140         }
 141       )
 142
 143     scheduled_activity_job =
 144       Repo.one(from(j in Oban.Job, where: j.queue == "scheduled_activities"))
 145
 146     assert scheduled_activity_job.args == %{"activity_id" => scheduled_activity.id}
 147
 148     res_conn =
 149       conn
 150       |> assign(:user, user)
 151       |> delete("/api/v1/scheduled_statuses/#{scheduled_activity.id}")
 152
 153     assert %{} = json_response(res_conn, 200)
 154     refute Repo.get(ScheduledActivity, scheduled_activity.id)
 155     refute Repo.get(Oban.Job, scheduled_activity_job.id)
 156
 157     res_conn =
 158       conn
 159       |> assign(:user, user)
 160       |> delete("/api/v1/scheduled_statuses/#{scheduled_activity.id}")
 161
 162     assert %{"error" => "Record not found"} = json_response(res_conn, 404)
 163   end
 164 end