Genesys.Client.Notifications 6.1.3

You can query asynchronous Genesys Cloud event streams using LINQ operators. Thus you can filter, project, aggregate, compose and perform time-based operations on multiple events easily by using these standard LINQ operators.

C# .NET Standard 2.0 lightweight implementation of the client Genesys Notifications websocket API with default 24 hours reconnection and handling socket closing notification.

• Multiple channels if more than 1000 topics.
• Serialization based on System.Text.Json.
• Logging functionality based on Microsoft.Extensions.Logging.
• User friendly with reactive model programming.

using Genesys.Client.Notifications;

static async Task Main(string[] args)
{            
    using (var topics = new GenesysTopics(genesysConfig, logger))
    {
        using (var notifications = await topics
            .Add<QueueConversationEmailEventTopicEmailConversation>("v2.routing.queues.{id}.conversations.emails", pcIds.Queues)
            .Add<PresenceEventUserPresence>("v2.users.{id}.presence", pcIds.Users)
            .CreateAsync())
        {
            notifications.Streams.Domain
                .OfType<QueueConversationEmailEventTopicEmailConversation>()
                .Subscribe(e => Console.WriteLine("{0} {1}", e.Id, e.Participants.Count));
            notifications.Streams.Domain
                .OfType<PresenceEventUserPresence>()
                .Subscribe(p => Console.WriteLine("Presence {0}", p?.PresenceDefinition?.SystemPresence));
            notifications.Streams.Domain
                .Subscribe(obj => Console.WriteLine(obj.ToString()));
            notifications.Streams.Pong
                .Subscribe(_ => Console.WriteLine("Pong"));
            notifications.Streams.Heartbeats
                .Subscribe(_ => Console.WriteLine("Heart beat"));
            notifications.Streams.SocketClosing
                .Subscribe(_ => Console.WriteLine("Socket closing"));
            notifications.Ping();
            Console.ReadLine();
        }
    }
}