Recover events a webhook endpoint missed

curl --request POST \
  --url https://api2.endstate.io/v1/webhooks/endpoints/{endpoint_id}/recover \
  --header 'Authorization: Bearer <token>' \
  --header 'Content-Type: application/json' \
  --data '
{
  "since": "2026-09-22T00:00:00Z"
}
'

import requests

url = "https://api2.endstate.io/v1/webhooks/endpoints/{endpoint_id}/recover"

payload = { "since": "2026-09-22T00:00:00Z" }
headers = {
    "Authorization": "Bearer <token>",
    "Content-Type": "application/json"
}

response = requests.post(url, json=payload, headers=headers)

print(response.text)

const options = {
  method: 'POST',
  headers: {Authorization: 'Bearer <token>', 'Content-Type': 'application/json'},
  body: JSON.stringify({since: '2026-09-22T00:00:00Z'})
};

fetch('https://api2.endstate.io/v1/webhooks/endpoints/{endpoint_id}/recover', options)
  .then(res => res.json())
  .then(res => console.log(res))
  .catch(err => console.error(err));

<?php

$curl = curl_init();

curl_setopt_array($curl, [
  CURLOPT_URL => "https://api2.endstate.io/v1/webhooks/endpoints/{endpoint_id}/recover",
  CURLOPT_RETURNTRANSFER => true,
  CURLOPT_ENCODING => "",
  CURLOPT_MAXREDIRS => 10,
  CURLOPT_TIMEOUT => 30,
  CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
  CURLOPT_CUSTOMREQUEST => "POST",
  CURLOPT_POSTFIELDS => json_encode([
    'since' => '2026-09-22T00:00:00Z'
  ]),
  CURLOPT_HTTPHEADER => [
    "Authorization: Bearer <token>",
    "Content-Type: application/json"
  ],
]);

$response = curl_exec($curl);
$err = curl_error($curl);

curl_close($curl);

if ($err) {
  echo "cURL Error #:" . $err;
} else {
  echo $response;
}

package main

import (
	"fmt"
	"strings"
	"net/http"
	"io"
)

func main() {

	url := "https://api2.endstate.io/v1/webhooks/endpoints/{endpoint_id}/recover"

	payload := strings.NewReader("{\n  \"since\": \"2026-09-22T00:00:00Z\"\n}")

	req, _ := http.NewRequest("POST", url, payload)

	req.Header.Add("Authorization", "Bearer <token>")
	req.Header.Add("Content-Type", "application/json")

	res, _ := http.DefaultClient.Do(req)

	defer res.Body.Close()
	body, _ := io.ReadAll(res.Body)

	fmt.Println(string(body))

}

HttpResponse<String> response = Unirest.post("https://api2.endstate.io/v1/webhooks/endpoints/{endpoint_id}/recover")
  .header("Authorization", "Bearer <token>")
  .header("Content-Type", "application/json")
  .body("{\n  \"since\": \"2026-09-22T00:00:00Z\"\n}")
  .asString();

require 'uri'
require 'net/http'

url = URI("https://api2.endstate.io/v1/webhooks/endpoints/{endpoint_id}/recover")

http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true

request = Net::HTTP::Post.new(url)
request["Authorization"] = 'Bearer <token>'
request["Content-Type"] = 'application/json'
request.body = "{\n  \"since\": \"2026-09-22T00:00:00Z\"\n}"

response = http.request(request)
puts response.read_body

{
  "since": "2026-09-22T00:00:00.000Z",
  "queued": 12,
  "missed": 9,
  "failed": 3
}

Webhooks

Recover events a webhook endpoint missed

Queues a delivery for every subscribed event created since since that never reached this endpoint, for example while it was disabled, and the next attempt for every event whose attempts to it all failed with no retry pending. Events that reached the endpoint or still have an attempt pending are left alone. since is clamped to the endpoint’s creation time and must be within the last 30 days. The work runs in batches so a large window never ties up one transaction; a resent event gets one more attempt. Deliveries start within about a minute, in the order the dispatcher’s sweep picks them up.

POST

webhooks

endpoints

{endpoint_id}

recover

Recover events a webhook endpoint missed

curl --request POST \
  --url https://api2.endstate.io/v1/webhooks/endpoints/{endpoint_id}/recover \
  --header 'Authorization: Bearer <token>' \
  --header 'Content-Type: application/json' \
  --data '
{
  "since": "2026-09-22T00:00:00Z"
}
'

import requests

url = "https://api2.endstate.io/v1/webhooks/endpoints/{endpoint_id}/recover"

