USignals.h

#ifndef _USIGNALS_H
#define _USIGNALS_H
// -------------------------------------------------------------------------
#include <sigc++/sigc++.h>
#include <UniSetTypes.h>
#include <MessageType.h>
#include <glibmm/ustring.h>
#include <glibmm/convert.h>
#include <ctime>
// -------------------------------------------------------------------------
class GuiPM;

namespace USignals 
{
class ValueMapItem;
} //namespace USingnals

namespace UMessages
{
struct MessageId
{
    MessageId(UniSetTypes::ObjectId id,
            UniSetTypes::ObjectId node,
            long value ):
        _id(id), _node(node), _value(value) {}
    MessageId() :
        _id(UniSetTypes::DefaultObjectId),
        _node(UniSetTypes::DefaultObjectId)
    {}
    UniSetTypes::ObjectId _id;
    UniSetTypes::ObjectId _node;
    long _value;
    bool operator==(const MessageId& x) const
    { return ( _id == x._id && _node == x._node && _value == x._value );}
    bool operator!=(const MessageId& x) const
    { return !(*this==x); }
    bool operator<(const MessageId& x)const {
        if (_id < x._id) return true;
        if (_id > x._id) return false;
        if (_node < x._node) return true;
        if (_node > x._node) return false;
        if (_value < x._value) return true;
        else return false;
    }
};
class Message
{
public:
    Message(const USignals::ValueMapItem& item, const UMessages::MessageId& id) : _item(&item), id_(id)  {}

    Message() : _item(NULL) {}

    MessageId getMessageId() const;     
    time_t getLastTime() const;     
    time_t getTimeUsec() const;     
    const Glib::ustring& getText() const;   
    int getMessageType() const;     
    bool valid() const;         
private:
    const USignals::ValueMapItem* _item;
    const UMessages::MessageId id_;
};
enum MessageType { INFO=1, WARNING=2, ALARM=3 };
} //namespace UMessages

namespace USignals
{
class SigControllerImpl;

typedef sigc::slot<void, UniSetTypes::ObjectId, UniSetTypes::ObjectId, long>
    ValueChangedSlot;
typedef sigc::slot<void, UniSetTypes::ObjectId, UniSetTypes::ObjectId, float>
    AnalogValueChangedSlot;
typedef sigc::slot<void, UniSetTypes::ObjectId, UniSetTypes::ObjectId, long>
    ValueInOutSlot;
typedef sigc::slot<void, UMessages::MessageId, Glib::ustring> MessageSlot;
typedef sigc::slot<void, UMessages::MessageId, int, time_t, Glib::ustring> FullMessageSlot;

typedef sigc::signal<void, UniSetTypes::ObjectId, UniSetTypes::ObjectId, long>
    ValueChangedSignal;
typedef sigc::signal<void, UniSetTypes::ObjectId, UniSetTypes::ObjectId, float>
    AnalogValueChangedSignal;
typedef sigc::signal<void, UniSetTypes::ObjectId, UniSetTypes::ObjectId, long>
    ValueInOutSignal;
typedef sigc::signal<void, UMessages::MessageId, Glib::ustring> MessageSignal;

typedef sigc::signal<void, UMessages::MessageId, int, time_t, Glib::ustring> FullMessageSignal;

class Connection : public sigc::connection
{
public:
    Connection( ) {}

    Connection( sigc::connection conn) :
        sigc::connection(conn)
    {}

    virtual void disconnect()
    {
        sigc::connection::disconnect();
    }
};
struct VConn
{
    sigc::connection conn;
    UniSetTypes::ObjectId id;
    UniSetTypes::ObjectId node;
    long value;
    void disconnect();
};
// -------------------------------------------------------------------------
class SigController
{
public:
    SigController(GuiPM* gpm);
    ~SigController();
    Connection connect_value_changed( const ValueChangedSlot& slot,
            UniSetTypes::ObjectId id,
            UniSetTypes::ObjectId node );
    Connection connect_analog_value_changed( const AnalogValueChangedSlot& slot,
            UniSetTypes::ObjectId id,
            UniSetTypes::ObjectId node );
    VConn connect_value_in( const ValueInOutSlot& slot,
            UniSetTypes::ObjectId id,
            UniSetTypes::ObjectId node,
            long value);
    VConn connect_value_out( const ValueInOutSlot& slot,
            UniSetTypes::ObjectId id,
            UniSetTypes::ObjectId node,
            long value);
    Connection connect_on_any_message( const MessageSlot& slot);
    Connection connect_on_message( const MessageSlot& slot,
            UMessages::MessageId id);
    Connection connect_on_any_message_full ( const FullMessageSlot& slot );
    long get_value(UniSetTypes::ObjectId id, UniSetTypes::ObjectId node);
    long get_value_from_gpm(UniSetTypes::ObjectId id, UniSetTypes::ObjectId node);
    float get_analog_value(UniSetTypes::ObjectId id, UniSetTypes::ObjectId node);
    UMessages::Message get_message( const UMessages::MessageId& id);
    std::list<UMessages::Message > get_message_list( const UMessages::MessageId& id);
    void sensorInfo(UniSetTypes::SensorMessage *sm);
    void on_connect();
private:
    SigController();
    SigControllerImpl* _impl;
};

} //namespace USignals
#endif