File

const SHEET_ID = '14ju5aOdkcn_y3xwGbXrM9Irh2Br5_HqAr7L8Nv5mmbw';

const SHARED_KEY = '__PHONE_OPERATOR_BRIDGE_KEY__';

const COMMANDS = 'commands';

const RESULTS = 'results';

const STATE = 'state';

function out_(obj) {

  return ContentService.createTextOutput(JSON.stringify(obj))

    .setMimeType(ContentService.MimeType.JSON);

}

function now_() {

  return new Date().toISOString();

}

function auth_(key) {

  return typeof key === 'string' && key === SHARED_KEY;

}

function doGet(e) {

  const p = (e && e.parameter) || {};

  if (!auth_(p.key)) return out_({ok:false,error:'unauthorized'});

  const op = String(p.op || 'health');

  if (op === 'health') {

    return out_({ok:true,bridge:'PHONE-OPERATOR-BRIDGE-1',time:now_()});

  }

  if (op === 'poll') {

    const deviceId = String(p.device_id || '');

    if (!deviceId) return out_({ok:false,error:'device_id_required'});

    return claimNext_(deviceId);

  }

  return out_({ok:false,error:'unsupported_op'});

}

function doPost(e) {

  let body = {};

  try {

    body = JSON.parse((e && e.postData && e.postData.contents) || '{}');

  } catch (err) {

    return out_({ok:false,error:'invalid_json'});

  }

  if (!auth_(body.key)) return out_({ok:false,error:'unauthorized'});

  const op = String(body.op || '');

  if (op === 'result') return acceptResult_(body);

  if (op === 'heartbeat') return heartbeat_(body);

  return out_({ok:false,error:'unsupported_op'});

}

function claimNext_(deviceId) {

  const lock = LockService.getScriptLock();

  if (!lock.tryLock(5000)) return out_({ok:false,error:'busy'});

  try {

    const ss = SpreadsheetApp.openById(SHEET_ID);

    const sh = ss.getSheetByName(COMMANDS);

    if (!sh) return out_({ok:false,error:'commands_sheet_missing'});

    const last = sh.getLastRow();

    if (last < 2) return out_({ok:true,command:null});

    const values = sh.getRange(2, 1, last - 1, 12).getValues();

    const nowMs = Date.now();

    for (let i = 0; i < values.length; i++) {

      const r = values[i];

      const commandId = String(r[0] || '');

      const createdAt = String(r[1] || '');

      const action = String(r[2] || '');

      const payload = String(r[3] || '{}');

      const status = String(r[4] || '');

      const ttl = Number(r[9] || 0);

      if (!commandId || status !== 'pending') continue;

      if (ttl > 0 && createdAt) {

        const createdMs = Date.parse(createdAt);

        if (!isNaN(createdMs) && nowMs - createdMs > ttl * 1000) {

          sh.getRange(i + 2, 5).setValue('expired');

          sh.getRange(i + 2, 7).setValue(now_());

          sh.getRange(i + 2, 9).setValue('ttl_expired');

          continue;

        }

      }

      sh.getRange(i + 2, 5).setValue('running');

      sh.getRange(i + 2, 6).setValue(now_());

      return out_({ok:true,command:{command_id:commandId,action:action,payload_json:payload,claimed_by:deviceId}});

    }

    return out_({ok:true,command:null});

  } finally {

    lock.releaseLock();

  }

}

function acceptResult_(body) {

  const commandId = String(body.command_id || '');

  const deviceId = String(body.device_id || '');

  if (!commandId || !deviceId) return out_({ok:false,error:'command_id_and_device_id_required'});

  const status = String(body.status || 'done');

  const resultObj = body.result === undefined ? null : body.result;

  const error = String(body.error || '');

  const durationMs = Number(body.duration_ms || 0);

  const artifactRef = String(body.artifact_ref || '');

  const resultSha = String(body.result_sha256 || '');

  const resultId = Utilities.getUuid();

  const lock = LockService.getScriptLock();

  if (!lock.tryLock(5000)) return out_({ok:false,error:'busy'});

  try {

    const ss = SpreadsheetApp.openById(SHEET_ID);

    const results = ss.getSheetByName(RESULTS);

    const commands = ss.getSheetByName(COMMANDS);

    if (!results || !commands) return out_({ok:false,error:'sheet_missing'});

    results.appendRow([resultId,commandId,now_(),status,JSON.stringify(resultObj),error,durationMs,artifactRef,resultSha,deviceId]);

    const hintedRow = Number(body.command_row || 0);

    let row = hintedRow >= 2 && hintedRow <= commands.getMaxRows() ? hintedRow : 0;

    if (row && String(commands.getRange(row, 1).getValue() || '') !== commandId) row = 0;

    if (!row) {

      const last = commands.getLastRow();

      const ids = last >= 2 ? commands.getRange(2, 1, last - 1, 1).getValues() : [];

      for (let i = 0; i < ids.length; i++) {

        if (String(ids[i][0] || '') === commandId) { row = i + 2; break; }

      }

    }

    if (row) {

      commands.getRange(row, 5).setValue(status);

      commands.getRange(row, 7).setValue(now_());

      commands.getRange(row, 8).setValue(resultId);

      commands.getRange(row, 9).setValue(error);

    }

    return out_({ok:true,result_id:resultId});

  } finally {

    lock.releaseLock();

  }

}

function heartbeat_(body) {

  const deviceId = String(body.device_id || '');

  if (!deviceId) return out_({ok:false,error:'device_id_required'});

  const ss = SpreadsheetApp.openById(SHEET_ID);

  const sh = ss.getSheetByName(STATE);

  if (!sh) return out_({ok:false,error:'state_sheet_missing'});

  const key = 'device:' + deviceId + ':heartbeat';

  const value = JSON.stringify({time:now_(),app_version:String(body.app_version || ''),bridge_version:String(body.bridge_version || ''),battery:String(body.battery || ''),note:String(body.note || '')});

  const last = sh.getLastRow();

  if (last >= 2) {

    const keys = sh.getRange(2, 1, last - 1, 1).getValues();

    for (let i = 0; i < keys.length; i++) {

      if (String(keys[i][0] || '') === key) {

        sh.getRange(i + 2, 2, 1, 3).setValues([[value,now_(),'APK heartbeat']]);

        return out_({ok:true});

      }

    }

  }

  sh.appendRow([key,value,now_(),'APK heartbeat']);

  return out_({ok:true});

}