defmodule Pleroma.Web.TwitterAPI.TwitterAPITest do use Pleroma.DataCase alias Pleroma.Builders.UserBuilder alias Pleroma.Web.TwitterAPI.{TwitterAPI, UserView} alias Pleroma.{Activity, User, Object, Repo, UserInviteToken} alias Pleroma.Web.ActivityPub.ActivityPub alias Pleroma.Web.TwitterAPI.ActivityView import Pleroma.Factory test "create a status" do user = insert(:user) _mentioned_user = UserBuilder.insert(%{nickname: "shp", ap_id: "shp"}) object_data = %{ "type" => "Image", "url" => [ %{ "type" => "Link", "mediaType" => "image/jpg", "href" => "http://example.org/image.jpg" } ], "uuid" => 1 } object = Repo.insert!(%Object{data: object_data}) input = %{ "status" => "Hello again, @shp.\nThis is on another :moominmamma: line. #2hu #epic #phantasmagoric", "media_ids" => [object.id] } {:ok, activity = %Activity{}} = TwitterAPI.create_status(user, input) expected_text = "Hello again, @shp.<script></script>
This is on another :moominmamma: line.
image.jpg" assert get_in(activity.data, ["object", "content"]) == expected_text assert get_in(activity.data, ["object", "type"]) == "Note" assert get_in(activity.data, ["object", "actor"]) == user.ap_id assert get_in(activity.data, ["actor"]) == user.ap_id assert Enum.member?(get_in(activity.data, ["cc"]), User.ap_followers(user)) assert Enum.member?( get_in(activity.data, ["to"]), "https://www.w3.org/ns/activitystreams#Public" ) assert Enum.member?(get_in(activity.data, ["cc"]), "shp") assert activity.local == true assert %{"moominmamma" => "http://localhost:4001/finmoji/128px/moominmamma-128.png"} = activity.data["object"]["emoji"] # hashtags assert activity.data["object"]["tag"] == ["2hu", "epic", "phantasmagoric"] # Add a context assert is_binary(get_in(activity.data, ["context"])) assert is_binary(get_in(activity.data, ["object", "context"])) assert is_list(activity.data["object"]["attachment"]) assert activity.data["object"] == Object.get_by_ap_id(activity.data["object"]["id"]).data user = User.get_by_ap_id(user.ap_id) assert user.info["note_count"] == 1 end test "create a status that is a reply" do user = insert(:user) input = %{ "status" => "Hello again." } {:ok, activity = %Activity{}} = TwitterAPI.create_status(user, input) input = %{ "status" => "Here's your (you).", "in_reply_to_status_id" => activity.id } {:ok, reply = %Activity{}} = TwitterAPI.create_status(user, input) assert get_in(reply.data, ["context"]) == get_in(activity.data, ["context"]) assert get_in(reply.data, ["object", "context"]) == get_in(activity.data, ["object", "context"]) assert get_in(reply.data, ["object", "inReplyTo"]) == get_in(activity.data, ["object", "id"]) assert get_in(reply.data, ["object", "inReplyToStatusId"]) == activity.id end test "Follow another user using user_id" do user = insert(:user) followed = insert(:user) {:ok, user, followed, _activity} = TwitterAPI.follow(user, %{"user_id" => followed.id}) assert User.ap_followers(followed) in user.following {:error, msg} = TwitterAPI.follow(user, %{"user_id" => followed.id}) assert msg == "Could not follow user: #{followed.nickname} is already on your list." end test "Follow another user using screen_name" do user = insert(:user) followed = insert(:user) {:ok, user, followed, _activity} = TwitterAPI.follow(user, %{"screen_name" => followed.nickname}) assert User.ap_followers(followed) in user.following followed = User.get_by_ap_id(followed.ap_id) assert followed.info["follower_count"] == 1 {:error, msg} = TwitterAPI.follow(user, %{"screen_name" => followed.nickname}) assert msg == "Could not follow user: #{followed.nickname} is already on your list." end test "Unfollow another user using user_id" do unfollowed = insert(:user) user = insert(:user, %{following: [User.ap_followers(unfollowed)]}) ActivityPub.follow(user, unfollowed) {:ok, user, unfollowed} = TwitterAPI.unfollow(user, %{"user_id" => unfollowed.id}) assert user.following == [] {:error, msg} = TwitterAPI.unfollow(user, %{"user_id" => unfollowed.id}) assert msg == "Not subscribed!" end test "Unfollow another user using screen_name" do unfollowed = insert(:user) user = insert(:user, %{following: [User.ap_followers(unfollowed)]}) ActivityPub.follow(user, unfollowed) {:ok, user, unfollowed} = TwitterAPI.unfollow(user, %{"screen_name" => unfollowed.nickname}) assert user.following == [] {:error, msg} = TwitterAPI.unfollow(user, %{"screen_name" => unfollowed.nickname}) assert msg == "Not subscribed!" end test "Block another user using user_id" do user = insert(:user) blocked = insert(:user) {:ok, user, blocked} = TwitterAPI.block(user, %{"user_id" => blocked.id}) assert User.blocks?(user, blocked) end test "Block another user using screen_name" do user = insert(:user) blocked = insert(:user) {:ok, user, blocked} = TwitterAPI.block(user, %{"screen_name" => blocked.nickname}) assert User.blocks?(user, blocked) end test "Unblock another user using user_id" do unblocked = insert(:user) user = insert(:user) {:ok, user, _unblocked} = TwitterAPI.block(user, %{"user_id" => unblocked.id}) {:ok, user, _unblocked} = TwitterAPI.unblock(user, %{"user_id" => unblocked.id}) assert user.info["blocks"] == [] end test "Unblock another user using screen_name" do unblocked = insert(:user) user = insert(:user) {:ok, user, _unblocked} = TwitterAPI.block(user, %{"screen_name" => unblocked.nickname}) {:ok, user, _unblocked} = TwitterAPI.unblock(user, %{"screen_name" => unblocked.nickname}) assert user.info["blocks"] == [] end test "upload a file" do file = %Plug.Upload{ content_type: "image/jpg", path: Path.absname("test/fixtures/image.jpg"), filename: "an_image.jpg" } response = TwitterAPI.upload(file) assert is_binary(response) end test "it favorites a status, returns the updated activity" do user = insert(:user) note_activity = insert(:note_activity) {:ok, status} = TwitterAPI.fav(user, note_activity.id) updated_activity = Activity.get_by_ap_id(note_activity.data["id"]) assert status == updated_activity end test "it unfavorites a status, returns the updated activity" do user = insert(:user) note_activity = insert(:note_activity) object = Object.get_by_ap_id(note_activity.data["object"]["id"]) {:ok, _like_activity, _object} = ActivityPub.like(user, object) updated_activity = Activity.get_by_ap_id(note_activity.data["id"]) assert ActivityView.render("activity.json", activity: updated_activity)["fave_num"] == 1 {:ok, activity} = TwitterAPI.unfav(user, note_activity.id) assert ActivityView.render("activity.json", activity: activity)["fave_num"] == 0 end test "it retweets a status and returns the retweet" do user = insert(:user) note_activity = insert(:note_activity) {:ok, status} = TwitterAPI.repeat(user, note_activity.id) updated_activity = Activity.get_by_ap_id(note_activity.data["id"]) assert status == updated_activity end test "it registers a new user and returns the user." do data = %{ "nickname" => "lain", "email" => "lain@wired.jp", "fullname" => "lain iwakura", "bio" => "close the world.", "password" => "bear", "confirm" => "bear" } {:ok, user} = TwitterAPI.register_user(data) fetched_user = Repo.get_by(User, nickname: "lain") assert UserView.render("show.json", %{user: user}) == UserView.render("show.json", %{user: fetched_user}) end @moduletag skip: "needs 'registrations_open: false' in config" test "it registers a new user via invite token and returns the user." do {:ok, token} = UserInviteToken.create_token() data = %{ "nickname" => "vinny", "email" => "pasta@pizza.vs", "fullname" => "Vinny Vinesauce", "bio" => "streamer", "password" => "hiptofbees", "confirm" => "hiptofbees", "token" => token.token } {:ok, user} = TwitterAPI.register_user(data) fetched_user = Repo.get_by(User, nickname: "vinny") token = Repo.get_by(UserInviteToken, token: token.token) assert token.used == true assert UserView.render("show.json", %{user: user}) == UserView.render("show.json", %{user: fetched_user}) end @moduletag skip: "needs 'registrations_open: false' in config" test "it returns an error if invalid token submitted" do data = %{ "nickname" => "GrimReaper", "email" => "death@reapers.afterlife", "fullname" => "Reaper Grim", "bio" => "Your time has come", "password" => "scythe", "confirm" => "scythe", "token" => "DudeLetMeInImAFairy" } {:error, msg} = TwitterAPI.register_user(data) assert msg == "Invalid token" refute Repo.get_by(User, nickname: "GrimReaper") end @moduletag skip: "needs 'registrations_open: false' in config" test "it returns an error if expired token submitted" do {:ok, token} = UserInviteToken.create_token() UserInviteToken.mark_as_used(token.token) data = %{ "nickname" => "GrimReaper", "email" => "death@reapers.afterlife", "fullname" => "Reaper Grim", "bio" => "Your time has come", "password" => "scythe", "confirm" => "scythe", "token" => token.token } {:error, msg} = TwitterAPI.register_user(data) assert msg == "Expired token" refute Repo.get_by(User, nickname: "GrimReaper") end test "it returns the error on registration problems" do data = %{ "nickname" => "lain", "email" => "lain@wired.jp", "fullname" => "lain iwakura", "bio" => "close the world.", "password" => "bear" } {:error, error_object} = TwitterAPI.register_user(data) assert is_binary(error_object[:error]) refute Repo.get_by(User, nickname: "lain") end test "it assigns an integer conversation_id" do note_activity = insert(:note_activity) status = ActivityView.render("activity.json", activity: note_activity) assert is_number(status["statusnet_conversation_id"]) end setup do Supervisor.terminate_child(Pleroma.Supervisor, Cachex) Supervisor.restart_child(Pleroma.Supervisor, Cachex) :ok end describe "context_to_conversation_id" do test "creates a mapping object" do conversation_id = TwitterAPI.context_to_conversation_id("random context") object = Object.get_by_ap_id("random context") assert conversation_id == object.id end test "returns an existing mapping for an existing object" do {:ok, object} = Object.context_mapping("random context") |> Repo.insert() conversation_id = TwitterAPI.context_to_conversation_id("random context") assert conversation_id == object.id end end describe "fetching a user by uri" do test "fetches a user by uri" do id = "https://mastodon.social/users/lambadalambda" user = insert(:user) {:ok, represented} = TwitterAPI.get_external_profile(user, id) remote = User.get_by_ap_id(id) assert represented["id"] == UserView.render("show.json", %{user: remote, for: user})["id"] # Also fetches the feed. # assert Activity.get_create_activity_by_object_ap_id("tag:mastodon.social,2017-04-05:objectId=1641750:objectType=Status") end end end