Object Detection and Identification (ODI)

curl --location "${API_BASE_URL}/api/tasking/v2/tasks" \
  --header "Content-Type: application/json" \
  --header "Accept: application/json, application/problem+json" \
  --header "Authorization: Bearer ${API_ACCESS_TOKEN}" \
  --data '{
    "acquisitionWindow": {
      "start": "2026-03-01T00:00:00Z",
      "end": "2026-03-02T00:00:00Z"
    },
    "contractID": "XXXXXXXX-XXXX-XXXX-XXXX-XXXXXXXXXXXX",
    "imagingMode": "SPOTLIGHT_EXTENDED_DWELL",
    "pointOfInterest": {
      "lat": 60.1699,
      "lon": 24.9384
    },
    "productTypes": ["GRD"],
    "derivativeProductTypes": ["ODI"]
  }'

import requests

task_payload = {
    "acquisitionWindow": {
        "start": "2026-03-01T00:00:00Z",
        "end": "2026-03-02T00:00:00Z"
    },
    "contractID": "XXXXXXXX-XXXX-XXXX-XXXX-XXXXXXXXXXXX",
    "imagingMode": "SPOTLIGHT_EXTENDED_DWELL",
    "pointOfInterest": {
        "lat": 60.1699,
        "lon": 24.9384
    },
    "productTypes": ["GRD"],
    "derivativeProductTypes": ["ODI"]
}

response = requests.post(
    f"{API_BASE_URL}/api/tasking/v2/tasks",
    headers={
        "Content-Type": "application/json",
        "Accept": "application/json, application/problem+json",
        "Authorization": f"Bearer {access_token}"
    },
    json=task_payload
)

task = response.json()
print(f"Task created: {task['id']}, status: {task['status']}")

const taskPayload = {
  acquisitionWindow: {
    start: "2026-03-01T00:00:00Z",
    end: "2026-03-02T00:00:00Z"
  },
  contractID: "XXXXXXXX-XXXX-XXXX-XXXX-XXXXXXXXXXXX",
  imagingMode: "SPOTLIGHT_EXTENDED_DWELL",
  pointOfInterest: {
    lat: 60.1699,
    lon: 24.9384
  },
  productTypes: ["GRD"],
  derivativeProductTypes: ["ODI"]
};

const response = await fetch(`${API_BASE_URL}/api/tasking/v2/tasks`, {
  method: "POST",
  headers: {
    "Content-Type": "application/json",
    "Accept": "application/json, application/problem+json",
    "Authorization": `Bearer ${accessToken}`
  },
  body: JSON.stringify(taskPayload)
});

const task = await response.json();
console.log(`Task created: ${task.id}, status: ${task.status}`);

curl --location "${API_BASE_URL}/api/tasking/v2/tasks/${taskID}" \
  --header "Accept: application/json, application/problem+json" \
  --header "Authorization: Bearer ${API_ACCESS_TOKEN}"

import time

while True:
    response = requests.get(
        f"{API_BASE_URL}/api/tasking/v2/tasks/{task_id}",
        headers={"Authorization": f"Bearer {access_token}"}
    )
    task = response.json()
    print(f"Status: {task['status']}")

    # Waiting for DONE is always safe. SLA-backed ODI is ready earlier, at
    # FULFILLED -- add "FULFILLED" here only to act on that earlier signal.
    if task["status"] in ["DONE", "FAILED", "REJECTED", "CANCELED"]:
        break

    time.sleep(30)

async function waitForCompletion(taskId) {
  // Waiting for DONE is always safe. SLA-backed ODI is ready earlier, at
  // FULFILLED -- add "FULFILLED" here only to act on that earlier signal.
  const terminalStates = ["DONE", "FAILED", "REJECTED", "CANCELED"];

  while (true) {
    const response = await fetch(
      `${API_BASE_URL}/api/tasking/v2/tasks/${taskId}`,
      { headers: { "Authorization": `Bearer ${accessToken}` } }
    );
    const task = await response.json();
    console.log(`Status: ${task.status}`);

    if (terminalStates.includes(task.status)) return task;

    await new Promise(resolve => setTimeout(resolve, 30000));
  }
}

curl --location "${API_BASE_URL}/api/tasking/v2/tasks/${taskID}/derivatives" \
  --header "Accept: application/json, application/problem+json" \
  --header "Authorization: Bearer ${API_ACCESS_TOKEN}"

response = requests.get(
    f"{API_BASE_URL}/api/tasking/v2/tasks/{task_id}/derivatives",
    headers={"Authorization": f"Bearer {access_token}"}
)

if response.status_code == 404:
    print("No derivatives available yet (task not DONE?)")
elif response.status_code == 200:
    print("All derivatives ready")
    derivatives = response.json()
    for derivative in derivatives["data"]:
        print(f"Type: {derivative['derivativeProductType']}")
        for asset in derivative.get("assets", []):
            print(f"  Download: {asset['href']}")

const response = await fetch(
  `${API_BASE_URL}/api/tasking/v2/tasks/${taskId}/derivatives`,
  { headers: { "Authorization": `Bearer ${accessToken}` } }
);

if (response.status === 404) {
  console.log("No derivatives available yet (task not DONE?)");
} else if (response.status === 200) {
  console.log("All derivatives ready");
  const derivatives = await response.json();
  for (const derivative of derivatives.data) {
    console.log(`Type: ${derivative.derivativeProductType}`);
    for (const asset of derivative.assets || []) {
      console.log(`  Download: ${asset.href}`);
    }
  }
}