Confirmar eventos

POSThttps://events.inovacc.dev/v1/workspaces/{workspace_id}/subscriptions/{subscription_id}/ack

Confirma los mensajes obtenidos, para que no se entreguen de nuevo.

Parámetros de la ruta

workspace_idstringobligatorio
Tu workspace. Una credencial vinculada a un workspace solo puede nombrar el suyo.
subscription_idstringobligatorio
Una suscripción pull o websocket: sub_ y 26 caracteres.

Parámetros del cuerpo

idsarrayobligatorio
De 1 a 100 event_id. Un id ya confirmado, o desconocido, cuenta 0.

Encabezados

Authorizationstringobligatorio
Bearer <clave de API>
Content-Typestringobligatorio
application/json, en una llamada con cuerpo

Ver también

Detalles de la fuente

Entrada del catálogo

Id: identity/component-taxonomy/capabilities#events
Repositorio: identity
Ruta: contracts/component-taxonomy/catalog/capabilities.json
Commit: 08ef3cd75d82

curl -X POST "https://events.inovacc.dev/v1/workspaces/{workspace_id}/subscriptions/{subscription_id}/ack" \ -H "Authorization: Bearer $INOVACC_API_KEY" \ -H "Content-Type: application/json" \ -d '{ "ids": [ "evt_01JCA4X9QY7M2KZ3N8PB5RT6VW" ] }'

const body: Record<string, unknown> = { "ids": [ "evt_01JCA4X9QY7M2KZ3N8PB5RT6VW" ] }; const url = "https://events.inovacc.dev/v1/workspaces/{workspace_id}/subscriptions/{subscription_id}/ack"; const response = await fetch(url, { method: "POST", headers: { Authorization: `Bearer ${process.env.INOVACC_API_KEY}`, "Content-Type": "application/json", }, body: JSON.stringify(body), }); console.log(response.status, await response.text());

import json import os import urllib.request body = { "ids": [ "evt_01JCA4X9QY7M2KZ3N8PB5RT6VW", ], } request = urllib.request.Request( "https://events.inovacc.dev/v1/workspaces/{workspace_id}/subscriptions/{subscription_id}/ack", data=json.dumps(body).encode(), method="POST", headers={ "User-Agent": "inovacc-python-sample", "Authorization": "Bearer " + os.environ["INOVACC_API_KEY"], "Content-Type": "application/json", }, ) with urllib.request.urlopen(request) as response: print(response.status, response.read().decode())

package main import ( "fmt" "io" "net/http" "os" "strings" ) const url = "https://events.inovacc.dev/v1/workspaces/{workspace_id}/subscriptions/{subscription_id}/ack" const body = `{ "ids": [ "evt_01JCA4X9QY7M2KZ3N8PB5RT6VW" ] }` func main() { req, err := http.NewRequest("POST", url, strings.NewReader(body)) if err != nil { panic(err) } req.Header.Set("Authorization", "Bearer "+os.Getenv("INOVACC_API_KEY")) req.Header.Set("Content-Type", "application/json") res, err := http.DefaultClient.Do(req) if err != nil { panic(err) } defer res.Body.Close() out, err := io.ReadAll(res.Body) if err != nil { panic(err) } fmt.Println(res.Status, string(out)) }

// Cargo.toml: reqwest = { version = "0.12", features = ["blocking", "json"] } // Cargo.toml: serde_json = "1" fn main() -> Result<(), Box<dyn std::error::Error>> { let api_key = std::env::var("INOVACC_API_KEY")?; let body = serde_json::json!({ "ids": [ "evt_01JCA4X9QY7M2KZ3N8PB5RT6VW" ] }); let response = reqwest::blocking::Client::new() .post("https://events.inovacc.dev/v1/workspaces/{workspace_id}/subscriptions/{subscription_id}/ack") .bearer_auth(api_key) .json(&body) .send()?; println!("{} {}", response.status(), response.text()?); Ok(()) }

<?php $body = <<<'JSON' { "ids": [ "evt_01JCA4X9QY7M2KZ3N8PB5RT6VW" ] } JSON; $curl = curl_init('https://events.inovacc.dev/v1/workspaces/{workspace_id}/subscriptions/{subscription_id}/ack'); curl_setopt_array($curl, [ CURLOPT_CUSTOMREQUEST => 'POST', CURLOPT_RETURNTRANSFER => true, CURLOPT_HTTPHEADER => [ 'Authorization: Bearer ' . getenv('INOVACC_API_KEY'), 'Content-Type: application/json', ], CURLOPT_POSTFIELDS => $body, ]); $response = curl_exec($curl); echo curl_getinfo($curl, CURLINFO_HTTP_CODE), ' ', $response, "\n"; curl_close($curl);

