C:/Users/Pasha/_Dev/fixforge-cpp/fix/cppEngine/include/OnixS/FIX/Session.h

/*
* Copyright 2005-2011 Onix Solutions Limited [OnixS]. All rights reserved. 
* 
* This software owned by Onix Solutions Limited [OnixS] and is protected by copyright law 
* and international copyright treaties. 
* 
* Access to and use of the software is governed by the terms of the applicable ONIXS Software
* Services Agreement (the Agreement) and Customer end user license agreements granting 
* a non-assignable, non-transferable and non-exclusive license to use the software 
* for it's own data processing purposes under the terms defined in the Agreement.
* 
* Except as otherwise granted within the terms of the Agreement, copying or reproduction of any part 
* of this source code or associated reference material to any other location for further reproduction
* or redistribution, and any amendments to this copyright notice, are expressly prohibited. 
*
* Any reproduction or redistribution for sale or hiring of the Software not in accordance with 
* the terms of the Agreement is a violation of copyright law. 
*/

#if !defined(__ONIXS_SESSION_H__)
#define __ONIXS_SESSION_H__

#include <string>

#include "OnixS/FIX/ABI.h"
#include "OnixS/FIX/Definitions.h"
#include "OnixS/FIX/Engine.h"

namespace OnixS
{
    namespace FIX
    {
        ONIXS_FIXENGINE_API_DECL(class, Message);
        ONIXS_FIXENGINE_API_DECL(class, Dialect);
        ONIXS_FIXENGINE_API_DECL(class, Engine);
        ONIXS_FIXENGINE_API_DECL(class, ISessionListener);
        ONIXS_FIXENGINE_API_DECL(class, ISessionStorage);

        class ONIXS_FIXENGINE_API Session
        {
        public: 
            enum SessionStorageType
            {
                FileBasedStorage, 
                MemoryBasedStorage, 
                PluggableStorage 
            };

            static const char* storageType2String(SessionStorageType value);

            Session(const std::string& senderCompId, const std::string& targetCompId, Version version, bool keepSequenceNumbersAfterLogout, 
                OnixS::FIX::ISessionListener* listener, SessionStorageType storageType = FileBasedStorage, ISessionStorage* storage = NULL);

            Session(const std::string& senderCompId, const std::string& targetCompId, Version version, ISessionListener* listener,
                SessionStorageType storageType = FileBasedStorage, ISessionStorage* storage = NULL);

            Session(const std::string& senderCompId, const std::string& targetCompId, const Dialect& dialect, ISessionListener* listener,
                SessionStorageType storageType = FileBasedStorage, ISessionStorage* storage = NULL);

            Session(const std::string& senderCompId, const std::string& targetCompId, const Dialect& dialect, bool keepSequenceNumbersAfterLogout, 
                OnixS::FIX::ISessionListener* listener, SessionStorageType storageType = FileBasedStorage, ISessionStorage* storage = NULL);

            Session(const std::string& senderCompId, const std::string& targetCompId, Version version, bool keepSequenceNumbersAfterLogout, 
                OnixS::FIX::ISessionListener* listener, const std::string& customSessionKey, SessionStorageType storageType = FileBasedStorage, 
                ISessionStorage* storage = NULL);

            Session(const std::string& senderCompId, const std::string& targetCompId, const Dialect& dialect, bool keepSequenceNumbersAfterLogout, 
                OnixS::FIX::ISessionListener* listener, const std::string& customSessionKey, SessionStorageType storageType = FileBasedStorage, 
                ISessionStorage* storage = NULL);


            ~Session(); 

            enum State{DISCONNECTED, LOGON_IN_PROGRESS, LOGOUT_IN_PROGRESS, ACTIVE, RECONNECTING};

            void clearOutboundQueue();

            State getState();   

            static const char* state2string(State state);

            enum EncryptionMethod{
                NONE, 
                SSL 
            };

            EncryptionMethod getEncryptionMethod() const;

            void setEncryptionMethod(EncryptionMethod newEncryptionMethod);

            int getListenPort() const;

            void setListenPort(int listenPort);

            void setLocalNetworkInterface(const std::string& localNetworkInterface);

            const std::string& getLocalNetworkInterface();

            void setTcpNoDelayOption(bool value = true);

            bool getTcpNoDelayOption() const;

            void setSslCertificateFile(const std::string& file);

            void setSslPrivateKeyFile(const std::string& file);

            void setSslPrivateKeyPassword(const std::string& password);

            void logonAsAcceptor();

            void logonAsInitiator(const std::string& host, int port, bool setResetSeqNumFlag);

            void logonAsInitiator(const std::string& host, int port);

            void logonAsInitiator(const std::string& host, int port, int heartBtInt);

            void logonAsInitiator(const std::string& host, int port, int heartBtInt, bool setResetSeqNumFlag);

            void logonAsInitiator(const std::string& host, int port, int heartBtInt, Message* customLogonMsg);

            void logonAsInitiator(const std::string& host, int port, int heartBtInt, Message* customLogonMsg, bool setResetSeqNumFlag);

            void logout();

            void logout(const std::string& text);

            void logout(Message * customLogoutMessage);

            void breakConnection();

            void send(Message* message);

            void shutdown();

            operator const std::string& ();

            const std::string& getStorageID();

            std::string getCounterpartyHost();

            std::string getCounterpartyIpAddress();

            size_t getCounterpartyPort();

            const std::string& getCustomKey() const;

            size_t getOutboundQueueBytes();

            size_t getOutboundQueueCount();

            int getHeartBtInt();

            bool getLogInboundMessages() const;

            void setLogInboundMessages(bool value);

            bool getLogOutboundMessages() const;

            void setLogOutboundMessages(bool value);

            int getInSeqNum();

            void setInSeqNum(int seqNum);       

            int getOutSeqNum();

            void setOutSeqNum(int seqNum);

            System::ThreadId getReceivingThreadId() const;  

            enum Role{NA, INITIATOR, ACCEPTOR};

            Role getRole();

            const std::string& getSenderCompID();

            System::ThreadId getSendingThreadId() const;

            const std::string& getTargetCompID();

            Version getVersion();

            const Dialect& dialect();

            Message* findSentMessage(int messageSequenceNumber);

            void registerListener(ISessionListener* listener);

            void unregisterListener();

            void reset();

            void resetSeqNumViaLogonExchange();

            void senderSubID(const std::string& value);

            void targetSubID(const std::string& value);

            void senderLocationID(const std::string& value);

            void targetLocationID(const std::string& value);

            void sendTestRequest(const std::string& testReqID = "");

            struct Impl; 

        private:        
            void init(const std::string& senderCompId, const std::string& targetCompId, Version version, ISessionListener* listener,
                bool keepSequenceNumbersAfterLogout, SessionStorageType storageType, ISessionStorage* storage, const std::string& customSessionKey);

            void init(const std::string& senderCompId, const std::string& targetCompId, const std::string& dialectId, ISessionListener* listener,
                bool keepSequenceNumbersAfterLogout, SessionStorageType storageType, ISessionStorage* storage, const std::string& customSessionKey);

            Session(void* native);

            Impl* impl_;        

            friend struct Engine::Impl;
        };
    }
}

#endif // __ONIXS_SESSION_H__