using System;
using System.Collections.Generic;
using System.Text;
using Caplin.StreamLink.Subscription;
using Caplin.StreamLink;
using Caplin.StreamLink.Configuration;
using Caplin.StreamLink.Authentication;
using System.Threading;
using Caplin.StreamLink.Logging;
using Caplin.StreamLink.Subscription.Chat;
using Caplin.StreamLink.Command;

namespace StreamLinkExamples.Chat
{
    public class CreateChatSubscription
    {
        // Subscription Listener class to be informed about all Subscription information
        class MyChatListener : IChatSubscriptionListener, ICommandListener
        {
            #region ISubscriptionListener Members

            public void SubscriptionErrorReceived(ISubscription subscription, ISubscriptionErrorEvent ev)
            {
                // Process Subscription error
                Console.WriteLine("Subscription Status Update " + ev.Subject + " Error: " + ev.Error.ToString());
            }

            public void SubscriptionStatusUpdated(ISubscription subscription, ISubscriptionStatusEvent status)
            {
                // Process Subscription status callback
                Console.WriteLine("Subscription Status Update " + status.Subject + " Status: " + status.Status.ToString() + " " + status.Message);
            }

            #endregion

            #region IChatSubscriptionListener Members

            void IChatSubscriptionListener.ChatMessageReceived(ISubscription subscription, IChatEvent ev)
            {
                String msg = String.Format("{0}: chat message received from {1}: {2}", ev.Time, ev.User, ev.Message);
                Console.WriteLine(msg);
            }

            void IChatSubscriptionListener.ChatUserLoggedIn(ISubscription subscription, IChatEvent ev)
            {
                String msg = String.Format("{0}: user {1} joins the chat", ev.Time, ev.User);
                Console.WriteLine(msg);
            }

            void IChatSubscriptionListener.ChatUserLoggedOut(ISubscription subscription, IChatEvent ev)
            {
                String msg = String.Format("{0}: user {1} leaves the chat", ev.Time, ev.User);
                Console.WriteLine(msg);
            }

            void IChatSubscriptionListener.ChatUsernameNotification(ISubscription subscription, IChatEvent ev)
            {
                String msg = String.Format("{0}: successfully logged into chat. Username is {0}", ev.Time, ev.User);
                Console.WriteLine(msg);
            }

            #endregion

            #region ICommandListener Members

            void ICommandListener.CommandSuccess(ICommandResultEvent ev)
            {
                String msg = String.Format("Successfully published chat message to chat object {0}", ev.Subject);
                Console.WriteLine(msg);
            }

            void ICommandListener.CommandError(ICommandResultEvent ev)
            {
                String msg = String.Format("Was not able to publish chat message to chat object {0}. Result was {1}", ev.Subject, ev.Result.ToString());
                Console.WriteLine(msg);
            }

            #endregion
        }

        // Main execution method
        static void Example()
        {
            // Create basic streamlink
            IStreamLinkConfiguration myConfiguration = SimpleConfiguration.CreateType2HttpConnection("localvm", 45260);
            IStreamLink myStreamLink = new StreamLink(myConfiguration);
            myStreamLink.CredentialsProvider = new PasswordCredentialsProvider("admin", "admin");
            myStreamLink.StreamLinkProvider.Connect();

            //uncomment to include logging
            myStreamLink.Logger = new ConsoleLogger();

            // Create a listener object for chat updates and command callbacks
            IChatSubscriptionListener chatListener = new MyChatListener();

            // Create a chat subscription and subscribe to it
            IChatSubscription subscription = myStreamLink.StreamLinkProvider.CreateChatSubscription(chatListener, "/MyChat");
            subscription.Subscribe();

            // Send a few chat messages
            for (int i = 1; i < 4; i++)
            {
                IPublishParameters parameters = myStreamLink.StreamLinkProvider.ParametersFactory.CreateChatPublishParameters("This is chat message number " + i);
                myStreamLink.StreamLinkProvider.Publish(chatListener as ICommandListener, "/MyChat", parameters);

                Thread.Sleep(1500);
            }

            Thread.Sleep(30000);

            // Discard chat object (other users in the chat room will receive a logout notification)
            subscription.Unsubscribe();

            // Log out of StreamLink
            myStreamLink.StreamLinkProvider.Disconnect();
        }
    }
}