Social Media Scraping API.

const API_URL = "https://api.socq.ai";
const API_KEY = process.env.SOCQ_API_KEY;
const headers = {
  Authorization: `Bearer ${API_KEY}`,
  "Content-Type": "application/json"
};

async function request(path, options = {}) {
  const response = await fetch(`${API_URL}${path}`, {
    ...options,
    headers: { ...headers, ...options.headers }
  });

  if (!response.ok) {
    throw new Error(`SocQ API error ${response.status}: ${await response.text()}`);
  }
  return response.json();
}

async function run() {
  // 1. Submit an Instagram profile search
  const { data: task } = await request("/v1/instagram/search", {
    method: "POST",
    body: JSON.stringify({
      query: "sustainable travel",
      results_limit: 25
    })
  });

  // 2. Poll until the asynchronous task finishes
  let current = task;
  while (!["succeeded", "failed"].includes(current.status)) {
    await new Promise((resolve) => setTimeout(resolve, 2000));
    ({ data: current } = await request(`/v1/tasks/${task.task_id}`));
  }

  if (current.status === "failed") {
    throw new Error(current.error_message || "SocQ task failed");
  }

  // 3. Read normalized results (follow next_cursor for more)
  const { data: resultTask } = await request(
    `/v1/tasks/${task.task_id}?limit=50`
  );
  console.log(resultTask.results.items);
}

run().catch(console.error);