File

"""Update the existing Phone Operator Apps Script deployment in one pass.

The script reads the already authenticated clasp OAuth cache, fetches the live

Apps Script source, applies small function-level changes, and updates the

existing deployment. No bridge or APK files are changed and no secret values

are written to this repository.

"""

from __future__ import annotations

import json

import re

import sys

import urllib.parse

import urllib.request

from pathlib import Path

SCRIPT_ID = "1IIxFOyACrloSR7X8BFq_vWZDh1xFaH9b19ndOs8geq4u0pcX_1UNY93V"

DEPLOYMENT_ID = "AKfycbw989WlNz87opQNE9gkcxKy2iVlQapXBjFhrDfQLOzj7bikZyeXSiOe-29wqxHvd9xt"

ROOT = "https://script.googleapis.com/v1"

DEFAULT_TTL_SECONDS = 120

POLL_FRESH_SECONDS = 45

def json_request(token: str, method: str, url: str, body: dict | None = None) -> dict:

    data = None if body is None else json.dumps(body).encode("utf-8")

    request = urllib.request.Request(

        url,

        data=data,

        method=method,

        headers={

            "Authorization": f"Bearer {token}",

            "Content-Type": "application/json; charset=utf-8",

        },

    )

    with urllib.request.urlopen(request, timeout=30) as response:

        return json.loads(response.read().decode("utf-8"))

def access_token() -> str:

    auth_file = Path.home() / ".clasprc.json"

    raw = json.loads(auth_file.read_text(encoding="utf-8"))

    token = raw["tokens"]["default"]

    body = urllib.parse.urlencode(

        {

            "client_id": token["client_id"],

            "client_secret": token["client_secret"],

            "refresh_token": token["refresh_token"],

            "grant_type": "refresh_token",

        }

    ).encode("ascii")

    request = urllib.request.Request(

        "https://oauth2.googleapis.com/token",

        data=body,

        method="POST",

        headers={"Content-Type": "application/x-www-form-urlencoded"},

    )

    with urllib.request.urlopen(request, timeout=30) as response:

        return json.loads(response.read().decode("utf-8"))["access_token"]

def replace_function(source: str, name: str, replacement: str) -> str:

    start_match = re.search(rf"(?m)^function {re.escape(name)}\s*\([^\n]*\)\s*\{{", source)

    if not start_match:

        raise RuntimeError(f"missing function: {name}")

    next_match = re.search(r"(?m)^function [A-Za-z0-9_]+\s*\(", source[start_match.end() :])

    end = start_match.end() + next_match.start() if next_match else len(source)

    return source[: start_match.start()] + replacement.rstrip() + "\n\n" + source[end:]

