IkvmToolLauncher.cs

Go to the documentation of this file.

using System;
using System.IO;
using System.Runtime.InteropServices;
using System.Text;
using System.Text.Json;
using System.Threading;
using System.Threading.Tasks;
 
using IKVM.Tools.Runner.Diagnostics;
 
namespace IKVM.Tools.Runner
{
 
    public abstract class IkvmToolLauncher
    {
 
        readonly string toolName;
        readonly string toolPath;
        readonly IIkvmToolDiagnosticEventListener listener;
 
        public IkvmToolLauncher(string toolName, string toolPath, IIkvmToolDiagnosticEventListener listener)
        {
            this.toolName = toolName ?? throw new ArgumentNullException(nameof(toolName));
            this.toolPath = toolPath ?? throw new ArgumentNullException(nameof(toolPath));
            this.listener = listener;
 
            if (Directory.Exists(toolPath) == false)
                throw new DirectoryNotFoundException($"Could not locate tool path {toolPath}.");
        }
 
        protected ValueTask LogEventAsync(in IkvmToolDiagnosticEvent @event, CancellationToken cancellationToken)
        {
            return listener.ReceiveAsync(@event, cancellationToken);
        }
 
        protected ValueTask LogEventAsync(IkvmToolDiagnosticEventLevel level, string message, string[] args, CancellationToken cancellationToken)
        {
            return LogEventAsync(new IkvmToolDiagnosticEvent(-1, level, message, args), cancellationToken);
        }
 
        protected ValueTask ParseAndLogEventAsync(string line, CancellationToken cancellationToken)
        {
            return LogEventAsync(ParseEvent(line), cancellationToken);
        }
 
        protected IkvmToolDiagnosticEvent ParseEvent(string line)
        {
            try
            {
                var buffer = Encoding.UTF8.GetBytes(line);
                var reader = new Utf8JsonReader(buffer);
                if (reader.Read() == false)
                    throw new JsonException();
 
                return IkvmToolDiagnosticEvent.ReadJson(ref reader);
            }
            catch (JsonException)
            {
                return new IkvmToolDiagnosticEvent(0, IkvmToolDiagnosticEventLevel.Fatal, "Unable to parse tool output: {0}", [line]);
            }
        }
 
        public string? GetToolExe()
        {
            foreach (var name in (Span<string>)[toolName + ".exe", toolName])
                if (File.Exists(Path.Combine(toolPath, name)))
                    return Path.Combine(toolPath, name);
 
            return null;
        }
 
    }
 
}