Monitoring and polling

# SW_PUBLIC_KEY, SW_SECRET_KEY and PROJECT set
API=${SW_VOD_API:-https://api-vod-express.syncwords.com/v1}

new_token() {
  TOKEN=$(curl -s "$API/token/create" -H 'Content-Type: application/json' -H 'Accept: application/json' \
    -d "$(jq -n --arg u "$SW_PUBLIC_KEY" --arg p "$SW_SECRET_KEY" '{username: $u, password: $p}')" \
    | jq -r .access_token)
}

new_token; RENEWED=1
while :; do
  STATUS=$(curl -s -o files.json -D headers.txt -w '%{http_code}' \
    -H "Authorization: Bearer $TOKEN" -H 'Accept: application/json' "$API/projects/$PROJECT/files")
  case $STATUS in
    401) [ -n "$RENEWED" ] && { echo "a new token is refused too: check the key pair"; exit 1; }
         new_token; RENEWED=1; continue ;;
    429) sleep "$(awk 'tolower($1)=="retry-after:" {print $2+0}' headers.txt)"; continue ;;
    200) RENEWED= ;;
    *) echo "HTTP $STATUS: $(cat files.json)"; exit 1 ;;
  esac
  echo "$(date +%T) $(jq -c .meta files.json)"
  jq -e '.meta.pending + .meta.processing == 0' files.json > /dev/null && break
  sleep 60
done
jq -r '.data[] | "\(.status)\t\(.name)"' files.json

import os
import time

import requests

API = os.environ.get("SW_VOD_API", "https://api-vod-express.syncwords.com/v1")
project = os.environ["PROJECT"]
token = None


def new_token():
    global token
    response = requests.post(
        API + "/token/create",
        json={"username": os.environ["SW_PUBLIC_KEY"], "password": os.environ["SW_SECRET_KEY"]},
        headers={"Accept": "application/json"},
    )
    response.raise_for_status()
    token = response.json()["access_token"]


def get(path):
    renewed = token is None
    if renewed:
        new_token()
    while True:
        response = requests.get(
            API + path, headers={"Authorization": f"Bearer {token}", "Accept": "application/json"}
        )
        if response.status_code == 401:
            if renewed:
                raise RuntimeError("a new token is refused too: check the key pair")
            new_token()
            renewed = True
        elif response.status_code == 429:
            time.sleep(int(response.headers.get("Retry-After", "5")))
        else:
            response.raise_for_status()
            return response.json()


while True:
    counts = get(f"/projects/{project}/files")["meta"]
    print(time.strftime("%X"), counts)
    if counts["pending"] + counts["processing"] == 0:
        break
    time.sleep(60)

const API = process.env.SW_VOD_API ?? 'https://api-vod-express.syncwords.com/v1';
const project = process.env.PROJECT;
const sleep = (seconds) => new Promise((resolve) => setTimeout(resolve, seconds * 1000));
let token;

async function newToken() {
  const response = await fetch(`${API}/token/create`, {
    method: 'POST',
    headers: { 'Content-Type': 'application/json', Accept: 'application/json' },
    body: JSON.stringify({ username: process.env.SW_PUBLIC_KEY, password: process.env.SW_SECRET_KEY }),
  });
  if (!response.ok) throw new Error(`token: ${response.status} ${await response.text()}`);
  token = (await response.json()).access_token;
}

async function get(path) {
  let renewed = !token;
  if (renewed) await newToken();
  for (;;) {
    const response = await fetch(API + path, {
      headers: { Authorization: `Bearer ${token}`, Accept: 'application/json' },
    });
    if (response.status === 401) {
      if (renewed) throw new Error('a new token is refused too: check the key pair');
      await newToken();
      renewed = true;
    } else if (response.status === 429) await sleep(Number(response.headers.get('retry-after') ?? 5));
    else if (!response.ok) throw new Error(`GET ${path}: ${response.status} ${await response.text()}`);
    else return response.json();
  }
}

for (;;) {
  const { meta: counts } = await get(`/projects/${project}/files`);
  console.log(new Date().toLocaleTimeString(), counts);
  if (counts.pending + counts.processing === 0) break;
  await sleep(60);
}