Upload audio for restoration, mastering, stems, or MIDI

import { readFile, writeFile } from "node:fs/promises";

const API_URL = "https://api.neuralanalog.com";
const API_KEY = process.env.NEURALANALOG_API_KEY;

async function waitForCompletion(objectType, objectId) {
  while (true) {
    const response = await fetch(`${API_URL}/status/${objectType}/${objectId}`, {
      headers: { "X-API-Key": API_KEY },
    });
    if (!response.ok) {
      throw new Error(`Status check failed with ${response.status}`);
    }

    const status = await response.json();
    if (status.is_failed) {
      throw new Error(status.error_message || `${objectType} processing failed`);
    }
    if (status.is_complete) {
      return status;
    }
    await new Promise((resolve) => setTimeout(resolve, 5000));
  }
}

const form = new FormData();
form.append(
  "audio",
  new Blob([await readFile("./my-audio.mp3")], { type: "audio/mpeg" }),
  "my-audio.mp3",
);
form.append("file_source", "from_file");

const requestResponse = await fetch(`${API_URL}/from-file`, {
  method: "POST",
  headers: { "X-API-Key": API_KEY },
  body: form,
});
if (!requestResponse.ok) {
  throw new Error(`Upload failed with ${requestResponse.status}`);
}

const result = await requestResponse.json();
const jobId = result["audio_id"];
const status = await waitForCompletion("audio", jobId);

const downloadResponse = await fetch(
  `${API_URL}/download/audio/${jobId}`,
  { headers: { "X-API-Key": API_KEY }, redirect: "follow" },
);
if (!downloadResponse.ok) {
  throw new Error(`Download failed with ${downloadResponse.status}`);
}
await writeFile("original.wav", Buffer.from(await downloadResponse.arrayBuffer()));