NameServerConnectionHandler.h

Go to the documentation of this file.

/*
 * SPDX-FileCopyrightText: 2006-2021 Istituto Italiano di Tecnologia (IIT)
 * SPDX-FileCopyrightText: 2006-2010 RobotCub Consortium
 * SPDX-License-Identifier: BSD-3-Clause
 */
 
#ifndef YARPDB_NAMESERVERCONNECTIONHANDLER_INC
#define YARPDB_NAMESERVERCONNECTIONHANDLER_INC
 
#include <yarp/name/api.h>
#include <yarp/os/PortReader.h>
#include <yarp/os/ConnectionReader.h>
#include <yarp/os/ConnectionWriter.h>
#include <yarp/os/Bottle.h>
#include <yarp/os/Contact.h>
#include <yarp/os/Time.h>
#include <yarp/os/Value.h>
 
#include <yarp/name/NameService.h>
 
#include <cstdio>
#include <string>
#include <algorithm>
 
namespace yarp::name {
class NameServerConnectionHandler;
}
 
 
class yarp::name::NameServerConnectionHandler :
        public yarp::os::PortReader
{
private:
    NameService *service;
public:
    NameServerConnectionHandler(NameService *service)
    {
        this->service = service;
    }
 
    bool read(yarp::os::ConnectionReader& reader) override
    {
        return apply(reader, nullptr);
    }
 
    virtual bool apply(yarp::os::ConnectionReader& reader,
                       yarp::os::ConnectionWriter *writer,
                       bool lock = true)
    {
        yarp::os::Bottle cmd;
        yarp::os::Bottle reply;
        yarp::os::Bottle event;
        bool ok = cmd.read(reader);
        if (!ok) {
            return false;
        }
        yarp::os::Contact remote;
        remote = reader.getRemoteContact();
        if (lock) {
            service->lock();
        }
        service->apply(cmd,reply,event,remote);
        for (size_t i=0; i<event.size(); i++) {
            yarp::os::Bottle *e = event.get(i).asList();
            if (e != nullptr) {
                service->onEvent(*e);
            }
        }
        if (lock) {
            service->unlock();
        }
        if (writer == nullptr) {
            writer = reader.getWriter();
        }
        if (writer != nullptr) {
            //printf("sending reply %s\n", reply.toString().c_str());
            if (reply.get(0).toString()=="old") {
                // support old name server messages
                for (size_t i=1; i<reply.size(); i++) {
                    yarp::os::Value& v = reply.get(i);
                    if (v.isList()) {
                        // old name server messages don't have quotes,
                        // so we strip them.
                        std::string si = v.asList()->toString();
                        si.erase(std::remove(si.begin(), si.end(), '\"'), si.end());
                        if (si.length()>0) {
                            writer->appendText(si);
                        }
                    } else {
                        if (v.isString()) {
                            writer->appendText(v.asString());
                        } else {
                            yarp::os::Bottle b;
                            b.add(v);
                            b.write(*writer);
                        }
                    }
                }
                writer->appendText("*** end of message");
            } else {
                reply.write(*writer);
            }
         }
        return true;
    }
};
 
 
#endif