ClockSynchronization.cs

using System;
using System.Collections.Generic;
using System.Diagnostics;
using System.Text;
using System.Threading.Tasks;
using Waher.Networking.XMPP.Server;
 
namespace Waher.Service.IoTBroker.Synchronization
{
    public static class ClockSynchronization
    {
        internal static Task RequestHandler(object Sender, IqEventArgs e)
        {
            DateTimeHF Now = XmppServerModule.Now;
            StringBuilder Xml = new StringBuilder();
 
            Xml.Append("<resp xmlns='");
            Xml.Append(e.Query.NamespaceURI);
 
            if (Now.Ticks.HasValue)
            {
                Xml.Append("' hf='");
                Xml.Append(Now.Ticks.Value.ToString());
                Xml.Append("' freq='");
                Xml.Append(Stopwatch.Frequency.ToString());
            }
 
            Xml.Append("'>");
            Encode(Now, Xml);
            Xml.Append("</resp>");
 
            e.IqResult(Xml.ToString(), e.To);
 
            return Task.CompletedTask;
        }
 
        public static void Encode(DateTimeHF Timestamp, StringBuilder Xml)
        {
            Xml.Append(Timestamp.Year.ToString("D4"));
            Xml.Append('-');
            Xml.Append(Timestamp.Month.ToString("D2"));
            Xml.Append('-');
            Xml.Append(Timestamp.Day.ToString("D2"));
            Xml.Append('T');
            Xml.Append(Timestamp.Hour.ToString("D2"));
            Xml.Append(':');
            Xml.Append(Timestamp.Minute.ToString("D2"));
            Xml.Append(':');
            Xml.Append(Timestamp.Second.ToString("D2"));
            Xml.Append('.');
            Xml.Append(Timestamp.Millisecond.ToString("D3"));
            Xml.Append(Timestamp.Microsecond.ToString("D3"));
            Xml.Append(Timestamp.Nanosecond100.ToString("D1"));
            Xml.Append('Z');
        }
 
        internal static Task ClockSourceReq(object Sender, IqEventArgs e)
        {
            XmppServer Server = XmppServerModule.Server;
 
            if (!string.IsNullOrEmpty(Server.Domain))
            {
                StringBuilder Xml = new StringBuilder();
 
                Xml.Append("<sourceResp xmlns='");
                Xml.Append(e.Query.NamespaceURI);
                Xml.Append("'>");
                Xml.Append(Server.Domain);
                Xml.Append("</sourceResp>");
 
                e.IqResult(Xml.ToString(), e.To);
            }
            else
                e.IqErrorItemNotFound(e.To, "Clock source not used.", "en");
 
            return Task.CompletedTask;
        }
    }
}