TwsRtdServerTopic.cs

/* Copyright (C) 2018 Interactive Brokers LLC. All rights reserved. This code is subject to the terms
 * and conditions of the IB API Non-Commercial License or the IB API Commercial License, as applicable. */

using System;

namespace TwsRtdServer
{
    // class represents RTD server topic (id, value, string name) (e.g. [25, 177.55, "BID"])
    public class TwsRtdServerTopic
    {
        // vars
        private int m_topicId = -1;
        private Object m_topicValue;
        private string m_topicStr;

        // constructor
        public TwsRtdServerTopic(string topicStr, int topicId)
        {
            m_topicStr = topicStr;
            m_topicId = topicId;
            m_topicValue = "";
        }

        public int TopicId()
        {
            return m_topicId;
        }

        public Object TopicValue()
        {
            return m_topicValue;
        }

        public string TopicStr()
        {
            return m_topicStr;
        }

        public void TopicValue(Object topicValue)
        {
            m_topicValue = topicValue;
        }
        
        public static string ParseTopicStrings(Array strings)
        {
            string topicStr = null;
            if (strings != null)
            {
                foreach (string s in strings)
                {
                    if (topicStr == null && s.ToLower().IndexOf(TwsRtdServerData.QT) >= 0)
                    {
                        // parse string like "qt=Bid"
                        // "qt" string should have priority than topic specified at other places
                        topicStr = s.Substring(TwsRtdServerData.QT.Length, s.Length - TwsRtdServerData.QT.Length).ToUpper();

                        if (Array.IndexOf(TwsRtdServerData.AllowedTopics(), topicStr) >= 0)
                        {
                            return topicStr; 
                        }
                        else
                        {
                            // if invalid "qt" is specified
                            return null; 
                        }
                    }
                    
                    if (topicStr == null && !s.ToLower().Contains(TwsRtdServerData.LOCALSYMBOL_STR) && s.ToLower().Contains(TwsRtdServerData.CHAR_SPACE.ToString()))
                    {
                        // pasre string like "IBM Bid" or "BRK B Bid"
                        topicStr = s.Substring(s.LastIndexOf(TwsRtdServerData.CHAR_SPACE) + 1, s.Length - 1 - s.LastIndexOf(TwsRtdServerData.CHAR_SPACE)).ToUpper();

                        if (Array.IndexOf(TwsRtdServerData.AllowedTopics(), topicStr) >= 0)
                        {
                            return topicStr;
                        }
                        else
                        {
                            topicStr = null;
                            continue;
                        }
                    }

                    if (topicStr == null)
                    {
                        // pasre string like "Bid"
                        topicStr = s.ToUpper();

                        if (Array.IndexOf(TwsRtdServerData.AllowedTopics(), topicStr) >= 0)
                        {
                            return topicStr;
                        }
                        else
                        {
                            topicStr = null;
                            continue;
                        }
                    }

                }
            }

            if (topicStr == null)
            {
                // topic not found, use default
                topicStr = TwsRtdServerData.LAST;
            }

            return topicStr;

        }

    }
}