soa/service/named_endpoint.h

/* named_endpoint.h                                                 -*- C++ -*-
   Jeremy Barnes, 14 September 2012
   Copyright (c) 2012 Datacratic Inc.  All rights reserved.

*/

#ifndef __service__named_endpoint_h__
#define __service__named_endpoint_h__

#include "service_base.h"
#include "jml/utils/exc_assert.h"
#include <net/if.h>
#include <arpa/inet.h>
#include <set>


namespace Datacratic {


/*****************************************************************************/
/* NAMED ENDPOINT                                                             */
/*****************************************************************************/

struct NamedEndpoint {

    void init(std::shared_ptr<ConfigurationService> config,
              const std::string & endpointName);
    
    void publishAddress(const std::string & address,
                        const Json::Value & addressConfig);
    
    void activate();

    struct Interface {
        int family;
        uint64_t flags;

        uint32_t up:1;            
        uint32_t running:1;       
        uint32_t loopback:1;      
        uint32_t pointtopoint:1;  
        uint32_t noarp:1;         

        std::string name;
        std::string addr;
        std::string netmask;
        std::string broadcast;
        std::string hostScope;    
    };

    static std::string addrToString(const sockaddr * addr);

    static std::string addrToIp(const std::string & addr);

    static std::vector<Interface>
    getInterfaces(const std::set<int> & families = std::set<int>({ AF_INET }),
                  int flagsRequired = IFF_UP,
                  int flagsExcluded = 0);
    
    std::vector<std::string> getPublishedUris() const;

private:
    std::shared_ptr<ConfigurationService> config;
    std::string endpointName;

    std::vector<std::string> publishedUris;
};



} // namespace Datacratic

#endif /* __service__named_endpoint_h__ */