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

namespace StreamLinkExamples.Page
{
    public class CreatePageSubscriptionFull
    {
        // Subscription Listener class to be informed about all Subscription information
        class MyPageSubscriptionListener : IPageSubscriptionListener
        {
            #region IPageSubscriptionListener Members

            void IPageSubscriptionListener.PageUpdated(ISubscription subscription, IPageEvent ev)
            {
                // Process update
                Console.WriteLine("Page Updated received for \"" +
                                  ev.Subject + "\"");


                IPageCoordinate pageCoordinate = null;

                foreach (var pair in ev.PageData.DataSlice)
                {
                    pageCoordinate = pair.Key;
                    Console.WriteLine("Page coordinate being updated:  Max Rows: {0}\tMax Columns: {1}\tRow Number: {2}\tColumn Number: {3}\tValue; {4}", ev.PageData.MaxX, ev.PageData.MaxY, pageCoordinate.YPos, pageCoordinate.XPos, pair.Value);
                }
            }

            #endregion

            #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
        }

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

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

            // Create Listener object
            IPageSubscriptionListener listener = new MyPageSubscriptionListener();

            //Create row parameter
            IPageSubscriptionParameters parameters = myStreamLink.StreamLinkProvider.ParametersFactory.CreatePageSubscriptionParameters(new int[] { 3, 5, 7, 11 });

            //subscribes to all Rows
            //Parameters = myStreamLink.StreamLinkProvider.ParametersFactory.CreatePageSubscriptionParameters(new int[] { });


            IPageSubscription mySubscription = myStreamLink.StreamLinkProvider.CreatePageSubscription(listener,
                                                                                                          "/DEMO/PAGE1",
                                                                                                          parameters);

            // Finally, subscribe
            mySubscription.Subscribe();

            // Sleep so we see some updates being received.
            Thread.Sleep(20000);


            mySubscription.Unsubscribe();
            myStreamLink.StreamLinkProvider.Disconnect();

        }

    }
}