Estiaje documentation

The official SDK: Install, your first event and, for the thread across services, Context and lineage.

Copy estiaje.py into your project. Python 3.8 or later.

# estiaje.py: copy this file into your project. No dependencies.
import contextvars, json, os, re, secrets, threading, urllib.request

URL = (os.environ.get("ESTIAJE_URL") or "https://estiaje.mx") + "/v1/events"
SERVICIO = "mi-api"
_hilo = contextvars.ContextVar("estiaje_hilo", default=None)
_envios = []
_TP = re.compile(r"^[0-9a-f]{2}-([0-9a-f]{32})-[0-9a-f]{16}-[0-9a-f]{2}$")


def empezar_hilo(traceparent=None):
    """When a request comes in: take the thread from the header or create a new one."""
    m = _TP.match((traceparent or "").strip().lower())
    hilo = m.group(1) if m and m.group(1) != "0" * 32 else secrets.token_hex(16)
    _hilo.set(hilo)
    return hilo


def traceparent():
    """For calls going out to another service: the same thread, a new step."""
    return "00-%s-%s-01" % (_hilo.get() or secrets.token_hex(16), secrets.token_hex(8))


def evento(name, attrs=None, kind="event"):
    """Sends the event in the background: it never slows down or breaks your app."""
    if not os.environ.get("ESTIAJE_TOKEN"):
        return  # without a key nothing goes out over the network
    ev = {"service": SERVICIO, "kind": kind, "name": name, "attrs": attrs or {}}
    if _hilo.get():
        ev["trace_id"] = _hilo.get()
    envio = threading.Thread(target=_mandar, args=([ev],))
    envio.start()
    _envios[:] = [e for e in _envios if e.is_alive()] + [envio]


def esperar():
    """In a lambda, before returning: let pending sends go out (2 s at most)."""
    for e in list(_envios):
        e.join()


def _mandar(lote):
    try:
        req = urllib.request.Request(URL, data=json.dumps(lote).encode(), headers={
            "content-type": "application/json",
            "authorization": "Bearer " + os.environ["ESTIAJE_TOKEN"]})
        urllib.request.urlopen(req, timeout=2).close()
    except Exception:
        pass  # if Estiaje doesn't answer, your app keeps going

Wherever something happens:

import estiaje

estiaje.evento("pedido.creado", {"order_id": pedido.id, "monto": pedido.total})

Django: the thread, in a middleware.

# miapp/middleware.py  (and in settings.MIDDLEWARE: "miapp.middleware.hilo_estiaje")
import estiaje

def hilo_estiaje(get_response):
    def middleware(request):
        estiaje.empezar_hilo(request.headers.get("traceparent"))
        return get_response(request)
    return middleware

Flask:

@app.before_request
def hilo_estiaje():
    estiaje.empezar_hilo(request.headers.get("traceparent"))

FastAPI: the thread in a middleware, and the event with BackgroundTasks so it goes out after responding.

from fastapi import BackgroundTasks, FastAPI, Request
import estiaje

app = FastAPI()

@app.middleware("http")
async def hilo_estiaje(request: Request, call_next):
    estiaje.empezar_hilo(request.headers.get("traceparent"))
    return await call_next(request)

@app.post("/pedidos")
async def crear(p: Pedido, tareas: BackgroundTasks):
    ...
    tareas.add_task(estiaje.evento, "pedido.creado", {"order_id": p.id, "monto": p.total})

When calling another of your services, pass the thread along:

requests.get(url, headers={"traceparent": estiaje.traceparent()}, timeout=5)

In a script or a cron job nothing else is needed: Python waits for the send before exiting.

Copy estiaje.php into your project. PHP 7.4 or later, with the curl extension. Events are collected and sent at the end, once your user already has their response (with PHP-FPM).

<?php
// estiaje.php: copy it into your project (in Laravel, app/Estiaje.php). No dependencies.
final class Estiaje
{
    const SERVICIO = 'mi-api';
    private static ?string $hilo = null;
    private static array $lote = [];

    /** When a request comes in: take the thread from the header or create a new one. */
    public static function empezarHilo(?string $traceparent): string
    {
        $tp = strtolower(trim((string) $traceparent));
        $ok = preg_match('/^[0-9a-f]{2}-([0-9a-f]{32})-[0-9a-f]{16}-[0-9a-f]{2}$/', $tp, $m);
        self::$hilo = $ok && $m[1] !== str_repeat('0', 32) ? $m[1] : bin2hex(random_bytes(16));
        return self::$hilo;
    }

