vos/metaobjects/misc/services.cc

Go to the documentation of this file.

/* $Id: services.cc,v 1.15 2003/07/23 00:17:27 reed Exp $ */


/* This file was generated by otd2cpp.pl.

    Copyright (C) 2002 Peter Amstutz <tetron@interreality.org>

    This library is free software; you can redistribute it and/or
    modify it under the terms of the GNU Lesser General Public
    License as published by the Free Software Foundation; either
    version 2 of the License, or (at your option) any later version.

    This library is distributed in the hope that it will be useful,
    but WITHOUT ANY WARRANTY; without even the implied warranty of
    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
    Lesser General Public License for more details.

    You should have received a copy of the GNU Lesser General Public
    License along with this library; if not, write to the Free Software
    Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307  USA

*/

/** @file services.cc Code: a MetaObject for Services object types. */

#include <vos/corelibs/vos/vos.hh>
#include <vos/metaobjects/property/property.hh>
#include "services.hh"
#include "hypercard.hh"

using namespace LSD;
using namespace std;

Services* Services::defaultServiceDir = 0;
string Services::serviceDirURL("vop://localhost:4231/services");


/* Constructor */
Services::Services(MetaObject* s)
    : MetaObject(s)
{
    accessControl = &NoPropertyAccessControl::static_;
}

/* Destructor */
Services::~Services() {
}

/* Get/Set default AC */
void Services::setPropertyAccessControl(PropertyAccessControl* ac) {
    accessControl = ac;
}
PropertyAccessControl* Services::getPropertyAccessControl() {
    return accessControl;
}

Services* Services::getDefaultServicesDir()
{
    if(! defaultServiceDir) {
        // following acquire released by: destructor or notifyObjectExcise()
        defaultServiceDir = meta_cast<Services*>(&(Vobject::findObjectFromRoot(serviceDirURL)));
    }
    if(defaultServiceDir) {
        defaultServiceDir->acquire(); // released by: caller
        return defaultServiceDir;
    } else {
        LOG("services", 2, "Could not contact default service list daemon");
        throw bad_cast();
    }
}

void Services::setDefaultServiceDir(const string& url)
{
    serviceDirURL = url;
}

void Services::registerServiceWithDefault(Vobject* service, const string& title, const string& desc)
{
    vRef<Services> dir = getDefaultServicesDir();
    dir->registerService(service, title, desc);
}

void Services::registerService(Vobject* service, const string& title, const string& desc)
{
    vRef<Site> site = getSite();

    vRef<Hypercard> h = meta_cast<Hypercard*>(site->createMetaObject("", "misc:hypercard", 0));
    h->set_link(service);

    vRef<Property> t = meta_cast<Property*>(site->createMetaObject("", "property:property", 0));
    t->replace(title);
    h->insertChild(-1, "misc:title", &t);

    vRef<Property> d = meta_cast<Property*>(site->createMetaObject("", "property:property", 0));
    d->replace(desc);
    h->insertChild(-1, "misc:description", &d);

    const TypeSet& ts = service->getTypes();
    for(TypeSet::const_iterator i = ts.begin(); i != ts.end(); i++) {
        h->addType(string("linktype=") + *i);
    }

    insertChild(-1, title, &h);
}

LocalServices::LocalServices(MetaObject* s) : Services(s), MetaObject(s)
{
    accessControl = &NoPropertyAccessControl::static_;

    addMessageHandler<LocalServices>("misc:service-query", this, &LocalServices::handleQuery);
    addMessageHandler<LocalServices>("misc:end-service-query", this, &LocalServices::handleEndQuery);
}

LocalServices::~LocalServices() {
}

/* Initialize required subobjects: */

void LocalServices::initialize(PropertyAccessControl* ac) {
    accessControl = ac;
    initialize();
}

void LocalServices::initialize() {

    vRef<LocalSite> localsite = Site::getDefaultPeer();
}


