using DocumentService.Application.Common.DTOs;
using DocumentService.Client.Interfaces;
using DocumentService.Client.Models.Results;

namespace DocumentService.Client.Clients;

/// <summary>
/// Orchestrated multi-step workflows that compose multiple DocumentService clients
/// into single, higher-level operations.
/// </summary>
public class WorkflowsClient(IPdfValidationClient validation, ISwissQrCodeClient swissQrCode) : IWorkflowsClient
{
    /// <inheritdoc />
    public async Task<SwissQrCodeResult> InspectSwissQrCodeAsync(
        byte[] pdfBytes,
        bool raw = false,
        CancellationToken cancellationToken = default)
    {
        var validationResult = await validation.ValidateAsync(pdfBytes, cancellationToken);
        var qrCode = validationResult.IsValid
            ? await swissQrCode.ExtractAsync(pdfBytes, raw, cancellationToken)
            : null;
        return new SwissQrCodeResult(qrCode, validationResult);
    }

    /// <inheritdoc />
    public async Task<SwissQrCodeResult> InspectSwissQrCodeAsync(
        Stream pdfStream,
        bool raw = false,
        CancellationToken cancellationToken = default)
    {
        var validationResult = await validation.ValidateAsync(pdfStream, cancellationToken);

        if (!validationResult.IsValid)
            return new SwissQrCodeResult(null, validationResult);

        // Stream was consumed by validation – reset if possible, otherwise re-open is caller's responsibility.
        if (pdfStream.CanSeek)
            pdfStream.Position = 0;

        var qrCode = await swissQrCode.ExtractAsync(pdfStream, raw, cancellationToken);
        return new SwissQrCodeResult(qrCode, validationResult);
    }
}