    /** For calls going out to another service: the same thread, a new step. */
    public static function traceparent(): string
    {
        return '00-' . (self::$hilo ?? bin2hex(random_bytes(16))) . '-' . bin2hex(random_bytes(8)) . '-01';
    }

    /** Collects the event; it's sent at the end, once your user has their response. */
    public static function evento(string $name, array $attrs = [], string $kind = 'event'): void
    {
        if (!getenv('ESTIAJE_TOKEN')) return; // without a key nothing goes out over the network
        $ev = ['service' => self::SERVICIO, 'kind' => $kind, 'name' => $name, 'attrs' => (object) $attrs];
        if (self::$hilo) $ev['trace_id'] = self::$hilo;
        if (!self::$lote) register_shutdown_function([self::class, 'mandar']);
        self::$lote[] = $ev;
    }

    public static function mandar(): void
    {
        if (function_exists('fastcgi_finish_request')) fastcgi_finish_request();
        $lote = self::$lote;
        self::$lote = [];
        if (!$lote) return;
        $ch = curl_init((getenv('ESTIAJE_URL') ?: 'https://estiaje.mx') . '/v1/events');
        curl_setopt_array($ch, [
            CURLOPT_POST => true,
            CURLOPT_HTTPHEADER => ['content-type: application/json',
                                   'authorization: Bearer ' . getenv('ESTIAJE_TOKEN')],
            CURLOPT_POSTFIELDS => json_encode($lote),
            CURLOPT_RETURNTRANSFER => true,
            CURLOPT_CONNECTTIMEOUT_MS => 1000,
            CURLOPT_TIMEOUT_MS => 2000,
        ]);
        curl_exec($ch); // if Estiaje doesn't answer, your app keeps going
    }
}

Wherever something happens:

Estiaje::evento('pedido.creado', ['order_id' => $pedido->id, 'monto' => $pedido->total]);

Laravel: the thread, in a middleware.

// app/Http/Middleware/HiloEstiaje.php
namespace App\Http\Middleware;

use Closure;
use Illuminate\Http\Request;

class HiloEstiaje
{
    public function handle(Request $request, Closure $next)
    {
        \Estiaje::empezarHilo($request->header('traceparent'));
        return $next($request);
    }
}

// bootstrap/app.php (Laravel 11+; before that, in $middleware in app/Http/Kernel.php)
->withMiddleware(fn ($middleware) => $middleware->append(\App\Http\Middleware\HiloEstiaje::class))

When calling another of your services with Laravel’s HTTP client, pass the thread along:

Http::withHeaders(['traceparent' => \Estiaje::traceparent()])->get($url);

Prefer to send the event with Laravel’s HTTP client? Make it go out after responding:

// in config/services.php: 'estiaje' => ['token' => env('ESTIAJE_TOKEN')]
dispatch(fn () => Http::timeout(2)->withToken(config('services.estiaje.token'))
    ->post('https://estiaje.mx/v1/events', [[
        'service' => 'mi-api', 'kind' => 'event', 'name' => 'pedido.creado',
        'attrs' => ['order_id' => $pedido->id, 'monto' => $pedido->total],
    ]]))->afterResponse();

estiaje.php reads the key with getenv. With php artisan config:cache, Laravel no longer loads the .env: set ESTIAJE_TOKEN as a server environment variable.

WordPress, in your plugin or in functions.php:

require_once __DIR__ . '/estiaje.php';
add_action('init', fn () => Estiaje::empezarHilo($_SERVER['HTTP_TRACEPARENT'] ?? null));

// when calling another service
wp_remote_get($url, ['headers' => ['traceparent' => Estiaje::traceparent()]]);

Copy Estiaje.java into your project. Java 17 or later.

// Estiaje.java: copy it into your project (with your package). No dependencies, Java 17+.
import java.net.URI;
import java.net.http.HttpClient;
import java.net.http.HttpRequest;
import java.net.http.HttpResponse;
import java.security.SecureRandom;
import java.time.Duration;
import java.util.Map;
import java.util.concurrent.CompletableFuture;
import java.util.regex.Matcher;
import java.util.regex.Pattern;