payload = { "since": "2026-09-22T00:00:00Z" }
headers = {
    "Authorization": "Bearer <token>",
    "Content-Type": "application/json"
}

response = requests.post(url, json=payload, headers=headers)

print(response.text)

const options = {
  method: 'POST',
  headers: {Authorization: 'Bearer <token>', 'Content-Type': 'application/json'},
  body: JSON.stringify({since: '2026-09-22T00:00:00Z'})
};

fetch('https://api2.endstate.io/v1/webhooks/endpoints/{endpoint_id}/recover', options)
  .then(res => res.json())
  .then(res => console.log(res))
  .catch(err => console.error(err));

<?php

$curl = curl_init();

curl_setopt_array($curl, [
  CURLOPT_URL => "https://api2.endstate.io/v1/webhooks/endpoints/{endpoint_id}/recover",
  CURLOPT_RETURNTRANSFER => true,
  CURLOPT_ENCODING => "",
  CURLOPT_MAXREDIRS => 10,
  CURLOPT_TIMEOUT => 30,
  CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
  CURLOPT_CUSTOMREQUEST => "POST",
  CURLOPT_POSTFIELDS => json_encode([
    'since' => '2026-09-22T00:00:00Z'
  ]),
  CURLOPT_HTTPHEADER => [
    "Authorization: Bearer <token>",
    "Content-Type: application/json"
  ],
]);

$response = curl_exec($curl);
$err = curl_error($curl);

curl_close($curl);

if ($err) {
  echo "cURL Error #:" . $err;
} else {
  echo $response;
}

package main

import (
	"fmt"
	"strings"
	"net/http"
	"io"
)

func main() {

	url := "https://api2.endstate.io/v1/webhooks/endpoints/{endpoint_id}/recover"

	payload := strings.NewReader("{\n  \"since\": \"2026-09-22T00:00:00Z\"\n}")

	req, _ := http.NewRequest("POST", url, payload)

	req.Header.Add("Authorization", "Bearer <token>")
	req.Header.Add("Content-Type", "application/json")

	res, _ := http.DefaultClient.Do(req)

	defer res.Body.Close()
	body, _ := io.ReadAll(res.Body)

	fmt.Println(string(body))

}

HttpResponse<String> response = Unirest.post("https://api2.endstate.io/v1/webhooks/endpoints/{endpoint_id}/recover")
  .header("Authorization", "Bearer <token>")
  .header("Content-Type", "application/json")
  .body("{\n  \"since\": \"2026-09-22T00:00:00Z\"\n}")
  .asString();

require 'uri'
require 'net/http'

url = URI("https://api2.endstate.io/v1/webhooks/endpoints/{endpoint_id}/recover")

http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true

request = Net::HTTP::Post.new(url)
request["Authorization"] = 'Bearer <token>'
request["Content-Type"] = 'application/json'
request.body = "{\n  \"since\": \"2026-09-22T00:00:00Z\"\n}"

response = http.request(request)
puts response.read_body

{
  "since": "2026-09-22T00:00:00.000Z",
  "queued": 12,
  "missed": 9,
  "failed": 3
}

Authorizations

Authorization

string

header

required

Use Authorization: Bearer end_sk_* for partner API keys (e.g. end_sk_AbCd_example_api_key).

Headers

Idempotency-Key

string

Unique key that makes this request safe to retry. Replaying the key with the same body returns the original response with Idempotent-Replayed: true; replaying it with a different body returns 409 idempotency.key_conflict.

Required string length: 1 - 255

Example:

"a1b2c3d4-0000-4000-8000-000000000000"

Path Parameters

endpoint_id

string<uuid>

required

Example:

"8e1a7f50-90ab-4cde-8012-3456789abcde"

Body

application/json

since

string<date-time>

required

Queue every subscribed event created at or after this time that never reached the endpoint. At most 30 days ago.

Example:

"2026-09-22T00:00:00Z"

Response

How many events were queued, split by missed and failed.

since

string<date-time>

required

The time recovery started from: the requested since, or the endpoint's creation time when that is later.

queued

integer

required

Attempts inserted by this call, missed plus failed. They arrive over the following minutes; follow them through the events list filtered by endpoint_id.

Required range: x >= 0

missed

integer

required

Events that had never been attempted to this endpoint.

Required range: x >= 0

failed

integer

required

Events whose attempts to this endpoint had all failed with no retry pending; each gets its next attempt.

Required range: x >= 0

Overview

Endpoints

Recover events a webhook endpoint missed

Authorizations

Headers

Path Parameters

Body

Response