vos/metaobjects/misc/gateway.cc

Go to the documentation of this file.

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


/** @file gateway.cc Define Gateway, a MetaObject for "misc:gateway" object types. */

/* This file was generated by otd2cpp.pl, a script for VOS by Reed Hedges
 * <reed@zerohour.net> and Peter Amstutz <tetron@interreality.org>.  Search for
 * TODO for stuff that needs editing. You will want to especially fill in
 * constructors, destructors, message handlers, non-property subobjects...
 *
 * The authors of otd2cpp.pl make no guarantee that this code will work, or even
 * that it even is safe to run.  Use it at your own risk.
 */




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

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

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

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

PropertyAccessControl* Gateway::getPropertyAccessControl() {
    return accessControl;
}

LocalGateway::LocalGateway(MetaObject* s) : Gateway(s), MetaObject(s)
{
    addMessageHandler<LocalGateway>("request-forward", this, &LocalGateway::handleRequestForward);
    accessControl = &NoPropertyAccessControl::static_;
}

LocalGateway::~LocalGateway() {
}

/* Initialize required subobjects: */

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

void LocalGateway::initialize() {

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

RemoteGateway::RemoteGateway(MetaObject* s) : Gateway(s), MetaObject(s)
{
    //addUpdateHandler<RemoteGateway>("request-forward-reply", this, &RemoteGateway::handleRequestForwardReply);
}

RemoteGateway::~RemoteGateway() {
}

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

const string Gateway::getType() {
    return string("misc:gateway");
}

/* Register extenders with libvos MetaFactory */
void Gateway::registerExtenders() {
    static bool done = false;
    if(! done) {
    LocalSite::addLocalObjectExtension(typeid(LocalGateway).name(), &LocalGateway::new_LocalGateway);
    LocalSite::addLocalObjectExtension(typeid(Gateway).name(), &LocalGateway::new_LocalGateway);
    LocalSite::addLocalObjectExtension("misc:gateway", &LocalGateway::new_LocalGateway);
    RemoteSite::addRemoteObjectExtension(typeid(RemoteGateway).name(), &RemoteGateway::new_RemoteGateway);
    RemoteSite::addRemoteObjectExtension(typeid(Gateway).name(), &RemoteGateway::new_RemoteGateway);
    RemoteSite::addRemoteObjectExtension("misc:gateway", &RemoteGateway::new_RemoteGateway);
    done = true;
    }
}

/* Get and set Subproperties and other Subobjects */

/* Local Actuators: */

/* Do request-forward. */

void LocalGateway::requestForward(LocalSocketSite* ls) {
    /* TODO: do stuff! */
}

/* Message Handlers:  */

/* Handle message request-forward */
void LocalGateway::handleRequestForward(Message* m) {
    /* Fields in this message are:
    */

    /* Replies are: request-forward-reply () Fields: sitename (The
        gateway has established a forward to theclient's actual site
        using this site name, which the clientshould now use as its
        primary site name.); error ( If this field is present, the
        operation failed.);
    */

    /* TODO: one way to handle the message is to call the actuator
     * (requestForward).  To reply to the message, if there is more
     * than one possible reply, you probably want to choose only
     * one... (but it's up to you of course...) */


    try {
        vRef<Message> reply = new Message();
        LocalVobject::initReply(this, &reply, m, "request-forward-reply");
        vRef<Vobject> from = Vobject::findObjectFromRoot(m->getFrom());

        /* TODO add fields to reply (reply->insertField(-1, "field", "value"); */

        from->sendMessage(&reply);
    } catch(Message::NoSuchFieldError e) {
        /* A field wasn't found */
    }
}

/* Remote Actuators: */

/* Do request-forward. */

void RemoteGateway::requestForward(LocalSocketSite* ls) {

    /* Create a new message and send it to the local object, and wait for reply.
     * If your message expects no reply, remove the line that calls "waitFor". */

    vRef<Message> m = new Message();
    vRef<LocalSite> oursite = RemoteVobject::initFields(this, &m, "request-forward", true);
    sendMessage(&m);
    vRef<RemoteSite> site = dynamic_cast<RemoteSite&>(getSite());
    vRef<Message> n = ls->waitFor(m->getNonce(), &site);

    try {
        URL u(ls->getURL());
        u.setHostAndPort(n->getField("sitename").value);
        ls->addHostAlias(u.getHostAndPort());
        ls->setPrimaryHostname(u.getHostAndPort());
    } catch(Message::NoSuchFieldError) {
        try {
            LOG("gateway", 1, "Could not get a forward: " << n->getField("error").value);
        } catch(Message::NoSuchFieldError) {
        }
    }
}

/* Generators for factory */

MetaObject* LocalGateway::new_LocalGateway(MetaObject *s, const string& type) {
    LocalGateway* o = new LocalGateway(s);
    return o;
}

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

/* Handle request-forward-reply. */

void RemoteGateway::handleRequestForwardReply(Message* m) { }

---