message_poll.php - master - streamlive/streamlivev12

message_poll.php

32 строки2 KB

TwixoffStudio

Create: streamtok.php, user_search.php, services.php, short_like.php, shorts.php, sitemap.xml.php, README.md, robots.txt, rss_channels.php, rss_forum.php, new_channel.php, news.php, now_playing.php, playerjs.js, profile.php, message_poll.php, message_send.php, messages.php, N8C42w.js, favorites.php, forum.php, forum_category.php, forum_new_thread.php, forum_thread.php, index.php, diagnose.php, docs.php, embed.php, embedstreamtok.php, check_stream_live.php, comment_add.php, comment_delete.php, dashboard.php, developers.php, channel_manage.php, chat_ban.php, chat_delete.php, chat_poll.php, chat_send.php, channel.php, channel_favorite.php, channel_like.php, channel-pc.php, broadcast_channel.php, broadcast_channels.php, broadcast_post_poll.php, broadcast_post_send.php, catalog.php, channel-full.php, antibot_challenge.php, antibot_challenge_view.php, antibot_image.svg.php, antibot_verify.php, smotrim.php, stats.php, sticker_packs.php, cookies.php, privacy.php, terms.php, ai_client.php, antibot.php, auth.php, bbcode.php, bbcode_toolbar.php, db.php, embed_helper.php, footer.php, functions.php, geo.php, header.php, migrations.php, mini_player.php, oauth.php, rss.php, stats.php, totp.php, fix_charset.sql, 001_add_comments.sql, 002_add_forum.sql, 003_add_features.sql, 004_add_messaging.sql, 005_add_rtmp.sql, 006_add_antibot.sql, 007_add_broadcast_pause.sql, 008_add_broadcast_channels.sql, 009_add_channel_visibility.sql, 010_add_geo_and_verify.sql, 011_add_phone.sql, 012_add_stats.sql, 013_add_rss_forum_link.sql, 014_add_sticker_packs.sql, 015_add_oauth_provider.sql, 016_add_stream_status_cache.sql, schema.sql, authorize.php, token.php, userinfo.php, ai.php, channels.php, forum.php, index.php, moderation.php, oauth.php, rss.php, security.php, sources.php, update.php, users.php, _layout_end.php, _layout_start.php, style.css, 2fa_setup.php, 2fa_verify.php, add_phone.php, login.php, logout.php, oauth_callback.php, oauth_start.php, register.php

17 июл 2026, 09:31

Верифицирован

17 июл 2026, 09:312cd4bb2

<?php
require_once __DIR__ . '/includes/auth.php';
header('Content-Type: application/json');

$user = current_user();
if (!$user) { http_response_code(401); echo json_encode(['messages' => []]); exit; }

$convId = (int)($_GET['conversation_id'] ?? 0);
$after = (int)($_GET['after'] ?? 0);

$stmt = db()->prepare('SELECT id FROM conversations WHERE id = ? AND (user_a_id = ? OR user_b_id = ?)');
$stmt->execute([$convId, $user['id'], $user['id']]);
if (!$stmt->fetch()) { echo json_encode(['messages' => []]); exit; }

$stmt = db()->prepare('SELECT id, sender_id, body FROM messages WHERE conversation_id = ? AND id > ? AND is_deleted = 0 ORDER BY id ASC LIMIT 100');
$stmt->execute([$convId, $after]);
$rows = $stmt->fetchAll();

// Новые входящие сообщения от собеседника сразу помечаем прочитанными — раз мы их сейчас забираем поллингом,
// значит диалог открыт у нас на экране.
$incomingIds = [];
foreach ($rows as $r) { if ((int)$r['sender_id'] !== (int)$user['id']) $incomingIds[] = (int)$r['id']; }
if ($incomingIds) {
  $in = implode(',', array_fill(0, count($incomingIds), '?'));
  db()->prepare("UPDATE messages SET read_at = NOW() WHERE id IN ($in) AND read_at IS NULL")->execute($incomingIds);
}

$messages = array_map(function ($r) {
  return ['id' => (int)$r['id'], 'senderId' => (int)$r['sender_id'], 'body' => $r['body']];
}, $rows);

echo json_encode(['messages' => $messages]);