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