Start a Run

const API_TOKEN = process.env.NUNU_API_TOKEN;
const PROJECT_ID = process.env.NUNU_PROJECT_ID;
const BASE_URL = `https://nunu.ai/api/v1/project/${PROJECT_ID}`;

async function startAndWaitForTest(
  testId: string,
  deploymentConfigId: string
): Promise<any> {
  // Start the test
  const startResponse = await fetch(`${BASE_URL}/runs`, {
    method: "POST",
    headers: {
      "X-Api-Key": API_TOKEN,
      "Content-Type": "application/json",
    },
    body: JSON.stringify({
      multiplayer_test_id: testId,
      deployment_config_id: deploymentConfigId,
    }),
  });

  const startResult = await startResponse.json();

  if (!startResponse.ok) {
    throw new Error(`Failed to start test: ${startResult.error}`);
  }

  const jobId = startResult.job_ids[0];
  console.log(`Test started with job: ${jobId}`);

  // Poll job for completion
  while (true) {
    const jobResponse = await fetch(`${BASE_URL}/jobs/${jobId}`, {
      headers: { "X-Api-Key": API_TOKEN },
    });

    const job = await jobResponse.json();

    if (job.status === "COMPLETED") {
      const result = job.runs[0]?.result ?? "unknown";
      console.log(`Test completed with result: ${result}`);
      return job;
    }

    console.log(`Test still running... (status: ${job.status})`);
    await new Promise((resolve) => setTimeout(resolve, 30000));
  }
}

import requests
import os
import time

API_TOKEN = os.environ["NUNU_API_TOKEN"]
PROJECT_ID = os.environ["NUNU_PROJECT_ID"]
BASE_URL = f"https://nunu.ai/api/v1/project/{PROJECT_ID}"

def start_and_wait_for_test(test_id: str, deployment_config_id: str) -> dict:
    headers = {"X-Api-Key": API_TOKEN}

    # Start the test
    start_response = requests.post(
        f"{BASE_URL}/runs",
        headers={**headers, "Content-Type": "application/json"},
        json={
            "multiplayer_test_id": test_id,
            "deployment_config_id": deployment_config_id
        }
    )

    start_result = start_response.json()

    if not start_response.ok:
        raise Exception(f"Failed to start test: {start_result.get('error')}")

    job_id = start_result["job_ids"][0]
    print(f"Test started with job: {job_id}")

    # Poll job for completion
    while True:
        job_response = requests.get(f"{BASE_URL}/jobs/{job_id}", headers=headers)
        job = job_response.json()

        if job["status"] == "COMPLETED":
            result = job["runs"][0]["result"] if job.get("runs") else "unknown"
            print(f"Test completed with result: {result}")
            return job

        print(f"Test still running... (status: {job['status']})")
        time.sleep(30)

#!/bin/bash
set -e

API_TOKEN="${NUNU_API_TOKEN}"
TEST_ID="${NUNU_TEST_ID}"
DEPLOYMENT_ID="${NUNU_DEPLOYMENT_ID}"
PROJECT_ID="${NUNU_PROJECT_ID}"
BASE_URL="https://nunu.ai/api/v1/project/${PROJECT_ID}"

# Start the test
START_RESPONSE=$(curl -s -X POST "${BASE_URL}/runs" \
  -H "X-Api-Key: ${API_TOKEN}" \
  -H "Content-Type: application/json" \
  -d "{
    \"multiplayer_test_id\": \"${TEST_ID}\",
    \"deployment_config_id\": \"${DEPLOYMENT_ID}\"
  }")

JOB_ID=$(echo "$START_RESPONSE" | jq -r '.job_ids[0]')

if [ "$JOB_ID" == "null" ]; then
  echo "Failed to start test: $START_RESPONSE"
  exit 1
fi

echo "Test started with job: $JOB_ID"

# Poll job for completion
while true; do
  JOB=$(curl -s "${BASE_URL}/jobs/${JOB_ID}" \
    -H "X-Api-Key: ${API_TOKEN}")

  STATUS=$(echo "$JOB" | jq -r '.status')

  if [ "$STATUS" == "COMPLETED" ]; then
    RESULT=$(echo "$JOB" | jq -r '.runs[0].result')
    echo "Test completed with result: $RESULT"
    [ "$RESULT" != "SUCCESS" ] && exit 1
    exit 0
  fi

  echo "Test running... (status: $STATUS)"
  sleep 30
done