Refresh, then automate the post you just published

const API = "https://api.indm.social/v1";
const headers = {
  Authorization: `Bearer ${process.env.INDM_API_KEY}`,
  "Content-Type": "application/json",
};
const sleep = (ms) => new Promise((r) => setTimeout(r, ms));

async function call(method, path, body) {
  const res = await fetch(API + path, {
    method,
    headers,
    body: body ? JSON.stringify(body) : undefined,
  });
  const json = await res.json();
  if (!res.ok) throw new Error(`${json.error.code}: ${json.error.message}`);
  return { status: res.status, json };
}

async function findPost(accountId, permalink) {
  const { json } = await call("GET", `/media?account_id=${accountId}&limit=10`);
  return json.data.find((m) => m.permalink === permalink);
}

async function refreshAndWait(accountId) {
  const { status, json } = await call("POST", `/accounts/${accountId}/refresh`);
  if (status === 200) return json.status; // "already_current"
  for (let i = 0; i < 60; i++) {
    await sleep(3000);
    const job = await call("GET", `/accounts/${accountId}/refresh/${json.job_id}`);
    if (!["pending", "running"].includes(job.json.status)) return job.json.status;
  }
  return "running";
}

export async function automateNewPost({ accountId, permalink }) {
  let post = await findPost(accountId, permalink);

  for (let attempt = 0; !post && attempt < 3; attempt++) {
    const outcome = await refreshAndWait(accountId);
    if (outcome === "already_current") await sleep(60_000);
    post = await findPost(accountId, permalink);
  }
  if (!post) throw new Error("The post hasn't reached inDM yet. Try again shortly.");

  const { json: automation } = await call("POST", "/automations", {
    media_id: post.id,
    keywords: ["GUIDE"],
    public_reply: "Sent it to your DMs.",
    dm_message: "Here is the spring planting guide. Enjoy it.",
    button_label: "Send me the guide",
    link_url: "https://example.com/spring-guide",
  });

  await call("POST", `/automations/${automation.id}/status`, { status: "live" });
  return automation.id;
}

import os
import time
import requests

API = "https://api.indm.social/v1"
HEADERS = {"Authorization": f"Bearer {os.environ['INDM_API_KEY']}"}


def call(method, path, body=None, params=None):
    res = requests.request(method, API + path, headers=HEADERS, json=body, params=params)
    data = res.json()
    if not res.ok:
        raise RuntimeError(f"{data['error']['code']}: {data['error']['message']}")
    return res.status_code, data


def find_post(account_id, permalink):
    _, page = call("GET", "/media", params={"account_id": account_id, "limit": 10})
    return next((m for m in page["data"] if m["permalink"] == permalink), None)


def refresh_and_wait(account_id):
    status, job = call("POST", f"/accounts/{account_id}/refresh")
    if status == 200:
        return job["status"]  # "already_current"
    for _ in range(60):
        time.sleep(3)
        _, job = call("GET", f"/accounts/{account_id}/refresh/{job['job_id']}")
        if job["status"] not in ("pending", "running"):
            return job["status"]
    return "running"


def automate_new_post(account_id, permalink):
    post = find_post(account_id, permalink)

    attempt = 0
    while post is None and attempt < 3:
        if refresh_and_wait(account_id) == "already_current":
            time.sleep(60)
        post = find_post(account_id, permalink)
        attempt += 1
    if post is None:
        raise RuntimeError("The post hasn't reached inDM yet. Try again shortly.")

    _, automation = call("POST", "/automations", {
        "media_id": post["id"],
        "keywords": ["GUIDE"],
        "public_reply": "Sent it to your DMs.",
        "dm_message": "Here is the spring planting guide. Enjoy it.",
        "button_label": "Send me the guide",
        "link_url": "https://example.com/spring-guide",
    })

    call("POST", f"/automations/{automation['id']}/status", {"status": "live"})
    return automation["id"]