squidex/backend/tools/TestSuite/TestSuite.Shared/Fixtures/WebhookCatcherClient.cs

// ==========================================================================
//  Squidex Headless CMS
// ==========================================================================
//  Copyright (c) Squidex UG (haftungsbeschraenkt)
//  All rights reserved. Licensed under the MIT license.
// ==========================================================================

using System.Net.Http.Json;
using System.Text;
using System.Text.Json.Serialization;

#pragma warning disable MA0048 // File name must match type name

namespace TestSuite.Fixtures
{
    public sealed class WebhookSession
    {
        public string Uuid { get; set; }
    }

    public sealed class WebhookRequest
    {
        [JsonPropertyName("uuid")]
        public string Uuid { get; set; }

        [JsonPropertyName("method")]
        public string Method { get; set; }

        [JsonPropertyName("content_base64")]
        public string Content { get; set; }
    }

    public sealed class WebhookCatcherClient
    {
        private readonly HttpClient httpClient;

        public string EndpointHost { get; }

        public int EndpointPort { get; }

        public WebhookCatcherClient(string apiHost, int apiPort, string endpointHost, int endpointPort)
        {
            if (string.IsNullOrWhiteSpace(apiHost))
            {
                apiHost = "localhost";
            }

            if (string.IsNullOrWhiteSpace(endpointHost))
            {
                endpointHost = "localhost";
            }

            EndpointHost = endpointHost;
            EndpointPort = endpointPort;

            httpClient = new HttpClient
            {
                BaseAddress = new Uri($"http://{apiHost}:{apiPort}")
            };
        }

        public async Task<(string, string)> CreateSessionAsync(
            CancellationToken ct = default)
        {
            var response = await httpClient.PostAsJsonAsync("/api/session", new { }, ct);

            response.EnsureSuccessStatusCode();

            var responseObj = await response.Content.ReadFromJsonAsync<WebhookSession>(cancellationToken: ct);

            return ($"http://{EndpointHost}:{EndpointPort}/{responseObj.Uuid}", responseObj.Uuid);
        }

        public async Task<WebhookRequest[]> GetRequestsAsync(string sessionId,
            CancellationToken ct = default)
        {
            var result = await httpClient.GetFromJsonAsync<WebhookRequest[]>($"/api/session/{sessionId}/requests", ct);

            foreach (var request in result)
            {
                if (request.Content != null)
                {
                    request.Content = Encoding.Default.GetString(Convert.FromBase64String(request.Content));
                }
            }

            return result;
        }

        public async Task<WebhookRequest[]> WaitForRequestsAsync(string sessionId, TimeSpan timeout)
        {
            var requests = Array.Empty<WebhookRequest>();

            try
            {
                using var cts = new CancellationTokenSource(timeout);

                while (!cts.IsCancellationRequested)
                {
                    requests = await GetRequestsAsync(sessionId, cts.Token);

                    if (requests.Length > 0)
                    {
                        break;
                    }

                    await Task.Delay(50, cts.Token);
                }
            }
            catch (OperationCanceledException)
            {
            }

            return requests;
        }
    }
}