ClockDiff.cs

using System;
using System.Text;
using System.Threading.Tasks;
using Waher.IoTGateway;
 
namespace Waher.Service.IoTBroker.Admin.Runtime
{
    public class ClockDiff : CommandOneParameter
    {
        public ClockDiff()
            : base()
        {
        }
 
        public override string Name => "ClockDiff";
 
        public override async Task Execute(ChatState State, string[] Arguments, string OrgMessage, ResponseCallbackHandler ResponseCallback)
        {
            if (Gateway.SynchronizationClient is null)
                await XmppServerModule.SendErrorMessage("No synchronization client available.", string.Empty, ResponseCallback);
            else
            {
                Networking.XMPP.Synchronization.SynchronizationEventArgs e =
                    await Gateway.SynchronizationClient.MeasureClockDifferenceAsync(Arguments[0]);
 
                if (e.Ok)
                {
                    StringBuilder sb = new StringBuilder();
                    TimeSpan ClockDiff = TimeSpan.FromSeconds(e.ClockDifference100Ns * 1e-7);
 
                    sb.Append("Difference: ");
                    sb.Append(ClockDiff.ToString());
                    sb.Append(", Latency: ");
                    sb.Append((e.Latency100Ns * 1e-7).ToString("F3"));
                    sb.Append(" s");
 
                    await ResponseCallback(sb.ToString(), string.Empty);
                }
                else
                {
                    await XmppServerModule.SendErrorMessage(string.IsNullOrEmpty(e.ErrorText) ? "Unable to measure clock difference." : e.ErrorText,
                        string.Empty, ResponseCallback);
                }
            }
        }
 
        public override string ParameterName => "SOURCE";
 
        public override string[] HelpParagraphs => new string[] { "Measures the difference in clocks, as well as network latency, between the broker and the `SOURCE`." };
    }
}