namespace OpcLabsTest
{
    using System;
    using System.Collections.Generic;
    using System.Linq;
    using System.Threading;
    using System.Threading.Tasks;
    using OpcLabs.EasyOpc;
    using OpcLabs.EasyOpc.DataAccess;
    using OpcLabs.EasyOpc.DataAccess.OperationModel;
 
    public class Program
    {
        static public void Main(string[] args)
        {
            EasyDAClient.SharedParameters.TopicParameters.SlowdownWeight = 0.0f;
            EasyDAClient.SharedParameters.TopicParameters.SpeedupWeight = 0.0f;
 
            OpcClient.InstanceParameters.Mode.AllowAsynchronousMethod = false;
            OpcClient.InstanceParameters.UpdateRates.ReadAutomatic = Timeout.Infinite;
            OpcClient.InstanceParameters.UpdateRates.WriteAutomatic = Timeout.Infinite;
 
            Subscribe();
 
            for (int i = 0; i < 500; ++i)
            {
                Task.Run(() => PullingCollectorThread(i));
                Thread.Sleep(500);
            }
 
            Console.WriteLine("Test started");
            Console.ReadKey();
        }
 
        static private void PullingCollectorThread(int id)
        {
 
            while (true)
            {
                var cache = new List<DAVtqResult>();
                DAVtqResult[] results = OpcClient.ReadMultipleItems(new[]
                        {
                    GetDATagArguments("WTG10.Int1"),
                    GetDATagArguments("WTG10.Alm"),
                    GetDATagArguments("WTG10.Bool"),
                    GetDATagArguments("WTG10.Int2"),
                    GetDATagArguments("WTG10.Int4"),
                    GetDATagArguments("WTG10.String1"),
                    GetDATagArguments("WTG10.Time"),
                    GetDATagArguments("WTG10.Time1"),
                    GetDATagArguments("WTG1.Alm"),
                    GetDATagArguments("WTG1.Bool"),
                    GetDATagArguments("WTG1.Int1"),
                    GetDATagArguments("WTG1.Int2"),
                    GetDATagArguments("WTG1.Int4"),
                    GetDATagArguments("WTG1.String1"),
                    GetDATagArguments("WTG1.Time"),
                    GetDATagArguments("WTG1.Time1"),
                });
 
                if (results.First().Succeeded)
                {
                    Console.WriteLine($"Test #{id} WTG10.Int1: {results[0].Vtq.Value}({results[0].Vtq.Quality})");
                }
                else
                {
                    Console.WriteLine($"Test #{id} Error happened: {results[0].Exception.Message}");
                }
 
                cache.Add(results[0]);
                Thread.Sleep(2000);
            }
        }
 
        static private void Subscribe()
        {
            var opcClient = new EasyDAClient();
            opcClient.ItemChanged += OnSubscriptionDataChanged;
 
            const string itemId = "WTG10.Int1";
            opcClient.SubscribeMultipleItems(
                new[] {
                    new EasyDAItemSubscriptionArguments(
                        new DAItemGroupArguments(
                            ServerDescriptor,
                            new DAItemDescriptor(itemId),
                            new DAGroupParameters(requestedUpdateRate:2 * 1000, percentDeadband: 0),
                            state:itemId)
                    )});
        }
 
        static private void OnSubscriptionDataChanged(object state, EasyDAItemChangedEventArgs args)
        {
            Console.WriteLine(args);
        }
 
        static private DAReadItemArguments GetDATagArguments(string tag)
        {
            return new DAReadItemArguments(ServerDescriptor, tag);
        }
 
        static private readonly EasyDAClient OpcClient = new EasyDAClient();
        static private readonly ServerDescriptor ServerDescriptor = "opcda://10.1.0.6/Matrikon.OPC.Simulation.1";
    }
}

EasyDAClient.SharedParameters.TopicParameters.SlowdownWeight = 0.0f;
EasyDAClient.SharedParameters.TopicParameters.SpeedupWeight = 0.0f;
 
EasyDAClient.AdaptableParameters.Mode.AllowAsynchronousMethod = false;
EasyDAClient.AdaptableParameters.UpdateRates.ReadAutomatic = Timeout.Infinite;
EasyDAClient.AdaptableParameters.UpdateRates.WriteAutomatic = Timeout.Infinite;