Ship data products
at warp speed.

# Terminal 1 — start with a local admin
export DOBASE_SECURITY_USERS_0_USERNAME="admin"
export DOBASE_SECURITY_USERS_0_PASSWORD="change-this-local-password"
export DOBASE_SECURITY_USERS_0_ROLES_0="ADMIN"
scripts/dev-dobase.sh

# Terminal 2 — authenticate the administrator once
BASE_URL="http://127.0.0.1:8888"
TOKEN=$(curl -fsS -X POST "$BASE_URL/generate-token" \
  -H "Content-Type: application/json" \
  -d '{"username":"admin","password":"change-this-local-password"}' | jq -er .token)
admin_api() {
  curl -fsS -H "Authorization: Bearer $TOKEN" \
    -H "Content-Type: application/json" "$@"
}

# Create a tenant boundary and issue a one-project credential
admin_api -X POST "$BASE_URL/organizations" \
  -d '{"id":"acme","name":"Acme"}'
admin_api -X POST "$BASE_URL/projects" \
  -d '{"id":"demo","organizationId":"acme","name":"Demo"}'
API_KEY=$(admin_api -X POST "$BASE_URL/projects/demo/api-keys" \
  -d '{"name":"Local app","roles":["ADMIN"]}' | jq -er .key)
api() {
  curl -fsS -H "X-API-Key: $API_KEY" \
    -H "Content-Type: application/json" "$@"
}

# Create project-owned data with typed collection metadata
api -X POST "$BASE_URL/db/create-database/perfdb" -d '{}'
api -X POST "$BASE_URL/db/perfdb/create-collection/events" \
  -d '[{"fieldName":"type","fieldType":"STRING","encrypted":false},{"fieldName":"userId","fieldType":"STRING","encrypted":false}]'
api -X POST "$BASE_URL/db/perfdb/events/insert" \
  -d '{"id":"evt-1001","type":"click","userId":"u-91"}'

# Queue the update, wait, then read the document
JOB_ID=$(api -X POST "$BASE_URL/queues/writes/jobs" \
  -d '{"operation":"DATABASE_UPDATE","database":"perfdb","collection":"events","documentId":"evt-1001","payload":{"id":"evt-1001","type":"processed","userId":"u-91"},"idempotencyKey":"process-evt-1001","maxAttempts":5}' | jq -er .job.id)

STATUS=""
for _ in {1..50}; do
  STATUS=$(api "$BASE_URL/queues/jobs/$JOB_ID" | jq -er .job.status)
  case "$STATUS" in
    SUCCEEDED) break ;;
    DEAD_LETTER|CANCELLED) echo "Job $STATUS" >&2; exit 1 ;;
  esac
  sleep 0.2
done
[ "$STATUS" = "SUCCEEDED" ] || { echo "Job timed out" >&2; exit 1; }
api "$BASE_URL/db/perfdb/events/find-by-id/evt-1001"