// Licensed to the .NET Foundation under one or more agreements.
// The .NET Foundation licenses this file to you under the MIT license.
 
#nullable disable
 
using System.IO.Pipes;
using System.Runtime.Versioning;
 
namespace Microsoft.DotNet.Cli.Installer.Windows;
 
/// <summary>
/// Provides logging support for external processes, allowing them to send log requests through a named pipe.
/// </summary>
/// <remarks>
/// Creates a new <see cref="PipeStreamSetupLogger"/> instance.
/// </remarks>
/// <param name="pipeStream">The <see cref="PipeStream"/> to use for sending log requests.</param>
/// <param name="pipeName"></param>
[SupportedOSPlatform("windows")]
internal class PipeStreamSetupLogger(PipeStream pipeStream, string pipeName) : SetupLoggerBase, ISetupLogger
{
    private readonly PipeStreamMessageDispatcherBase _dispatcher = new PipeStreamMessageDispatcherBase(pipeStream);
 
    /// <summary>
    /// Queue to track log requests issued before the pipestream is connected.
    /// </summary>
    private readonly Queue<string> _messageQueue = new();
 
    public string LogPath
    {
        get;
        private set;
    } = pipeName;
 
    /// <summary>
    /// Waits for the underlying pipe stream to become connected.
    /// </summary>
    public void Connect()
    {
        _dispatcher.Connect();
 
        // Flush out any queued messages.
        while (_messageQueue.Count > 0)
        {
            if (_messageQueue.TryDequeue(out string message))
            {
                _dispatcher.WriteMessage(Encoding.UTF8.GetBytes(message));
            }
        }
    }
 
    /// <summary>
    /// Writes the message to the underlying named pipe.
    /// </summary>
    /// <param name="message">The message to write.</param>
    protected override void WriteMessage(string message)
    {
        if (_dispatcher.IsConnected)
        {
            _dispatcher.WriteMessage(Encoding.UTF8.GetBytes(message));
        }
        else
        {
            _messageQueue.Enqueue(message);
        }
    }
}