1 # Pleroma: A lightweight social networking server
2 # Copyright © 2017-2020 Pleroma Authors <https://pleroma.social/>
3 # SPDX-License-Identifier: AGPL-3.0-only
5 defmodule Pleroma.Web.FedSockets.IncomingHandler do
8 alias Pleroma.Web.FedSockets.FedRegistry
9 alias Pleroma.Web.FedSockets.FedSocket
10 alias Pleroma.Web.FedSockets.SocketInfo
12 import HTTPSignatures, only: [validate_conn: 1, split_signature: 1]
14 @behaviour :cowboy_websocket
16 def init(req, state) do
17 shake = FedSocket.shake()
19 with true <- Pleroma.Config.get([:fed_sockets, :enabled]),
20 sec_protocol <- :cowboy_req.header("sec-websocket-protocol", req, nil),
21 headers = %{"(request-target)" => ^shake} <- :cowboy_req.headers(req),
22 true <- validate_conn(%{req_headers: headers}),
23 %{"keyId" => origin} <- split_signature(headers["signature"]) do
25 if is_nil(sec_protocol) do
28 :cowboy_req.set_resp_header("sec-websocket-protocol", sec_protocol, req)
31 {:cowboy_websocket, req, %{origin: origin}, %{}}
38 def websocket_init(%{origin: origin}) do
39 case FedRegistry.add_fed_socket(origin) do
44 Logger.error("FedSocket websocket_init failed - #{inspect(e)}")
49 # Use the ping to check if the connection should be expired
50 def websocket_handle(:ping, socket_info) do
51 if SocketInfo.expired?(socket_info) do
54 {:ok, socket_info, :hibernate}
58 def websocket_handle({:text, data}, socket_info) do
59 socket_info = SocketInfo.touch(socket_info)
61 case FedSocket.receive_package(socket_info, data) do
66 {:reply, {:text, Jason.encode!(reply)}, socket_info}
69 Logger.error("incoming error - receive_package: #{inspect(reason)}")
74 def websocket_info({:send, message}, socket_info) do
75 socket_info = SocketInfo.touch(socket_info)
77 {:reply, {:text, message}, socket_info}
80 def websocket_info(:close, state) do
84 def websocket_info(message, state) do
85 Logger.debug("#{__MODULE__} unknown message #{inspect(message)}")