def patch_source(source: str) -> str:

    marker = "const STATE ="

    if marker not in source:

        raise RuntimeError("unexpected Apps Script source: STATE marker missing")

    missing_constants = []

    if not re.search(r"(?m)^const DEFAULT_TTL_SECONDS\s*=", source):

        missing_constants.append("const DEFAULT_TTL_SECONDS = 120;")

    if not re.search(r"(?m)^const POLL_FRESH_SECONDS\s*=", source):

        missing_constants.append("const POLL_FRESH_SECONDS = 45;")

    if missing_constants:

        source, count = re.subn(

            r"(?m)^function out_",

            "\n".join(missing_constants) + "\n\nfunction out_",

            source,

            count=1,

        )

        if count != 1:

            raise RuntimeError("unable to insert Apps Script constants before out_()")

    source = replace_function(

        source,

        "doGet",

        r'''function doGet(e) {

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

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

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

  try {

    if (op === 'health') return out_({ok:true,bridge:'PHONE-OPERATOR-BRIDGE-1',time:now_(),status:'READY'});

    if (op === 'status') return status_();

    if (op === 'self_test') return selfTest_();

    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'});

  } catch (err) {

    recordError_('HTTP_GET_' + op, err);

    return out_({ok:false,error:'server_error',operation:op});

  }

}''',

    )

    source = replace_function(

        source,

        "doPost",

        r'''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',status:'UNAUTHORIZED'});

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

  try {

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

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

    if (op === 'self_test') return selfTest_();

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

  } catch (err) {

    recordError_('HTTP_POST_' + op, err);

    return out_({ok:false,error:'server_error',operation:op});

  }

}''',

    )

    source = replace_function(

        source,

        "claimNext_",

        r'''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();

    const nowMs = Date.now();

    let expired = 0;

    let duplicate = 0;

    const seen = {};

    if (last >= 2) {

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

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

        const r = values[i];

        const row = i + 2;

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

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

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

        if (seen[commandId]) {

          sh.getRange(row, 5).setValue('expired');

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

          sh.getRange(row, 9).setValue('duplicate_command_id');

          duplicate++;

          continue;

        }

        seen[commandId] = true;

        const createdMs = Date.parse(String(r[1] || ''));

        const claimedMs = Date.parse(String(r[5] || ''));

        const ttl = Math.max(10, Number(r[9] || DEFAULT_TTL_SECONDS));

        const ageMs = status === 'running' && !isNaN(claimedMs) ? nowMs - claimedMs : nowMs - createdMs;

        const maxAgeMs = (status === 'running' ? ttl * 2 : ttl) * 1000;

        if (!isNaN(ageMs) && ageMs > maxAgeMs) {

          sh.getRange(row, 5).setValue('expired');

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

          sh.getRange(row, 9).setValue(status === 'running' ? 'lease_expired' : 'ttl_expired');

          expired++;

        }

      }

    }

    stateSet_('active_transport', 'HTTP', 'Phone Operator poll request');

    stateSet_('last_poll_ok', 'true', 'Command poll reached Apps Script');

    stateSet_('last_poll_at', now_(), 'Command poll');

    stateSet_('last_error', '', 'Poll healthy');

    stateSet_('last_device_id', deviceId, 'Latest polling device');

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

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

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

      const r = values[i];

      if (String(r[4] || '').toLowerCase() !== 'pending') continue;

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

      if (!commandId) continue;

      const row = i + 2;

      sh.getRange(row, 5).setValue('running');

      sh.getRange(row, 6).setValue(now_());

      stateSet_('last_command_id', commandId, 'Command claimed');

      return out_({ok:true,command:{row:row,command_id:commandId,action:String(r[2] || ''),payload_json:String(r[3] || '{}'),claimed_by:deviceId},expired:expired,duplicates:duplicate});

    }

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

  } finally {

    lock.releaseLock();

  }

}''',

    )

    source = replace_function(

        source,

        "acceptResult_",

        r'''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').toLowerCase() === 'done' ? 'done' : 'error';

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

  const error = String(body.error || '').slice(0, 4000);

  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);

    }

    stateSet_('active_transport', 'HTTP', 'Result received');

    stateSet_('last_result_post', now_(), 'Phone result received');

    stateSet_('last_command_id', commandId, 'Result command');

    stateSet_('last_error', status === 'done' ? '' : error, status === 'done' ? 'Command succeeded' : 'Command failed');

    return out_({ok:true,result_id:resultId,command_id:commandId,status:status,row:row});

  } finally {

    lock.releaseLock();

  }

}''',

    )

    source = replace_function(

        source,

        "heartbeat_",

        r'''function heartbeat_(body) {

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

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

  const current = stateMap_().values;

  const active = String(body.active_transport || current.active_transport || 'HTTP');

  const hasPollOk = Object.prototype.hasOwnProperty.call(body, 'last_poll_ok');

  const pollOk = hasPollOk

    ? String(body.last_poll_ok).toLowerCase() === 'true'

    : current.last_poll_ok === 'true';

  stateSet_('active_transport', active, 'Phone heartbeat');

  stateSet_('last_heartbeat_at', now_(), 'Phone heartbeat');

  stateSet_('last_device_id', deviceId, 'Heartbeat device');

  stateSet_('app_version', String(body.app_version || ''), 'Phone heartbeat');

  stateSet_('bridge_version', String(body.bridge_version || ''), 'Phone heartbeat');

  if (hasPollOk) stateSet_('last_poll_ok', pollOk ? 'true' : 'false', 'Phone heartbeat report');

  stateSet_('relay_status', pollOk ? (active.indexOf('DRIVE') >= 0 ? 'FALLBACK' : 'ONLINE') : 'DEGRADED', 'Derived from poll health');

  if (body.last_error) stateSet_('last_error', String(body.last_error).slice(0, 4000), 'Phone heartbeat error');

  return out_({ok:true,status:pollOk ? 'ONLINE' : 'DEGRADED',active_transport:active,updated_at:now_()});

}''',

    )

    insert_before = "function claimNext_"

    helpers = r'''function stateMap_() {

  const ss = SpreadsheetApp.openById(SHEET_ID);

  const sh = ss.getSheetByName(STATE);

  if (!sh) throw new Error('state_sheet_missing');

  const out = {};

  const last = sh.getLastRow();

  if (last >= 2) {

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

    rows.forEach(function(r) { if (String(r[0] || '')) out[String(r[0])] = String(r[1] || ''); });

  }

  return {sheet:sh,values:out};

}

function stateSet_(key, value, notes) {

  const x = stateMap_();

  const sh = x.sheet;

  const last = sh.getLastRow();

  if (last >= 2) {

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

    for (let i = 0; i < rows.length; i++) if (String(rows[i][0] || '') === key) {

      sh.getRange(i + 2, 2, 1, 3).setValues([[String(value || ''), now_(), String(notes || '')]]);

      return;

    }

  }

  sh.appendRow([key, String(value || ''), now_(), String(notes || '')]);

}

function recordError_(where, err) {

  try { stateSet_('last_error', where + ': ' + String(err && err.message ? err.message : err).slice(0, 4000), 'Apps Script diagnostic'); } catch (ignored) {}

}

function status_() {

  const x = stateMap_().values;

  const nowMs = Date.now();

  const pollMs = Date.parse(x.last_poll_at || '');

  const hbMs = Date.parse(x.last_heartbeat_at || '');

  const pollAge = isNaN(pollMs) ? null : Math.max(0, Math.round((nowMs - pollMs) / 1000));

  const hbAge = isNaN(hbMs) ? null : Math.max(0, Math.round((nowMs - hbMs) / 1000));

  const pollHealthy = pollAge !== null && pollAge <= POLL_FRESH_SECONDS && x.last_poll_ok === 'true';

  const fallback = String(x.active_transport || '').indexOf('DRIVE') >= 0;

  return out_({ok:true,status:pollHealthy ? (fallback ? 'FALLBACK' : 'ONLINE') : (x.last_error ? 'DEGRADED' : 'OFFLINE'),active_transport:x.active_transport || 'NONE',last_poll_ok:x.last_poll_ok === 'true',poll_age_seconds:pollAge,heartbeat_age_seconds:hbAge,last_command_id:x.last_command_id || '',last_result_post:x.last_result_post || '',last_error:x.last_error || '',device_id:x.last_device_id || '',app_version:x.app_version || '',bridge_version:x.bridge_version || '',updated_at:now_()});

}

function selfTest_() {

  const checks = {};

  try {

    const ss = SpreadsheetApp.openById(SHEET_ID);

    checks.spreadsheet_access = true;

    checks.commands_sheet = !!ss.getSheetByName(COMMANDS);

    checks.results_sheet = !!ss.getSheetByName(RESULTS);

    checks.state_sheet = !!ss.getSheetByName(STATE);

    checks.schema = checks.commands_sheet && checks.results_sheet && checks.state_sheet;

    checks.script_lock = true;

  } catch (err) {

    checks.spreadsheet_access = false;

    checks.error = String(err && err.message ? err.message : err).slice(0, 4000);

  }

  const ok = checks.spreadsheet_access && checks.schema;

  stateSet_('self_test', ok ? 'PASS' : 'FAIL', 'Apps Script self-test');

  return out_({ok:ok,status:ok ? 'READY' : 'ERROR',action:'self_test',checks:checks,updated_at:now_()});

}

'''

    if "function stateMap_()" not in source:

        source = source.replace(insert_before, helpers + insert_before, 1)

    return source

