Exportações do resumo gerencial

curl -X POST https://api.muveya.com/v1/analytics/exports \
  -H "Authorization: Bearer $MUVEYA_API_KEY" \
  -H "Content-Type: application/json" \
  -H "Accept-Language: es" \
  -d '{"period": "weekly"}'

const response = await fetch("https://api.muveya.com/v1/analytics/exports", {
  method: "POST",
  headers: {
    Authorization: `Bearer ${process.env.MUVEYA_API_KEY}`,
    "Content-Type": "application/json",
    "Accept-Language": "es",
  },
  body: JSON.stringify({ period: "weekly" }),
});
const job = await response.json();
console.log(response.status, job.exportId, job.status);

import os
import requests

response = requests.post(
    "https://api.muveya.com/v1/analytics/exports",
    headers={
        "Authorization": f"Bearer {os.environ['MUVEYA_API_KEY']}",
        "Accept-Language": "es",
    },
    json={"period": "weekly"},
    timeout=30,
)
job = response.json()
print(response.status_code, job["exportId"], job["status"])

curl -s -o management-briefing-weekly.csv "$DOWNLOAD_URL"
sha256sum management-briefing-weekly.csv
# The first value must equal the checksum field

import { createHash } from "node:crypto";
import { writeFile } from "node:fs/promises";

const file = Buffer.from(await (await fetch(job.downloadUrl)).arrayBuffer());
const sha256 = createHash("sha256").update(file).digest("hex");
if (sha256 !== job.checksum || file.length !== job.byteSize) {
  throw new Error("Export download is incomplete; download it again");
}
await writeFile("management-briefing-weekly.csv", file);

import hashlib
import requests

file = requests.get(job["downloadUrl"], timeout=60).content
if hashlib.sha256(file).hexdigest() != job["checksum"] or len(file) != job["byteSize"]:
    raise RuntimeError("Export download is incomplete; download it again")
with open("management-briefing-weekly.csv", "wb") as handle:
    handle.write(file)

import { createHash } from "node:crypto";
import { writeFile } from "node:fs/promises";

const BASE_URL = "https://api.muveya.com";
const auth = { Authorization: `Bearer ${process.env.MUVEYA_API_KEY}` };
const sleep = (ms) => new Promise((resolve) => setTimeout(resolve, ms));

async function exportBriefing(period = "weekly", language = "en") {
  const created = await fetch(`${BASE_URL}/v1/analytics/exports`, {
    method: "POST",
    headers: { ...auth, "Content-Type": "application/json", "Accept-Language": language },
    body: JSON.stringify({ period }),
  });
  if (created.status !== 202) throw new Error(`Export request failed: ${created.status}`);
  let job = await created.json();

  for (let attempt = 0; attempt < 100 && job.status !== "ready"; attempt += 1) {
    if (job.status === "failed") throw new Error(`Export failed: ${job.error}`);
    await sleep(3000);
    const polled = await fetch(`${BASE_URL}/v1/analytics/exports/${job.exportId}`, { headers: auth });
    if (polled.status === 429) {
      await sleep(Number(polled.headers.get("retry-after") ?? "1") * 1000);
      continue;
    }
    if (!polled.ok) throw new Error(`Export poll failed: ${polled.status}`);
    job = await polled.json();
  }
  if (job.status !== "ready") throw new Error("Export is taking too long; poll it again later");

  const file = Buffer.from(await (await fetch(job.downloadUrl)).arrayBuffer());
  if (createHash("sha256").update(file).digest("hex") !== job.checksum) {
    throw new Error("Checksum mismatch; poll again for a fresh link and retry");
  }
  await writeFile(`management-briefing-${period}.csv`, file);
  return job;
}

console.log(await exportBriefing("weekly", "es"));

import hashlib
import os
import time
import requests

BASE_URL = "https://api.muveya.com"
session = requests.Session()
session.headers["Authorization"] = f"Bearer {os.environ['MUVEYA_API_KEY']}"

def export_briefing(period="weekly", language="en"):
    created = session.post(
        f"{BASE_URL}/v1/analytics/exports",
        json={"period": period},
        headers={"Accept-Language": language},
        timeout=30,
    )
    if created.status_code != 202:
        raise RuntimeError(f"Export request failed: {created.status_code}")
    job = created.json()

    for _ in range(100):
        if job["status"] == "ready":
            break
        if job["status"] == "failed":
            raise RuntimeError(f"Export failed: {job['error']}")
        time.sleep(3)
        polled = session.get(f"{BASE_URL}/v1/analytics/exports/{job['exportId']}", timeout=30)
        if polled.status_code == 429:
            time.sleep(int(polled.headers.get("Retry-After", "1")))
            continue
        polled.raise_for_status()
        job = polled.json()
    else:
        raise RuntimeError("Export is taking too long; poll it again later")

    file = requests.get(job["downloadUrl"], timeout=60).content
    if hashlib.sha256(file).hexdigest() != job["checksum"]:
        raise RuntimeError("Checksum mismatch; poll again for a fresh link and retry")
    with open(f"management-briefing-{period}.csv", "wb") as handle:
        handle.write(file)
    return job

print(export_briefing("weekly", "es"))