TalentReef Jobs API.

from urllib.parse import urlparse

PUBLIC_HOST = "apply.jobappnetwork.com"

def parse_talentreef(url: str) -> dict:
    parsed = urlparse(url)
    if parsed.netloc.lower() != PUBLIC_HOST:
        raise ValueError("not a TalentReef board host")

    parts = [p for p in parsed.path.strip("/").split("/") if p]
    if len(parts) < 2 or parts[0] != "clients" or not parts[1].isdigit():
        raise ValueError("expected /clients/{numericClientId}")

    job_id = parts[3] if len(parts) >= 4 and parts[2] == "posting" and parts[3].isdigit() else None
    return {"client_id": parts[1], "job_id": job_id}

print(parse_talentreef("https://apply.jobappnetwork.com/clients/10043/posting/11052368"))
# {'client_id': '10043', 'job_id': '11052368'}

import requests

SEARCH = ("https://prod-kong.internal.talentreef.com"
          "/apply/proxy-es/search-en-us/posting/_search")
PAGE_SIZE = 100

session = requests.Session()
session.headers.update({
    "Content-Type": "application/json",
    "Origin": "https://apply.jobappnetwork.com",
})

def search_body(client_id: str, size: int = PAGE_SIZE, after: list | None = None) -> dict:
    body = {
        "size": size,
        "query": {"bool": {"filter": [{"term": {"clientId.raw": client_id}}]}},
        # Sorting on jobId plus the document id makes the cursor deterministic.
        "sort": [{"jobId": "asc"}, {"_id": "asc"}],
    }
    if after:
        body["search_after"] = after
    return body

first = session.post(SEARCH, json=search_body("10043"), timeout=30)
first.raise_for_status()
payload = first.json()
total = payload["hits"]["total"]
print("authoritative total:", total["value"] if isinstance(total, dict) else total)

def fetch_all(client_id: str) -> list[dict]:
    postings, after, seen = [], None, set()
    while True:
        resp = session.post(SEARCH, json=search_body(client_id, after=after), timeout=30)
        resp.raise_for_status()
        hits = resp.json()["hits"]["hits"]
        if not hits:
            return postings

        for hit in hits:
            source = hit["_source"]
            job_id = str(source.get("jobId"))
            # Reject anything that is not this client, then dedupe on the native id.
            if str(source.get("clientId")) != client_id or job_id in seen:
                continue
            seen.add(job_id)
            postings.append(source)

        last = hits[-1].get("sort")
        if not last:
            raise RuntimeError("hit omitted its sort values — cannot page deterministically")
        after = last

postings = fetch_all("10043")
print(f"{len(postings)} postings")

def to_job(source: dict) -> dict:
    client_id = str(source.get("clientId"))
    job_id = str(source.get("jobId"))
    address = source.get("address") or {}
    return {
        "id": job_id,
        "client_id": client_id,
        "title": source.get("title") or source.get("jobTitle"),
        "description_html": source.get("description"),
        "brand": source.get("brand"),
        "category": source.get("category"),
        "city": address.get("city"),
        "state": address.get("state"),
        "postal_code": address.get("postalCode"),
        "listing_url": f"https://apply.jobappnetwork.com/clients/{client_id}/posting/{job_id}",
    }

for source in postings[:3]:
    job = to_job(source)
    print(job["title"], "-", job["city"], job["state"])

def board_state(client_id: str) -> str:
    resp = session.post(SEARCH, json=search_body(client_id, size=2), timeout=30)
    if resp.status_code in (403, 429):
        return "rate_limited"          # back off; the board is not empty
    resp.raise_for_status()

    hits = resp.json().get("hits")
    if not isinstance(hits, dict) or "hits" not in hits:
        return "malformed"             # inconclusive — do not expire anything

    total = hits.get("total")
    count = total.get("value") if isinstance(total, dict) else total
    if count == 0 and not hits["hits"]:
        return "empty"                 # dormant board, tenant identity still valid
    return "active"

for client in ("10043", "10129", "10233"):
    print(client, board_state(client))