clacks/lib/clacks_web/controllers/frontend_controller.ex

181 lines
4.9 KiB
Elixir
Raw Normal View History

2019-10-06 23:41:18 +00:00
defmodule ClacksWeb.FrontendController do
use ClacksWeb, :controller
2020-04-21 02:40:48 +00:00
alias Clacks.{Actor, User, Timeline, Repo, ActivityPub, Activity, Object}
2019-10-06 23:41:18 +00:00
alias ClacksWeb.Router.Helpers, as: Routes
alias ClacksWeb.Endpoint
2020-04-23 02:54:46 +00:00
@public "https://www.w3.org/ns/activitystreams#Public"
def index(%Plug.Conn{assigns: %{user: user}} = conn, params) do
2019-10-06 23:41:18 +00:00
user = Repo.preload(user, :actor)
render(conn, "home.html", %{
user: user,
actor: user.actor,
statuses_with_authors: Timeline.home_timeline(user, params, true)
2019-10-06 23:41:18 +00:00
})
end
def index(conn, params) do
Application.get_env(:clacks, :frontend, %{})
|> Keyword.get(:unauthenticated_homepage, :public_timeline)
|> index(conn, params)
end
defp index(:public_timeline, conn, params) do
# tood: show public timeline
end
defp index({:profile, nickname}, conn, params) do
case Actor.get_by_nickname(nickname) do
%Actor{local: true} = actor ->
# only local profiles are shown
render(conn, "profile.html", %{
actor: actor,
statuses: actor_statuses(actor, params, only_public: true)
})
_ ->
# otherwise show public timeline
index(:public_timeline, conn)
end
end
defp actor_statuses(actor, params, only_public: only_public) do
Timeline.actor_timeline(actor, params, only_public)
2019-10-06 23:41:18 +00:00
end
def status(conn, %{"id" => id}) do
current_user = conn.assigns[:user] |> Repo.preload(:actor)
with %Activity{
local: true,
2020-04-23 02:54:46 +00:00
data:
%{
"type" => "Create",
"object" => %{"type" => "Note", "attributedTo" => author_id} = note
} = data
2020-04-25 16:30:47 +00:00
} = activity <- Activity.get(id),
2020-04-23 02:54:46 +00:00
%Actor{} = author <- Actor.get_by_ap_id(author_id) do
case conn.assigns[:format] do
"activity+json" ->
json(conn, data)
"html" ->
render(conn, "status.html", %{
current_user: current_user,
2020-04-25 16:30:47 +00:00
status: activity,
2020-04-23 02:54:46 +00:00
author: author
})
end
else
nil ->
case conn.assigns[:format] do
"activity+json" ->
conn
|> put_status(404)
|> json(%{error: "Not Found"})
"html" ->
resp(conn, 404, "Not Found")
end
%Activity{local: false, data: %{"id" => ap_id}} ->
case conn.assigns[:format] do
"activity+json" ->
conn
|> put_status(404)
|> json(%{error: "Not Found"})
"html" ->
redirect(conn, external: ap_id)
end
end
end
def reply(conn, %{"id" => id}) do
current_user = conn.assigns[:user]
with %Activity{
2019-10-06 23:41:18 +00:00
data: %{
"type" => "Create",
2020-04-25 16:30:47 +00:00
"object" => %{"type" => "Note", "attributedTo" => author_id}
2019-10-06 23:41:18 +00:00
}
2020-04-25 16:30:47 +00:00
} = activity <- Activity.get(id),
2019-10-06 23:41:18 +00:00
%Actor{} = author <- Actor.get_by_ap_id(author_id) do
2020-04-25 16:30:47 +00:00
render(conn, "status.html", %{
2019-10-06 23:41:18 +00:00
current_user: current_user,
2020-04-25 16:30:47 +00:00
status: activity,
2019-10-06 23:41:18 +00:00
author: author
})
else
2020-04-23 02:54:46 +00:00
_ ->
resp(conn, 404, "Not Found")
2019-10-06 23:41:18 +00:00
end
end
def profile(conn, %{"username" => username} = params) do
current_user = conn.assigns[:user] |> Repo.preload(:actor)
case User.get_by_username(username) do
nil ->
put_status(conn, 404)
user ->
user = Repo.preload(user, :actor)
render(conn, "profile.html", %{
current_user: current_user,
actor: user.actor,
statuses: actor_statuses(user.actor, params, only_public: true)
})
end
end
def post_status(conn, %{"content" => content} = params) do
current_user = conn.assigns[:user] |> Repo.preload(:actor)
2020-04-23 02:54:46 +00:00
note = note_for_posting(current_user, params)
2020-04-21 02:40:48 +00:00
note_changeset = Object.changeset_for_creating(note)
{:ok, object} = Repo.insert(note_changeset)
2019-10-06 23:41:18 +00:00
2020-04-21 02:40:48 +00:00
create = ActivityPub.create(note)
create_changeset = Activity.changeset_for_creating(create, true)
{:ok, activity} = Repo.insert(create_changeset)
2019-10-06 23:41:18 +00:00
2020-04-20 23:16:02 +00:00
%{id: activity.id, actor_id: current_user.actor.id}
|> Clacks.Worker.Federate.new()
|> Oban.insert()
2019-10-06 23:41:18 +00:00
path = Map.get(params, "continue", Routes.frontend_path(Endpoint, :status, activity.id))
redirect(conn, to: path)
end
2020-04-23 02:54:46 +00:00
defp note_for_posting(current_user, %{"content" => content, "in_reply_to" => in_reply_to_ap_id}) do
with %Activity{data: %{"context" => context, "actor" => in_reply_to_actor}} <-
Activity.get_by_ap_id(in_reply_to_ap_id) do
to = [in_reply_to_actor, @public]
# todo: followers
cc = []
ActivityPub.note(
current_user.actor.ap_id,
content,
context,
in_reply_to_ap_id,
nil,
DateTime.utc_now(),
to,
cc
)
else
_ ->
ActivityPub.note(current_user.actor.ap_id, content)
end
end
defp note_for_posting(current_user, %{"content" => content}) do
ActivityPub.note(current_user.actor.ap_id, content)
end
2019-10-06 23:41:18 +00:00
end