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 if status_text |> String.trim |> String.length != 0 do
18 media_ids = extract_media_ids(status_data)
19 {:ok, activity} = TwitterAPI.create_status(user, Map.put(status_data, "media_ids", media_ids))
21 |> json_reply(200, ActivityRepresenter.to_json(activity, %{user: user}))
23 empty_status_reply(conn)
27 def status_update(conn, _status_data) do
28 empty_status_reply(conn)
31 defp empty_status_reply(conn) do
32 bad_request_reply(conn, "Client must provide a 'status' parameter with a value.")
35 defp extract_media_ids(status_data) do
36 with media_ids when not is_nil(media_ids) <- status_data["media_ids"],
37 split_ids <- String.split(media_ids, ","),
38 clean_ids <- Enum.reject(split_ids, fn (id) -> String.length(id) == 0 end)
45 def public_and_external_timeline(%{assigns: %{user: user}} = conn, params) do
46 statuses = TwitterAPI.fetch_public_and_external_statuses(user, params)
47 {:ok, json} = Poison.encode(statuses)
50 |> json_reply(200, json)
53 def public_timeline(%{assigns: %{user: user}} = conn, params) do
54 statuses = TwitterAPI.fetch_public_statuses(user, params)
55 {:ok, json} = Poison.encode(statuses)
58 |> json_reply(200, json)
61 def friends_timeline(%{assigns: %{user: user}} = conn, params) do
62 statuses = TwitterAPI.fetch_friend_statuses(user, params)
63 {:ok, json} = Poison.encode(statuses)
66 |> json_reply(200, json)
69 def user_timeline(%{assigns: %{user: user}} = conn, params) do
70 case TwitterAPI.get_user(user, params) do
72 params = Map.merge(params, %{"actor_id" => target_user.ap_id})
73 statuses = TwitterAPI.fetch_user_statuses(user, params)
75 |> json_reply(200, statuses |> Poison.encode!)
77 bad_request_reply(conn, msg)
81 def mentions_timeline(%{assigns: %{user: user}} = conn, params) do
82 statuses = TwitterAPI.fetch_mentions(user, params)
83 {:ok, json} = Poison.encode(statuses)
86 |> json_reply(200, json)
89 def follow(%{assigns: %{user: user}} = conn, params) do
90 case TwitterAPI.follow(user, params) do
91 {:ok, user, followed, _activity} ->
92 response = followed |> UserRepresenter.to_json(%{for: user})
94 |> json_reply(200, response)
95 {:error, msg} -> forbidden_json_reply(conn, msg)
99 def unfollow(%{assigns: %{user: user}} = conn, params) do
100 case TwitterAPI.unfollow(user, params) do
101 {:ok, user, unfollowed} ->
102 response = unfollowed |> UserRepresenter.to_json(%{for: user})
104 |> json_reply(200, response)
105 {:error, msg} -> forbidden_json_reply(conn, msg)
109 def fetch_status(%{assigns: %{user: user}} = conn, %{"id" => id}) do
110 response = Poison.encode!(TwitterAPI.fetch_status(user, id))
113 |> json_reply(200, response)
116 def fetch_conversation(%{assigns: %{user: user}} = conn, %{"id" => id}) do
117 id = String.to_integer(id)
118 response = Poison.encode!(TwitterAPI.fetch_conversation(user, id))
121 |> json_reply(200, response)
124 def upload(conn, %{"media" => media}) do
125 response = TwitterAPI.upload(media)
127 |> put_resp_content_type("application/atom+xml")
128 |> send_resp(200, response)
131 def help_test(conn, _params) do
132 conn |> json_reply(200, Poison.encode!("ok"))
135 def upload_json(conn, %{"media" => media}) do
136 response = TwitterAPI.upload(media, "json")
138 |> json_reply(200, response)
141 def config(conn, _params) do
145 server: Web.base_url,
152 |> json_reply(200, response)
155 def favorite(%{assigns: %{user: user}} = conn, %{"id" => id}) do
156 activity = Repo.get(Activity, id)
157 {:ok, status} = TwitterAPI.favorite(user, activity)
158 response = Poison.encode!(status)
161 |> json_reply(200, response)
164 def unfavorite(%{assigns: %{user: user}} = conn, %{"id" => id}) do
165 activity = Repo.get(Activity, id)
166 {:ok, status} = TwitterAPI.unfavorite(user, activity)
167 response = Poison.encode!(status)
170 |> json_reply(200, response)
173 def retweet(%{assigns: %{user: user}} = conn, %{"id" => id}) do
174 activity = Repo.get(Activity, id)
175 if activity.data["actor"] == user.ap_id do
176 bad_request_reply(conn, "You cannot repeat your own notice.")
178 {:ok, status} = TwitterAPI.retweet(user, activity)
179 response = Poison.encode!(status)
183 |> json_reply(200, response)
187 def register(conn, params) do
188 with {:ok, user} <- TwitterAPI.register_user(params) do
190 |> json_reply(200, Poison.encode!(user))
194 |> json_reply(400, Poison.encode!(errors))
198 def update_avatar(%{assigns: %{user: user}} = conn, params) do
199 {:ok, object} = ActivityPub.upload(params)
200 change = Changeset.change(user, %{avatar: object.data})
201 {:ok, user} = Repo.update(change)
203 response = Poison.encode!(UserRepresenter.to_map(user, %{for: user}))
206 |> json_reply(200, response)
209 defp bad_request_reply(conn, error_message) do
210 json = error_json(conn, error_message)
211 json_reply(conn, 400, json)
214 defp json_reply(conn, status, json) do
216 |> put_resp_content_type("application/json")
217 |> send_resp(status, json)
220 defp forbidden_json_reply(conn, error_message) do
221 json = error_json(conn, error_message)
222 json_reply(conn, 403, json)
225 defp error_json(conn, error_message) do
226 %{"error" => error_message, "request" => conn.request_path} |> Poison.encode!