mirror of
git://f0xx.org/ac/ac-ms-issues
synced 2026-07-29 02:17:57 +03:00
115 lines
3.8 KiB
PHP
115 lines
3.8 KiB
PHP
<?php
|
|
declare(strict_types=1);
|
|
require_once __DIR__ . '/../../src/bootstrap.php';
|
|
|
|
header('Content-Type: application/json; charset=utf-8');
|
|
|
|
$method = strtoupper((string) ($_SERVER['REQUEST_METHOD'] ?? 'GET'));
|
|
$action = '';
|
|
$body = [];
|
|
|
|
if ($method === 'GET') {
|
|
$action = trim((string) ($_GET['action'] ?? 'active'));
|
|
} else {
|
|
$raw = file_get_contents('php://input') ?: '';
|
|
$body = json_decode($raw, true);
|
|
if (!is_array($body)) {
|
|
json_out(['ok' => false, 'error' => 'invalid_json'], 400);
|
|
}
|
|
$action = trim((string) ($body['action'] ?? ''));
|
|
}
|
|
|
|
$public = ($method === 'GET' && $action === 'session')
|
|
|| ($method === 'POST' && $action === 'join_event');
|
|
|
|
if ($method === 'POST' && in_array($action, ['create_intent', 'heartbeat'], true)) {
|
|
$platform = strtolower(trim((string) ($body['platform'] ?? '')));
|
|
if ($action === 'create_intent' && str_starts_with($platform, 'education')) {
|
|
$public = true;
|
|
}
|
|
if ($action === 'heartbeat') {
|
|
$sid = trim((string) ($body['session_id'] ?? ''));
|
|
if ($sid !== '') {
|
|
$existing = LiveCastRepository::sessionById($sid);
|
|
$existingPlatform = strtolower((string) ($existing['platform'] ?? ''));
|
|
if ($existing !== null && str_starts_with($existingPlatform, 'education')) {
|
|
$public = true;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
if (!$public) {
|
|
Auth::check();
|
|
}
|
|
$actor = Auth::user() ?? [];
|
|
|
|
if ($method === 'GET') {
|
|
if ($action === 'active') {
|
|
$platform = trim((string) ($_GET['platform'] ?? ''));
|
|
$rows = LiveCastRepository::activeSessions($actor, $platform !== '' ? $platform : null);
|
|
json_out(['ok' => true, 'sessions' => $rows]);
|
|
}
|
|
if ($action === 'analytics') {
|
|
$days = (int) ($_GET['days'] ?? 14);
|
|
$payload = LiveCastRepository::analytics($days, $actor);
|
|
json_out(['ok' => true, 'data' => $payload]);
|
|
}
|
|
if ($action === 'list') {
|
|
$days = (int) ($_GET['days'] ?? 14);
|
|
$limit = (int) ($_GET['limit'] ?? 200);
|
|
$rows = LiveCastRepository::listSessions($days, $actor, $limit);
|
|
json_out(['ok' => true, 'sessions' => $rows]);
|
|
}
|
|
if ($action === 'session') {
|
|
$sessionId = trim((string) ($_GET['session_id'] ?? ''));
|
|
if ($sessionId === '') {
|
|
json_out(['ok' => false, 'error' => 'missing_session_id'], 400);
|
|
}
|
|
$row = LiveCastRepository::publicSession($sessionId);
|
|
if ($row === null) {
|
|
json_out(['ok' => false, 'error' => 'not_found'], 404);
|
|
}
|
|
json_out(['ok' => true, 'session' => $row]);
|
|
}
|
|
json_out(['ok' => false, 'error' => 'unknown_action'], 400);
|
|
}
|
|
|
|
if ($method !== 'POST') {
|
|
json_out(['ok' => false, 'error' => 'method_not_allowed'], 405);
|
|
}
|
|
|
|
if ($action === 'create_intent') {
|
|
$row = LiveCastRepository::createIntent($body, $actor);
|
|
if ($row === []) {
|
|
json_out(['ok' => false, 'error' => 'create_failed'], 500);
|
|
}
|
|
json_out(['ok' => true, 'session' => $row]);
|
|
}
|
|
|
|
if ($action === 'heartbeat') {
|
|
$sessionId = trim((string) ($body['session_id'] ?? ''));
|
|
if ($sessionId === '') {
|
|
json_out(['ok' => false, 'error' => 'missing_session_id'], 400);
|
|
}
|
|
$row = LiveCastRepository::heartbeat($sessionId, $body, $actor);
|
|
if ($row === null) {
|
|
json_out(['ok' => false, 'error' => 'not_found'], 404);
|
|
}
|
|
json_out(['ok' => true, 'session' => $row]);
|
|
}
|
|
|
|
if ($action === 'join_event') {
|
|
$sessionId = trim((string) ($body['session_id'] ?? ''));
|
|
if ($sessionId === '') {
|
|
json_out(['ok' => false, 'error' => 'missing_session_id'], 400);
|
|
}
|
|
$ok = LiveCastRepository::registerJoin($sessionId, $body, $actor);
|
|
if (!$ok) {
|
|
json_out(['ok' => false, 'error' => 'not_found'], 404);
|
|
}
|
|
json_out(['ok' => true]);
|
|
}
|
|
|
|
json_out(['ok' => false, 'error' => 'unknown_action'], 400);
|