radio/lib/wModel/model.cpp

#include "model.h"

M::Model::Model(const W::Address p_address, QObject* parent):
    QObject(parent),
    address(p_address),
    registered(false),
    subscribers(new Map()),
    connector(0),
    subscribersCount(0),
    handlers(new HList()),
    properties(new W::Vector()),
    models(new MList()),
    controllers(new Controllers())
{
    W::Handler* subscribe = W::Handler::create(address + W::Address({u"subscribe"}), this, &M::Model::_h_subscribe);
    W::Handler* unsubscribe = W::Handler::create(address + W::Address({u"unsubscribe"}), this, &M::Model::_h_unsubscribe);
    addHandler(subscribe);
    addHandler(unsubscribe);
}

M::Model::~Model()
{
    if (registered) {
        getUnregistered();
    }
    
    MList::iterator itr = models->begin();
    MList::iterator end = models->end();
        
    for (; itr != end; ++itr) {
        delete *itr;
    }
    
    HList::iterator hItr = handlers->begin();
    HList::iterator hEnd = handlers->end();
        
    for (; hItr != hEnd; ++hItr) {
        delete *hItr;
    }
    
    Controllers::iterator cItr = controllers->begin();
    Controllers::iterator cEnd = controllers->end();
    
    for (; cItr != cEnd; ++cItr) {
        delete cItr->first;
    }

    delete subscribers;
    delete properties;
    delete handlers;
    delete models;
    delete controllers;
}

void M::Model::addModel(M::Model* model)
{
    models->push_back(model);
    connect(model, SIGNAL(serviceMessage(const QString&)), SIGNAL(serviceMessage(const QString&)));
    if (registered) {
        model->getRegistered(connector);
    }
}

void M::Model::addHandler(W::Handler* handler)
{
    handlers->push_back(handler);
    if (registered) {
        connector->registerHandler(handler);
    }
}

void M::Model::addProperty(const W::String& value, const W::String& name)
{
    W::Vocabulary vc;
    vc.insert(u"key", name);
    vc.insert(u"property", value);
    
    properties->push(vc);
    
    if (registered) {
        W::Vocabulary* nvc = new W::Vocabulary;
        nvc->insert(u"properties", *properties);
        broadcast(nvc, W::Address({u"properties"}));
    }
}


W::Address M::Model::getAddress() const
{
    return address;
}


void M::Model::getRegistered(U::Connector* cn)
{
    if (registered) {
        emit serviceMessage(QString("Model ") + address.toString().c_str() + " is already registered");
        throw 1;
    } else {
        connector = cn;
        
        MList::iterator itr = models->begin();
        MList::iterator end = models->end();
        
        for (; itr != end; ++itr) {
            M::Model* model = *itr;
            model->getRegistered(connector);
        }
        
        HList::iterator hItr = handlers->begin();
        HList::iterator hEnd = handlers->end();
        
        for (; hItr != hEnd; ++hItr) {
            W::Handler* handler = *hItr;
            connector->registerHandler(handler);
        }
        
        Controllers::iterator cItr = controllers->begin();
        Controllers::iterator cEnd = controllers->end();
        
        for (; cItr != cEnd; ++cItr) {
            connector->registerController(cItr->first, cItr->second);
        }
        
        registered = true;
    }
}

void M::Model::getUnregistered()
{
    if (!registered) {
        emit serviceMessage(QString("Model ") + address.toString().c_str() + " is not registered");
        throw 2;
    } else {
        MList::iterator itr = models->begin();
        MList::iterator end = models->end();
        
        for (; itr != end; ++itr) {
            Model* model = *itr;
            model->getUnregistered();
        }
        
        HList::iterator hItr = handlers->begin();
        HList::iterator hEnd = handlers->end();
        
        for (; hItr != hEnd; ++hItr) {
            W::Handler* handler = *hItr;
            connector->unregisterHandler(handler);
        }
        
        Map::iterator sItr = subscribers->begin();
        Map::iterator sEnd = subscribers->end();
        
        for (; sItr != sEnd; ++sItr) {
            const W::Socket* socket = connector->getConnection(sItr->first);
            disconnect(socket, SIGNAL(disconnected()), this, SLOT(onSocketDisconnected()));
        }
        subscribers->clear();
        subscribersCount = 0;
        
        Controllers::iterator cItr = controllers->begin();
        Controllers::iterator cEnd = controllers->end();
        
        for (; cItr != cEnd; ++cItr) {
            connector->unregisterController(cItr->first, cItr->second);
        }
        
        connector = 0;
        
        registered = false;
    }
    
}

