ComponentSynchronization.cs

using System;
using System.Threading.Tasks;
using Waher.Events;
using Waher.IoTGateway;
using Waher.Networking.XMPP.Server;
using Waher.Persistence;
 
namespace Waher.Service.IoTBroker.Synchronization
{
    public static class ComponentSynchronization
    {
        public static async Task SendMessage(CaseInsensitiveString Sender, CaseInsensitiveString Recipient,
            CaseInsensitiveString RecipientServer, string Xml)
        {
            DateTime TP = DateTime.UtcNow;
            SynchronizationMessage Message = new SynchronizationMessage()
            {
                Sender = Sender,
                Recipient = Recipient,
                RecipientServer = RecipientServer,
                Xml = Xml,
                Created = TP,
                NextAttempt = TP.AddHours(1),
                NrAttempts = 1
            };
 
            await Database.Insert();
 
            await SendMessage(Message);
        }
 
        internal static async Task QueueUnprocessedMessages()
        {
            foreach (SynchronizationMessage Message in await Database.Find<SynchronizationMessage>())
            {
                DateTime TP = Message.NextAttempt.ToLocalTime();
 
                if (TP <= DateTime.Now)
                    await ResendMessage(Message);
                else
                    Gateway.ScheduleEvent(ResendMessage, TP, Message);
            }
        }
 
        private static async Task ResendMessage(object State)
        {
            if (!(State is SynchronizationMessage Message))
                return;
 
            Message.NrAttempts++;
            Message.NextAttempt = DateTime.UtcNow.AddHours(Message.NrAttempts);
 
            await Database.Update(Message);
 
            await SendMessage(Message);
        }
 
        private static async Task SendMessage(SynchronizationMessage Message)
        {
            try
            {
                IqResultEventArgs e = await XmppServerModule.Server.IqRequest("set", Message.Sender, Message.Recipient, 
                    string.Empty, Message.Xml);
 
                if (e.Ok)
                    await Database.Delete(Message);
                else
                {
                    await XmppServerModule.Server.SendMessage(string.Empty, string.Empty, Message.Sender, Message.Recipient,
                        string.Empty, Message.Xml);
 
                    Gateway.ScheduleEvent(ResendMessage, Message.NextAttempt.ToLocalTime(), Message);
                }
            }
            catch (Exception ex)
            {
                Log.Exception(ex);
            }
        }
    }
}