Upload and download files

import os
from urllib.parse import quote
import requests

sid = os.environ["TILION_SESSION_ID"]
local = os.environ["UPLOAD_FILE"]
name = os.path.basename(local)

with open(local, "rb") as body:
    response = requests.put(
        f"https://back.tilion.dev/v1/session/{sid}/files/{quote(name, safe='')}",
        headers={"Authorization": f"Bearer {os.environ['TILION_API_KEY']}"},
        data=body, timeout=600,
    )
response.raise_for_status()
print(response.json()["path"])

import { createReadStream, statSync } from "node:fs";
import { basename } from "node:path";
import { Readable } from "node:stream";

const local = process.env.UPLOAD_FILE;
const response = await fetch(
  `https://back.tilion.dev/v1/session/${process.env.TILION_SESSION_ID}/files/${encodeURIComponent(basename(local))}`,
  {
    method: "PUT",
    headers: {
      Authorization: `Bearer ${process.env.TILION_API_KEY}`,
      "Content-Length": String(statSync(local).size),
    },
    body: Readable.toWeb(createReadStream(local)),
    duplex: "half",
    signal: AbortSignal.timeout(600_000),
  },
);
if (!response.ok) throw new Error(await response.text());
console.log((await response.json()).path);

# Requires jq.
curl --fail-with-body --silent --show-error -T "$UPLOAD_FILE" \
  -H "Authorization: Bearer $TILION_API_KEY" \
  "https://back.tilion.dev/v1/session/$TILION_SESSION_ID/files/$(basename "$UPLOAD_FILE" | jq -sRr 'rtrimstr("\n") | @uri')" \
  | jq -r .path

import os
from playwright.sync_api import sync_playwright

with sync_playwright() as p:
    browser = p.chromium.connect_over_cdp(os.environ["CONNECT_URL"], timeout=60000)
    page = browser.contexts[0].pages[0]
    cdp = page.context.new_cdp_session(page)
    root = cdp.send("DOM.getDocument")["root"]["nodeId"]
    node = cdp.send("DOM.querySelector", {"nodeId": root, "selector": "input[type=file]"})
    cdp.send("DOM.setFileInputFiles", {
        "files": [os.environ["UPLOADED_PATH"]], "nodeId": node["nodeId"],
    })
    browser.close()

import { chromium } from "playwright-core";

const browser = await chromium.connectOverCDP(process.env.CONNECT_URL, { timeout: 60_000 });
const page = browser.contexts()[0].pages()[0];
const cdp = await page.context().newCDPSession(page);
const { root } = await cdp.send("DOM.getDocument");
const { nodeId } = await cdp.send("DOM.querySelector", {
  nodeId: root.nodeId, selector: "input[type=file]",
});
await cdp.send("DOM.setFileInputFiles", { files: [process.env.UPLOADED_PATH], nodeId });
await browser.close();

import os
import time
from urllib.parse import quote
import requests

base = f"https://back.tilion.dev/v1/session/{os.environ['TILION_SESSION_ID']}/downloads"
headers = {"Authorization": f"Bearer {os.environ['TILION_API_KEY']}"}

done = []
for _ in range(60):
    listing = requests.get(base, headers=headers, timeout=30)
    listing.raise_for_status()
    done = [f for f in listing.json()["files"] if not f["in_progress"]]
    if done:
        break
    time.sleep(2)
if not done:
    raise RuntimeError("no finished download")

name = done[0]["name"]
with requests.get(f"{base}/{quote(name, safe='/')}", headers=headers, stream=True, timeout=600) as response:
    response.raise_for_status()
    with open(os.path.basename(name), "wb") as out:
        for chunk in response.iter_content(1024 * 1024):
            out.write(chunk)
print("Saved", name)

import { createWriteStream } from "node:fs";
import { basename } from "node:path";
import { Readable } from "node:stream";
import { pipeline } from "node:stream/promises";
import { setTimeout as sleep } from "node:timers/promises";

const base = `https://back.tilion.dev/v1/session/${process.env.TILION_SESSION_ID}/downloads`;
const headers = { Authorization: `Bearer ${process.env.TILION_API_KEY}` };

let done = [];
for (let i = 0; i < 60 && done.length === 0; i++) {
  if (i > 0) await sleep(2000);
  const listing = await fetch(base, { headers, signal: AbortSignal.timeout(30_000) });
  if (!listing.ok) throw new Error(await listing.text());
  done = (await listing.json()).files.filter(file => !file.in_progress);
}
if (done.length === 0) throw new Error("no finished download");

const { name } = done[0];
const path = name.split("/").map(encodeURIComponent).join("/");
const response = await fetch(`${base}/${path}`, { headers, signal: AbortSignal.timeout(600_000) });
if (!response.ok) throw new Error(await response.text());
await pipeline(Readable.fromWeb(response.body), createWriteStream(basename(name)));
console.log("Saved", name);

# Requires jq. Repeat the list until a finished file appears.
BASE="https://back.tilion.dev/v1/session/$TILION_SESSION_ID/downloads"
NAME=$(curl --fail-with-body --silent --show-error "$BASE" \
  -H "Authorization: Bearer $TILION_API_KEY" \
  | jq -r '[.files[] | select(.in_progress | not)][0].name // empty')
NAME_PATH=$(printf %s "$NAME" | jq -sRr 'split("/") | map(@uri) | join("/")')
curl --fail-with-body -o "$(basename "$NAME")" "$BASE/$NAME_PATH" \
  -H "Authorization: Bearer $TILION_API_KEY"