vos/corelibs/vos/messagecontext.cc

Go to the documentation of this file.

/*
    This file is part of the Virtual Object System of
    the Interreality project (http://interreality.org).

    Copyright (C) 2001-2003 Peter Amstutz

    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

    Peter Amstutz <tetron@interreality.org>
*/

#include "messagecontext.hh"
#include "message.hh"
#include "log.hh"

using namespace VOS;

MessageContext::MessageContext()
    : parentcontext(0)
{
}

MessageContext::~MessageContext()
{
    LOG("refcount", 5, "deleting message context");
    for(map<string, Message*>::iterator i = reply_record.begin(); i != reply_record.end(); i++) {
        if((*i).second) (*i).second->release(); // acquired by: addToReplyRecord()
    }
    if(parentcontext) parentcontext->release(); // acquired by: setParentContext()
}

void MessageContext::setParameter(const string& p, const string& v)
{
    parameters[p]=v;
}

string MessageContext::getParameter(const string& p) throw (NoSuchParameterError)
{
    map<string, string>::iterator i = parameters.find(p);
    if(i != parameters.end()) return (*i).second;
    else {
        if(parentcontext) return parentcontext->getParameter(p);
        else throw NoSuchParameterError("No parameter");
    }
}

void MessageContext::addToReplyRecord(Message* m)
{
    if(parentcontext) parentcontext->addToReplyRecord(m);
    else {
        m->acquire(); // released by: removeFromReplyRecord() or destructor
        LOG("messagecontext", 4, "adding " << m->getNonce() << " to the reply record");
        reply_record[m->getNonce()] = m;
    }
}

bool MessageContext::replyRecordContains(const string& nonce)
{
    if(parentcontext) return parentcontext->replyRecordContains(nonce);
    else {
        map<string, Message*>::iterator i = reply_record.find(nonce);
        return (i != reply_record.end() && (*i).second);
    }
}

Message* MessageContext::getFromReplyRecord(const string& nonce)
{
    if(parentcontext) return parentcontext->getFromReplyRecord(nonce);
    else {
        map<string, Message*>::iterator i = reply_record.find(nonce);
        if(i != reply_record.end()) return (*i).second;
        else return 0;
    }
}

void MessageContext::removeFromReplyRecord(Message* m)
{
    if(parentcontext) parentcontext->removeFromReplyRecord(m);
    {
        map<string, Message*>::iterator i = reply_record.find(m->getNonce());
        if(i != reply_record.end()) {
            (*i).second->release(); // acquired by: addToReplyRecord()
            reply_record.erase(i);
        }
    }
}

void MessageContext::doSubstitution(string& s, unsigned int p)
{
    LOG("messagecontext", 5, "entering dosubst");
    for(; p < s.size() && s[p] != ')'; p++) {
        if(s[p] == '\\') {
            s.replace(p, 2, 1, s[p+1]);
            continue;
        }
        LOG("messagecontext", 5, "looking at " << s[p]);
        if(s[p] == '$') {
            int d = p++;
            string nonce;
            while(p < s.size() && s[p] != '(' && s[p] != '$') {
                if(s[p] == '\\') {
                    s.replace(p, 2, 1, s[p+1]);
                    p++;
                }
                nonce += s[p++];
            }

            if(s[p] == '$') {
                doSubstitution(s, p);
                p=d-1;
                continue;
            } else p++;
            LOG("messagecontext", 5, "recursing, before recurse: " << s);
            doSubstitution(s, p);
            LOG("messagecontext", 5, "recursing, after recurse: " << s);
            unsigned int q;
            for(q = p; q < s.size() && s[q] != ')'; q++) {
                if(s[q] == '\\') {
                    s.replace(q, 2, 1, s[q+1]);
                }
            }

            if(nonce == "") {
                LOG("messagecontext", 5, p << " " << q << " (p - 2) = " << (p-2) << "   (q - p + 3) = " << (q-p+3));
                try {
                    string rep = getParameter(s.substr(p, q-p));
                    if(parentcontext) parentcontext->doSubstitution(rep);
                    s.replace(p - 2, q - p + 3, rep);
                } catch(NoSuchParameterError) {
                    LOG("messagecontext", 3, "doSubst: didn't have " << s.substr(p, q-p) << " field substituting into \"" << s << "\"");
                    s.replace(p - 2, q - p + 3, "**error**");
                }
            } else {
                Message* m = getFromReplyRecord(nonce);
                if(m) {
                    try {
                        s.replace(p - 2 - nonce.size(), q - p + 3 + nonce.size(), m->getField(s.substr(p, q-p)).value);
                    } catch(Message::NoSuchFieldError) {
                        LOG("messagecontext", 3, "doSubst: didn't have " << s.substr(p, q-p) << " field in message nonce " << nonce << " substituting into \"" << s << "\"");
                        s.replace(p - 2 - nonce.size(), q - p + 3 + nonce.size(), "**error**");
                    }
                } else {
                    LOG("messagecontext", 3, "doSubst: no caught message nonce " << nonce << " in substitution \"" << s << "\"");
                    s.replace(p - 2 - nonce.size(), q - p + 3 + nonce.size(), "**error**");
                }
            }
            p-=2;
        }
    }
    LOG("messagecontext", 5, "leaving dosubst");
}

void MessageContext::setParentContext(MessageContext* mc)
{
    if(parentcontext) parentcontext->release(); // acquired by: below
    if(mc) {
        mc->acquire();
        parentcontext=mc;
    } else parentcontext=0;
}

MessageContext* MessageContext::getParentContext()
{
    parentcontext->acquire();
    return parentcontext;
}

---