Re-verifica y reactiva una suscripción

curl --request POST \
  --url https://streaming-hub.sandbox.lerian.net/v1/subscriptions/{id}/verify \
  --header 'Authorization: Bearer <token>'

import requests

url = "https://streaming-hub.sandbox.lerian.net/v1/subscriptions/{id}/verify"

headers = {"Authorization": "Bearer <token>"}

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

print(response.text)

const options = {method: 'POST', headers: {Authorization: 'Bearer <token>'}};

fetch('https://streaming-hub.sandbox.lerian.net/v1/subscriptions/{id}/verify', 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://streaming-hub.sandbox.lerian.net/v1/subscriptions/{id}/verify",
  CURLOPT_RETURNTRANSFER => true,
  CURLOPT_ENCODING => "",
  CURLOPT_MAXREDIRS => 10,
  CURLOPT_TIMEOUT => 30,
  CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
  CURLOPT_CUSTOMREQUEST => "POST",
  CURLOPT_HTTPHEADER => [
    "Authorization: Bearer <token>"
  ],
]);

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

curl_close($curl);

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

package main

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

func main() {

	url := "https://streaming-hub.sandbox.lerian.net/v1/subscriptions/{id}/verify"

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

	req.Header.Add("Authorization", "Bearer <token>")

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

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

	fmt.Println(string(body))

}

require 'uri'
require 'net/http'

url = URI("https://streaming-hub.sandbox.lerian.net/v1/subscriptions/{id}/verify")

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

request = Net::HTTP::Post.new(url)
request["Authorization"] = 'Bearer <token>'

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

{
  "statusCode": 123,
  "errorClass": "<string>"
}

{
  "type": "<string>",
  "title": "<string>",
  "status": 123,
  "detail": "<string>",
  "code": "<string>"
}

"<string>"

{
  "type": "<string>",
  "title": "<string>",
  "status": 123,
  "detail": "<string>",
  "code": "<string>"
}

{
  "type": "<string>",
  "title": "<string>",
  "status": 123,
  "detail": "<string>",
  "code": "<string>"
}

{
  "type": "<string>",
  "title": "<string>",
  "status": 123,
  "detail": "<string>",
  "code": "<string>"
}

Re-verifica y reactiva una suscripción

Re-ejecuta la sonda apropiada para el sink (despachada por tipo de sink) y, ante un éxito de la sonda, transita la suscripción de vuelta a active y limpia cualquier auto-disable en la misma transacción. La fila se transita en el lugar — se preservan el id y el secreto de firma. Un fallo de sonda clasificado sigue siendo un 200. Esta ruta es naturalmente idempotente y no requiere header X-Idempotency. Los sinks webhook, sqs y eventbridge tienen sondas de verify registradas. Para un sink AWS este es el camino de activación por delegated grant, la alternativa a una credencial de salida en PUT /v1/subscriptions/{id}/credential, que prueba todo tipo de cola en el momento de la escritura. Cualquier otro tipo de sink devuelve 422 probe_unsupported_for_sink_kind: un sink rabbitmq se sondea en ese PUT de credential, que mueve solo verification_state, y una suscripción pull no tiene destino que sondear.

POST

subscriptions

{id}

verify

Re-verifica y reactiva una suscripción

curl --request POST \
  --url https://streaming-hub.sandbox.lerian.net/v1/subscriptions/{id}/verify \
  --header 'Authorization: Bearer <token>'

import requests

url = "https://streaming-hub.sandbox.lerian.net/v1/subscriptions/{id}/verify"

headers = {"Authorization": "Bearer <token>"}

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

print(response.text)

const options = {method: 'POST', headers: {Authorization: 'Bearer <token>'}};

fetch('https://streaming-hub.sandbox.lerian.net/v1/subscriptions/{id}/verify', 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://streaming-hub.sandbox.lerian.net/v1/subscriptions/{id}/verify",
  CURLOPT_RETURNTRANSFER => true,
  CURLOPT_ENCODING => "",
  CURLOPT_MAXREDIRS => 10,
  CURLOPT_TIMEOUT => 30,
  CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
  CURLOPT_CUSTOMREQUEST => "POST",
  CURLOPT_HTTPHEADER => [
    "Authorization: Bearer <token>"
  ],
]);

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

curl_close($curl);

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

package main

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

func main() {

	url := "https://streaming-hub.sandbox.lerian.net/v1/subscriptions/{id}/verify"

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

	req.Header.Add("Authorization", "Bearer <token>")

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

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

	fmt.Println(string(body))

}

require 'uri'
require 'net/http'

url = URI("https://streaming-hub.sandbox.lerian.net/v1/subscriptions/{id}/verify")

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

request = Net::HTTP::Post.new(url)
request["Authorization"] = 'Bearer <token>'

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

{
  "statusCode": 123,
  "errorClass": "<string>"
}

{
  "type": "<string>",
  "title": "<string>",
  "status": 123,
  "detail": "<string>",
  "code": "<string>"
}

"<string>"

{
  "type": "<string>",
  "title": "<string>",
  "status": 123,
  "detail": "<string>",
  "code": "<string>"
}

{
  "type": "<string>",
  "title": "<string>",
  "status": 123,
  "detail": "<string>",
  "code": "<string>"
}

{
  "type": "<string>",
  "title": "<string>",
  "status": 123,
  "detail": "<string>",
  "code": "<string>"
}

Autorizaciones

Authorization

string

header

requerido

Un JWT bearer emitido por plugin-auth (lib-auth). La identidad del tenant se resuelve a partir de los claims validados del token; la superficie /v1 nunca lee un tenant del cuerpo, del path ni de la query. Los llamadores de máquina obtienen un token vía el flujo client-credentials de plugin-auth. La superficie /admin autoriza contra un scope de operador y no lleva contexto de tenant.

Parámetros de ruta

string<uuid>

requerido

The unique identifier of the subscription (UUIDv7).

Respuesta

La sonda se ejecutó; el cuerpo lleva el resultado clasificado.

The classified result of a synchronous probe (ping, verify, or credential write). A classified failure is still returned with HTTP 200 — the probe ran and produced a verdict. It carries no secret, endpoint, or detail string.

outcome

enum<string>

requerido

The classified verdict of a synchronous probe.

Opciones disponibles:

ok,

failed

statusCode

integer

requerido

The target's protocol status. For webhook probes, the HTTP status (0 when none applies, e.g. a transport error or a blocked endpoint). For queue-kind credential probes, always 0.

Ejemplo:

200

errorClass

string

requerido

A frozen taxonomy token classifying a failure. Empty on success.

Ejemplo:

""

⌘I

Catálogo

Suscripciones

Entrega de eventos

Administración

Operacional

Re-verifica y reactiva una suscripción

Autorizaciones

Parámetros de ruta

Respuesta