using System;
using System.Collections.Generic;
using System.Text;
using Caplin.StreamLink;
using Caplin.StreamLink.Authentication;
using Caplin.StreamLink.Subscription.Record;

namespace StreamLinkExamples.Record
{
    /// <summary>
    /// Various examples of how to create an IRecordSubscription using the
    /// IStreamLinkProvider interface.
    /// </summary>
    public class CreateRecordSubscriptionWithFilteringAndFields
    {
        /// <summary>
        /// Subscribe to a record and specify fields and filter on one of those fields.
        /// </summary>
        public static void CreateRecordSubscriptionWithFilteringAndFieldsExample()
        {
            IStreamLink myStreamLink = new StreamLink();
            myStreamLink.CredentialsProvider = new PasswordCredentialsProvider("admin", "admin");

            IRecordSubscriptionListener subscriptionListener = new ExampleRecordSubscriptionListener();

            // Specify fields and filter
            string[] fields = new string[] { "Bid", "Ask" };
            string filter = "Bid>10";
            IRecordSubscriptionParameters recordParameters =
                myStreamLink.StreamLinkProvider.ParametersFactory.CreateRecordSubscriptionParameters(fields, filter);

            IRecordSubscription subscription =
                myStreamLink.StreamLinkProvider.CreateRecordSubscription(subscriptionListener,
                                                                         "/DEMO/MSFT");

            subscription.Subscribe();

            myStreamLink.StreamLinkProvider.Connect();
        }
    }
}