public final class Estiaje {
    static final String SERVICIO = "mi-api";
    static final String TOKEN = System.getenv("ESTIAJE_TOKEN");
    static final String BASE = System.getenv("ESTIAJE_URL");
    static final String URL = (BASE == null || BASE.isEmpty() ? "https://estiaje.mx" : BASE) + "/v1/events";
    static final HttpClient HTTP = HttpClient.newBuilder().connectTimeout(Duration.ofSeconds(1)).build();
    static final ThreadLocal<String> HILO = new ThreadLocal<>();
    static final Pattern TP = Pattern.compile("^[0-9a-f]{2}-([0-9a-f]{32})-[0-9a-f]{16}-[0-9a-f]{2}$");
    static final SecureRandom AZAR = new SecureRandom();

    /** When a request comes in: take the thread from the header or create a new one. */
    public static String empezarHilo(String traceparent) {
        Matcher m = TP.matcher(traceparent == null ? "" : traceparent.trim().toLowerCase());
        String hilo = m.matches() && !m.group(1).equals("0".repeat(32)) ? m.group(1) : hex(16);
        HILO.set(hilo);
        return hilo;
    }

    /** When the request ends: the Java thread is reused for the next one. */
    public static void terminarHilo() {
        HILO.remove();
    }

    /** For calls going out to another service: the same thread, a new step. */
    public static String traceparent() {
        String hilo = HILO.get();
        return "00-" + (hilo != null ? hilo : hex(16)) + "-" + hex(8) + "-01";
    }

    /** Sends the event in the background: it never slows down or breaks your app. */
    public static CompletableFuture<Void> evento(String name, Map<String, ?> attrs) {
        try {
            if (TOKEN == null || TOKEN.isEmpty()) return CompletableFuture.completedFuture(null);
            StringBuilder j = new StringBuilder("[{\"service\":" + q(SERVICIO) + ",\"kind\":\"event\",\"name\":" + q(name));
            if (HILO.get() != null) j.append(",\"trace_id\":").append(q(HILO.get()));
            j.append(",\"attrs\":{");
            String coma = "";
            for (Map.Entry<String, ?> a : attrs.entrySet()) {
                Object v = a.getValue();
                j.append(coma).append(q(a.getKey())).append(':')
                 .append(v instanceof Number || v instanceof Boolean ? v.toString() : q(String.valueOf(v)));
                coma = ",";
            }
            j.append("}}]");
            HttpRequest req = HttpRequest.newBuilder(URI.create(URL)).timeout(Duration.ofSeconds(2))
                .header("content-type", "application/json")
                .header("authorization", "Bearer " + TOKEN)
                .POST(HttpRequest.BodyPublishers.ofString(j.toString())).build();
            return HTTP.sendAsync(req, HttpResponse.BodyHandlers.discarding()).handle((r, e) -> null);
        } catch (RuntimeException e) {
            return CompletableFuture.completedFuture(null); // if something fails, your app keeps going
        }
    }

    static String q(String s) {
        StringBuilder b = new StringBuilder("\"");
        for (char c : s.toCharArray()) {
            if (c == '"' || c == '\\') b.append('\\').append(c);
            else if (c < 0x20) b.append(String.format("\\u%04x", (int) c));
            else b.append(c);
        }
        return b.append('"').toString();
    }

    static String hex(int bytes) {
        byte[] b = new byte[bytes];
        AZAR.nextBytes(b);
        StringBuilder s = new StringBuilder();
        for (byte x : b) s.append(String.format("%02x", x));
        return s.toString();
    }
}

Wherever something happens:

Estiaje.evento("pedido.creado", Map.of("order_id", pedido.getId(), "monto", pedido.getTotal()));

Spring Boot: the thread, in a filter.

@Component
public class HiloEstiaje extends OncePerRequestFilter {
    @Override
    protected void doFilterInternal(HttpServletRequest req, HttpServletResponse res, FilterChain chain)
            throws ServletException, IOException {
        Estiaje.empezarHilo(req.getHeader("traceparent"));
        try {
            chain.doFilter(req, res);
        } finally {
            Estiaje.terminarHilo();
        }
    }
}

When calling another of your services (with RestClient), pass the thread along:

RestClient http = RestClient.builder()
    .requestInterceptor((req, cuerpo, sigue) -> {
        req.getHeaders().set("traceparent", Estiaje.traceparent());
        return sigue.execute(req, cuerpo);
    })
    .build();

In a program that exits right away, wait for the send: Estiaje.evento(…).join().

Copy Estiaje.cs into your project. .NET 6 or later.

