X-Git-Url: http://git.squeep.com/?a=blobdiff_plain;f=lib%2Fpleroma%2Fweb%2Ftwitter_api%2Ftwitter_api.ex;h=dc66e27adba77965769539eed976b15a7daa8cdf;hb=19e8421947472eb2207caa299bc4bf5947ce3cca;hp=5881af95e61782c6eb78c0bfe8106b84eff9f293;hpb=af49c11193d7e78159b5a45fa798cce1565cece7;p=akkoma diff --git a/lib/pleroma/web/twitter_api/twitter_api.ex b/lib/pleroma/web/twitter_api/twitter_api.ex index 5881af95e..dc66e27ad 100644 --- a/lib/pleroma/web/twitter_api/twitter_api.ex +++ b/lib/pleroma/web/twitter_api/twitter_api.ex @@ -1,19 +1,18 @@ defmodule Pleroma.Web.TwitterAPI.TwitterAPI do alias Pleroma.{User, Activity, Repo, Object} alias Pleroma.Web.ActivityPub.ActivityPub - alias Pleroma.Web.ActivityPub.Utils - alias Pleroma.Web.TwitterAPI.Representers.{ActivityRepresenter, UserRepresenter} + alias Pleroma.Web.TwitterAPI.Representers.ActivityRepresenter + alias Pleroma.Web.TwitterAPI.UserView alias Pleroma.Web.OStatus alias Pleroma.Formatter - import Ecto.Query import Pleroma.Web.TwitterAPI.Utils @httpoison Application.get_env(:pleroma, :httpoison) def to_for_user_and_mentions(user, mentions, inReplyTo) do default_to = [ - User.ap_followers(user), + user.follower_address, "https://www.w3.org/ns/activitystreams#Public" ] @@ -40,7 +39,9 @@ defmodule Pleroma.Web.TwitterAPI.TwitterAPI do context <- make_context(inReplyTo), tags <- Formatter.parse_tags(status), object <- make_note_data(user.ap_id, to, context, content_html, attachments, inReplyTo, tags) do - ActivityPub.create(to, user, context, object) + res = ActivityPub.create(to, user, context, object) + User.update_note_count(user) + res end end @@ -197,7 +198,7 @@ defmodule Pleroma.Web.TwitterAPI.TwitterAPI do changeset = User.register_changeset(%User{}, params) with {:ok, user} <- Repo.insert(changeset) do - {:ok, UserRepresenter.to_map(user)} + {:ok, user} else {:error, changeset} -> errors = Ecto.Changeset.traverse_errors(changeset, fn {msg, _opts} -> msg end) @@ -308,7 +309,7 @@ defmodule Pleroma.Web.TwitterAPI.TwitterAPI do {:ok, %{body: body}} <- @httpoison.get(url, [], follow_redirect: true, timeout: 10000, recv_timeout: 20000) do OStatus.handle_incoming(body) end - {:ok, UserRepresenter.to_map(user, %{for: for_user})} + {:ok, UserView.render("show.json", %{user: user, for: for_user})} else _e -> {:error, "Couldn't find user"} end