DistributedServiceDirectory.hpp

Go to the documentation of this file.

#ifndef FIPA_SERVICES_DISTRIBUTED_SERVICE_DIRECTORY_HPP
#define FIPA_SERVICES_DISTRIBUTED_SERVICE_DIRECTORY_HPP

#include <fipa_services/ServiceDirectory.hpp>
#include <service_discovery/ServiceDiscovery.hpp>

#define DEFAULT_SERVICE_SCOPE "_fipa_service_directory._udp"

namespace fipa {
namespace services {
class DistributedServiceDirectory : public ServiceDirectory
{
    typedef std::map<ServiceDirectoryEntry, servicediscovery::avahi::ServiceDiscovery*> ServiceDiscoveryMap;
    ServiceDiscoveryMap mServiceDiscoveries;

    static std::string canonizeName(const std::string& name);

    // Default listing object (to make sure service discovery is working when
    // no other service is registered)
    servicediscovery::avahi::ServiceDiscovery* mServiceDiscovery;

public:

    DistributedServiceDirectory(const std::string& scope = DEFAULT_SERVICE_SCOPE);

    DistributedServiceDirectory(const std::vector<std::string>& scopes);

    virtual ~DistributedServiceDirectory();

    static servicediscovery::avahi::ServiceDescription convert(const ServiceDirectoryEntry& entry);

    static ServiceDirectoryEntry convert(const servicediscovery::avahi::ServiceDescription& description);

    static ServiceDirectoryList convert(const std::map<std::string, servicediscovery::avahi::ServiceDescription>& servicesMap);

    void registerService(const ServiceDirectoryEntry& entry) { registerService(entry, DEFAULT_SERVICE_SCOPE); }

    void registerService(const ServiceDirectoryEntry& entry, const std::string& publishDomain, uint32_t ttlInMS = 30000);

    virtual void deregisterService(const std::string& regex, ServiceDirectoryEntry::Field field);

    ServiceDirectoryList search(const std::string& regex, ServiceDirectoryEntry::Field field, bool doThrow) const;
};

} // end namespace services
} // end namespace fipa
#endif // FIPA_SERVICES_DISTRIBUTED_SERVICE_DIRECTORY_HPP