클라우드 안드로이드 앱을 Dock 에

#!/usr/bin/env node
// 클라우드 안드로이드 앱을 Dock 에 — endue OS 샘플.
//   android 가상 기기를 띄우고 → 설치된 앱 목록에서 하나를 골라 그 기기의 앱으로 저장해 Dock 1단에도 고정하고
//   → 그 앱을 열고 → 화면을 저장한다.
//
//   node android-shortcut.mjs com.android.settings settings.png
//   ENDUE_OS_TOKEN=… ENDUE_OS_URL=… node …   운영 — endue 계정의 토큰
//   ANDROID_DEVICE_ID=res_… node …            가상 기기 대신 이미 연결한 폰(actual Device)을 쓴다 — 같은 방식으로 된다
import { writeFile } from 'node:fs/promises';

const [pkg = 'com.android.settings', out = 'android.png'] = process.argv.slice(2);
const BASE = (process.env.ENDUE_OS_URL ?? 'http://127.0.0.1:5173').replace(/\/+$/, '');
const API = `${BASE}/api/v1`;
const sleep = (ms) => new Promise((r) => setTimeout(r, ms));
const token =
  process.env.ENDUE_OS_TOKEN ??
  (await (await fetch(`${BASE}/idp/token?sub=${process.env.ENDUE_OS_SUB ?? `sample-${Date.now().toString(36)}`}&ttl=3600`, { method: 'POST' })).json()).access_token;

async function api(method, path, body, { raw = false } = {}) {
  const res = await fetch(`${API}${path}`, {
    method,
    headers: { Authorization: `Bearer ${token}`, ...(body ? { 'Content-Type': 'application/json' } : {}) },
    body: body ? JSON.stringify(body) : undefined,
  });
  if (raw) return res;
  const json = res.status === 204 ? null : await res.json();
  if (res.status === 402) throw new Error(`${method} ${path} → 402 ${json?.error?.code}: 크레딧이 부족해요 (잔액 ${json?.error?.details?.balance ?? '?'}). 충전한 뒤 다시 돌려 주세요.`);
  if (!res.ok) throw new Error(`${method} ${path} → ${res.status} ${json?.error?.code}`);
  return json?.data;
}

let stationId = process.env.STATION_ID;
let did = process.env.ANDROID_DEVICE_ID ?? process.env.ANDROID_RESOURCE_ID; // device_id 는 res_ 그대로다
// 이 스크립트가 만든 것만 끝에서 멈추고 지운다 — 이미 연결한 폰(ANDROID_DEVICE_ID)은 건드리지 않는다.
let createdDevice = null;
let createdStation = null;
if (!did) {
  if (!stationId) stationId = createdStation = (await api('POST', '/stations', { name: 'phone-lab' })).station_id;
}
try {
  if (!did) {
    // 에뮬레이터가 뜨는 데 몇 분 걸릴 수 있다. 가상 기기는 만들 때 Dock 1단에 붙는다.
    let device = (await api('POST', `/stations/${stationId}/devices`, { type: 'virtual', kind: 'android', name: 'pixel' })).device;
    createdDevice = device.device_id;
    const until = Date.now() + 420_000;
    while (!(device.compute_status === 'running' && device.online)) {
      if (device.compute_status === 'failed') throw new Error(device.status_reason);
      if (Date.now() > until) throw new Error('7분 안에 running 이 되지 않았다');
      await sleep(3000);
      device = await api('GET', `/devices/${device.device_id}`);
    }
    did = device.device_id;
    console.log(`android running — device ${did}`);
  } else {
    stationId ??= (await api('GET', `/devices/${did}`)).station_id;
  }

  // 설치된 앱은 OS 가 저장하지 않는다 — 에이전트에게 그때그때 묻는다 (명령 기록에 남지 않는다).
  const installed = await api('GET', `/devices/${did}/installed-apps`);
  console.log(`설치된 앱 ${installed.length}개: ${installed.slice(0, 6).map((a) => a.label).join(', ')} …`);
  const target = installed.find((a) => a.package === pkg) ?? installed[0];

  // 같은 기기의 같은 package 면 있는 앱을 돌려준다 — 몇 번을 돌려도 하나.
  const app = await api('POST', `/devices/${did}/apps`, {
    package: target.package,
    label: target.label,
    pin_to_dock: true,
  });
  const dock = await api('GET', `/stations/${stationId}/dock`);
  console.log(`Dock: ${dock.items.map((i) => `${i.type}:${i.label}`).join(' | ')}`);

  const launched = await api('POST', `/apps/${app.app_id}/launch`);
  console.log(`${target.label} 열기 → ${launched.status}`);

  await sleep(1500);
  const shot = await api('GET', `/devices/${did}/screen?max_age_ms=500`, undefined, { raw: true });
  if (shot.status !== 200) throw new Error(`screen → ${shot.status}`);
  await writeFile(out, Buffer.from(await shot.arrayBuffer()));
  console.log(`${out} 저장`);
} finally {
  // 가상 기기는 켜져 있는 동안 크레딧을 쓴다 — 만든 것은 멈추고 지운다.
  if (createdDevice) {
    await api('POST', `/devices/${createdDevice}/stop`).catch(() => {});
    await api('DELETE', `/devices/${createdDevice}`).catch((e) => console.warn(String(e)));
  }
  if (createdStation) {
    for (let i = 0; i < 15 && !(await api('DELETE', `/stations/${createdStation}`).then(() => true, () => false)); i++) await sleep(2000);
  }
  if (createdDevice || createdStation) console.log('정리했다');
}