RemoteServices::RemoteServices(MetaObject* s) : Services(s), MetaObject(s)
{
    addUpdateHandler<RemoteServices>("misc:service-advertisement", this, &RemoteServices::handleAdvertisement);
}

RemoteServices::~RemoteServices() {
}

int RemoteServices::query(const string& typepattern,
                          const string& titlepattern,
                          const string& descpattern,
                          const string& urlpattern,
                          LSD::ServiceAdvertismentListener* cb)
{
    LOG("RemoteServices", 3, "sending service-query message...");
    vRef<Message> m = new Message();
    vRef<LocalSite> ls = RemoteVobject::initFields(this, &m, "misc:service-query", false);
    m->insertField(-1, "type", typepattern);
    m->insertField(-1, "title", titlepattern);
    m->insertField(-1, "desc", descpattern);
    m->insertField(-1, "url", urlpattern);
    char n[32];
    snprintf(n, sizeof(n), "%i", rand());
    m->setNonce(n);
    sendMessage(&m);

    queries[atoi(m->getNonce().c_str())] = cb;

    //vRef<RemoteSite> rs = dynamic_cast<RemoteSite&>(getSite());
    //vRef<Message> reply = ls->waitFor(m->getNonce(), &rs);

    return atoi(m->getNonce().c_str());
}

void RemoteServices::endQuery(int r)
{
    vRef<Message> m = new Message();
    vRef<LocalSite> ls = RemoteVobject::initFields(this, &m, "misc:end-service-query", false);
    char n[32];
    snprintf(n, sizeof(n), "%i", r);
    m->setNonce(n);

    sendMessage(&m);

    queries.erase(r);
}

void RemoteServices::handleAdvertisement(Message* m)
{
    LOG("RemoteServices", 3, "handleAdvertisement");
    int r = atoi(m->getNonce().c_str());
    if(queries.count(r)) {
        LSD::Service s;
        for(int i = 0; i < m->getNumFields(); i++) {
            const Message::Field& f = m->getField(i);
            if(f.key == "title") s.title = f.value;
            else if(f.key == "desc") s.description = f.value;
            else if(f.key == "url") s.url = f.value;
            else if(f.key == "type") s.types.insert(f.value);
        }
        queries[r]->notifyNewService(r, s);
    }
}

/* Return type string ("misc:services") */

const string Services::getType() {
    return string("misc:services");
}

/* Register extenders with libvos MetaFactory */
void Services::registerExtenders() {
    static bool done = false;

    Hypercard::registerExtenders();

    if(! done) {
    LocalSite::addLocalObjectExtension(typeid(LocalServices).name(), &LocalServices::new_LocalServices);
    LocalSite::addLocalObjectExtension(typeid(Services).name(), &LocalServices::new_LocalServices);
    LocalSite::addLocalObjectExtension("misc:services", &LocalServices::new_LocalServices);
    RemoteSite::addRemoteObjectExtension(typeid(RemoteServices).name(), &RemoteServices::new_RemoteServices);
    RemoteSite::addRemoteObjectExtension(typeid(Services).name(), &RemoteServices::new_RemoteServices);
    RemoteSite::addRemoteObjectExtension("misc:services", &RemoteServices::new_RemoteServices);
    done = true;
    }
}

/* Generators for factory */


MetaObject* LocalServices::new_LocalServices(MetaObject *s, const string& type) {
    LocalServices* o = new LocalServices(s);
    o->addChildListener(o);
    return o;
}

MetaObject* RemoteServices::new_RemoteServices(MetaObject *s, const string& type) {
    return new RemoteServices(s);
}


void LocalServices::notifyChildInserted(VobjectEvent& event)
{
    try {
        if(event.getParent() == this) {
            Hypercard* hc = meta_cast<Hypercard*>(event.getChild());
            if(hc)
                hc->addChildListener(this);
        }
    } catch(bad_cast) {
    } catch(NoSuchObjectError) {
    }
}

