using System;
using System.Collections.Generic;
using System.Text;
using Caplin.StreamLink.Subscription.Directory;
using Caplin.StreamLink.Subscription;

namespace StreamLinkExamples.Directory
{
    public class ExampleDirectorySubscriptionListener: IDirectorySubscriptionListener
    {
        #region IDirectorySubscriptionListener Members

        /// <summary>
        /// Called when the directory contents changes.
        /// </summary>
        /// <param name="subscription">The subscription.</param>
        /// <param name="ev">The event.</param>
        /// <remarks>
        /// Updated occur subjects have been added to the directory and / or existing subjects may have been removed.
        /// </remarks>
        public void DirectoryUpdated(ISubscription subscription, IDirectoryEvent ev)
        {
            Console.WriteLine("DirectoryUpdated received for \"" +
                              ev.Subject + "\"");

            Console.WriteLine("Added: ");
            foreach (IDirectoryElement dirEl in ev.AddedElements)
            {
                Console.WriteLine("Subject: " + dirEl.Subject +
                                  ", Type: " + dirEl.SubjectType.ToString());
            }
        }

        #endregion

        #region ISubscriptionListener Members

        /// <summary>
        /// Subscription Ended Callback. For 'not found', 'read denied' etc.
        /// </summary>
        public void SubscriptionErrorReceived(ISubscription subscription,
                                              ISubscriptionErrorEvent ev)
        {
            Console.WriteLine("Subscription Status Update " + ev.Subject +
                               " Error: " + ev.Error.ToString());
        }

        /// <summary>
        /// Status Callback
        /// </summary>
        public void SubscriptionStatusUpdated(ISubscription subscription,
                                              ISubscriptionStatusEvent ev)
        {
            Console.WriteLine("Subscription Status Update " + ev.Subject +
                              " Status: " + ev.Status.ToString() +
                              " " + ev.Message);
        }

        #endregion
    }
}