Association.h

/*************************************************************************
 * odil - Copyright (C) Universite de Strasbourg
 * Distributed under the terms of the CeCILL-B license, as published by
 * the CEA-CNRS-INRIA. Refer to the LICENSE file or to
 * http://www.cecill.info/licences/Licence_CeCILL-B_V1-en.html
 * for details.
 ************************************************************************/

#ifndef _a52696bc_5c6e_402d_a343_6cb085eb0138
#define _a52696bc_5c6e_402d_a343_6cb085eb0138

#include <cstdint>
#include <functional>
#include <map>
#include <string>
#include <vector>

#include "odil/AssociationAcceptor.h"
#include "odil/AssociationParameters.h"
#include "odil/dul/StateMachine.h"
#include "odil/message/Message.h"

namespace odil
{

class Association
{
public:
    enum Result
    {
        Accepted=0,
        RejectedPermanent=1,
        RejectedTransient=2,
    };

    enum ResultSource
    {
        ULServiceUser=1,
        ULServiceProviderACSERelatedFunction=2,
        ULServiceProvderPresentationRelatedFunction=3,
    };

    // PS 3.8, 7.1.1.9, and PS 3.8, 9.3.4, and ITU-T X.227 (UL service-user,
    // UL service-provider ACSE-related function), ITU-T X.226 (UL
    // service-provider presentation-related function)
    enum Diagnostic
    {
        // UL service-user
        NoReasonGiven=1,
        ApplicationContextNameNotSupported=2,
        CallingAETitleNotRecognized=3,
        CallingAPInvocationIdentifierNotRecognized=4,
        CallingAEQualifierNotRecognized=5,
        CallingAEInvocationIdentifierNotRecognized=6,
        CalledAETitleNotRecognized=7,
        CalledAPInvocationIdentifierNotRecognized=8,
        CalledAEQualifierNotRecognized=9,
        CalledAEInvocationIdentifierNotRecognized=10,

        // UL service-provider, ACSE-related function
        NoCommonULVersion=2,

        // UL service-provider, presentation-related function
        TemporaryCongestion=1,
        LocalLimitExceeded=2,
        CalledPresentationAddressUnknown=3,
        PresentationProtocolVersionNotSupported=4,
        NoPresentationServiceAccessPointAvailable=7,
    };

    typedef dul::StateMachine::duration_type duration_type;

    Association();

    Association(Association const & other);

    ~Association();

    dul::Transport & get_transport();

    Association & operator=(Association const & other);


    std::string const & get_peer_host() const;
    void set_peer_host(std::string const & host);

    uint16_t get_peer_port() const;
    void set_peer_port(uint16_t port);


    AssociationParameters const & get_parameters() const;

    AssociationParameters & update_parameters();

    void set_parameters(AssociationParameters const & value);

    AssociationParameters const & get_negotiated_parameters() const;


    duration_type get_tcp_timeout() const;

    void set_tcp_timeout(duration_type const & duration);

    duration_type get_message_timeout() const;

    void set_message_timeout(duration_type const & duration);



    bool is_associated() const;

    void associate();

    void receive_association(
        boost::asio::ip::tcp const & protocol, unsigned short port,
        AssociationAcceptor acceptor=default_association_acceptor);

    void reject(Result result, ResultSource result_source, Diagnostic diagnostic);

    void release();
    void abort(int source, int reason);



    message::Message receive_message();

    void send_message(
        message::Message const & message, std::string const & abstract_syntax);

    uint16_t next_message_id();


private:
    dul::StateMachine _state_machine;

    std::string _peer_host;
    uint16_t _peer_port;

    AssociationParameters _association_parameters;
    AssociationParameters _negotiated_parameters;

    std::map<std::string, std::pair<uint8_t, std::string>>
        _transfer_syntaxes_by_abstract_syntax;
    std::map<uint8_t, std::string> _transfer_syntaxes_by_id;

    uint16_t _next_message_id;
};

class AssociationReleased: public Exception
{
public:
    AssociationReleased()
    : Exception("Association released")
    {
        // Nothing else.
    }
};

class AssociationAborted: public Exception
{
public:
    uint8_t source;
    
    uint8_t reason;
    
    AssociationAborted(unsigned char source, unsigned char reason)
    : Exception("Association aborted"), source(source), reason(reason)
    {
        // Nothing else.
    }
};

}

#endif // _a52696bc_5c6e_402d_a343_6cb085eb0138