1 defmodule Pleroma.Web.TwitterAPI.Controller do
2 use Pleroma.Web, :controller
3 alias Pleroma.Web.TwitterAPI.TwitterAPI
4 alias Pleroma.Web.TwitterAPI.Representers.{UserRepresenter, ActivityRepresenter}
5 alias Pleroma.{Web, Repo, Activity}
6 alias Pleroma.Web.ActivityPub.ActivityPub
9 def verify_credentials(%{assigns: %{user: user}} = conn, _params) do
10 response = user |> UserRepresenter.to_json(%{for: user})
13 |> json_reply(200, response)
16 def status_update(%{assigns: %{user: user}} = conn, %{"status" => status_text} = status_data) do
17 l = status_text |> String.trim |> String.length
18 if l > 0 && l < 5000 do
19 media_ids = extract_media_ids(status_data)
20 {:ok, activity} = TwitterAPI.create_status(user, Map.put(status_data, "media_ids", media_ids))
22 |> json_reply(200, ActivityRepresenter.to_json(activity, %{user: user}))
24 empty_status_reply(conn)
28 def status_update(conn, _status_data) do
29 empty_status_reply(conn)
32 defp empty_status_reply(conn) do
33 bad_request_reply(conn, "Client must provide a 'status' parameter with a value.")
36 defp extract_media_ids(status_data) do
37 with media_ids when not is_nil(media_ids) <- status_data["media_ids"],
38 split_ids <- String.split(media_ids, ","),
39 clean_ids <- Enum.reject(split_ids, fn (id) -> String.length(id) == 0 end)
46 def public_and_external_timeline(%{assigns: %{user: user}} = conn, params) do
47 statuses = TwitterAPI.fetch_public_and_external_statuses(user, params)
48 {:ok, json} = Poison.encode(statuses)
51 |> json_reply(200, json)
54 def public_timeline(%{assigns: %{user: user}} = conn, params) do
55 statuses = TwitterAPI.fetch_public_statuses(user, params)
56 {:ok, json} = Poison.encode(statuses)
59 |> json_reply(200, json)
62 def friends_timeline(%{assigns: %{user: user}} = conn, params) do
63 statuses = TwitterAPI.fetch_friend_statuses(user, params)
64 {:ok, json} = Poison.encode(statuses)
67 |> json_reply(200, json)
70 def user_timeline(%{assigns: %{user: user}} = conn, params) do
71 case TwitterAPI.get_user(user, params) do
73 params = Map.merge(params, %{"actor_id" => target_user.ap_id})
74 statuses = TwitterAPI.fetch_user_statuses(user, params)
76 |> json_reply(200, statuses |> Poison.encode!)
78 bad_request_reply(conn, msg)
82 def mentions_timeline(%{assigns: %{user: user}} = conn, params) do
83 statuses = TwitterAPI.fetch_mentions(user, params)
84 {:ok, json} = Poison.encode(statuses)
87 |> json_reply(200, json)
90 def follow(%{assigns: %{user: user}} = conn, params) do
91 case TwitterAPI.follow(user, params) do
92 {:ok, user, followed, _activity} ->
93 response = followed |> UserRepresenter.to_json(%{for: user})
95 |> json_reply(200, response)
96 {:error, msg} -> forbidden_json_reply(conn, msg)
100 def unfollow(%{assigns: %{user: user}} = conn, params) do
101 case TwitterAPI.unfollow(user, params) do
102 {:ok, user, unfollowed} ->
103 response = unfollowed |> UserRepresenter.to_json(%{for: user})
105 |> json_reply(200, response)
106 {:error, msg} -> forbidden_json_reply(conn, msg)
110 def fetch_status(%{assigns: %{user: user}} = conn, %{"id" => id}) do
111 response = Poison.encode!(TwitterAPI.fetch_status(user, id))
114 |> json_reply(200, response)
117 def fetch_conversation(%{assigns: %{user: user}} = conn, %{"id" => id}) do
118 id = String.to_integer(id)
119 response = Poison.encode!(TwitterAPI.fetch_conversation(user, id))
122 |> json_reply(200, response)
125 def upload(conn, %{"media" => media}) do
126 response = TwitterAPI.upload(media)
128 |> put_resp_content_type("application/atom+xml")
129 |> send_resp(200, response)
132 def help_test(conn, _params) do
133 conn |> json_reply(200, Poison.encode!("ok"))
136 def upload_json(conn, %{"media" => media}) do
137 response = TwitterAPI.upload(media, "json")
139 |> json_reply(200, response)
142 def config(conn, _params) do
146 server: Web.base_url,
153 |> json_reply(200, response)
156 def favorite(%{assigns: %{user: user}} = conn, %{"id" => id}) do
157 activity = Repo.get(Activity, id)
158 {:ok, status} = TwitterAPI.favorite(user, activity)
159 response = Poison.encode!(status)
162 |> json_reply(200, response)
165 def unfavorite(%{assigns: %{user: user}} = conn, %{"id" => id}) do
166 activity = Repo.get(Activity, id)
167 {:ok, status} = TwitterAPI.unfavorite(user, activity)
168 response = Poison.encode!(status)
171 |> json_reply(200, response)
174 def retweet(%{assigns: %{user: user}} = conn, %{"id" => id}) do
175 activity = Repo.get(Activity, id)
176 if activity.data["actor"] == user.ap_id do
177 bad_request_reply(conn, "You cannot repeat your own notice.")
179 {:ok, status} = TwitterAPI.retweet(user, activity)
180 response = Poison.encode!(status)
184 |> json_reply(200, response)
188 def register(conn, params) do
189 with {:ok, user} <- TwitterAPI.register_user(params) do
191 |> json_reply(200, Poison.encode!(user))
195 |> json_reply(400, Poison.encode!(errors))
199 def update_avatar(%{assigns: %{user: user}} = conn, params) do
200 {:ok, object} = ActivityPub.upload(params)
201 change = Changeset.change(user, %{avatar: object.data})
202 {:ok, user} = Repo.update(change)
204 response = Poison.encode!(UserRepresenter.to_map(user, %{for: user}))
207 |> json_reply(200, response)
210 defp bad_request_reply(conn, error_message) do
211 json = error_json(conn, error_message)
212 json_reply(conn, 400, json)
215 defp json_reply(conn, status, json) do
217 |> put_resp_content_type("application/json")
218 |> send_resp(status, json)
221 defp forbidden_json_reply(conn, error_message) do
222 json = error_json(conn, error_message)
223 json_reply(conn, 403, json)
226 defp error_json(conn, error_message) do
227 %{"error" => error_message, "request" => conn.request_path} |> Poison.encode!