git.squeep.com Git - akkoma/blob - lib/pleroma/web/twitter_api/twitter_api_controller.ex

   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
   6   def verify_credentials(%{assigns: %{user: user}} = conn, _params) do
   7     response = user |> UserRepresenter.to_json(%{for: user})
   8
   9     conn
  10     |> json_reply(200, response)
  11   end
  12
  13   def status_update(%{assigns: %{user: user}} = conn, status_data) do
  14     {:ok, activity} = TwitterAPI.create_status(user, status_data)
  15     conn
  16     |> json_reply(200, ActivityRepresenter.to_json(activity, %{user: user}))
  17   end
  18
  19   def public_timeline(%{assigns: %{user: user}} = conn, params) do
  20     statuses = TwitterAPI.fetch_public_statuses(user, params)
  21     {:ok, json} = Poison.encode(statuses)
  22
  23     conn
  24     |> json_reply(200, json)
  25   end
  26
  27   def friends_timeline(%{assigns: %{user: user}} = conn, params) do
  28     statuses = TwitterAPI.fetch_friend_statuses(user, params)
  29     {:ok, json} = Poison.encode(statuses)
  30
  31     conn
  32     |> json_reply(200, json)
  33   end
  34
  35   def follow(%{assigns: %{user: user}} = conn, %{ "user_id" => followed_id }) do
  36     { :ok, _user, follower } = TwitterAPI.follow(user, followed_id)
  37
  38     response = follower |> UserRepresenter.to_json(%{for: user})
  39
  40     conn
  41     |> json_reply(200, response)
  42   end
  43
  44   def unfollow(%{assigns: %{user: user}} = conn, %{ "user_id" => followed_id }) do
  45     { :ok, user, follower } = TwitterAPI.unfollow(user, followed_id)
  46
  47     response = follower |> UserRepresenter.to_json(%{for: user})
  48
  49     conn
  50     |> json_reply(200, response)
  51   end
  52
  53   def fetch_status(%{assigns: %{user: user}} = conn, %{ "id" => id }) do
  54     response = TwitterAPI.fetch_status(user, id) |> Poison.encode!
  55
  56     conn
  57     |> json_reply(200, response)
  58   end
  59
  60   def fetch_conversation(%{assigns: %{user: user}} = conn, %{ "id" => id }) do
  61     id = String.to_integer(id)
  62     response = TwitterAPI.fetch_conversation(user, id) |> Poison.encode!
  63
  64     conn
  65     |> json_reply(200, response)
  66   end
  67
  68   def upload(conn, %{"media" => media}) do
  69     response = TwitterAPI.upload(media)
  70     conn
  71     |> put_resp_content_type("application/atom+xml")
  72     |> send_resp(200, response)
  73   end
  74
  75   defp json_reply(conn, status, json) do
  76     conn
  77     |> put_resp_content_type("application/json")
  78     |> send_resp(status, json)
  79   end
  80 end