IEngineListener.h

Go to the documentation of this file.

/*
* Copyright 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.
*/

#pragma once

#include <string>

#include <OnixS/FIXEngine/ABI.h>
#include <OnixS/FIXEngine/Compiler.h>

namespace OnixS {
namespace FIX {
ONIXS_FIXENGINE_API_DECL(class, FlatMessage);
ONIXS_FIXENGINE_API_DECL(class, Session);

/// Warning reason.
struct EngineWarningReason {
    enum Enum {
        /// General system-related warning.
        GeneralWarning,

        /// First message cannot be received during timeout.
        CannotReceiveFirstMessageDuringTimeout,

        /// Garbled message is received.
        GarbledMessageReceived,

        /// Session state cannot be changed.
        RestoreSessionStateWarning,

        /// License expiration warning.
        LicenseExpiration
    };
};

/// Error reason.
struct EngineErrorReason {
    enum Enum {
        /// Cannot backup the file.
        BackupError,

        /// Exception was thrown during reading of the sent message.
        ErrorWhileReadingSentMessages,

        /// General system-related error.
        GeneralError,

        /// Internal error, please contact support@onixs.biz to investigate the issue.
        InternalError,

        /// Session state cannot be restored.
        RestoreSessionStateError,

        /// Socket options cannot be set.
        SetSocketOptionError
    };
};

/// Engine's Listener.
class ONIXS_FIXENGINE_API IEngineListener
{
public:
    /// @note FIX Engine does NOT manage the lifetime of this listener.
    virtual ~IEngineListener() ONIXS_FIXENGINE_DEFAULT;

    /// Called when an unknown incoming FIX connection is detected.
    ///
    /// To accept the connection dynamic new session may be created in scope of this callback with appropriate
    /// TargetCompID, SenderCompID and FIX version/dialect.
    /// This dynamically created session should be logon as acceptor otherwise the incoming connection will be rejected.
    ///
    /// If the dynamic session will not be created then incoming connection will be rejected and the rejectReason could be specified then the Logout(5) message will be sent to the counterparty.
    ///
    /// @param[in] incomingLogon Incoming Logon message. In general it is needed to examine the content and properties of this message
    /// to create appropriate acceptor.
    ///
    /// @param[in] listenPort Listen port.
    ///
    /// @param[in] counterpartyPort Counterparty port.
    ///
    /// @param[in] counterpartyIpAddress Counterparty IP address.
    ///
    /// @param[out] rejectReason To send the Logout message before closing the rejected connection set the rejection description to this parameter.
    virtual void onUnknownIncomingConnection(const FlatMessage & incomingLogon, const int listenPort,
                                             const int counterpartyPort, const std::string & counterpartyIpAddress,
                                             std::string * rejectReason) = 0;

    /// Called when an error is detected.
    ///
    /// @param[in] reason Error reason.
    ///
    /// @param[in] description Error description.
    virtual void onError(EngineErrorReason::Enum reason, const std::string & description) = 0;

    /// Called when an warning is detected.
    ///
    /// @param[in] reason Warning reason.
    ///
    /// @param[in] description Warning description.
    virtual void onWarning(EngineWarningReason::Enum reason, const std::string & description) = 0;
};
}
}