void M::Model::h_subscribe(const W::Event& ev)
{
    uint64_t id = ev.getSenderId();
    const W::Vocabulary& vc = static_cast<const W::Vocabulary&>(ev.getData());
    const W::Address& source = static_cast<const W::Address&>(vc.at(u"source"));
    W::Vocabulary params;
    if (vc.has(u"params")) {
        params = static_cast<const W::Vocabulary&>(vc.at(u"params"));
    }
    
    Map::iterator sItr = subscribers->find(id);
    
    if (sItr == subscribers->end()) {
        std::pair<Map::iterator, bool> pair = subscribers->emplace(std::make_pair(id, SMap()));
        if (!pair.second) {
            emit serviceMessage(QString("Model ") + address.toString().c_str() + ": something completely wrong happened");
            throw 3;
        }
        const W::Socket* socket = connector->getConnection(id);
        connect(socket, SIGNAL(disconnected()), this, SLOT(onSocketDisconnected()));
        sItr = pair.first;
    }
    SMap::const_iterator oItr = sItr->second.find(source);
    if (oItr != sItr->second.end()) {
        emit serviceMessage(QString("Socket ") + id + 
                            " subscriber " + source.toString().c_str() + 
                            " is already subscribed to model " + source.toString().c_str());
        throw 4;
    }
    
    sItr->second.insert(std::make_pair(source, params));
    ++subscribersCount;
    
    W::Vocabulary* nvc = new W::Vocabulary();
    nvc->insert(u"properties", *properties);
    
    response(nvc, W::Address({u"properties"}), ev);
    emit serviceMessage(QString("Model ") + address.toString().c_str() + ": now has " + std::to_string(subscribersCount).c_str() + " subscribers");
    emit subscribersCountChange(subscribersCount);
}

void M::Model::onSocketDisconnected()
{
    W::Socket* socket = static_cast<W::Socket*>(sender());
    disconnect(socket, SIGNAL(disconnected()), this, SLOT(onSocketDisconnected()));
    uint64_t id = socket->getId();
    Map::iterator itr = subscribers->find(id);
    
    if (itr == subscribers->end()) {
        emit serviceMessage(QString("Model ") + address.toString().c_str() + 
                            ": socket disconnected have been handled for not subscribed id");
        throw 5;
    }
    
    subscribersCount -= itr->second.size();
    subscribers->erase(itr);
    
    emit serviceMessage(QString("Model ") + address.toString().c_str() + ": now has " + std::to_string(subscribersCount).c_str() + " subscribers");
    emit subscribersCountChange(subscribersCount);
}

void M::Model::h_unsubscribe(const W::Event& ev)
{
    uint64_t id = ev.getSenderId();
    const W::Vocabulary& vc = static_cast<const W::Vocabulary&>(ev.getData());
    const W::Address& source = static_cast<const W::Address&>(vc.at(u"source"));
    
    Map::iterator itr = subscribers->find(id);
    if (itr == subscribers->end()) {
        emit serviceMessage(QString("Socket ") + id + 
                            " has no subscribed addresses to model " + source.toString().c_str());
        throw 6;
    }
    
    SMap& smap = itr->second;
    SMap::const_iterator sItr = smap.find(source);
    if (sItr == smap.end()) {
        emit serviceMessage(QString("Socket ") + id + 
                            " subscriber " + source.toString().c_str() + 
                            " is not subscribed to model " + source.toString().c_str());
        throw 7;
    }

    smap.erase(sItr);
    if (smap.size() == 0) {
        const W::Socket* socket = connector->getConnection(itr->first);
        disconnect(socket, SIGNAL(disconnected()), this, SLOT(onSocketDisconnected()));
        subscribers->erase(itr);
    }
    --subscribersCount;
    
    emit serviceMessage(QString("Model ") + address.toString().c_str() + ": now has " + std::to_string(subscribersCount).c_str() + " subscribers");
    emit subscribersCountChange(subscribersCount);
}

void M::Model::send(W::Vocabulary* vc, const W::Address& destination, uint64_t connectionId)
{
    if (!registered) {
        emit serviceMessage(QString("An attempt to send event from model ") + address.toString().c_str() + " which was not registered");
        throw 8;
    }
    W::Event ev(destination, vc);
    ev.setSenderId(connectionId);
    connector->getConnection(connectionId)->send(ev);
}