// Estiaje.cs: copy it into your project. No packages, .NET 6 or later.
using System.Net.Http.Json;
using System.Security.Cryptography;
using System.Text.RegularExpressions;

public static class Estiaje
{
    const string Servicio = "mi-api";
    static readonly HttpClient Http = new() { Timeout = TimeSpan.FromSeconds(2) };
    static readonly string Base = Environment.GetEnvironmentVariable("ESTIAJE_URL") ?? "";
    static readonly string Url = (Base.Length > 0 ? Base : "https://estiaje.mx") + "/v1/events";
    static readonly AsyncLocal<string?> Hilo = new();
    static readonly Regex Formato = new("^[0-9a-f]{2}-([0-9a-f]{32})-[0-9a-f]{16}-[0-9a-f]{2}$");

    /// When a request comes in: take the thread from the header or create a new one.
    public static string EmpezarHilo(string? traceparent)
    {
        var m = Formato.Match((traceparent ?? "").Trim().ToLowerInvariant());
        Hilo.Value = m.Success && m.Groups[1].Value != new string('0', 32) ? m.Groups[1].Value : Azar(16);
        return Hilo.Value;
    }

    /// For calls going out to another service: the same thread, a new step.
    public static string Traceparent() => $"00-{Hilo.Value ?? Azar(16)}-{Azar(8)}-01";

    /// Sends the event in the background: it never slows down or breaks your app. No need to await it.
    public static Task Evento(string name, object? attrs = null)
    {
        var token = Environment.GetEnvironmentVariable("ESTIAJE_TOKEN");
        if (string.IsNullOrEmpty(token)) return Task.CompletedTask; // without a key nothing goes out
        var ev = new Dictionary<string, object?>
        {
            ["service"] = Servicio, ["kind"] = "event", ["name"] = name, ["attrs"] = attrs ?? new { },
        };
        if (Hilo.Value is { } hilo) ev["trace_id"] = hilo;
        var req = new HttpRequestMessage(HttpMethod.Post, Url) { Content = JsonContent.Create(new[] { ev }) };
        req.Headers.TryAddWithoutValidation("authorization", "Bearer " + token);
        return Http.SendAsync(req).ContinueWith(t => // if Estiaje doesn't answer, your app keeps going
        {
            if (t.IsCompletedSuccessfully) t.Result.Dispose(); else _ = t.Exception;
        });
    }

    static string Azar(int bytes) => Convert.ToHexString(RandomNumberGenerator.GetBytes(bytes)).ToLowerInvariant();
}

/// Puts traceparent on whatever goes out through an HttpClient to your other services.
public class EstiajeSaliente : DelegatingHandler
{
    protected override Task<HttpResponseMessage> SendAsync(HttpRequestMessage req, CancellationToken ct)
    {
        req.Headers.Remove("traceparent");
        req.Headers.TryAddWithoutValidation("traceparent", Estiaje.Traceparent());
        return base.SendAsync(req, ct);
    }
}

In Program.cs: the thread in a middleware, and your HttpClients passing it on to your other services.

var builder = WebApplication.CreateBuilder(args);
builder.Services.AddTransient<EstiajeSaliente>();
builder.Services.AddHttpClient("inventario").AddHttpMessageHandler<EstiajeSaliente>();
var app = builder.Build();

app.Use(async (ctx, next) =>
{
    Estiaje.EmpezarHilo(ctx.Request.Headers["traceparent"]);
    await next();
});

Wherever something happens (no await needed):

Estiaje.Evento("pedido.creado", new { order_id = pedido.Id, monto = pedido.Total });

In a console app that exits right away, do await it: await Estiaje.Evento(…).

Copy estiaje.go into your project, in its own estiaje package. Go 1.18 or later.

// estiaje.go: copy it into your project (package estiaje). No dependencies.
package estiaje

import (
	"bytes"
	"context"
	"crypto/rand"
	"encoding/hex"
	"encoding/json"
	"net/http"
	"os"
	"regexp"
	"strings"
	"sync"
	"time"
)

const servicio = "mi-api"

var (
	cliente    = &http.Client{Timeout: 2 * time.Second}
	formato    = regexp.MustCompile(`^[0-9a-f]{2}-([0-9a-f]{32})-[0-9a-f]{16}-[0-9a-f]{2}$`)
	pendientes sync.WaitGroup
)

type claveHilo struct{}