void LocalServices::notifyChildReplaced(VobjectEvent& event)
{
    try {
        if(event.getParent() == this) {
            Hypercard* oldhc = meta_cast<Hypercard*>(event.getOldChild());
            if(oldhc)
                oldhc->removeChildListener(this);

            Hypercard* newhc = meta_cast<Hypercard*>(event.getNewChild());
            if(newhc)
                newhc->addChildListener(this);
        }
    } catch(bad_cast) {
    } catch(NoSuchObjectError) {
    }
}

void LocalServices::notifyChildRemoved(VobjectEvent& event)
{
    try {
        if(event.getParent() == this) {
            Hypercard* oldhc = meta_cast<Hypercard*>(event.getOldChild());
            if(oldhc)
                oldhc->removeChildListener(this);
        } else {
            vRef<ParentChildRelation> pcr = event.getParent()->findParent(*this);
            if(event.getContextualName() == "misc:link") {
                // destroy the hypercard as well
                Hypercard* oldhc = meta_cast<Hypercard*>(event.getParent());
                if(!oldhc) throw bad_cast();
                try {
                    vRef<Vobject> t = oldhc->findObject("misc:title");
                    t->excise();
                } catch(NoSuchObjectError) { }
                try {
                    vRef<Vobject> d = oldhc->findObject("misc:description");
                    d->excise();
                } catch(NoSuchObjectError) { }
                oldhc->excise();
            }
        }
    } catch(bad_cast) {
    } catch(NoSuchObjectError) {
    }
}

void LocalServices::handleQuery(Message* m)
{
    try {
        LOG("LocalServices", 3, "Recieved query.");
        vRef<Site> site = m->getSourceSite();
        ServiceListenerSiteWrapper* note = new ServiceListenerSiteWrapper(this, &site, m->getNonce().c_str());
        int r = query(m->getField("type").value,
                      m->getField("title").value,
                      m->getField("desc").value,
                      m->getField("url").value,
                      note);
        assert(r != -1);
        note->setQueryID(r);
        queries[r] = note;
    } catch(Message::NoSuchFieldError) {
    }
}

int LocalServices::query(const string& typepattern,
                         const string& titlepattern,
                         const string& descpattern,
                         const string& urlpattern,
                         LSD::ServiceAdvertismentListener* cb)
{
    cerr << "Internal Error! (You must override LocalServices::query)\n";
    return -1;

}

void LocalServices::endQuery(int q)
{
}

void LocalServices::handleEndQuery(Message* m)
{
    int r = atoi(m->getNonce().c_str());
    endQuery(r);
    LSD::ServiceAdvertismentListener* sal = queries[r];
    queries.erase(r);
    if(dynamic_cast<ServiceListenerSiteWrapper*>(sal)) delete sal;
}

ServiceListenerSiteWrapper::ServiceListenerSiteWrapper(LocalServices* s, Site* r, const string& n)
    : services(s), site(r), nonce(n)
{
    site->acquire(); // released by: destructor
    site->addExciseListener(this);
    services->acquire(); // released by: destructor
}

ServiceListenerSiteWrapper::~ServiceListenerSiteWrapper()
{
    site->release(); // acquired by: constructor
    services->release(); // acquired by: constructor
}

void ServiceListenerSiteWrapper::notifyNewService(int id, const LSD::Service& s)
{
    LOG("ServiceListenerSiteWrapper", 3, "notifyNewService");
    vRef<Message> m = new Message();
    m->setType("update");
    m->setFrom(services->getURL().getString());
    assert(&site);
    m->setTo(site->getURL().getString());
    m->setMethod("misc:service-advertisement");
    m->setNonce(nonce);

    for(set<string>::const_iterator i = s.types.begin(); i != s.types.end(); i++) {
        m->insertField(-1, "type", *i);
    }
    m->insertField(-1, "title", s.title);
    m->insertField(-1, "desc", s.description);
    m->insertField(-1, "url", s.url);

    site->sendMessage(&m);
}

void ServiceListenerSiteWrapper::notifyObjectExcise(RefCounted* rc)
{
    services->endQuery(queryID);
    services->queries.erase(queryID);
    delete this;
}

---