삭제 통지

curl "https://tahoe.workonward.com/api/partner/v1/erasures?limit=100" \
  -H "Authorization: Bearer $TAHOE_API_KEY"

{
  "object": "list",
  "data": [
    {
      "object": "erasure",
      "id": "ers_5Nx3jLm7Qd2s",
      "action": "suppression_applied",
      "reason": "data_subject_erasure",
      "workspace_id": "wsp_4Kd8sPm2Qx7L",
      "resources": [
        {
          "object": "applicant",
          "id": "apl_8Fj3kLm2Qd7s",
          "workspace_id": "wsp_4Kd8sPm2Qx7L"
        },
        {
          "object": "application",
          "id": "app_6Qm2xKd4Rp8v",
          "workspace_id": "wsp_4Kd8sPm2Qx7L"
        }
      ],
      "action_required": "cease_processing_and_delete_your_copy",
      "deadline_at": "2026-09-14T14:02:11.408Z",
      "destruction_pending": true,
      "destruction_reason": "retention_floor",
      "at": "2026-09-07T14:02:11.408Z",
      "subject_identified": false
    }
  ],
  "has_more": false,
  "next_cursor": null
}

BASE = "https://tahoe.workonward.com/api/partner/v1"


def consume_erasures(session, store):
    """Act on every erasure notice. Run at least once a day."""
    cursor = None

    # A cursor expires after an hour and the last page has none, so there is
    # no resume point to keep between runs. Read from the start every time and
    # skip the notices you have already acted on.
    while True:
        params = {"limit": 100}
        if cursor:
            params["cursor"] = cursor
        response = session.get(f"{BASE}/erasures", params=params, timeout=30)
        response.raise_for_status()
        body = response.json()

        for notice in body["data"]:
            if store.notice_handled(notice["id"]):
                continue
            # Delete on EITHER action. suppression_applied starts the 7-day
            # clock; erasure_completed can arrive on its own when Tahoe
            # destroys a record at once. Never wait for erasure_completed.
            for resource in notice["resources"]:
                store.purge(resource["object"], resource["id"])
                store.suppress_forever(resource["object"], resource["id"])
            # A notice with workspace_id null applies to every holder of the
            # data, so never filter this feed by workspace.
            store.record_notice(notice["id"], notice["reason"], notice["deadline_at"])

        cursor = body["next_cursor"]
        if not cursor:
            return