openvk/Web/Presenters/MessengerPresenter.php
2020-08-01 14:29:22 +00:00

137 lines
4.3 KiB
PHP

<?php declare(strict_types=1);
namespace openvk\Web\Presenters;
use Chandler\Signaling\SignalManager;
use openvk\Web\Events\NewMessageEvent;
use openvk\Web\Models\Repositories\{Users, Clubs, Messages};
use openvk\Web\Models\Entities\{Message, Correspondence};
final class MessengerPresenter extends OpenVKPresenter
{
private $messages;
private $signaler;
function __construct(Messages $messages)
{
$this->messages = $messages;
$this->signaler = SignalManager::i();
parent::__construct();
}
private function getCorrespondent(int $id): object
{
if($id > 0)
return (new Users)->get($id);
else if($id < 0)
return (new Clubs)->get(abs($id));
else if($id === 0)
return $this->user->identity;
}
function renderIndex(): void
{
$this->assertUserLoggedIn();
if(isset($_GET["sel"]))
$this->pass("openvk!Messenger->app", $_GET["sel"]);
$page = $_GET["p"] ?? 1;
$correspondences = iterator_to_array($this->messages->getCorrespondencies($this->user->identity, $page));
$this->template->corresps = $correspondences;
}
function renderApp(int $sel): void
{
$this->assertUserLoggedIn();
$correspondent = $this->getCorrespondent($sel);
if(!$correspondent)
$this->notFound();
$this->template->selId = $sel;
$this->template->correspondent = $correspondent;
}
function renderEvents(int $randNum): void
{
$this->assertUserLoggedIn();
header("Content-Type: application/json");
$this->signaler->listen(function($event, $id) {
exit(json_encode([[
"UUID" => $id,
"event" => $event->getLongPoolSummary(),
]]));
}, $this->user->id);
}
function renderVKEvents(int $id): void
{
header("Content-Type: application/json");
if($this->queryParam("act") !== "a_check")
exit(header("HTTP/1.1 400 Bad Request"));
else if(!$this->queryParam("key"))
exit(header("HTTP/1.1 403 Forbidden"));
$key = $this->queryParam("key");
$payload = hex2bin(substr($key, 0, 16));
$signature = hex2bin(substr($key, 16));
if(($signature ^ ( ~CHANDLER_ROOT_CONF["security"]["secret"] | ((string) $id))) !== $payload) {
exit(json_encode([
"failed" => 3,
]));
}
$legacy = $this->queryParam("version") < 3;
$this->signaler->listen(function($event, $eId) use ($id) {
exit(json_encode([
"ts" => time(),
"updates" => [
$event->getVKAPISummary($id),
],
]));
}, $id);
}
function renderApiGetMessages(int $sel, int $lastMsg): void
{
$this->assertUserLoggedIn();
$correspondent = $this->getCorrespondent($sel);
if(!$correspondent)
$this->notFound();
$messages = [];
$correspondence = new Correspondence($this->user->identity, $correspondent);
foreach($correspondence->getMessages(1, $lastMsg === 0 ? null : $lastMsg) as $message)
$messages[] = $message->simplify();
header("Content-Type: application/json");
exit(json_encode($messages));
}
function renderApiWriteMessage(int $sel): void
{
$this->assertUserLoggedIn();
if(empty($this->postParam("content"))) {
header("HTTP/1.1 400 Bad Request");
exit("<b>Argument error</b>: param 'content' expected to be string, undefined given.");
}
$sel = $this->getCorrespondent($sel);
if($sel->getId() !== $this->user->id && $sel->getSubscriptionStatus($this->user->identity) !== 3)
exit(header("HTTP/1.1 403 Forbidden"));
$cor = new Correspondence($this->user->identity, $sel);
$msg = new Message;
$msg->setContent($this->postParam("content"));
$cor->sendMessage($msg);
header("HTTP/1.1 202 Accepted");
header("Content-Type: application/json");
exit(json_encode($msg->simplify()));
}
}