A=https://api.jobopportunitiesapi.org
H="Authorization: Bearer $JOA_KEY"
out=ie.ndjson
touch "$out"

while : ; do
  # Resume from the last id we successfully wrote, if any.
  after=$(tail -1 "$out" | jq -r '.id // empty' 2>/dev/null)
  curl -sN --fail-with-body -H "$H" --get "$A/v1/export" \
       --data-urlencode 'country=IE' \
       ${after:+--data-urlencode "after=$after"} >> "$out" && break
  echo "interrupted after ${after:-start}; retrying in 5s" >&2
  sleep 5
done

# The LAST LINE may be an error object rather than a row. Always check.
tail -1 "$out" | jq -e 'has("error") | not' >/dev/null \
  || echo "export ended early: $(tail -1 "$out")" >&2

{
  "error": "record_quota_exhausted",
  "message": "This plan's monthly record allowance is used up. It resets on the 1st.",
  "after": "9f3c1a2e-…" 
}

import json, os, urllib.parse, urllib.request

API = "https://api.jobopportunitiesapi.org"
KEY = os.environ["JOA_KEY"]

def export(**filters):
    """Yield rows. Raises if the stream ended on an error object."""
    qs = urllib.parse.urlencode(filters)
    req = urllib.request.Request(
        f"{API}/v1/export?{qs}",
        headers={"Authorization": f"Bearer {KEY}"},
    )
    last = None
    with urllib.request.urlopen(req, timeout=None) as r:
        for raw in r:                       # one object per line, as it arrives
            line = raw.decode().strip()
            if not line:
                continue
            last = json.loads(line)
            if "error" in last:
                break                       # do not yield the error as a row
            yield last
    # The stream can end on an error INSIDE a 200. Silence here is a truncated
    # dataset that looks complete.
    if last and "error" in last:
        raise RuntimeError(
            f"export ended early: {last['error']}; resume with after={last.get('after')}"
        )

for row in export(country="IE", limit=1):
    print(row["id"], row["title"])