Создание плагина для отправки логов (событийной информации) - MONQDL/agent-docs GitHub Wiki

public class PluginTaskStrategy : IPluginTaskStrategy
{
    public Task<IDictionary<string, object?>> Run(
        IDictionary<string, object?> variables, 
        IEnumerable<string> securedVariables, 
        CancellationToken cancellationToken)
    {
        // Здесь будет выполняться задача полученная от агента.
    }
}

public class TaskConfig
{
    public string BaseUri { get; set; }
    public long UserspaceId { get; set; }
    public string StreamKey { get; set; }
}

 var config = variables.ToObject<TaskConfig>();

    public Task<IDictionary<string, object?>> Run(…)
    {
        var config = variables.ToObject<TaskConfig>();
        ValidateConfig(config);
        // Здесь будет выполняться задача полученная от агента.
    }
    void ValidateConfig(TaskConfig config)
    {
        if (string.IsNullOrWhiteSpace(config.StreamKey) 
            || string.IsNullOrWhiteSpace(config.BaseUri) 
            || config.UserspaceId == 0)
            throw new PluginNotConfiguredException();
    }

public class SystemInformation
{
    public string Name { get; set; }
}

    public Task<IDictionary<string, object?>> Run(…)
    {
        var config = variables.ToObject<TaskConfig>();
        ValidateConfig(config);
        var sysInfo = GetSystemInformation();
        // Здесь будет выполняться задача полученная от агента.
    }
    SystemInformation GetSystemInformation()
    {
        return new SystemInformation()
        { 
            Name = Environment.MachineName
        };
    }

public interface IStreamDataCollectorApiHttpService
{
    public Task PushEvents(string baseUri, string streamKey, long userspaceId, IList events);
}

public class StreamDataCollectorApiHttpService : IStreamDataCollectorApiHttpService
{
    public async Task PushEvents(string baseUri, string streamKey, long userspaceId, IList events)
    {
        // Здесь будет выполняться пересылка событий.
    }
}

    readonly IHttpClientFactory _httpClientFactory;

    public StreamDataCollectorApiHttpService(IHttpClientFactory httpClientFactory)
    {
        _httpClientFactory = httpClientFactory;
    }

    const string UserspaceHeader = "X-Smon-Userspace-Id";

    public async Task PushEvents(string baseUri, string streamKey, long userspaceId, IList events)
    {
        using var client = _httpClientFactory.CreateClient();
        client.BaseAddress = new Uri(baseUri);
        client.DefaultRequestHeaders.TryAddWithoutValidation(UserspaceHeader, userspaceId.ToString());
        // Здесь будет выполняться пересылка событий.
    }

using System.Text.Json;
using System.Text.Json.Serialization;
…
    static readonly JsonSerializerOptions _serializerOptions = new()
    {
        WriteIndented = true,
        PropertyNameCaseInsensitive = true,
        DefaultIgnoreCondition = JsonIgnoreCondition.WhenWritingNull,
    };

    public async Task PushEvents(string baseUri, string streamKey, long userspaceId, IList events)
    {
        …
        var json = JsonSerializer.Serialize(events, _serializerOptions);
        // Здесь будет выполняться пересылка событий.
    }

    const string StreamDataApiUri = "api/public/cl/v1/stream-data";
    …
    public async Task PushEvents(string baseUri, string streamKey, long userspaceId, IList events)
    {
        …
        var json = JsonSerializer.Serialize(events, _serializerOptions);
        var data = new StringContent(json, Encoding.UTF8, Application.Json);
        var requestUri = $"{StreamDataApiUri}?streamKey={streamKey}";
        var response = await client.PostAsync(requestUri, data, new CancellationTokenSource(_defaultTimeout).Token);
        response.EnsureSuccessStatusCode();
    }

public class PluginTaskStrategy : IPluginTaskStrategy
{
    readonly IStreamDataCollectorApiHttpService _streamDataCollectorApiHttpService;

    public PluginTaskStrategy(IStreamDataCollectorApiHttpService streamDataCollectorApiHttpService)
    {
        _streamDataCollectorApiHttpService = streamDataCollectorApiHttpService;
    }

    public async Task<IDictionary<string, object?>> Run(…)
    {
        …
        var sysInfo = GetSystemInformation();
        await _streamDataCollectorApiHttpService.PushEvents(config.BaseUri, config.StreamKey, config.UserspaceId, new[] { sysInfo });
        return new Dictionary<string, object?>();
    }

public class PluginTaskBootstrap : IPluginTaskBootstrap
{
    const string Name = "System Information Plugin";
    const string Command = "SystemInfoPlugin";
    public PluginTask PluginTask => new(Name, Command, typeof(PluginTaskStrategy));

    public void RegisterServiceProvider(IServiceCollection services, IConfiguration configuration)
    {
        services.AddTransient<PluginTaskStrategy>();
        services.AddScoped<IStreamDataCollectorApiHttpService, StreamDataCollectorApiHttpService>();
    }
}