// ConHilo: when a request comes in, take the thread from the header or create a new one.
func ConHilo(ctx context.Context, traceparent string) context.Context {
	hilo := azar(16)
	if m := formato.FindStringSubmatch(strings.ToLower(strings.TrimSpace(traceparent))); m != nil && m[1] != strings.Repeat("0", 32) {
		hilo = m[1]
	}
	return context.WithValue(ctx, claveHilo{}, hilo)
}

// Middleware for net/http (works the same with chi or gorilla/mux).
func Middleware(next http.Handler) http.Handler {
	return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
		next.ServeHTTP(w, r.WithContext(ConHilo(r.Context(), r.Header.Get("traceparent"))))
	})
}

func Hilo(ctx context.Context) string {
	h, _ := ctx.Value(claveHilo{}).(string)
	return h
}

// Traceparent: for calls going out to another service. The same thread, a new step.
func Traceparent(ctx context.Context) string {
	h := Hilo(ctx)
	if h == "" {
		h = azar(16)
	}
	return "00-" + h + "-" + azar(8) + "-01"
}

// Transporte puts traceparent on everything that goes out through an http.Client:
// &http.Client{Transport: estiaje.Transporte{}}, and the request with its ctx.
type Transporte struct{ Base http.RoundTripper }

func (t Transporte) RoundTrip(r *http.Request) (*http.Response, error) {
	r = r.Clone(r.Context())
	r.Header.Set("traceparent", Traceparent(r.Context()))
	if t.Base == nil {
		return http.DefaultTransport.RoundTrip(r)
	}
	return t.Base.RoundTrip(r)
}

// Evento sends it in the background: it never slows down or breaks your app.
func Evento(ctx context.Context, name string, attrs map[string]any) {
	token := os.Getenv("ESTIAJE_TOKEN")
	if token == "" {
		return // without a key nothing goes out over the network
	}
	if attrs == nil {
		attrs = map[string]any{}
	}
	ev := map[string]any{"service": servicio, "kind": "event", "name": name, "attrs": attrs}
	if h := Hilo(ctx); h != "" {
		ev["trace_id"] = h
	}
	cuerpo, err := json.Marshal([]any{ev})
	if err != nil {
		return
	}
	url := os.Getenv("ESTIAJE_URL")
	if url == "" {
		url = "https://estiaje.mx"
	}
	pendientes.Add(1)
	go func() {
		defer pendientes.Done()
		req, err := http.NewRequest("POST", url+"/v1/events", bytes.NewReader(cuerpo))
		if err != nil {
			return
		}
		req.Header.Set("content-type", "application/json")
		req.Header.Set("authorization", "Bearer "+token)
		if res, err := cliente.Do(req); err == nil {
			res.Body.Close()
		}
	}()
}

// Esperar: in a program that exits right away (a cron job), call it before exiting.
func Esperar() { pendientes.Wait() }

func azar(n int) string {
	b := make([]byte, n)
	rand.Read(b)
	return hex.EncodeToString(b)
}

net/http (and chi, gorilla/mux): wrap your router, and use the Transporte for outgoing calls.

http.ListenAndServe(":8080", estiaje.Middleware(mux))

// wherever something happens, with the request's context
estiaje.Evento(r.Context(), "pedido.creado", map[string]any{"order_id": p.ID, "monto": p.Total})

// when calling another of your services
cliente := &http.Client{Transport: estiaje.Transporte{}}
req, _ := http.NewRequestWithContext(r.Context(), "GET", url, nil)
cliente.Do(req)

Gin:

r.Use(func(c *gin.Context) {
    c.Request = c.Request.WithContext(estiaje.ConHilo(c.Request.Context(), c.GetHeader("traceparent")))
    c.Next()
})

In a program that exits right away (a cron job), call estiaje.Esperar() before exiting.

Copy estiaje.rb into your project. Ruby 2.7 or later, no gems.

# estiaje.rb: copy it into your project (in Rails, lib/estiaje.rb). No gems.
require "json"
require "net/http"
require "securerandom"

