diff options
Diffstat (limited to 'test')
24 files changed, 896 insertions, 389 deletions
| diff --git a/test/config_test.exs b/test/config_test.exs index 0a6f0395a..73f3fcb0a 100644 --- a/test/config_test.exs +++ b/test/config_test.exs @@ -28,6 +28,15 @@ defmodule Pleroma.ConfigTest do      assert Pleroma.Config.get([:azerty, :uiop], true) == true    end +  test "get/1 when value is false" do +    Pleroma.Config.put([:instance, :false_test], false) +    Pleroma.Config.put([:instance, :nested], []) +    Pleroma.Config.put([:instance, :nested, :false_test], false) + +    assert Pleroma.Config.get([:instance, :false_test]) == false +    assert Pleroma.Config.get([:instance, :nested, :false_test]) == false +  end +    test "get!/1" do      assert Pleroma.Config.get!(:instance) == Application.get_env(:pleroma, :instance) @@ -43,6 +52,15 @@ defmodule Pleroma.ConfigTest do      end)    end +  test "get!/1 when value is false" do +    Pleroma.Config.put([:instance, :false_test], false) +    Pleroma.Config.put([:instance, :nested], []) +    Pleroma.Config.put([:instance, :nested, :false_test], false) + +    assert Pleroma.Config.get!([:instance, :false_test]) == false +    assert Pleroma.Config.get!([:instance, :nested, :false_test]) == false +  end +    test "put/2 with a key" do      Pleroma.Config.put(:config_test, true) diff --git a/test/conversation_test.exs b/test/conversation_test.exs index cdec18f0f..5903d10ff 100644 --- a/test/conversation_test.exs +++ b/test/conversation_test.exs @@ -4,7 +4,9 @@  defmodule Pleroma.ConversationTest do    use Pleroma.DataCase +  alias Pleroma.Activity    alias Pleroma.Conversation +  alias Pleroma.Object    alias Pleroma.Web.CommonAPI    import Pleroma.Factory @@ -154,4 +156,40 @@ defmodule Pleroma.ConversationTest do      assert {:error, _} = Conversation.create_or_bump_for(activity)    end + +  test "create_or_bump_for does not normalize objects before checking the activity type" do +    note = insert(:note) +    note_id = note.data["id"] +    Repo.delete(note) +    refute Object.get_by_ap_id(note_id) + +    Tesla.Mock.mock(fn env -> +      case env.url do +        ^note_id -> +          # TODO: add attributedTo and tag to the note factory +          body = +            note.data +            |> Map.put("attributedTo", note.data["actor"]) +            |> Map.put("tag", []) +            |> Jason.encode!() + +          %Tesla.Env{status: 200, body: body} +      end +    end) + +    undo = %Activity{ +      id: "fake", +      data: %{ +        "id" => Pleroma.Web.ActivityPub.Utils.generate_activity_id(), +        "actor" => note.data["actor"], +        "to" => [note.data["actor"]], +        "object" => note_id, +        "type" => "Undo" +      } +    } + +    Conversation.create_or_bump_for(undo) + +    refute Object.get_by_ap_id(note_id) +  end  end diff --git a/test/plugs/ensure_public_or_authenticated_plug_test.exs b/test/plugs/ensure_public_or_authenticated_plug_test.exs new file mode 100644 index 000000000..ce5d77ff7 --- /dev/null +++ b/test/plugs/ensure_public_or_authenticated_plug_test.exs @@ -0,0 +1,55 @@ +# Pleroma: A lightweight social networking server +# Copyright © 2017-2018 Pleroma Authors <https://pleroma.social/> +# SPDX-License-Identifier: AGPL-3.0-only + +defmodule Pleroma.Plugs.EnsurePublicOrAuthenticatedPlugTest do +  use Pleroma.Web.ConnCase, async: true + +  alias Pleroma.Config +  alias Pleroma.Plugs.EnsurePublicOrAuthenticatedPlug +  alias Pleroma.User + +  test "it halts if not public and no user is assigned", %{conn: conn} do +    set_public_to(false) + +    conn = +      conn +      |> EnsurePublicOrAuthenticatedPlug.call(%{}) + +    assert conn.status == 403 +    assert conn.halted == true +  end + +  test "it continues if public", %{conn: conn} do +    set_public_to(true) + +    ret_conn = +      conn +      |> EnsurePublicOrAuthenticatedPlug.call(%{}) + +    assert ret_conn == conn +  end + +  test "it continues if a user is assigned, even if not public", %{conn: conn} do +    set_public_to(false) + +    conn = +      conn +      |> assign(:user, %User{}) + +    ret_conn = +      conn +      |> EnsurePublicOrAuthenticatedPlug.call(%{}) + +    assert ret_conn == conn +  end + +  defp set_public_to(value) do +    orig = Config.get!([:instance, :public]) +    Config.put([:instance, :public], value) + +    on_exit(fn -> +      Config.put([:instance, :public], orig) +    end) +  end +end diff --git a/test/plugs/http_signature_plug_test.exs b/test/plugs/http_signature_plug_test.exs index 6a00dd4fd..efd811df7 100644 --- a/test/plugs/http_signature_plug_test.exs +++ b/test/plugs/http_signature_plug_test.exs @@ -4,7 +4,6 @@  defmodule Pleroma.Web.Plugs.HTTPSignaturePlugTest do    use Pleroma.Web.ConnCase -  alias Pleroma.Web.HTTPSignatures    alias Pleroma.Web.Plugs.HTTPSignaturePlug    import Plug.Conn diff --git a/test/plugs/rate_limit_plug_test.exs b/test/plugs/rate_limit_plug_test.exs new file mode 100644 index 000000000..2ec9a8fb7 --- /dev/null +++ b/test/plugs/rate_limit_plug_test.exs @@ -0,0 +1,50 @@ +defmodule Pleroma.Plugs.RateLimitPlugTest do +  use ExUnit.Case, async: true +  use Plug.Test + +  alias Pleroma.Plugs.RateLimitPlug + +  @opts RateLimitPlug.init(%{max_requests: 5, interval: 1}) + +  setup do +    enabled = Pleroma.Config.get([:app_account_creation, :enabled]) + +    Pleroma.Config.put([:app_account_creation, :enabled], true) + +    on_exit(fn -> +      Pleroma.Config.put([:app_account_creation, :enabled], enabled) +    end) + +    :ok +  end + +  test "it restricts by opts" do +    conn = conn(:get, "/") +    bucket_name = conn.remote_ip |> Tuple.to_list() |> Enum.join(".") +    ms = 1000 + +    conn = RateLimitPlug.call(conn, @opts) +    {1, 4, _, _, _} = ExRated.inspect_bucket(bucket_name, ms, 5) +    conn = RateLimitPlug.call(conn, @opts) +    {2, 3, _, _, _} = ExRated.inspect_bucket(bucket_name, ms, 5) +    conn = RateLimitPlug.call(conn, @opts) +    {3, 2, _, _, _} = ExRated.inspect_bucket(bucket_name, ms, 5) +    conn = RateLimitPlug.call(conn, @opts) +    {4, 1, _, _, _} = ExRated.inspect_bucket(bucket_name, ms, 5) +    conn = RateLimitPlug.call(conn, @opts) +    {5, 0, to_reset, _, _} = ExRated.inspect_bucket(bucket_name, ms, 5) +    conn = RateLimitPlug.call(conn, @opts) +    assert conn.status == 403 +    assert conn.halted +    assert conn.resp_body == "{\"error\":\"Rate limit exceeded.\"}" + +    Process.sleep(to_reset) + +    conn = conn(:get, "/") +    conn = RateLimitPlug.call(conn, @opts) +    {1, 4, _, _, _} = ExRated.inspect_bucket(bucket_name, ms, 5) +    refute conn.status == 403 +    refute conn.halted +    refute conn.resp_body +  end +end diff --git a/test/user_test.exs b/test/user_test.exs index adc77a264..0b65e89e9 100644 --- a/test/user_test.exs +++ b/test/user_test.exs @@ -8,6 +8,7 @@ defmodule Pleroma.UserTest do    alias Pleroma.Object    alias Pleroma.Repo    alias Pleroma.User +  alias Pleroma.Web.ActivityPub.ActivityPub    alias Pleroma.Web.CommonAPI    use Pleroma.DataCase @@ -213,8 +214,8 @@ defmodule Pleroma.UserTest do    test "fetches correct profile for nickname beginning with number" do      # Use old-style integer ID to try to reproduce the problem      user = insert(:user, %{id: 1080}) -    userwithnumbers = insert(:user, %{nickname: "#{user.id}garbage"}) -    assert userwithnumbers == User.get_cached_by_nickname_or_id(userwithnumbers.nickname) +    user_with_numbers = insert(:user, %{nickname: "#{user.id}garbage"}) +    assert user_with_numbers == User.get_cached_by_nickname_or_id(user_with_numbers.nickname)    end    describe "user registration" do @@ -349,7 +350,7 @@ defmodule Pleroma.UserTest do      end      test "it creates confirmed user if :confirmed option is given" do -      changeset = User.register_changeset(%User{}, @full_user_data, confirmed: true) +      changeset = User.register_changeset(%User{}, @full_user_data, need_confirmation: false)        assert changeset.valid?        {:ok, user} = Repo.insert(changeset) @@ -816,13 +817,73 @@ defmodule Pleroma.UserTest do      assert addressed in recipients    end -  test ".deactivate can de-activate then re-activate a user" do -    user = insert(:user) -    assert false == user.info.deactivated -    {:ok, user} = User.deactivate(user) -    assert true == user.info.deactivated -    {:ok, user} = User.deactivate(user, false) -    assert false == user.info.deactivated +  describe ".deactivate" do +    test "can de-activate then re-activate a user" do +      user = insert(:user) +      assert false == user.info.deactivated +      {:ok, user} = User.deactivate(user) +      assert true == user.info.deactivated +      {:ok, user} = User.deactivate(user, false) +      assert false == user.info.deactivated +    end + +    test "hide a user from followers " do +      user = insert(:user) +      user2 = insert(:user) + +      {:ok, user} = User.follow(user, user2) +      {:ok, _user} = User.deactivate(user) + +      info = User.get_cached_user_info(user2) + +      assert info.follower_count == 0 +      assert {:ok, []} = User.get_followers(user2) +    end + +    test "hide a user from friends" do +      user = insert(:user) +      user2 = insert(:user) + +      {:ok, user2} = User.follow(user2, user) +      assert User.following_count(user2) == 1 + +      {:ok, _user} = User.deactivate(user) + +      info = User.get_cached_user_info(user2) + +      assert info.following_count == 0 +      assert User.following_count(user2) == 0 +      assert {:ok, []} = User.get_friends(user2) +    end + +    test "hide a user's statuses from timelines and notifications" do +      user = insert(:user) +      user2 = insert(:user) + +      {:ok, user2} = User.follow(user2, user) + +      {:ok, activity} = CommonAPI.post(user, %{"status" => "hey @#{user2.nickname}"}) + +      activity = Repo.preload(activity, :bookmark) + +      [notification] = Pleroma.Notification.for_user(user2) +      assert notification.activity.id == activity.id + +      assert [activity] == ActivityPub.fetch_public_activities(%{}) |> Repo.preload(:bookmark) + +      assert [activity] == +               ActivityPub.fetch_activities([user2.ap_id | user2.following], %{"user" => user2}) +               |> ActivityPub.contain_timeline(user2) + +      {:ok, _user} = User.deactivate(user) + +      assert [] == ActivityPub.fetch_public_activities(%{}) +      assert [] == Pleroma.Notification.for_user(user2) + +      assert [] == +               ActivityPub.fetch_activities([user2.ap_id | user2.following], %{"user" => user2}) +               |> ActivityPub.contain_timeline(user2) +    end    end    test ".delete_user_activities deletes all create activities" do diff --git a/test/web/activity_pub/activity_pub_test.exs b/test/web/activity_pub/activity_pub_test.exs index 1e056b7ee..0f90aa1ac 100644 --- a/test/web/activity_pub/activity_pub_test.exs +++ b/test/web/activity_pub/activity_pub_test.exs @@ -10,6 +10,7 @@ defmodule Pleroma.Web.ActivityPub.ActivityPubTest do    alias Pleroma.Object    alias Pleroma.User    alias Pleroma.Web.ActivityPub.ActivityPub +  alias Pleroma.Web.ActivityPub.Publisher    alias Pleroma.Web.ActivityPub.Utils    alias Pleroma.Web.CommonAPI @@ -963,8 +964,7 @@ defmodule Pleroma.Web.ActivityPub.ActivityPubTest do        private_activity_1 = Activity.get_by_ap_id_with_object(private_activity_1.data["id"]) -      assert [public_activity, private_activity_1, private_activity_3] == -               activities +      assert [public_activity, private_activity_1, private_activity_3] == activities        assert length(activities) == 3 @@ -1057,7 +1057,7 @@ defmodule Pleroma.Web.ActivityPub.ActivityPubTest do        actor = insert(:user)        inbox = "http://200.site/users/nick1/inbox" -      assert {:ok, _} = ActivityPub.publish_one(%{inbox: inbox, json: "{}", actor: actor, id: 1}) +      assert {:ok, _} = Publisher.publish_one(%{inbox: inbox, json: "{}", actor: actor, id: 1})        assert called(Instances.set_reachable(inbox))      end @@ -1070,7 +1070,7 @@ defmodule Pleroma.Web.ActivityPub.ActivityPubTest do        inbox = "http://200.site/users/nick1/inbox"        assert {:ok, _} = -               ActivityPub.publish_one(%{ +               Publisher.publish_one(%{                   inbox: inbox,                   json: "{}",                   actor: actor, @@ -1089,7 +1089,7 @@ defmodule Pleroma.Web.ActivityPub.ActivityPubTest do        inbox = "http://200.site/users/nick1/inbox"        assert {:ok, _} = -               ActivityPub.publish_one(%{ +               Publisher.publish_one(%{                   inbox: inbox,                   json: "{}",                   actor: actor, @@ -1107,8 +1107,7 @@ defmodule Pleroma.Web.ActivityPub.ActivityPubTest do        actor = insert(:user)        inbox = "http://404.site/users/nick1/inbox" -      assert {:error, _} = -               ActivityPub.publish_one(%{inbox: inbox, json: "{}", actor: actor, id: 1}) +      assert {:error, _} = Publisher.publish_one(%{inbox: inbox, json: "{}", actor: actor, id: 1})        assert called(Instances.set_unreachable(inbox))      end @@ -1120,8 +1119,7 @@ defmodule Pleroma.Web.ActivityPub.ActivityPubTest do        actor = insert(:user)        inbox = "http://connrefused.site/users/nick1/inbox" -      assert {:error, _} = -               ActivityPub.publish_one(%{inbox: inbox, json: "{}", actor: actor, id: 1}) +      assert {:error, _} = Publisher.publish_one(%{inbox: inbox, json: "{}", actor: actor, id: 1})        assert called(Instances.set_unreachable(inbox))      end @@ -1133,7 +1131,7 @@ defmodule Pleroma.Web.ActivityPub.ActivityPubTest do        actor = insert(:user)        inbox = "http://200.site/users/nick1/inbox" -      assert {:ok, _} = ActivityPub.publish_one(%{inbox: inbox, json: "{}", actor: actor, id: 1}) +      assert {:ok, _} = Publisher.publish_one(%{inbox: inbox, json: "{}", actor: actor, id: 1})        refute called(Instances.set_unreachable(inbox))      end @@ -1146,7 +1144,7 @@ defmodule Pleroma.Web.ActivityPub.ActivityPubTest do        inbox = "http://connrefused.site/users/nick1/inbox"        assert {:error, _} = -               ActivityPub.publish_one(%{ +               Publisher.publish_one(%{                   inbox: inbox,                   json: "{}",                   actor: actor, diff --git a/test/web/activity_pub/visibilty_test.exs b/test/web/activity_pub/visibilty_test.exs index ff0e72401..e2584f635 100644 --- a/test/web/activity_pub/visibilty_test.exs +++ b/test/web/activity_pub/visibilty_test.exs @@ -105,4 +105,16 @@ defmodule Pleroma.Web.ActivityPub.VisibilityTest do      Cachex.clear(:user_cache)      refute Visibility.is_private?(direct)    end + +  test "get_visibility", %{ +    public: public, +    private: private, +    direct: direct, +    unlisted: unlisted +  } do +    assert Visibility.get_visibility(public) == "public" +    assert Visibility.get_visibility(private) == "private" +    assert Visibility.get_visibility(direct) == "direct" +    assert Visibility.get_visibility(unlisted) == "unlisted" +  end  end diff --git a/test/web/admin_api/admin_api_controller_test.exs b/test/web/admin_api/admin_api_controller_test.exs index b89c42327..6c1897b5a 100644 --- a/test/web/admin_api/admin_api_controller_test.exs +++ b/test/web/admin_api/admin_api_controller_test.exs @@ -9,7 +9,7 @@ defmodule Pleroma.Web.AdminAPI.AdminAPIControllerTest do    alias Pleroma.UserInviteToken    import Pleroma.Factory -  describe "/api/pleroma/admin/user" do +  describe "/api/pleroma/admin/users" do      test "Delete" do        admin = insert(:user, info: %{is_admin: true})        user = insert(:user) @@ -18,7 +18,7 @@ defmodule Pleroma.Web.AdminAPI.AdminAPIControllerTest do          build_conn()          |> assign(:user, admin)          |> put_req_header("accept", "application/json") -        |> delete("/api/pleroma/admin/user?nickname=#{user.nickname}") +        |> delete("/api/pleroma/admin/users?nickname=#{user.nickname}")        assert json_response(conn, 200) == user.nickname      end @@ -30,7 +30,7 @@ defmodule Pleroma.Web.AdminAPI.AdminAPIControllerTest do          build_conn()          |> assign(:user, admin)          |> put_req_header("accept", "application/json") -        |> post("/api/pleroma/admin/user", %{ +        |> post("/api/pleroma/admin/users", %{            "nickname" => "lain",            "email" => "lain@example.org",            "password" => "test" @@ -75,7 +75,7 @@ defmodule Pleroma.Web.AdminAPI.AdminAPIControllerTest do      end    end -  describe "/api/pleroma/admin/user/follow" do +  describe "/api/pleroma/admin/users/follow" do      test "allows to force-follow another user" do        admin = insert(:user, info: %{is_admin: true})        user = insert(:user) @@ -84,7 +84,7 @@ defmodule Pleroma.Web.AdminAPI.AdminAPIControllerTest do        build_conn()        |> assign(:user, admin)        |> put_req_header("accept", "application/json") -      |> post("/api/pleroma/admin/user/follow", %{ +      |> post("/api/pleroma/admin/users/follow", %{          "follower" => follower.nickname,          "followed" => user.nickname        }) @@ -96,7 +96,7 @@ defmodule Pleroma.Web.AdminAPI.AdminAPIControllerTest do      end    end -  describe "/api/pleroma/admin/user/unfollow" do +  describe "/api/pleroma/admin/users/unfollow" do      test "allows to force-unfollow another user" do        admin = insert(:user, info: %{is_admin: true})        user = insert(:user) @@ -107,7 +107,7 @@ defmodule Pleroma.Web.AdminAPI.AdminAPIControllerTest do        build_conn()        |> assign(:user, admin)        |> put_req_header("accept", "application/json") -      |> post("/api/pleroma/admin/user/unfollow", %{ +      |> post("/api/pleroma/admin/users/unfollow", %{          "follower" => follower.nickname,          "followed" => user.nickname        }) @@ -191,7 +191,7 @@ defmodule Pleroma.Web.AdminAPI.AdminAPIControllerTest do      end    end -  describe "/api/pleroma/admin/permission_group" do +  describe "/api/pleroma/admin/users/:nickname/permission_group" do      test "GET is giving user_info" do        admin = insert(:user, info: %{is_admin: true}) @@ -199,7 +199,7 @@ defmodule Pleroma.Web.AdminAPI.AdminAPIControllerTest do          build_conn()          |> assign(:user, admin)          |> put_req_header("accept", "application/json") -        |> get("/api/pleroma/admin/permission_group/#{admin.nickname}") +        |> get("/api/pleroma/admin/users/#{admin.nickname}/permission_group/")        assert json_response(conn, 200) == %{                 "is_admin" => true, @@ -215,7 +215,7 @@ defmodule Pleroma.Web.AdminAPI.AdminAPIControllerTest do          build_conn()          |> assign(:user, admin)          |> put_req_header("accept", "application/json") -        |> post("/api/pleroma/admin/permission_group/#{user.nickname}/admin") +        |> post("/api/pleroma/admin/users/#{user.nickname}/permission_group/admin")        assert json_response(conn, 200) == %{                 "is_admin" => true @@ -230,7 +230,7 @@ defmodule Pleroma.Web.AdminAPI.AdminAPIControllerTest do          build_conn()          |> assign(:user, admin)          |> put_req_header("accept", "application/json") -        |> delete("/api/pleroma/admin/permission_group/#{user.nickname}/admin") +        |> delete("/api/pleroma/admin/users/#{user.nickname}/permission_group/admin")        assert json_response(conn, 200) == %{                 "is_admin" => false @@ -238,7 +238,7 @@ defmodule Pleroma.Web.AdminAPI.AdminAPIControllerTest do      end    end -  describe "PUT /api/pleroma/admin/activation_status" do +  describe "PUT /api/pleroma/admin/users/:nickname/activation_status" do      setup %{conn: conn} do        admin = insert(:user, info: %{is_admin: true}) @@ -255,7 +255,7 @@ defmodule Pleroma.Web.AdminAPI.AdminAPIControllerTest do        conn =          conn -        |> put("/api/pleroma/admin/activation_status/#{user.nickname}", %{status: false}) +        |> put("/api/pleroma/admin/users/#{user.nickname}/activation_status", %{status: false})        user = User.get_cached_by_id(user.id)        assert user.info.deactivated == true @@ -267,7 +267,7 @@ defmodule Pleroma.Web.AdminAPI.AdminAPIControllerTest do        conn =          conn -        |> put("/api/pleroma/admin/activation_status/#{user.nickname}", %{status: true}) +        |> put("/api/pleroma/admin/users/#{user.nickname}/activation_status", %{status: true})        user = User.get_cached_by_id(user.id)        assert user.info.deactivated == false @@ -280,7 +280,7 @@ defmodule Pleroma.Web.AdminAPI.AdminAPIControllerTest do        conn =          conn          |> assign(:user, user) -        |> put("/api/pleroma/admin/activation_status/#{user.nickname}", %{status: false}) +        |> put("/api/pleroma/admin/users/#{user.nickname}/activation_status", %{status: false})        assert json_response(conn, :forbidden)      end @@ -309,7 +309,9 @@ defmodule Pleroma.Web.AdminAPI.AdminAPIControllerTest do        conn =          conn          |> assign(:user, user) -        |> post("/api/pleroma/admin/email_invite?email=#{recipient_email}&name=#{recipient_name}") +        |> post( +          "/api/pleroma/admin/users/email_invite?email=#{recipient_email}&name=#{recipient_name}" +        )        assert json_response(conn, :no_content) @@ -341,13 +343,13 @@ defmodule Pleroma.Web.AdminAPI.AdminAPIControllerTest do        conn =          conn          |> assign(:user, non_admin_user) -        |> post("/api/pleroma/admin/email_invite?email=foo@bar.com&name=JD") +        |> post("/api/pleroma/admin/users/email_invite?email=foo@bar.com&name=JD")        assert json_response(conn, :forbidden)      end    end -  describe "POST /api/pleroma/admin/email_invite, with invalid config" do +  describe "POST /api/pleroma/admin/users/email_invite, with invalid config" do      setup do        [user: insert(:user, info: %{is_admin: true})]      end @@ -367,7 +369,7 @@ defmodule Pleroma.Web.AdminAPI.AdminAPIControllerTest do        conn =          conn          |> assign(:user, user) -        |> post("/api/pleroma/admin/email_invite?email=foo@bar.com&name=JD") +        |> post("/api/pleroma/admin/users/email_invite?email=foo@bar.com&name=JD")        assert json_response(conn, :internal_server_error)      end @@ -387,7 +389,7 @@ defmodule Pleroma.Web.AdminAPI.AdminAPIControllerTest do        conn =          conn          |> assign(:user, user) -        |> post("/api/pleroma/admin/email_invite?email=foo@bar.com&name=JD") +        |> post("/api/pleroma/admin/users/email_invite?email=foo@bar.com&name=JD")        assert json_response(conn, :internal_server_error)      end @@ -405,7 +407,7 @@ defmodule Pleroma.Web.AdminAPI.AdminAPIControllerTest do      assert conn.status == 200    end -  test "/api/pleroma/admin/password_reset" do +  test "/api/pleroma/admin/users/:nickname/password_reset" do      admin = insert(:user, info: %{is_admin: true})      user = insert(:user) @@ -413,20 +415,25 @@ defmodule Pleroma.Web.AdminAPI.AdminAPIControllerTest do        build_conn()        |> assign(:user, admin)        |> put_req_header("accept", "application/json") -      |> get("/api/pleroma/admin/password_reset?nickname=#{user.nickname}") +      |> get("/api/pleroma/admin/users/#{user.nickname}/password_reset")      assert conn.status == 200    end    describe "GET /api/pleroma/admin/users" do -    test "renders users array for the first page" do +    setup do        admin = insert(:user, info: %{is_admin: true}) -      user = insert(:user, local: false, tags: ["foo", "bar"])        conn =          build_conn()          |> assign(:user, admin) -        |> get("/api/pleroma/admin/users?page=1") + +      {:ok, conn: conn, admin: admin} +    end + +    test "renders users array for the first page", %{conn: conn, admin: admin} do +      user = insert(:user, local: false, tags: ["foo", "bar"]) +      conn = get(conn, "/api/pleroma/admin/users?page=1")        assert json_response(conn, 200) == %{                 "count" => 2, @@ -452,14 +459,10 @@ defmodule Pleroma.Web.AdminAPI.AdminAPIControllerTest do               }      end -    test "renders empty array for the second page" do -      admin = insert(:user, info: %{is_admin: true}) +    test "renders empty array for the second page", %{conn: conn} do        insert(:user) -      conn = -        build_conn() -        |> assign(:user, admin) -        |> get("/api/pleroma/admin/users?page=2") +      conn = get(conn, "/api/pleroma/admin/users?page=2")        assert json_response(conn, 200) == %{                 "count" => 2, @@ -468,14 +471,10 @@ defmodule Pleroma.Web.AdminAPI.AdminAPIControllerTest do               }      end -    test "regular search" do -      admin = insert(:user, info: %{is_admin: true}) +    test "regular search", %{conn: conn} do        user = insert(:user, nickname: "bob") -      conn = -        build_conn() -        |> assign(:user, admin) -        |> get("/api/pleroma/admin/users?query=bo") +      conn = get(conn, "/api/pleroma/admin/users?query=bo")        assert json_response(conn, 200) == %{                 "count" => 1, @@ -493,17 +492,101 @@ defmodule Pleroma.Web.AdminAPI.AdminAPIControllerTest do               }      end -    test "regular search with page size" do -      admin = insert(:user, info: %{is_admin: true}) +    test "search by domain", %{conn: conn} do +      user = insert(:user, nickname: "nickname@domain.com") +      insert(:user) + +      conn = get(conn, "/api/pleroma/admin/users?query=domain.com") + +      assert json_response(conn, 200) == %{ +               "count" => 1, +               "page_size" => 50, +               "users" => [ +                 %{ +                   "deactivated" => user.info.deactivated, +                   "id" => user.id, +                   "nickname" => user.nickname, +                   "roles" => %{"admin" => false, "moderator" => false}, +                   "local" => true, +                   "tags" => [] +                 } +               ] +             } +    end + +    test "search by full nickname", %{conn: conn} do +      user = insert(:user, nickname: "nickname@domain.com") +      insert(:user) + +      conn = get(conn, "/api/pleroma/admin/users?query=nickname@domain.com") + +      assert json_response(conn, 200) == %{ +               "count" => 1, +               "page_size" => 50, +               "users" => [ +                 %{ +                   "deactivated" => user.info.deactivated, +                   "id" => user.id, +                   "nickname" => user.nickname, +                   "roles" => %{"admin" => false, "moderator" => false}, +                   "local" => true, +                   "tags" => [] +                 } +               ] +             } +    end + +    test "search by display name", %{conn: conn} do +      user = insert(:user, name: "Display name") +      insert(:user) + +      conn = get(conn, "/api/pleroma/admin/users?name=display") + +      assert json_response(conn, 200) == %{ +               "count" => 1, +               "page_size" => 50, +               "users" => [ +                 %{ +                   "deactivated" => user.info.deactivated, +                   "id" => user.id, +                   "nickname" => user.nickname, +                   "roles" => %{"admin" => false, "moderator" => false}, +                   "local" => true, +                   "tags" => [] +                 } +               ] +             } +    end + +    test "search by email", %{conn: conn} do +      user = insert(:user, email: "email@example.com") +      insert(:user) + +      conn = get(conn, "/api/pleroma/admin/users?email=email@example.com") + +      assert json_response(conn, 200) == %{ +               "count" => 1, +               "page_size" => 50, +               "users" => [ +                 %{ +                   "deactivated" => user.info.deactivated, +                   "id" => user.id, +                   "nickname" => user.nickname, +                   "roles" => %{"admin" => false, "moderator" => false}, +                   "local" => true, +                   "tags" => [] +                 } +               ] +             } +    end + +    test "regular search with page size", %{conn: conn} do        user = insert(:user, nickname: "aalice")        user2 = insert(:user, nickname: "alice") -      conn = -        build_conn() -        |> assign(:user, admin) -        |> get("/api/pleroma/admin/users?query=a&page_size=1&page=1") +      conn1 = get(conn, "/api/pleroma/admin/users?query=a&page_size=1&page=1") -      assert json_response(conn, 200) == %{ +      assert json_response(conn1, 200) == %{                 "count" => 2,                 "page_size" => 1,                 "users" => [ @@ -518,12 +601,9 @@ defmodule Pleroma.Web.AdminAPI.AdminAPIControllerTest do                 ]               } -      conn = -        build_conn() -        |> assign(:user, admin) -        |> get("/api/pleroma/admin/users?query=a&page_size=1&page=2") +      conn2 = get(conn, "/api/pleroma/admin/users?query=a&page_size=1&page=2") -      assert json_response(conn, 200) == %{ +      assert json_response(conn2, 200) == %{                 "count" => 2,                 "page_size" => 1,                 "users" => [ @@ -566,7 +646,7 @@ defmodule Pleroma.Web.AdminAPI.AdminAPIControllerTest do               }      end -    test "only local users with no query" do +    test "only local users with no query", %{admin: old_admin} do        admin = insert(:user, info: %{is_admin: true}, nickname: "john")        user = insert(:user, nickname: "bob") @@ -578,7 +658,7 @@ defmodule Pleroma.Web.AdminAPI.AdminAPIControllerTest do          |> get("/api/pleroma/admin/users?filters=local")        assert json_response(conn, 200) == %{ -               "count" => 2, +               "count" => 3,                 "page_size" => 50,                 "users" => [                   %{ @@ -596,6 +676,100 @@ defmodule Pleroma.Web.AdminAPI.AdminAPIControllerTest do                     "roles" => %{"admin" => true, "moderator" => false},                     "local" => true,                     "tags" => [] +                 }, +                 %{ +                   "deactivated" => false, +                   "id" => old_admin.id, +                   "local" => true, +                   "nickname" => old_admin.nickname, +                   "roles" => %{"admin" => true, "moderator" => false}, +                   "tags" => [] +                 } +               ] +             } +    end + +    test "load only admins", %{conn: conn, admin: admin} do +      second_admin = insert(:user, info: %{is_admin: true}) +      insert(:user) +      insert(:user) + +      conn = get(conn, "/api/pleroma/admin/users?filters=is_admin") + +      assert json_response(conn, 200) == %{ +               "count" => 2, +               "page_size" => 50, +               "users" => [ +                 %{ +                   "deactivated" => false, +                   "id" => admin.id, +                   "nickname" => admin.nickname, +                   "roles" => %{"admin" => true, "moderator" => false}, +                   "local" => admin.local, +                   "tags" => [] +                 }, +                 %{ +                   "deactivated" => false, +                   "id" => second_admin.id, +                   "nickname" => second_admin.nickname, +                   "roles" => %{"admin" => true, "moderator" => false}, +                   "local" => second_admin.local, +                   "tags" => [] +                 } +               ] +             } +    end + +    test "load only moderators", %{conn: conn} do +      moderator = insert(:user, info: %{is_moderator: true}) +      insert(:user) +      insert(:user) + +      conn = get(conn, "/api/pleroma/admin/users?filters=is_moderator") + +      assert json_response(conn, 200) == %{ +               "count" => 1, +               "page_size" => 50, +               "users" => [ +                 %{ +                   "deactivated" => false, +                   "id" => moderator.id, +                   "nickname" => moderator.nickname, +                   "roles" => %{"admin" => false, "moderator" => true}, +                   "local" => moderator.local, +                   "tags" => [] +                 } +               ] +             } +    end + +    test "load users with tags list", %{conn: conn} do +      user1 = insert(:user, tags: ["first"]) +      user2 = insert(:user, tags: ["second"]) +      insert(:user) +      insert(:user) + +      conn = get(conn, "/api/pleroma/admin/users?tags[]=first&tags[]=second") + +      assert json_response(conn, 200) == %{ +               "count" => 2, +               "page_size" => 50, +               "users" => [ +                 %{ +                   "deactivated" => false, +                   "id" => user1.id, +                   "nickname" => user1.nickname, +                   "roles" => %{"admin" => false, "moderator" => false}, +                   "local" => user1.local, +                   "tags" => ["first"] +                 }, +                 %{ +                   "deactivated" => false, +                   "id" => user2.id, +                   "nickname" => user2.nickname, +                   "roles" => %{"admin" => false, "moderator" => false}, +                   "local" => user2.local, +                   "tags" => ["second"]                   }                 ]               } @@ -650,14 +824,19 @@ defmodule Pleroma.Web.AdminAPI.AdminAPIControllerTest do               }    end -  describe "GET /api/pleroma/admin/invite_token" do -    test "without options" do +  describe "GET /api/pleroma/admin/users/invite_token" do +    setup do        admin = insert(:user, info: %{is_admin: true})        conn =          build_conn()          |> assign(:user, admin) -        |> get("/api/pleroma/admin/invite_token") + +      {:ok, conn: conn} +    end + +    test "without options", %{conn: conn} do +      conn = get(conn, "/api/pleroma/admin/users/invite_token")        token = json_response(conn, 200)        invite = UserInviteToken.find_by_token!(token) @@ -667,13 +846,9 @@ defmodule Pleroma.Web.AdminAPI.AdminAPIControllerTest do        assert invite.invite_type == "one_time"      end -    test "with expires_at" do -      admin = insert(:user, info: %{is_admin: true}) - +    test "with expires_at", %{conn: conn} do        conn = -        build_conn() -        |> assign(:user, admin) -        |> get("/api/pleroma/admin/invite_token", %{ +        get(conn, "/api/pleroma/admin/users/invite_token", %{            "invite" => %{"expires_at" => Date.to_string(Date.utc_today())}          }) @@ -686,13 +861,9 @@ defmodule Pleroma.Web.AdminAPI.AdminAPIControllerTest do        assert invite.invite_type == "date_limited"      end -    test "with max_use" do -      admin = insert(:user, info: %{is_admin: true}) - +    test "with max_use", %{conn: conn} do        conn = -        build_conn() -        |> assign(:user, admin) -        |> get("/api/pleroma/admin/invite_token", %{ +        get(conn, "/api/pleroma/admin/users/invite_token", %{            "invite" => %{"max_use" => 150}          }) @@ -704,13 +875,9 @@ defmodule Pleroma.Web.AdminAPI.AdminAPIControllerTest do        assert invite.invite_type == "reusable"      end -    test "with max use and expires_at" do -      admin = insert(:user, info: %{is_admin: true}) - +    test "with max use and expires_at", %{conn: conn} do        conn = -        build_conn() -        |> assign(:user, admin) -        |> get("/api/pleroma/admin/invite_token", %{ +        get(conn, "/api/pleroma/admin/users/invite_token", %{            "invite" => %{"max_use" => 150, "expires_at" => Date.to_string(Date.utc_today())}          }) @@ -723,26 +890,27 @@ defmodule Pleroma.Web.AdminAPI.AdminAPIControllerTest do      end    end -  describe "GET /api/pleroma/admin/invites" do -    test "no invites" do +  describe "GET /api/pleroma/admin/users/invites" do +    setup do        admin = insert(:user, info: %{is_admin: true})        conn =          build_conn()          |> assign(:user, admin) -        |> get("/api/pleroma/admin/invites") + +      {:ok, conn: conn} +    end + +    test "no invites", %{conn: conn} do +      conn = get(conn, "/api/pleroma/admin/users/invites")        assert json_response(conn, 200) == %{"invites" => []}      end -    test "with invite" do -      admin = insert(:user, info: %{is_admin: true}) +    test "with invite", %{conn: conn} do        {:ok, invite} = UserInviteToken.create_invite() -      conn = -        build_conn() -        |> assign(:user, admin) -        |> get("/api/pleroma/admin/invites") +      conn = get(conn, "/api/pleroma/admin/users/invites")        assert json_response(conn, 200) == %{                 "invites" => [ @@ -760,7 +928,7 @@ defmodule Pleroma.Web.AdminAPI.AdminAPIControllerTest do      end    end -  describe "POST /api/pleroma/admin/revoke_invite" do +  describe "POST /api/pleroma/admin/users/revoke_invite" do      test "with token" do        admin = insert(:user, info: %{is_admin: true})        {:ok, invite} = UserInviteToken.create_invite() @@ -768,7 +936,7 @@ defmodule Pleroma.Web.AdminAPI.AdminAPIControllerTest do        conn =          build_conn()          |> assign(:user, admin) -        |> post("/api/pleroma/admin/revoke_invite", %{"token" => invite.token}) +        |> post("/api/pleroma/admin/users/revoke_invite", %{"token" => invite.token})        assert json_response(conn, 200) == %{                 "expires_at" => nil, diff --git a/test/web/admin_api/search_test.exs b/test/web/admin_api/search_test.exs index 3950996ed..501a8d007 100644 --- a/test/web/admin_api/search_test.exs +++ b/test/web/admin_api/search_test.exs @@ -70,11 +70,11 @@ defmodule Pleroma.Web.AdminAPI.SearchTest do      test "it returns specific user" do        insert(:user)        insert(:user) -      insert(:user, nickname: "bob", local: true, info: %{deactivated: false}) +      user = insert(:user, nickname: "bob", local: true, info: %{deactivated: false})        {:ok, _results, total_count} = Search.user(%{query: ""}) -      {:ok, _results, count} = +      {:ok, [^user], count} =          Search.user(%{            query: "Bo",            active: true, @@ -84,5 +84,87 @@ defmodule Pleroma.Web.AdminAPI.SearchTest do        assert total_count == 3        assert count == 1      end + +    test "it returns user by domain" do +      insert(:user) +      insert(:user) +      user = insert(:user, nickname: "some@domain.com") + +      {:ok, _results, total} = Search.user() +      {:ok, [^user], count} = Search.user(%{query: "domain.com"}) +      assert total == 3 +      assert count == 1 +    end + +    test "it return user by full nickname" do +      insert(:user) +      insert(:user) +      user = insert(:user, nickname: "some@domain.com") + +      {:ok, _results, total} = Search.user() +      {:ok, [^user], count} = Search.user(%{query: "some@domain.com"}) +      assert total == 3 +      assert count == 1 +    end + +    test "it returns admin user" do +      admin = insert(:user, info: %{is_admin: true}) +      insert(:user) +      insert(:user) + +      {:ok, _results, total} = Search.user() +      {:ok, [^admin], count} = Search.user(%{is_admin: true}) +      assert total == 3 +      assert count == 1 +    end + +    test "it returns moderator user" do +      moderator = insert(:user, info: %{is_moderator: true}) +      insert(:user) +      insert(:user) + +      {:ok, _results, total} = Search.user() +      {:ok, [^moderator], count} = Search.user(%{is_moderator: true}) +      assert total == 3 +      assert count == 1 +    end + +    test "it returns users with tags" do +      user1 = insert(:user, tags: ["first"]) +      user2 = insert(:user, tags: ["second"]) +      insert(:user) +      insert(:user) + +      {:ok, _results, total} = Search.user() +      {:ok, users, count} = Search.user(%{tags: ["first", "second"]}) +      assert total == 4 +      assert count == 2 +      assert user1 in users +      assert user2 in users +    end + +    test "it returns user by display name" do +      user = insert(:user, name: "Display name") +      insert(:user) +      insert(:user) + +      {:ok, _results, total} = Search.user() +      {:ok, [^user], count} = Search.user(%{name: "display"}) + +      assert total == 3 +      assert count == 1 +    end + +    test "it returns user by email" do +      user = insert(:user, email: "some@example.com") +      insert(:user) +      insert(:user) + +      {:ok, _results, total} = Search.user() +      {:ok, [^user], count} = Search.user(%{email: "some@example.com"}) + +      assert total == 3 +      assert count == 1 +    end    end  end diff --git a/test/web/common_api/common_api_test.exs b/test/web/common_api/common_api_test.exs index a5b07c446..8d4f401ee 100644 --- a/test/web/common_api/common_api_test.exs +++ b/test/web/common_api/common_api_test.exs @@ -87,6 +87,28 @@ defmodule Pleroma.Web.CommonAPITest do        assert object.data["content"] == "<p><b>2hu</b></p>alert('xss')"      end + +    test "it does not allow replies to direct messages that are not direct messages themselves" do +      user = insert(:user) + +      {:ok, activity} = CommonAPI.post(user, %{"status" => "suya..", "visibility" => "direct"}) + +      assert {:ok, _} = +               CommonAPI.post(user, %{ +                 "status" => "suya..", +                 "visibility" => "direct", +                 "in_reply_to_status_id" => activity.id +               }) + +      Enum.each(["public", "private", "unlisted"], fn visibility -> +        assert {:error, {:private_to_public, _}} = +                 CommonAPI.post(user, %{ +                   "status" => "suya..", +                   "visibility" => visibility, +                   "in_reply_to_status_id" => activity.id +                 }) +      end) +    end    end    describe "reactions" do diff --git a/test/web/federator_test.exs b/test/web/federator_test.exs index 52729eb50..0f43bc8f2 100644 --- a/test/web/federator_test.exs +++ b/test/web/federator_test.exs @@ -58,7 +58,7 @@ defmodule Pleroma.Web.FederatorTest do    describe "Targets reachability filtering in `publish`" do      test_with_mock "it federates only to reachable instances via AP", -                   Federator, +                   Pleroma.Web.ActivityPub.Publisher,                     [:passthrough],                     [] do        user = insert(:user) @@ -88,13 +88,18 @@ defmodule Pleroma.Web.FederatorTest do        {:ok, _activity} =          CommonAPI.post(user, %{"status" => "HI @nick1@domain.com, @nick2@domain2.com!"}) -      assert called(Federator.publish_single_ap(%{inbox: inbox1, unreachable_since: dt})) +      assert called( +               Pleroma.Web.ActivityPub.Publisher.publish_one(%{ +                 inbox: inbox1, +                 unreachable_since: dt +               }) +             ) -      refute called(Federator.publish_single_ap(%{inbox: inbox2})) +      refute called(Pleroma.Web.ActivityPub.Publisher.publish_one(%{inbox: inbox2}))      end      test_with_mock "it federates only to reachable instances via Websub", -                   Federator, +                   Pleroma.Web.Websub,                     [:passthrough],                     [] do        user = insert(:user) @@ -122,17 +127,17 @@ defmodule Pleroma.Web.FederatorTest do        {:ok, _activity} = CommonAPI.post(user, %{"status" => "HI"})        assert called( -               Federator.publish_single_websub(%{ +               Pleroma.Web.Websub.publish_one(%{                   callback: sub2.callback,                   unreachable_since: dt                 })               ) -      refute called(Federator.publish_single_websub(%{callback: sub1.callback})) +      refute called(Pleroma.Web.Websub.publish_one(%{callback: sub1.callback}))      end      test_with_mock "it federates only to reachable instances via Salmon", -                   Federator, +                   Pleroma.Web.Salmon,                     [:passthrough],                     [] do        user = insert(:user) @@ -162,13 +167,13 @@ defmodule Pleroma.Web.FederatorTest do          CommonAPI.post(user, %{"status" => "HI @nick1@domain.com, @nick2@domain2.com!"})        assert called( -               Federator.publish_single_salmon(%{ +               Pleroma.Web.Salmon.publish_one(%{                   recipient: remote_user2,                   unreachable_since: dt                 })               ) -      refute called(Federator.publish_single_websub(%{recipient: remote_user1})) +      refute called(Pleroma.Web.Salmon.publish_one(%{recipient: remote_user1}))      end    end diff --git a/test/web/http_sigs/http_sig_test.exs b/test/web/http_sigs/http_sig_test.exs deleted file mode 100644 index c4d2eaf78..000000000 --- a/test/web/http_sigs/http_sig_test.exs +++ /dev/null @@ -1,194 +0,0 @@ -# Pleroma: A lightweight social networking server -# Copyright © 2017-2018 Pleroma Authors <https://pleroma.social/> -# SPDX-License-Identifier: AGPL-3.0-only - -# http signatures -# Test data from https://tools.ietf.org/html/draft-cavage-http-signatures-08#appendix-C -defmodule Pleroma.Web.HTTPSignaturesTest do -  use Pleroma.DataCase -  alias Pleroma.Web.HTTPSignatures -  import Pleroma.Factory -  import Tesla.Mock - -  setup do -    mock(fn env -> apply(HttpRequestMock, :request, [env]) end) -    :ok -  end - -  @public_key hd(:public_key.pem_decode(File.read!("test/web/http_sigs/pub.key"))) -              |> :public_key.pem_entry_decode() - -  @headers %{ -    "(request-target)" => "post /foo?param=value&pet=dog", -    "host" => "example.com", -    "date" => "Thu, 05 Jan 2014 21:31:40 GMT", -    "content-type" => "application/json", -    "digest" => "SHA-256=X48E9qOokqqrvdts8nOJRJN3OWDUoyWxBf7kbu9DBPE=", -    "content-length" => "18" -  } - -  @default_signature """ -  keyId="Test",algorithm="rsa-sha256",signature="jKyvPcxB4JbmYY4mByyBY7cZfNl4OW9HpFQlG7N4YcJPteKTu4MWCLyk+gIr0wDgqtLWf9NLpMAMimdfsH7FSWGfbMFSrsVTHNTk0rK3usrfFnti1dxsM4jl0kYJCKTGI/UWkqiaxwNiKqGcdlEDrTcUhhsFsOIo8VhddmZTZ8w=" -  """ - -  @basic_signature """ -  keyId="Test",algorithm="rsa-sha256",headers="(request-target) host date",signature="HUxc9BS3P/kPhSmJo+0pQ4IsCo007vkv6bUm4Qehrx+B1Eo4Mq5/6KylET72ZpMUS80XvjlOPjKzxfeTQj4DiKbAzwJAb4HX3qX6obQTa00/qPDXlMepD2JtTw33yNnm/0xV7fQuvILN/ys+378Ysi082+4xBQFwvhNvSoVsGv4=" -  """ - -  @all_headers_signature """ -  keyId="Test",algorithm="rsa-sha256",headers="(request-target) host date content-type digest content-length",signature="Ef7MlxLXoBovhil3AlyjtBwAL9g4TN3tibLj7uuNB3CROat/9KaeQ4hW2NiJ+pZ6HQEOx9vYZAyi+7cmIkmJszJCut5kQLAwuX+Ms/mUFvpKlSo9StS2bMXDBNjOh4Auj774GFj4gwjS+3NhFeoqyr/MuN6HsEnkvn6zdgfE2i0=" -  """ - -  test "split up a signature" do -    expected = %{ -      "keyId" => "Test", -      "algorithm" => "rsa-sha256", -      "signature" => -        "jKyvPcxB4JbmYY4mByyBY7cZfNl4OW9HpFQlG7N4YcJPteKTu4MWCLyk+gIr0wDgqtLWf9NLpMAMimdfsH7FSWGfbMFSrsVTHNTk0rK3usrfFnti1dxsM4jl0kYJCKTGI/UWkqiaxwNiKqGcdlEDrTcUhhsFsOIo8VhddmZTZ8w=", -      "headers" => ["date"] -    } - -    assert HTTPSignatures.split_signature(@default_signature) == expected -  end - -  test "validates the default case" do -    signature = HTTPSignatures.split_signature(@default_signature) -    assert HTTPSignatures.validate(@headers, signature, @public_key) -  end - -  test "validates the basic case" do -    signature = HTTPSignatures.split_signature(@basic_signature) -    assert HTTPSignatures.validate(@headers, signature, @public_key) -  end - -  test "validates the all-headers case" do -    signature = HTTPSignatures.split_signature(@all_headers_signature) -    assert HTTPSignatures.validate(@headers, signature, @public_key) -  end - -  test "it contructs a signing string" do -    expected = "date: Thu, 05 Jan 2014 21:31:40 GMT\ncontent-length: 18" -    assert expected == HTTPSignatures.build_signing_string(@headers, ["date", "content-length"]) -  end - -  test "it validates a conn" do -    public_key_pem = -      "-----BEGIN PUBLIC KEY-----\nMIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8AMIIBCgKCAQEAnGb42rPZIapY4Hfhxrgn\nxKVJczBkfDviCrrYaYjfGxawSw93dWTUlenCVTymJo8meBlFgIQ70ar4rUbzl6GX\nMYvRdku072d1WpglNHXkjKPkXQgngFDrh2sGKtNB/cEtJcAPRO8OiCgPFqRtMiNM\nc8VdPfPdZuHEIZsJ/aUM38EnqHi9YnVDQik2xxDe3wPghOhqjxUM6eLC9jrjI+7i\naIaEygUdyst9qVg8e2FGQlwAeS2Eh8ygCxn+bBlT5OyV59jSzbYfbhtF2qnWHtZy\nkL7KOOwhIfGs7O9SoR2ZVpTEQ4HthNzainIe/6iCR5HGrao/T8dygweXFYRv+k5A\nPQIDAQAB\n-----END PUBLIC KEY-----\n" - -    [public_key] = :public_key.pem_decode(public_key_pem) - -    public_key = -      public_key -      |> :public_key.pem_entry_decode() - -    conn = %{ -      req_headers: [ -        {"host", "localtesting.pleroma.lol"}, -        {"connection", "close"}, -        {"content-length", "2316"}, -        {"user-agent", "http.rb/2.2.2 (Mastodon/2.1.0.rc3; +http://mastodon.example.org/)"}, -        {"date", "Sun, 10 Dec 2017 14:23:49 GMT"}, -        {"digest", "SHA-256=x/bHADMW8qRrq2NdPb5P9fl0lYpKXXpe5h5maCIL0nM="}, -        {"content-type", "application/activity+json"}, -        {"(request-target)", "post /users/demiurge/inbox"}, -        {"signature", -         "keyId=\"http://mastodon.example.org/users/admin#main-key\",algorithm=\"rsa-sha256\",headers=\"(request-target) user-agent host date digest content-type\",signature=\"i0FQvr51sj9BoWAKydySUAO1RDxZmNY6g7M62IA7VesbRSdFZZj9/fZapLp6YSuvxUF0h80ZcBEq9GzUDY3Chi9lx6yjpUAS2eKb+Am/hY3aswhnAfYd6FmIdEHzsMrpdKIRqO+rpQ2tR05LwiGEHJPGS0p528NvyVxrxMT5H5yZS5RnxY5X2HmTKEgKYYcvujdv7JWvsfH88xeRS7Jlq5aDZkmXvqoR4wFyfgnwJMPLel8P/BUbn8BcXglH/cunR0LUP7sflTxEz+Rv5qg+9yB8zgBsB4C0233WpcJxjeD6Dkq0EcoJObBR56F8dcb7NQtUDu7x6xxzcgSd7dHm5w==\""} -      ] -    } - -    assert HTTPSignatures.validate_conn(conn, public_key) -  end - -  test "it validates a conn and fetches the key" do -    conn = %{ -      params: %{"actor" => "http://mastodon.example.org/users/admin"}, -      req_headers: [ -        {"host", "localtesting.pleroma.lol"}, -        {"x-forwarded-for", "127.0.0.1"}, -        {"connection", "close"}, -        {"content-length", "2307"}, -        {"user-agent", "http.rb/2.2.2 (Mastodon/2.1.0.rc3; +http://mastodon.example.org/)"}, -        {"date", "Sun, 11 Feb 2018 17:12:01 GMT"}, -        {"digest", "SHA-256=UXsAnMtR9c7mi1FOf6HRMtPgGI1yi2e9nqB/j4rZ99I="}, -        {"content-type", "application/activity+json"}, -        {"signature", -         "keyId=\"http://mastodon.example.org/users/admin#main-key\",algorithm=\"rsa-sha256\",headers=\"(request-target) user-agent host date digest content-type\",signature=\"qXKqpQXUpC3d9bZi2ioEeAqP8nRMD021CzH1h6/w+LRk4Hj31ARJHDwQM+QwHltwaLDUepshMfz2WHSXAoLmzWtvv7xRwY+mRqe+NGk1GhxVZ/LSrO/Vp7rYfDpfdVtkn36LU7/Bzwxvvaa4ZWYltbFsRBL0oUrqsfmJFswNCQIG01BB52BAhGSCORHKtQyzo1IZHdxl8y80pzp/+FOK2SmHkqWkP9QbaU1qTZzckL01+7M5btMW48xs9zurEqC2sM5gdWMQSZyL6isTV5tmkTZrY8gUFPBJQZgihK44v3qgfWojYaOwM8ATpiv7NG8wKN/IX7clDLRMA8xqKRCOKw==\""}, -        {"(request-target)", "post /users/demiurge/inbox"} -      ] -    } - -    assert HTTPSignatures.validate_conn(conn) -  end - -  test "validate this" do -    conn = %{ -      params: %{"actor" => "https://niu.moe/users/rye"}, -      req_headers: [ -        {"x-forwarded-for", "149.202.73.191"}, -        {"host", "testing.pleroma.lol"}, -        {"x-cluster-client-ip", "149.202.73.191"}, -        {"connection", "upgrade"}, -        {"content-length", "2396"}, -        {"user-agent", "http.rb/3.0.0 (Mastodon/2.2.0; +https://niu.moe/)"}, -        {"date", "Sun, 18 Feb 2018 20:31:51 GMT"}, -        {"digest", "SHA-256=dzH+vLyhxxALoe9RJdMl4hbEV9bGAZnSfddHQzeidTU="}, -        {"content-type", "application/activity+json"}, -        {"signature", -         "keyId=\"https://niu.moe/users/rye#main-key\",algorithm=\"rsa-sha256\",headers=\"(request-target) user-agent host date digest content-type\",signature=\"wtxDg4kIpW7nsnUcVJhBk6SgJeDZOocr8yjsnpDRqE52lR47SH6X7G16r7L1AUJdlnbfx7oqcvomoIJoHB3ghP6kRnZW6MyTMZ2jPoi3g0iC5RDqv6oAmDSO14iw6U+cqZbb3P/odS5LkbThF0UNXcfenVNfsKosIJycFjhNQc54IPCDXYq/7SArEKJp8XwEgzmiC2MdxlkVIUSTQYfjM4EG533cwlZocw1mw72e5mm/owTa80BUZAr0OOuhoWARJV9btMb02ZyAF6SCSoGPTA37wHyfM1Dk88NHf7Z0Aov/Fl65dpRM+XyoxdkpkrhDfH9qAx4iuV2VEWddQDiXHA==\""}, -        {"(request-target)", "post /inbox"} -      ] -    } - -    assert HTTPSignatures.validate_conn(conn) -  end - -  test "validate this too" do -    conn = %{ -      params: %{"actor" => "https://niu.moe/users/rye"}, -      req_headers: [ -        {"x-forwarded-for", "149.202.73.191"}, -        {"host", "testing.pleroma.lol"}, -        {"x-cluster-client-ip", "149.202.73.191"}, -        {"connection", "upgrade"}, -        {"content-length", "2342"}, -        {"user-agent", "http.rb/3.0.0 (Mastodon/2.2.0; +https://niu.moe/)"}, -        {"date", "Sun, 18 Feb 2018 21:44:46 GMT"}, -        {"digest", "SHA-256=vS8uDOJlyAu78cF3k5EzrvaU9iilHCX3chP37gs5sS8="}, -        {"content-type", "application/activity+json"}, -        {"signature", -         "keyId=\"https://niu.moe/users/rye#main-key\",algorithm=\"rsa-sha256\",headers=\"(request-target) user-agent host date digest content-type\",signature=\"IN6fHD8pLiDEf35dOaRHzJKc1wBYh3/Yq0ItaNGxUSbJTd2xMjigZbcsVKzvgYYjglDDN+disGNeD+OBKwMqkXWaWe/lyMc9wHvCH5NMhpn/A7qGLY8yToSt4vh8ytSkZKO6B97yC+Nvy6Fz/yMbvKtFycIvSXCq417cMmY6f/aG+rtMUlTbKO5gXzC7SUgGJCtBPCh1xZzu5/w0pdqdjO46ePNeR6JyJSLLV4hfo3+p2n7SRraxM4ePVCUZqhwS9LPt3Zdhy3ut+IXCZgMVIZggQFM+zXLtcXY5HgFCsFQr5WQDu+YkhWciNWtKFnWfAsnsg5sC330lZ/0Z8Z91yA==\""}, -        {"(request-target)", "post /inbox"} -      ] -    } - -    assert HTTPSignatures.validate_conn(conn) -  end - -  test "it generates a signature" do -    user = insert(:user) -    assert HTTPSignatures.sign(user, %{host: "mastodon.example.org"}) =~ "keyId=\"" -  end - -  test "this too" do -    conn = %{ -      params: %{"actor" => "https://mst3k.interlinked.me/users/luciferMysticus"}, -      req_headers: [ -        {"host", "soc.canned-death.us"}, -        {"user-agent", "http.rb/3.0.0 (Mastodon/2.2.0; +https://mst3k.interlinked.me/)"}, -        {"date", "Sun, 11 Mar 2018 12:19:36 GMT"}, -        {"digest", "SHA-256=V7Hl6qDK2m8WzNsjzNYSBISi9VoIXLFlyjF/a5o1SOc="}, -        {"content-type", "application/activity+json"}, -        {"signature", -         "keyId=\"https://mst3k.interlinked.me/users/luciferMysticus#main-key\",algorithm=\"rsa-sha256\",headers=\"(request-target) user-agent host date digest content-type\",signature=\"CTYdK5a6lYMxzmqjLOpvRRASoxo2Rqib2VrAvbR5HaTn80kiImj15pCpAyx8IZp53s0Fn/y8MjCTzp+absw8kxx0k2sQAXYs2iy6xhdDUe7iGzz+XLAEqLyZIZfecynaU2nb3Z2XnFDjhGjR1vj/JP7wiXpwp6o1dpDZj+KT2vxHtXuB9585V+sOHLwSB1cGDbAgTy0jx/2az2EGIKK2zkw1KJuAZm0DDMSZalp/30P8dl3qz7DV2EHdDNfaVtrs5BfbDOZ7t1hCcASllzAzgVGFl0BsrkzBfRMeUMRucr111ZG+c0BNOEtJYOHSyZsSSdNknElggCJekONYMYk5ZA==\""}, -        {"x-forwarded-for", "2607:5300:203:2899::31:1337"}, -        {"x-forwarded-host", "soc.canned-death.us"}, -        {"x-forwarded-server", "soc.canned-death.us"}, -        {"connection", "Keep-Alive"}, -        {"content-length", "2006"}, -        {"(request-target)", "post /inbox"} -      ] -    } - -    assert HTTPSignatures.validate_conn(conn) -  end -end diff --git a/test/web/http_sigs/priv.key b/test/web/http_sigs/priv.key deleted file mode 100644 index 425518a06..000000000 --- a/test/web/http_sigs/priv.key +++ /dev/null @@ -1,15 +0,0 @@ ------BEGIN RSA PRIVATE KEY----- -MIICXgIBAAKBgQDCFENGw33yGihy92pDjZQhl0C36rPJj+CvfSC8+q28hxA161QF -NUd13wuCTUcq0Qd2qsBe/2hFyc2DCJJg0h1L78+6Z4UMR7EOcpfdUE9Hf3m/hs+F -UR45uBJeDK1HSFHD8bHKD6kv8FPGfJTotc+2xjJwoYi+1hqp1fIekaxsyQIDAQAB -AoGBAJR8ZkCUvx5kzv+utdl7T5MnordT1TvoXXJGXK7ZZ+UuvMNUCdN2QPc4sBiA -QWvLw1cSKt5DsKZ8UETpYPy8pPYnnDEz2dDYiaew9+xEpubyeW2oH4Zx71wqBtOK -kqwrXa/pzdpiucRRjk6vE6YY7EBBs/g7uanVpGibOVAEsqH1AkEA7DkjVH28WDUg -f1nqvfn2Kj6CT7nIcE3jGJsZZ7zlZmBmHFDONMLUrXR/Zm3pR5m0tCmBqa5RK95u -412jt1dPIwJBANJT3v8pnkth48bQo/fKel6uEYyboRtA5/uHuHkZ6FQF7OUkGogc -mSJluOdc5t6hI1VsLn0QZEjQZMEOWr+wKSMCQQCC4kXJEsHAve77oP6HtG/IiEn7 -kpyUXRNvFsDE0czpJJBvL/aRFUJxuRK91jhjC68sA7NsKMGg5OXb5I5Jj36xAkEA -gIT7aFOYBFwGgQAQkWNKLvySgKbAZRTeLBacpHMuQdl1DfdntvAyqpAZ0lY0RKmW -G6aFKaqQfOXKCyWoUiVknQJAXrlgySFci/2ueKlIE1QqIiLSZ8V8OlpFLRnb1pzI -7U1yQXnTAEFYM560yJlzUpOb1V4cScGd365tiSMvxLOvTA== ------END RSA PRIVATE KEY----- diff --git a/test/web/http_sigs/pub.key b/test/web/http_sigs/pub.key deleted file mode 100644 index b3bbf6cb9..000000000 --- a/test/web/http_sigs/pub.key +++ /dev/null @@ -1,6 +0,0 @@ ------BEGIN PUBLIC KEY----- -MIGfMA0GCSqGSIb3DQEBAQUAA4GNADCBiQKBgQDCFENGw33yGihy92pDjZQhl0C3 -6rPJj+CvfSC8+q28hxA161QFNUd13wuCTUcq0Qd2qsBe/2hFyc2DCJJg0h1L78+6 -Z4UMR7EOcpfdUE9Hf3m/hs+FUR45uBJeDK1HSFHD8bHKD6kv8FPGfJTotc+2xjJw -oYi+1hqp1fIekaxsyQIDAQAB ------END PUBLIC KEY----- diff --git a/test/web/mastodon_api/mastodon_api_controller_test.exs b/test/web/mastodon_api/mastodon_api_controller_test.exs index 505e45010..40e7739e7 100644 --- a/test/web/mastodon_api/mastodon_api_controller_test.exs +++ b/test/web/mastodon_api/mastodon_api_controller_test.exs @@ -16,6 +16,7 @@ defmodule Pleroma.Web.MastodonAPI.MastodonAPIControllerTest do    alias Pleroma.Web.CommonAPI    alias Pleroma.Web.MastodonAPI.FilterView    alias Pleroma.Web.OAuth.App +  alias Pleroma.Web.OAuth.Token    alias Pleroma.Web.OStatus    alias Pleroma.Web.Push    alias Pleroma.Web.TwitterAPI.TwitterAPI @@ -80,6 +81,19 @@ defmodule Pleroma.Web.MastodonAPI.MastodonAPIControllerTest do      end)    end +  test "the public timeline when public is set to false", %{conn: conn} do +    public = Pleroma.Config.get([:instance, :public]) +    Pleroma.Config.put([:instance, :public], false) + +    on_exit(fn -> +      Pleroma.Config.put([:instance, :public], public) +    end) + +    assert conn +           |> get("/api/v1/timelines/public", %{"local" => "False"}) +           |> json_response(403) == %{"error" => "This resource requires authentication."} +  end +    test "posting a status", %{conn: conn} do      user = insert(:user) @@ -572,6 +586,7 @@ defmodule Pleroma.Web.MastodonAPI.MastodonAPIControllerTest do        assert response = json_response(conn, 200)        assert response["phrase"] == filter.phrase        assert response["context"] == filter.context +      assert response["irreversible"] == false        assert response["id"] != nil        assert response["id"] != ""      end @@ -3215,4 +3230,129 @@ defmodule Pleroma.Web.MastodonAPI.MastodonAPIControllerTest do      replied_to_user = User.get_by_ap_id(replied_to.data["actor"])      assert reblogged_activity["reblog"]["in_reply_to_account_id"] == replied_to_user.id    end + +  describe "create account by app" do +    setup do +      enabled = Pleroma.Config.get([:app_account_creation, :enabled]) +      max_requests = Pleroma.Config.get([:app_account_creation, :max_requests]) +      interval = Pleroma.Config.get([:app_account_creation, :interval]) + +      Pleroma.Config.put([:app_account_creation, :enabled], true) +      Pleroma.Config.put([:app_account_creation, :max_requests], 5) +      Pleroma.Config.put([:app_account_creation, :interval], 1) + +      on_exit(fn -> +        Pleroma.Config.put([:app_account_creation, :enabled], enabled) +        Pleroma.Config.put([:app_account_creation, :max_requests], max_requests) +        Pleroma.Config.put([:app_account_creation, :interval], interval) +      end) + +      :ok +    end + +    test "Account registration via Application", %{conn: conn} do +      conn = +        conn +        |> post("/api/v1/apps", %{ +          client_name: "client_name", +          redirect_uris: "urn:ietf:wg:oauth:2.0:oob", +          scopes: "read, write, follow" +        }) + +      %{ +        "client_id" => client_id, +        "client_secret" => client_secret, +        "id" => _, +        "name" => "client_name", +        "redirect_uri" => "urn:ietf:wg:oauth:2.0:oob", +        "vapid_key" => _, +        "website" => nil +      } = json_response(conn, 200) + +      conn = +        conn +        |> post("/oauth/token", %{ +          grant_type: "client_credentials", +          client_id: client_id, +          client_secret: client_secret +        }) + +      assert %{"access_token" => token, "refresh_token" => refresh, "scope" => scope} = +               json_response(conn, 200) + +      assert token +      token_from_db = Repo.get_by(Token, token: token) +      assert token_from_db +      assert refresh +      assert scope == "read write follow" + +      conn = +        build_conn() +        |> put_req_header("authorization", "Bearer " <> token) +        |> post("/api/v1/accounts", %{ +          username: "lain", +          email: "lain@example.org", +          password: "PlzDontHackLain", +          agreement: true +        }) + +      %{ +        "access_token" => token, +        "created_at" => _created_at, +        "scope" => _scope, +        "token_type" => "Bearer" +      } = json_response(conn, 200) + +      token_from_db = Repo.get_by(Token, token: token) +      assert token_from_db +      token_from_db = Repo.preload(token_from_db, :user) +      assert token_from_db.user + +      assert token_from_db.user.info.confirmation_pending +    end + +    test "rate limit", %{conn: conn} do +      app_token = insert(:oauth_token, user: nil) + +      conn = +        put_req_header(conn, "authorization", "Bearer " <> app_token.token) +        |> Map.put(:remote_ip, {15, 15, 15, 15}) + +      for i <- 1..5 do +        conn = +          conn +          |> post("/api/v1/accounts", %{ +            username: "#{i}lain", +            email: "#{i}lain@example.org", +            password: "PlzDontHackLain", +            agreement: true +          }) + +        %{ +          "access_token" => token, +          "created_at" => _created_at, +          "scope" => _scope, +          "token_type" => "Bearer" +        } = json_response(conn, 200) + +        token_from_db = Repo.get_by(Token, token: token) +        assert token_from_db +        token_from_db = Repo.preload(token_from_db, :user) +        assert token_from_db.user + +        assert token_from_db.user.info.confirmation_pending +      end + +      conn = +        conn +        |> post("/api/v1/accounts", %{ +          username: "6lain", +          email: "6lain@example.org", +          password: "PlzDontHackLain", +          agreement: true +        }) + +      assert json_response(conn, 403) == %{"error" => "Rate limit exceeded."} +    end +  end  end diff --git a/test/web/oauth/oauth_controller_test.exs b/test/web/oauth/oauth_controller_test.exs index cb6836983..1c04ac9ad 100644 --- a/test/web/oauth/oauth_controller_test.exs +++ b/test/web/oauth/oauth_controller_test.exs @@ -614,6 +614,27 @@ defmodule Pleroma.Web.OAuth.OAuthControllerTest do        assert token.scopes == ["scope1", "scope2"]      end +    test "issue a token for client_credentials grant type" do +      app = insert(:oauth_app, scopes: ["read", "write"]) + +      conn = +        build_conn() +        |> post("/oauth/token", %{ +          "grant_type" => "client_credentials", +          "client_id" => app.client_id, +          "client_secret" => app.client_secret +        }) + +      assert %{"access_token" => token, "refresh_token" => refresh, "scope" => scope} = +               json_response(conn, 200) + +      assert token +      token_from_db = Repo.get_by(Token, token: token) +      assert token_from_db +      assert refresh +      assert scope == "read write" +    end +      test "rejects token exchange with invalid client credentials" do        user = insert(:user)        app = insert(:oauth_app) @@ -644,7 +665,7 @@ defmodule Pleroma.Web.OAuth.OAuthControllerTest do        password = "testpassword"        user = insert(:user, password_hash: Comeonin.Pbkdf2.hashpwsalt(password)) -      info_change = Pleroma.User.Info.confirmation_changeset(user.info, :unconfirmed) +      info_change = Pleroma.User.Info.confirmation_changeset(user.info, need_confirmation: true)        {:ok, user} =          user diff --git a/test/web/oauth/token/utils_test.exs b/test/web/oauth/token/utils_test.exs new file mode 100644 index 000000000..20e338cab --- /dev/null +++ b/test/web/oauth/token/utils_test.exs @@ -0,0 +1,53 @@ +# Pleroma: A lightweight social networking server +# Copyright © 2017-2018 Pleroma Authors <https://pleroma.social/> +# SPDX-License-Identifier: AGPL-3.0-only + +defmodule Pleroma.Web.OAuth.Token.UtilsTest do +  use Pleroma.DataCase +  alias Pleroma.Web.OAuth.Token.Utils +  import Pleroma.Factory + +  describe "fetch_app/1" do +    test "returns error when credentials is invalid" do +      assert {:error, :not_found} = +               Utils.fetch_app(%Plug.Conn{params: %{"client_id" => 1, "client_secret" => "x"}}) +    end + +    test "returns App by params credentails" do +      app = insert(:oauth_app) + +      assert {:ok, load_app} = +               Utils.fetch_app(%Plug.Conn{ +                 params: %{"client_id" => app.client_id, "client_secret" => app.client_secret} +               }) + +      assert load_app == app +    end + +    test "returns App by header credentails" do +      app = insert(:oauth_app) +      header = "Basic " <> Base.encode64("#{app.client_id}:#{app.client_secret}") + +      conn = +        %Plug.Conn{} +        |> Plug.Conn.put_req_header("authorization", header) + +      assert {:ok, load_app} = Utils.fetch_app(conn) +      assert load_app == app +    end +  end + +  describe "format_created_at/1" do +    test "returns formatted created at" do +      token = insert(:oauth_token) +      date = Utils.format_created_at(token) + +      token_date = +        token.inserted_at +        |> DateTime.from_naive!("Etc/UTC") +        |> DateTime.to_unix() + +      assert token_date == date +    end +  end +end diff --git a/test/web/ostatus/activity_representer_test.exs b/test/web/ostatus/activity_representer_test.exs index a4bb68c4d..16ee02abb 100644 --- a/test/web/ostatus/activity_representer_test.exs +++ b/test/web/ostatus/activity_representer_test.exs @@ -67,37 +67,31 @@ defmodule Pleroma.Web.OStatus.ActivityRepresenterTest do    end    test "a reply note" do -    note = insert(:note_activity) -    answer = insert(:note_activity) -    object = answer.data["object"] -    object = Map.put(object, "inReplyTo", note.data["object"]["id"]) - -    data = %{answer.data | "object" => object} -    answer = %{answer | data: data} - -    note_object = Object.get_by_ap_id(note.data["object"]["id"]) +    user = insert(:user) +    note_object = insert(:note) +    _note = insert(:note_activity, %{note: note_object}) +    object = insert(:note, %{data: %{"inReplyTo" => note_object.data["id"]}}) +    answer = insert(:note_activity, %{note: object})      Repo.update!(        Object.change(note_object, %{data: Map.put(note_object.data, "external_url", "someurl")})      ) -    user = User.get_cached_by_ap_id(answer.data["actor"]) -      expected = """      <activity:object-type>http://activitystrea.ms/schema/1.0/note</activity:object-type>      <activity:verb>http://activitystrea.ms/schema/1.0/post</activity:verb> -    <id>#{answer.data["object"]["id"]}</id> +    <id>#{object.data["id"]}</id>      <title>New note by #{user.nickname}</title> -    <content type="html">#{answer.data["object"]["content"]}</content> -    <published>#{answer.data["object"]["published"]}</published> -    <updated>#{answer.data["object"]["published"]}</updated> +    <content type="html">#{object.data["content"]}</content> +    <published>#{object.data["published"]}</published> +    <updated>#{object.data["published"]}</updated>      <ostatus:conversation ref="#{answer.data["context"]}">#{answer.data["context"]}</ostatus:conversation>      <link ref="#{answer.data["context"]}" rel="ostatus:conversation" />      <summary>2hu</summary> -    <link type="application/atom+xml" href="#{answer.data["object"]["id"]}" rel="self" /> -    <link type="text/html" href="#{answer.data["object"]["id"]}" rel="alternate" /> +    <link type="application/atom+xml" href="#{object.data["id"]}" rel="self" /> +    <link type="text/html" href="#{object.data["id"]}" rel="alternate" />      <category term="2hu"/> -    <thr:in-reply-to ref="#{note.data["object"]["id"]}" href="someurl" /> +    <thr:in-reply-to ref="#{note_object.data["id"]}" href="someurl" />      <link rel="mentioned" ostatus:object-type="http://activitystrea.ms/schema/1.0/collection" href="http://activityschema.org/collection/public"/>      <link name="2hu" rel="emoji" href="corndog.png" />      """ diff --git a/test/web/salmon/salmon_test.exs b/test/web/salmon/salmon_test.exs index 7532578ca..232082779 100644 --- a/test/web/salmon/salmon_test.exs +++ b/test/web/salmon/salmon_test.exs @@ -7,7 +7,9 @@ defmodule Pleroma.Web.Salmon.SalmonTest do    alias Pleroma.Activity    alias Pleroma.Repo    alias Pleroma.User +  alias Pleroma.Web.Federator.Publisher    alias Pleroma.Web.Salmon +  import Mock    import Pleroma.Factory    @magickey "RSA.pu0s-halox4tu7wmES1FVSx6u-4wc0YrUFXcqWXZG4-27UmbCOpMQftRCldNRfyA-qLbz-eqiwQhh-1EwUvjsD4cYbAHNGHwTvDOyx5AKthQUP44ykPv7kjKGh3DWKySJvcs9tlUG87hlo7AvnMo9pwRS_Zz2CacQ-MKaXyDepk=.AQAB" @@ -77,7 +79,10 @@ defmodule Pleroma.Web.Salmon.SalmonTest do               "RSA.uzg6r1peZU0vXGADWxGJ0PE34WvmhjUmydbX5YYdOiXfODVLwCMi1umGoqUDm-mRu4vNEdFBVJU1CpFA7dKzWgIsqsa501i2XqElmEveXRLvNRWFB6nG03Q5OUY2as8eE54BJm0p20GkMfIJGwP6TSFb-ICp3QjzbatuSPJ6xCE=.AQAB"    end -  test "it pushes an activity to remote accounts it's addressed to" do +  test_with_mock "it pushes an activity to remote accounts it's addressed to", +                 Publisher, +                 [:passthrough], +                 [] do      user_data = %{        info: %{          salmon: "http://test-example.org/salmon" @@ -102,10 +107,8 @@ defmodule Pleroma.Web.Salmon.SalmonTest do      user = User.get_cached_by_ap_id(activity.data["actor"])      {:ok, user} = Pleroma.Web.WebFinger.ensure_keys_present(user) -    poster = fn url, _data, _headers -> -      assert url == "http://test-example.org/salmon" -    end +    Salmon.publish(user, activity) -    Salmon.publish(user, activity, poster) +    assert called(Publisher.enqueue_one(Salmon, %{recipient: mentioned_user}))    end  end diff --git a/test/web/twitter_api/twitter_api_controller_test.exs b/test/web/twitter_api/twitter_api_controller_test.exs index 90718cfb4..e194f14fb 100644 --- a/test/web/twitter_api/twitter_api_controller_test.exs +++ b/test/web/twitter_api/twitter_api_controller_test.exs @@ -1094,7 +1094,7 @@ defmodule Pleroma.Web.TwitterAPI.ControllerTest do    describe "GET /api/account/confirm_email/:id/:token" do      setup do        user = insert(:user) -      info_change = User.Info.confirmation_changeset(user.info, :unconfirmed) +      info_change = User.Info.confirmation_changeset(user.info, need_confirmation: true)        {:ok, user} =          user @@ -1145,7 +1145,7 @@ defmodule Pleroma.Web.TwitterAPI.ControllerTest do        end        user = insert(:user) -      info_change = User.Info.confirmation_changeset(user.info, :unconfirmed) +      info_change = User.Info.confirmation_changeset(user.info, need_confirmation: true)        {:ok, user} =          user diff --git a/test/web/twitter_api/util_controller_test.exs b/test/web/twitter_api/util_controller_test.exs index 56474447b..2cd82b3e7 100644 --- a/test/web/twitter_api/util_controller_test.exs +++ b/test/web/twitter_api/util_controller_test.exs @@ -141,7 +141,7 @@ defmodule Pleroma.Web.TwitterAPI.UtilControllerTest do      test "it returns the managed config", %{conn: conn} do        Pleroma.Config.put([:instance, :managed_config], false) -      Pleroma.Config.put([:fe], theme: "rei-ayanami-towel") +      Pleroma.Config.put([:frontend_configurations, :pleroma_fe], %{theme: "asuka-hospital"})        response =          conn @@ -157,29 +157,7 @@ defmodule Pleroma.Web.TwitterAPI.UtilControllerTest do          |> get("/api/statusnet/config.json")          |> json_response(:ok) -      assert response["site"]["pleromafe"] -    end - -    test "if :pleroma, :fe is false, it returns the new style config settings", %{conn: conn} do -      Pleroma.Config.put([:instance, :managed_config], true) -      Pleroma.Config.put([:fe, :theme], "rei-ayanami-towel") -      Pleroma.Config.put([:frontend_configurations, :pleroma_fe], %{theme: "asuka-hospital"}) - -      response = -        conn -        |> get("/api/statusnet/config.json") -        |> json_response(:ok) - -      assert response["site"]["pleromafe"]["theme"] == "rei-ayanami-towel" - -      Pleroma.Config.put([:fe], false) - -      response = -        conn -        |> get("/api/statusnet/config.json") -        |> json_response(:ok) - -      assert response["site"]["pleromafe"]["theme"] == "asuka-hospital" +      assert response["site"]["pleromafe"] == %{"theme" => "asuka-hospital"}      end    end @@ -251,4 +229,22 @@ defmodule Pleroma.Web.TwitterAPI.UtilControllerTest do      assert conn.status in [200, 503]    end + +  describe "POST /api/pleroma/disable_account" do +    test "it returns HTTP 200", %{conn: conn} do +      user = insert(:user) + +      response = +        conn +        |> assign(:user, user) +        |> post("/api/pleroma/disable_account", %{"password" => "test"}) +        |> json_response(:ok) + +      assert response == %{"status" => "success"} + +      user = User.get_cached_by_id(user.id) + +      assert user.info.deactivated == true +    end +  end  end diff --git a/test/web/twitter_api/views/activity_view_test.exs b/test/web/twitter_api/views/activity_view_test.exs index 1aa533b48..43bd77f78 100644 --- a/test/web/twitter_api/views/activity_view_test.exs +++ b/test/web/twitter_api/views/activity_view_test.exs @@ -295,8 +295,8 @@ defmodule Pleroma.Web.TwitterAPI.ActivityViewTest do        "id" => announce.id,        "is_local" => true,        "is_post_verb" => false, -      "statusnet_html" => "shp retweeted a status.", -      "text" => "shp retweeted a status.", +      "statusnet_html" => "shp repeated a status.", +      "text" => "shp repeated a status.",        "uri" => "tag:#{announce.data["id"]}:objectType=note",        "user" => UserView.render("show.json", user: other_user),        "retweeted_status" => ActivityView.render("activity.json", activity: activity), diff --git a/test/web/views/error_view_test.exs b/test/web/views/error_view_test.exs index d529fd2c3..3857d585f 100644 --- a/test/web/views/error_view_test.exs +++ b/test/web/views/error_view_test.exs @@ -4,6 +4,7 @@  defmodule Pleroma.Web.ErrorViewTest do    use Pleroma.Web.ConnCase, async: true +  import ExUnit.CaptureLog    # Bring render/3 and render_to_string/3 for testing custom views    import Phoenix.View @@ -13,17 +14,23 @@ defmodule Pleroma.Web.ErrorViewTest do    end    test "render 500.json" do -    assert render(Pleroma.Web.ErrorView, "500.json", []) == -             %{errors: %{detail: "Internal server error", reason: "nil"}} +    assert capture_log(fn -> +             assert render(Pleroma.Web.ErrorView, "500.json", []) == +                      %{errors: %{detail: "Internal server error", reason: "nil"}} +           end) =~ "[error] Internal server error: nil"    end    test "render any other" do -    assert render(Pleroma.Web.ErrorView, "505.json", []) == -             %{errors: %{detail: "Internal server error", reason: "nil"}} +    assert capture_log(fn -> +             assert render(Pleroma.Web.ErrorView, "505.json", []) == +                      %{errors: %{detail: "Internal server error", reason: "nil"}} +           end) =~ "[error] Internal server error: nil"    end    test "render 500.json with reason" do -    assert render(Pleroma.Web.ErrorView, "500.json", reason: "test reason") == -             %{errors: %{detail: "Internal server error", reason: "\"test reason\""}} +    assert capture_log(fn -> +             assert render(Pleroma.Web.ErrorView, "500.json", reason: "test reason") == +                      %{errors: %{detail: "Internal server error", reason: "\"test reason\""}} +           end) =~ "[error] Internal server error: \"test reason\""    end  end | 