require "net/http" require "uri" uri = URI('https://events.inovacc.dev/v1/workspaces/{workspace_id}/subscriptions/{subscription_id}/ack') body = <<~'JSON' { "ids": [ "evt_01JCA4X9QY7M2KZ3N8PB5RT6VW" ] } JSON request = Net::HTTP::Post.new(uri) request["Authorization"] = "Bearer #{ENV.fetch('INOVACC_API_KEY')}" request["Content-Type"] = "application/json" request.body = body response = Net::HTTP.start(uri.host, uri.port, use_ssl: uri.scheme == "https") do |http| http.request(request) end puts "#{response.code} #{response.body}"

import java.net.URI; import java.net.http.HttpClient; import java.net.http.HttpRequest; import java.net.http.HttpResponse; public class Main { public static void main(String[] args) throws Exception { String apiKey = System.getenv("INOVACC_API_KEY"); String body = "{" + "\"ids\": [" + "\"evt_01JCA4X9QY7M2KZ3N8PB5RT6VW\"" + "]" + "}"; HttpRequest request = HttpRequest.newBuilder() .uri(URI.create("https://events.inovacc.dev/v1/workspaces/{workspace_id}/subscriptions/{subscription_id}/ack")) .header("Authorization", "Bearer " + apiKey) .header("Content-Type", "application/json") .method("POST", HttpRequest.BodyPublishers.ofString(body)) .build(); HttpResponse<String> response = HttpClient.newHttpClient() .send(request, HttpResponse.BodyHandlers.ofString()); System.out.println(response.statusCode() + " " + response.body()); } }

using System.Text; var body = "{" + "\"ids\": [" + "\"evt_01JCA4X9QY7M2KZ3N8PB5RT6VW\"" + "]" + "}"; var url = "https://events.inovacc.dev/v1/workspaces/{workspace_id}/subscriptions/{subscription_id}/ack"; var apiKey = Environment.GetEnvironmentVariable("INOVACC_API_KEY"); using var client = new HttpClient(); using var request = new HttpRequestMessage(HttpMethod.Post, url); request.Headers.Add("Authorization", $"Bearer {apiKey}"); request.Content = new StringContent(body, Encoding.UTF8, "application/json"); using var response = await client.SendAsync(request); Console.WriteLine($"{(int)response.StatusCode} {await response.Content.ReadAsStringAsync()}");

import java.net.URI import java.net.http.HttpClient import java.net.http.HttpRequest import java.net.http.HttpResponse fun main() { val apiKey = System.getenv("INOVACC_API_KEY") val body = "{" + "\"ids\": [" + "\"evt_01JCA4X9QY7M2KZ3N8PB5RT6VW\"" + "]" + "}" val request = HttpRequest.newBuilder() .uri(URI.create("https://events.inovacc.dev/v1/workspaces/{workspace_id}/subscriptions/{subscription_id}/ack")) .header("Authorization", "Bearer " + apiKey) .header("Content-Type", "application/json") .method("POST", HttpRequest.BodyPublishers.ofString(body)) .build() val response = HttpClient.newHttpClient() .send(request, HttpResponse.BodyHandlers.ofString()) println("${response.statusCode()} ${response.body()}") }

import Foundation #if canImport(FoundationNetworking) import FoundationNetworking #endif let body = #""" { "ids": [ "evt_01JCA4X9QY7M2KZ3N8PB5RT6VW" ] } """# let apiKey = ProcessInfo.processInfo.environment["INOVACC_API_KEY"] ?? "" let url = URL(string: "https://events.inovacc.dev/v1/workspaces/{workspace_id}/subscriptions/{subscription_id}/ack")! var request = URLRequest(url: url) request.httpMethod = "POST" request.setValue("Bearer \(apiKey)", forHTTPHeaderField: "Authorization") request.setValue("application/json", forHTTPHeaderField: "Content-Type") request.httpBody = Data(body.utf8) let (data, response) = try await URLSession.shared.data(for: request) let status = (response as? HTTPURLResponse)?.statusCode ?? 0 print(status, String(decoding: data, as: UTF8.self))