Review | CS | Patrolling | Monitoring

/**
 * Review | CS | Patrolling | Monitoring - Telegram Topic Photo Tracker
 * Timezone: Africa/Cairo (Daily reset at 00:00 Midnight Cairo Time)
 */
const TIMEZONE = 'Africa/Cairo';
const ALLOWED_TOPICS = ['CS', 'Patrolling', 'Reports', 'Splash'];

function setupSheets() {
  const ss = SpreadsheetApp.getActiveSpreadsheet();
  let logs = ss.getSheetByName('Logs');
  if (!logs) {
    logs = ss.insertSheet('Logs');
    logs.appendRow(['id', 'cairoDate', 'cairoTime', 'timestampIso', 'topic', 'displayName', 'username', 'userId', 'threadId']);
  }
  let roster = ss.getSheetByName('Roster');
  if (!roster) {
    roster = ss.insertSheet('Roster');
    roster.appendRow(['id', 'name', 'username', 'topic', 'shift']);
  }
  let topicMap = ss.getSheetByName('TopicMap');
  if (!topicMap) {
    topicMap = ss.insertSheet('TopicMap');
    topicMap.appendRow(['threadId', 'topicName']);
  }
  return { logs, roster, topicMap };
}

function getTopicMapDict(topicMapSheet) {
  const rows = topicMapSheet.getDataRange().getValues();
  const map = {};
  for (let i = 1; i < rows.length; i++) {
    if (rows[i][0] && rows[i][1]) map[String(rows[i][0])] = String(rows[i][1]);
  }
  return map;
}

function doPost(e) {
  const { logs, roster, topicMap } = setupSheets();
  try {
    const payload = JSON.parse(e.postData.contents);

    // 1. Handle Dashboard Roster Sync / Manual Entry POST
    if (payload.action === 'syncRoster' && Array.isArray(payload.roster)) {
      roster.clearContents();
      roster.appendRow(['id', 'name', 'username', 'topic', 'shift']);
      payload.roster.forEach(m => {
        roster.appendRow([m.id, m.name, m.username || '', m.topic, m.shift || '']);
      });
      return ContentService.createTextOutput(JSON.stringify({ ok: true })).setMimeType(ContentService.MimeType.JSON);
    }

    // 2. Handle Incoming Telegram Bot Webhook Update
    const msg = payload.message || payload.edited_message;
    if (!msg) return ContentService.createTextOutput('OK');

    const threadId = String(msg.message_thread_id || 'general');
    const from = msg.from || {};
    const displayName = [from.first_name || '', from.last_name || ''].join(' ').trim() || from.username || ('User_' + (from.id || 'unknown'));
    const username = from.username ? '@' + from.username : '';

    // Allow "/register Splash" or "/register@BotName Splash" inside each topic
    const rawText = (msg.text || msg.caption || '').trim();
    if (rawText.toLowerCase().startsWith('/register')) {
      const parts = rawText.split(/\s+/);
      const requestedTopic = parts.slice(1).join(' ');
      const matched = ALLOWED_TOPICS.find(t => requestedTopic.toLowerCase().includes(t.toLowerCase()));
      if (matched) {
        topicMap.appendRow([threadId, matched]);
        // Also ensure sender is added to Roster for this topic
        const rRows = roster.getDataRange().getValues();
        const exists = rRows.slice(1).some(r => String(r[3]) === matched && String(r[1]).toLowerCase() === displayName.toLowerCase());
        if (!exists) {
          roster.appendRow(['m_' + new Date().getTime(), displayName, username, matched, 'Registered via Bot']);
        }
      }
      return ContentService.createTextOutput('OK');
    }

    // Only count messages that contain a Photo (or image document)
    const isPhoto = Boolean(msg.photo && msg.photo.length > 0) || Boolean(msg.document && msg.document.mime_type && msg.document.mime_type.startsWith('image/'));
    if (!isPhoto) return ContentService.createTextOutput('OK');

    // Resolve Topic Name from threadId or forum_topic_created
    const mapDict = getTopicMapDict(topicMap);
    let topicName = mapDict[threadId] || '';
    if (!topicName && msg.reply_to_message && msg.reply_to_message.forum_topic_created) {
      const rawTitle = msg.reply_to_message.forum_topic_created.name || '';
      const found = ALLOWED_TOPICS.find(t => rawTitle.toLowerCase().includes(t.toLowerCase()));
      if (found) {
        topicName = found;
        topicMap.appendRow([threadId, found]);
      }
    }
    if (!topicName) topicName = 'CS'; // Fallback if unmapped

    // Convert timestamp to Cairo Time (Midnight 00:00 daily boundary)
    const msgDate = msg.date ? new Date(msg.date * 1000) : new Date();
    const cairoDate = Utilities.formatDate(msgDate, TIMEZONE, 'yyyy-MM-dd');
    const cairoTime = Utilities.formatDate(msgDate, TIMEZONE, 'HH:mm:ss');
    const id = 'tg_' + (msg.message_id || new Date().getTime());

    logs.appendRow([id, cairoDate, cairoTime, msgDate.toISOString(), topicName, displayName, username, String(from.id || ''), threadId]);
    return ContentService.createTextOutput('OK');
  } catch (err) {
    return ContentService.createTextOutput(JSON.stringify({ ok: false, error: String(err) })).setMimeType(ContentService.MimeType.JSON);
  }
}

function doGet(e) {
  const { logs, roster, topicMap } = setupSheets();
  const logRows = logs.getDataRange().getValues().slice(1).map(r => ({
    id: String(r[0]),
    cairoDate: Utilities.formatDate(new Date(r[1]), TIMEZONE, 'yyyy-MM-dd').slice(0, 10) || String(r[1]),
    cairoTime: String(r[2]),
    timestampIso: String(r[3]),
    topic: String(r[4]),
    displayName: String(r[5]),
    username: String(r[6]),
    userId: String(r[7]),
    threadId: String(r[8])
  }));
  const rosterRows = roster.getDataRange().getValues().slice(1).map(r => ({
    id: String(r[0]),
    name: String(r[1]),
    username: String(r[2]),
    topic: String(r[3]),
    shift: String(r[4])
  }));
  return ContentService.createTextOutput(JSON.stringify({
    ok: true,
    logs: logRows,
    roster: rosterRows,
    topicMap: getTopicMapDict(topicMap)
  })).setMimeType(ContentService.MimeType.JSON);
}