Install an APK

#!/usr/bin/env bash
set -euo pipefail
API=https://akaphone.abhgnx-417.workers.dev
AUTH="Authorization: Bearer $AKAPHONE_API_KEY"
FILE=${1:-app-release.apk}
DEVICE_ID=$2
SIZE=$(wc -c < "$FILE" | tr -d ' ')

UP=$(curl -sf -X POST "$API/v1/uploads" -H "$AUTH" -H "Content-Type: application/json" \
  -d "{\"filename\": \"$(basename "$FILE")\", \"size_bytes\": $SIZE}")
UPLOAD_ID=$(echo "$UP" | jq -r .upload.id)
PUT_URL=$(echo "$UP" | jq -r .put_url)
CTYPE=$(echo "$UP" | jq -r '.headers["content-type"]')

curl -sf -X PUT "$PUT_URL" -H "Content-Type: $CTYPE" --data-binary @"$FILE"
curl -sf -X POST "$API/v1/uploads/$UPLOAD_ID/complete" -H "$AUTH" > /dev/null
INSTALL_ID=$(curl -sf -X POST "$API/v1/devices/$DEVICE_ID/apps" -H "$AUTH" -H "Content-Type: application/json" \
  -d "{\"upload_id\": \"$UPLOAD_ID\"}" | jq -r .install_id)

for i in $(seq 1 100); do
  STATUS=$(curl -sf "$API/v1/devices/$DEVICE_ID/apps/$INSTALL_ID" -H "$AUTH" | jq -r .status)
  [ "$STATUS" != pending ] && break
  sleep 3
done
echo "install: $STATUS"
[ "$STATUS" = installed ]

import { readFile } from "node:fs/promises";
import { basename } from "node:path";

const API = "https://akaphone.abhgnx-417.workers.dev";
const auth = { Authorization: `Bearer ${process.env.AKAPHONE_API_KEY}` };

async function installApk(path: string, deviceId: string) {
  const bytes = await readFile(path);
  const up = await fetch(`${API}/v1/uploads`, {
    method: "POST",
    headers: { ...auth, "Content-Type": "application/json" },
    body: JSON.stringify({ filename: basename(path), size_bytes: bytes.length }),
  }).then((r) => r.json());

  const put = await fetch(up.put_url, { method: "PUT", headers: up.headers, body: bytes });
  if (!put.ok) throw new Error(`upload failed: ${put.status}`);

  await fetch(`${API}/v1/uploads/${up.upload.id}/complete`, { method: "POST", headers: auth });
  const res = await fetch(`${API}/v1/devices/${deviceId}/apps`, {
    method: "POST",
    headers: { ...auth, "Content-Type": "application/json" },
    body: JSON.stringify({ upload_id: up.upload.id }),
  });
  const { install_id } = await res.json();

  for (let i = 0; i < 100; i++) {
    const inst = await fetch(`${API}/v1/devices/${deviceId}/apps/${install_id}`, { headers: auth }).then((r) => r.json());
    if (inst.status !== "pending") return inst; // { status: "installed" | "failed", package?, error? }
    await new Promise((r) => setTimeout(r, 3000));
  }
  throw new Error("install still pending");
}

import os, time, requests

API = "https://akaphone.abhgnx-417.workers.dev"
AUTH = {"Authorization": f"Bearer {os.environ['AKAPHONE_API_KEY']}"}

def install_apk(path: str, device_id: str) -> dict:
    size = os.path.getsize(path)
    up = requests.post(f"{API}/v1/uploads", headers=AUTH,
                       json={"filename": os.path.basename(path), "size_bytes": size}).json()
    with open(path, "rb") as f:
        requests.put(up["put_url"], headers=up["headers"], data=f).raise_for_status()
    requests.post(f"{API}/v1/uploads/{up['upload']['id']}/complete", headers=AUTH).raise_for_status()
    r = requests.post(f"{API}/v1/devices/{device_id}/apps", headers=AUTH,
                      json={"upload_id": up["upload"]["id"]})
    r.raise_for_status()
    install_id = r.json()["install_id"]
    for _ in range(100):
        inst = requests.get(f"{API}/v1/devices/{device_id}/apps/{install_id}", headers=AUTH).json()
        if inst["status"] != "pending":
            return inst  # {"status": "installed" | "failed", "package"?, "error"?}
        time.sleep(3)
    raise TimeoutError("install still pending")