/* ========================================================================
 * Copyright (c) 2005-2026 The OPC Foundation, Inc. All rights reserved.
 *
 * OPC Foundation MIT License 1.00
 *
 * Permission is hereby granted, free of charge, to any person
 * obtaining a copy of this software and associated documentation
 * files (the "Software"), to deal in the Software without
 * restriction, including without limitation the rights to use,
 * copy, modify, merge, publish, distribute, sublicense, and/or sell
 * copies of the Software, and to permit persons to whom the
 * Software is furnished to do so, subject to the following
 * conditions:
 *
 * The above copyright notice and this permission notice shall be
 * included in all copies or substantial portions of the Software.
 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
 * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES
 * OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
 * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT
 * HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY,
 * WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
 * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR
 * OTHER DEALINGS IN THE SOFTWARE.
 *
 * The complete license agreement can be found here:
 * http://opcfoundation.org/License/MIT/1.00/
 * ======================================================================*/

using System;
using Microsoft.Extensions.Hosting;
using Opc.Ua.WotCon;
using Opc.Ua.WotCon.Client;
using AggregationClient;

try
{
    HostApplicationBuilder builder = Host.CreateApplicationBuilder(args);
    var options = new AggregationClientOptions
    {
        AggregationEndpoint = builder.Configuration["aggregationEndpoint"] ??
            "opc.tcp://localhost:62550/AggregationServer",
        SourceAEndpoint = builder.Configuration["sourceAEndpoint"] ??
            "opc.tcp://localhost:62551/SourceA",
        SourceBEndpoint = builder.Configuration["sourceBEndpoint"] ??
            "opc.tcp://localhost:62552/SourceB",
        DocumentsDirectory = builder.Configuration["documentsDirectory"] ??
            System.IO.Path.Combine(AppContext.BaseDirectory, "Documents")
    };

    AggregationClientResult result = await AggregationClientRunner
        .RunAsync(options)
        .ConfigureAwait(false);

    foreach (WotRegistryDocumentLoadOutcome upload in result.LoadResult.Uploaded)
    {
        Console.WriteLine(
            $"Loaded {upload.Document.Kind} {upload.Document.ResourceId} " +
            $"(version {upload.VersionId}, created: {upload.Created}).");
    }

    WotRegistryRefreshResult refresh = result.LoadResult.Refresh ??
        throw new InvalidOperationException("The registry refresh did not run.");
    Console.WriteLine(
        $"Refresh generation {refresh.NewGeneration}: {refresh.Summary.Outcome}, " +
        $"{refresh.Summary.Succeeded}/{refresh.Summary.Total} succeeded.");
    foreach (WoTResourceLoadResultDataType resource in refresh.Results)
    {
        Console.WriteLine(
            $"  {resource.ResourceId}: {resource.Phase}/{resource.Outcome} " +
            $"({resource.LoadState})");
        if (!string.IsNullOrWhiteSpace(resource.Message))
        {
            Console.WriteLine($"    Message: {resource.Message}");
        }
    }

    Console.WriteLine("Materialized Pump browse:");
    foreach (WotPumpBrowseNode node in result.BrowsedNodes)
    {
        Console.WriteLine($"  {node.NodeId}: {node.DisplayName} ({node.NodeClass})");
    }

    Console.WriteLine("Materialized Pump values:");
    foreach (WotPumpValueResult value in result.Values)
    {
        Console.WriteLine(
            $"  {value.Name}: {value.Value} [{value.StatusCode}]");
    }
}
catch (Exception ex)
{
    Console.Error.WriteLine(ex);
    Console.Error.WriteLine(ex.StackTrace);
    Environment.ExitCode = 1;
}