Uploads

import fs from "node:fs";

const form = new FormData();
form.append("file", new Blob([fs.readFileSync("./leads.csv")]), "leads.csv");
form.append("phone_column", "phone");

const res = await fetch("https://api.optimaldial.com/api/v1/uploads", {
  method: "POST",
  headers: { Authorization: `Bearer ${process.env.OPTIMALDIAL_API_KEY}` },
  body: form,
});
const upload = await res.json();

with open("leads.csv", "rb") as f:
    resp = requests.post(
        "https://api.optimaldial.com/api/v1/uploads",
        headers={"Authorization": f"Bearer {os.environ['OPTIMALDIAL_API_KEY']}"},
        files={"file": ("leads.csv", f, "text/csv")},
        data={"phone_column": "phone"},
    )
upload = resp.json()

const contacts = leads.map(l => ({
  phone: l.phone,
  first_name: l.firstName,
  list: "april",
}));

const res = await fetch("https://api.optimaldial.com/api/v1/uploads", {
  method: "POST",
  headers: {
    Authorization: `Bearer ${process.env.OPTIMALDIAL_API_KEY}`,
    "Content-Type": "application/json",
  },
  body: JSON.stringify({
    filename: "april-cohort.csv",
    contacts,
    phone_column: "phone",
  }),
});

contacts = [
    {"phone": l["phone"], "first_name": l["first_name"], "list": "april"}
    for l in leads
]
resp = requests.post(
    "https://api.optimaldial.com/api/v1/uploads",
    headers={
        "Authorization": f"Bearer {os.environ['OPTIMALDIAL_API_KEY']}",
        "Content-Type": "application/json",
    },
    json={
        "filename": "april-cohort.csv",
        "contacts": contacts,
        "phone_column": "phone",
    },
)

async function* allUploads() {
  let cursor: string | null = null;
  do {
    const url = new URL("https://api.optimaldial.com/api/v1/uploads");
    url.searchParams.set("limit", "100");
    if (cursor) url.searchParams.set("cursor", cursor);

    const res = await fetch(url, {
      headers: { Authorization: `Bearer ${process.env.OPTIMALDIAL_API_KEY}` },
    });
    const page = await res.json();
    yield* page.data;
    cursor = page.next_cursor;
  } while (cursor);
}

def all_uploads():
    cursor = None
    while True:
        params = {"limit": 100}
        if cursor:
            params["cursor"] = cursor
        resp = requests.get(
            "https://api.optimaldial.com/api/v1/uploads",
            headers={"Authorization": f"Bearer {os.environ['OPTIMALDIAL_API_KEY']}"},
            params=params,
        )
        page = resp.json()
        yield from page["data"]
        cursor = page.get("next_cursor")
        if not cursor:
            return

const res = await fetch(
  `https://api.optimaldial.com/api/v1/uploads/${uploadId}`,
  { headers: { Authorization: `Bearer ${process.env.OPTIMALDIAL_API_KEY}` } },
);
const upload = await res.json();

resp = requests.get(
    f"https://api.optimaldial.com/api/v1/uploads/{upload_id}",
    headers={"Authorization": f"Bearer {os.environ['OPTIMALDIAL_API_KEY']}"},
)
upload = resp.json()

const meta = await fetch(
  `https://api.optimaldial.com/api/v1/uploads/${uploadId}/download/processed`,
  { headers: { Authorization: `Bearer ${process.env.OPTIMALDIAL_API_KEY}` } },
).then(r => r.json());

const file = await fetch(meta.download_url);
await fs.promises.writeFile("processed.csv", Buffer.from(await file.arrayBuffer()));

meta = requests.get(
    f"https://api.optimaldial.com/api/v1/uploads/{upload_id}/download/processed",
    headers={"Authorization": f"Bearer {os.environ['OPTIMALDIAL_API_KEY']}"},
).json()

with requests.get(meta["download_url"], stream=True) as r:
    r.raise_for_status()
    with open("processed.csv", "wb") as f:
        for chunk in r.iter_content(chunk_size=64 * 1024):
            f.write(chunk)