InstSubject.h

Go to the documentation of this file.

#ifndef WPP_INST_SUBJECT_H_
#define WPP_INST_SUBJECT_H_
 
#include "ItemOp.h"
#include "InstOpObserver.h"
#include "InstEventObserver.h"
 
namespace wpp {
 
class Instance;
 
class InstSubject {
public:
    void opSubscribe(InstOpObserver *observer) {
        if (!observer) return;
        if (std::find(_opObservers.begin(), _opObservers.end(), observer) == _opObservers.end()) 
            _opObservers.push_back(observer);
    }
 
    void opUnsubscribe(InstOpObserver *observer) {
        _opObservers.erase(std::find(_opObservers.begin(), _opObservers.end(), observer));
    }
 
    void eventSubscribe(InstEventObserver *observer) {
        if (!observer) return;
        if (std::find(_eventObservers.begin(), _eventObservers.end(), observer) == _eventObservers.end()) 
            _eventObservers.push_back(observer);
    }
 
    void eventUnsubscribe(InstEventObserver *observer) {
        _eventObservers.erase(std::find(_eventObservers.begin(), _eventObservers.end(), observer));
    }
 
protected:
    void operationNotify(Instance &inst, const ResLink &resLink, ItemOp::TYPE type) {
        for(InstOpObserver *observer : _opObservers) {
            switch (type) {
            case ItemOp::WRITE:
                observer->resourceWrite(inst, resLink);
                break;
            case ItemOp::EXECUTE:
                 observer->resourceExecute(inst, resLink);
                break;
            default: break;
            }
        }
    }
 
    void eventNotify(Instance &inst, EVENT_ID_T eventId) {
        for(InstEventObserver *observer : _eventObservers) observer->instEvent(inst, eventId);
    }
 
private:
    std::vector<InstOpObserver*> _opObservers;
    std::vector<InstEventObserver*> _eventObservers;
};
 
}
 
#endif //WPP_INST_SUBJECT_H_