module Estiaje
  SERVICIO = "mi-api"
  FORMATO = /\A[0-9a-f]{2}-([0-9a-f]{32})-[0-9a-f]{16}-[0-9a-f]{2}\z/
  @envios = []
  @candado = Mutex.new

  # When a request comes in: take the thread from the header or create a new one.
  def self.empezar_hilo(traceparent)
    m = FORMATO.match(traceparent.to_s.strip.downcase)
    Thread.current[:estiaje_hilo] = m && m[1] != "0" * 32 ? m[1] : SecureRandom.hex(16)
  end

  def self.hilo
    Thread.current[:estiaje_hilo]
  end

  # For calls going out to another service: the same thread, a new step.
  def self.traceparent
    "00-#{hilo || SecureRandom.hex(16)}-#{SecureRandom.hex(8)}-01"
  end

  # Sends the event in the background: it never slows down or breaks your app.
  def self.evento(name, attrs = {}, kind: "event")
    token = ENV["ESTIAJE_TOKEN"].to_s
    return if token.empty? # without a key nothing goes out over the network
    ev = { service: SERVICIO, kind: kind, name: name, attrs: attrs }
    ev[:trace_id] = hilo if hilo
    base = ENV["ESTIAJE_URL"].to_s.empty? ? "https://estiaje.mx" : ENV["ESTIAJE_URL"]
    envio = Thread.new do
      uri = URI("#{base}/v1/events")
      Net::HTTP.start(uri.host, uri.port, use_ssl: uri.scheme == "https",
                      open_timeout: 1, read_timeout: 2, write_timeout: 2) do |http|
        http.post(uri.path, [ev].to_json,
                  "content-type" => "application/json", "authorization" => "Bearer #{token}")
      end
    rescue StandardError
      nil # if Estiaje doesn't answer, your app keeps going
    end
    @candado.synchronize { @envios.select!(&:alive?); @envios << envio }
  end

  # In a script that exits right away (a cron job, a rake task), call it before exiting.
  def self.esperar
    @candado.synchronize { @envios.dup }.each(&:join)
  end

  # The Rack middleware: Rails, Sinatra, Hanami.
  class Middleware
    def initialize(app)
      @app = app
    end

    def call(env)
      Estiaje.empezar_hilo(env["HTTP_TRACEPARENT"])
      @app.call(env)
    ensure
      Thread.current[:estiaje_hilo] = nil
    end
  end
end

Rails, in config/application.rb (in Sinatra: use Estiaje::Middleware):

require_relative "../lib/estiaje"
# …inside class Application:
config.middleware.use Estiaje::Middleware

Wherever something happens, and when calling another of your services:

Estiaje.evento("pedido.creado", { order_id: pedido.id, monto: pedido.total })

req = Net::HTTP::Get.new(uri)
req["traceparent"] = Estiaje.traceparent

In a script or a rake task, call Estiaje.esperar before exiting.

A serverless function is frozen as soon as it returns its response, and whatever was about to go out never does. That’s why, here, you do wait for the send at the end.

• Vercel and Lambda with Node: await estiaje.flush() before returning the response.
• Lambda with the recipes above: estiaje.esperar() in Python, estiaje.Esperar() in Go, Estiaje.esperar in Ruby, .join() in Java and await in C#.
• Cloudflare Workers: ctx.waitUntil lets the send finish after responding, without making your user wait.

export default {
  async fetch(request, env, ctx) {
    // the thread: the one from the traceparent header, or a new one
    const m = /^[0-9a-f]{2}-([0-9a-f]{32})-/.exec(request.headers.get('traceparent') ?? '');
    const trace_id = m ? m[1] : crypto.randomUUID().replaceAll('-', '');

    ctx.waitUntil(fetch('https://estiaje.mx/v1/events', {
      method: 'POST',
      headers: { 'content-type': 'application/json', authorization: `Bearer ${env.ESTIAJE_TOKEN}` },
      body: JSON.stringify([{ service: 'mi-worker', kind: 'event', name: 'pedido.creado', trace_id }]),
    }).catch(() => {}));  // if Estiaje doesn't answer, your worker keeps going

    return new Response('ok');
  },
};

One HTTP request step at the end of your flow: in n8n, the HTTP Request node; in Make, HTTP › Make a request; in Zapier, Webhooks by Zapier › Custom Request.

[{"service": "n8n", "kind": "event", "name": "pedido.creado",
  "attrs": {"order_id": "{{ $json.id }}", "monto": {{ $json.total }}}}]

Keep the key in the tool’s credentials, not written into the step. Set the step to continue on failure: if Estiaje doesn’t answer, your flow doesn’t stop.

One line at the end of your pipeline reports every deploy, with who and what: npx @estiaje/sdk desplegado. It works no matter what language your service is written in. The details are in Deploys.