void M::Model::response(W::Vocabulary* vc, const W::Address& handlerAddress, const W::Event& src)
{
    if (!registered) {
        emit serviceMessage(QString("An attempt to send event from model ") + address.toString().c_str() + " which was not registered");
        throw 8;
    }
    const W::Vocabulary& svc = static_cast<const W::Vocabulary&>(src.getData());
    const W::Address& source = static_cast<const W::Address&>(svc.at(u"source"));
    uint64_t id = src.getSenderId();
    vc->insert(u"source", address);
    
    W::Event ev(source + handlerAddress, vc);
    ev.setSenderId(id);
    connector->getConnection(id)->send(ev);
}

void M::Model::fakeResponse(W::Vocabulary* vc, const W::Address& handlerAddress, const W::Address& sourceAddress, const W::Event& src)
{
    if (!registered) {
        emit serviceMessage(QString("An attempt to send event from model ") + address.toString().c_str() + " which was not registered");
        throw 8;
    }
    const W::Vocabulary& svc = static_cast<const W::Vocabulary&>(src.getData());
    const W::Address& source = static_cast<const W::Address&>(svc.at(u"source"));
    uint64_t id = src.getSenderId();
    vc->insert(u"source", sourceAddress);
    
    W::Event ev(source + handlerAddress, vc);
    ev.setSenderId(id);
    connector->getConnection(id)->send(ev);
}

void M::Model::broadcast(W::Vocabulary* vc, const W::Address& handlerAddress)
{
    if (!registered) {
        emit serviceMessage(QString("An attempt to send event from model ") + address.toString().c_str() + " which was not registered");
        throw 8;
    }
    Map::const_iterator itr = subscribers->begin();
    Map::const_iterator end = subscribers->end();
    vc->insert(u"source", address);
    
    for (;itr != end; ++itr) {
        SMap::const_iterator oItr = itr->second.begin();
        SMap::const_iterator oEnd = itr->second.end();
        for (;oItr != oEnd; ++oItr) {
            W::Event ev(oItr->first + handlerAddress, vc->copy());
            ev.setSenderId(itr->first);
            connector->getConnection(itr->first)->send(ev);
        }
    }
    delete vc;
}

void M::Model::removeHandler(W::Handler* handler)
{
    handlers->erase(handler);
    if (registered) {
        connector->unregisterHandler(handler);
    }
}

void M::Model::removeModel(M::Model* model)
{
    models->erase(model);
    disconnect(model, SIGNAL(serviceMessage(const QString&)), this, SIGNAL(serviceMessage(const QString&)));
    if (registered) {
        model->getUnregistered();
    }
}

void M::Model::passToLocalHandler(const W::Event& event) const
{
    if (registered) {
        connector->passThroughDispatcher(event);
    } else {
        emit serviceMessage(QString("An attempt to pass event to dispatcher from unregistered model\nModel address ") + address.toString().c_str());
    }
}

void M::Model::addController(C::Controller* ctrl, const W::String& nodeName)
{
    Controllers::const_iterator itr = controllers->find(ctrl);
    if (itr != controllers->end()) {
        emit serviceMessage(QString("An attempt to add controller ") +  ctrl->getAddress().toString().c_str() + QString(" for the second time in model ") + address.toString().c_str());
        throw 9;
    }
    controllers->insert(std::make_pair(ctrl, nodeName));
    connect(ctrl, SIGNAL(serviceMessage(const QString&)), SIGNAL(serviceMessage(const QString&)));
    if (registered) {
        connector->registerController(ctrl, nodeName);;
    }
}

void M::Model::removeController(C::Controller* ctrl)
{
    Controllers::const_iterator itr = controllers->find(ctrl);
    if (itr == controllers->end()) {
        emit serviceMessage(QString("An attempt to remove absent controller ") +  ctrl->getAddress().toString().c_str() + QString(" from the model ") + address.toString().c_str());
        throw 10;
    }
    
    disconnect(ctrl, SIGNAL(serviceMessage(const QString&)), this, SIGNAL(serviceMessage(const QString&)));
    if (registered) {
        connector->unregisterController(itr->first, itr->second);
    }
    controllers->erase(itr);
}