def main() -> int:

    token = access_token()

    content = json_request(token, "GET", f"{ROOT}/projects/{SCRIPT_ID}/content")

    files = content.get("files", [])

    code = next((item for item in files if item.get("name") == "Code"), None)

    manifest = next((item for item in files if item.get("name") == "appsscript"), None)

    if not code or not manifest:

        raise RuntimeError("live Apps Script project is missing Code or appsscript")

    original = code.get("source", "")

    updated = patch_source(original)

    if updated == original:

        raise RuntimeError("source patch made no change")

    json_request(

        token,

        "PUT",

        f"{ROOT}/projects/{SCRIPT_ID}/content",

        {"files": [manifest, {"name": "Code", "type": "SERVER_JS", "source": updated}]},

    )

    version = json_request(

        token,

        "POST",

        f"{ROOT}/projects/{SCRIPT_ID}/versions",

        {"description": "Phone Operator diagnostics, health gate, fallback telemetry and queue hygiene"},

    )

    version_number = int(version["versionNumber"])

    deployment = json_request(

        token,

        "PUT",

        f"{ROOT}/projects/{SCRIPT_ID}/deployments/{DEPLOYMENT_ID}",

        {

            "deploymentConfig": {

                "scriptId": SCRIPT_ID,

                "versionNumber": version_number,

                "manifestFileName": "appsscript",

                "description": "Phone Operator Bridge v1 - diagnostics and failover",

            }

        },

    )

    print(json.dumps({"ok": True, "version": version_number, "deployment_id": deployment.get("deploymentId", "")}, separators=(",", ":")))

    return 0

if __name__ == "__main__":

    try:

        raise SystemExit(main())

    except Exception as exc:

        print(f"ERROR={type(exc).__name__}: {exc}", file=sys.stderr)

        raise SystemExit(1)