Handling Webhooks

var deliveryId = request.Headers["svix-id"].ToString();
var sentAt = request.Headers["svix-timestamp"].ToString();

$deliveryId = $request->getHeaderLine('svix-id');
$sentAt = $request->getHeaderLine('svix-timestamp');

app.MapPost("/webhooks/a8f3c1d92e/items",
    async (JtlEvent jtlEvent, ITenantStore tenants, EventQueue queue) =>
{
    if (!await tenants.IsConnectedAsync(jtlEvent.TenantId))
    {
        return Results.NotFound();
    }

    // a background job scheduler that processes your events
    queue.Enqueue(jtlEvent);

    return Results.Ok();
});

<?php
$app->post('/webhooks/a8f3c1d92e/items', function ($request, $response) {
    $event = json_decode((string) $request->getBody(), true);

    if (!isConnectedTenant($event['tenantid'])) {
        return $response->withStatus(404);
    }

    // a background job scheduler that processes your events
    enqueue($event);

    return $response->withStatus(200);
});

public sealed record GraphQlError(string Message);
public sealed record GraphQlResponse<T>(T? Data, GraphQlError[]? Errors);
public sealed record ItemsData(ItemConnection? Items);
public sealed record ItemConnection(Item[]? Nodes);
public sealed record Item(string Id, string Sku, string Name);

public sealed class ErpClient(HttpClient httpClient)
{
    private const string ItemQuery = """
        query Item($id: ID!) {
          Items(where: { id: { eq: $id } }) {
            nodes {
              id
              sku
              name
            }
          }
        }
        """;

    public async Task<Item?> FetchItemAsync(JtlEvent jtlEvent, string accessToken)
    {
        using var request = new HttpRequestMessage(
            HttpMethod.Post,
            "https://api.jtl-cloud.com/erp/v2/graphql");

        request.Headers.Authorization = new AuthenticationHeaderValue("Bearer", accessToken);
        request.Headers.Add("X-Tenant-ID", jtlEvent.TenantId);
        request.Content = JsonContent.Create(new
        {
            query = ItemQuery,
            variables = new { id = jtlEvent.Data.ObjectKey },
        });

        using var response = await httpClient.SendAsync(request);
        var result = await response.Content
            .ReadFromJsonAsync<GraphQlResponse<ItemsData>>();

        var error = result?.Errors?.FirstOrDefault()?.Message;

        if (!response.IsSuccessStatusCode || error is not null)
        {
            throw new InvalidOperationException(
                error ?? $"GraphQL request failed: {(int)response.StatusCode}");
        }

        return result?.Data?.Items?.Nodes?.FirstOrDefault();
    }
}

<?php

use GuzzleHttp\Client;
use GuzzleHttp\Exception\GuzzleException;

const ITEM_QUERY = <<<'GRAPHQL'
    query Item($id: ID!) {
      Items(where: { id: { eq: $id } }) {
        nodes {
          id
          sku
          name
        }
      }
    }
    GRAPHQL;

function fetchItem(Client $client, array $event, string $accessToken): ?array
{
    try {
        $response = $client->post('https://api.jtl-cloud.com/erp/v2/graphql', [
            'headers' => [
                'Authorization' => "Bearer {$accessToken}",
                'X-Tenant-ID' => $event['tenantid'],
            ],
            'json' => [
                'query' => ITEM_QUERY,
                'variables' => [
                    'id' => $event['data']['objectKey'],
                ],
            ],
        ]);
    } catch (GuzzleException $e) {
        throw new RuntimeException('GraphQL request failed', 0, $e);
    }

    $result = json_decode((string) $response->getBody(), true);

    if (isset($result['errors'])) {
        throw new RuntimeException(
            $result['errors'][0]['message'] ?? 'Unknown GraphQL error'
        );
    }

    return $result['data']['Items']['nodes'][0] ?? null;
}