from orbit_sdk import OrbitClient

client = OrbitClient.from_env()  # reads ORBIT_API_KEY

page = client.request(
    "GET",
    "/usage/cdr",
    params={
        "from": "2026-08-01T00:00:00Z",
        "until": "2026-08-02T00:00:00Z",
        "types": "message",
        "limit": "1000",
    },
)

for row in page["data"]:
    print(row["id"], row["type"], row["status"], row["price"])

params = {
    "from": "2026-08-01T00:00:00Z",
    "until": "2026-08-02T00:00:00Z",
    "limit": "1000",
}

rows = []
while True:
    page = client.request("GET", "/usage/cdr", params=params)
    rows.extend(page["data"])
    pagination = page["pagination"]
    if not pagination["has_more"]:
        break
    params["cursor"] = pagination["cursor"]

print(f"Fetched {len(rows)} records")

package main

import (
    "context"
    "fmt"
    "net/url"
    "os"

    "github.com/devotel/orbit-go/orbit"
)

func main() {
    client, err := orbit.NewClient(os.Getenv("ORBIT_API_KEY"))
    if err != nil {
        panic(err)
    }

    query := url.Values{
        "from":  {"2026-08-01T00:00:00Z"},
        "until": {"2026-08-02T00:00:00Z"},
        "types": {"message"},
        "limit": {"1000"},
    }

    var page map[string]any
    if err := client.Request(context.Background(), "GET", "/usage/cdr", query, nil, &page, ""); err != nil {
        panic(err)
    }
    fmt.Printf("Rows on page: %d\n", len(page["data"].([]any)))
}

require "orbit_sdk"

client = OrbitSdk::Client.from_env

page = client.request(
  "GET",
  "/usage/cdr",
  query: {
    "from" => "2026-08-01T00:00:00Z",
    "until" => "2026-08-02T00:00:00Z",
    "types" => "message",
    "limit" => "1000",
  }
)

page["data"].each do |row|
  puts "#{row["id"]} #{row["status"]} #{row["price"]}"
end

<?php
use Devotel\Orbit\OrbitClient;

$client = OrbitClient::fromEnv();

$page = $client->request(
    method: "GET",
    path: "/usage/cdr",
    query: [
        "from" => "2026-08-01T00:00:00Z",
        "until" => "2026-08-02T00:00:00Z",
        "types" => "message",
        "limit" => "1000",
    ],
);

foreach ($page["data"] as $row) {
    echo $row["id"] . " " . $row["status"] . " " . $row["price"] . PHP_EOL;
}

import { writeFileSync } from "node:fs";

const query = new URLSearchParams({
  types: "message",
  channels: "sms,whatsapp",
  filename: "august-usage",
});

const res = await fetch(
  `https://api.orbit.devotel.io/usage/cdr/export.csv?${query.toString()}`,
  {
    headers: { "X-API-Key": process.env.ORBIT_API_KEY! },
  }
);

if (!res.ok) {
  throw new Error(`Export failed: ${res.status} ${await res.text()}`);
}
if (res.headers.get("X-Export-Truncated") === "true") {
  console.warn(
    "Window exceeds 50,000 rows — narrow the window or drain it via /usage/cdr"
  );
}

// One pass over the body: buffer the stream first, then re-read the
// buffer as often as needed (a response body can only be consumed once).
const csv = Buffer.from(await res.arrayBuffer());
writeFileSync("august-usage.csv", csv);
console.log(
  `Saved august-usage.csv (${csv.toString("utf8").trim().split("\n").length - 1} rows)`
);