eddie-communication: rework networking code to match CoAP standards

• new executable files for both client and server applications;
• resource publication: a node MUST provide a value for ep, d and base-address where the resources are located, while the payload of the request MUST contain a textual representation of the list of resources to publish; The resource directory will answer with a Location-Path, that can be used to modify the attributes of the publication;
• publication update: to update a previous publication, a node can perform a POST request using the Location-Path value obtained after the registration, to modify parameters of the publication; to remove a publication, a node can perform a DELETE request using the same Location-Path value obtained after the registration; to change the list of published resources, a node MUST perform a new publication;
• resource discovery: a node that wants to find resources in the network can reach the special resource /rd-lookup/res, specifying query parameters to filter the results.

communication/include/CoapClient.h

@@ -35,22 +35,29 @@ public:
     Value get(Key const &k) {
         std::unique_lock<decltype(m_)> lock(m_);
         Value elem = c_[k];
-        // m_.unlock()
         return elem;
     }
 
+    std::list<Value> get_all() {
+        std::unique_lock<decltype(m_)> lock(m_);
+        std::list<Value> return_list;
+
+        for(auto const& imap: c_)
+            return_list.push_back(imap.second);
+
+        return return_list;
+    }
+
     template<class Value2>
     void set(Key const &k, Value2 &&v) {
         std::unique_lock<decltype(m_)> lock(m_);
         c_[k] = std::forward<Value2>(v);
-        // m_.unlock()
     }
 
     void erase(Key const &k) {
         std::unique_lock<decltype(m_)> lock(m_);
         Value elem = this->get(k);
         c_.erase(k);
-        // m_.unlock()
     }
 };
 
@@ -79,8 +86,6 @@ public:
      */
     void remove_valid_key (Key const &k) {
         std::unique_lock<decltype(m_)> lock(m_);
-
-        // erase key and remove all messages
         s_.erase(k);
         mm_.erase(k);
     }
@@ -91,10 +96,7 @@ public:
      * @return      true if the key is found, false otherwise
      */
     int contains_key(Key const &k) {
-        // lock the storage
         std::unique_lock<decltype(m_)> lock(m_);
-
-        // check if the set contains the key
         auto result = s_.find(k);
         return result != s_.end();
     }
@@ -103,18 +105,16 @@ public:
     void insert_new_message(Key const &k, Value2 &&v) {
         std::unique_lock<decltype(m_)> lock(m_);
 
-        if (s_.find(k) != s_.end()) { // the key is present, add the message
+        if (s_.find(k) != s_.end()) {
             mm_.insert(std::make_pair(k, v));
         }
-        // key not present, ignore the message
     }
 
     std::list<Value> get(Key const &k) {
         std::unique_lock<decltype(m_)> lock(m_);
         std::list<Value> return_list;
 
-        if (s_.find(k) != s_.end()) { // work only if the key is valid
-
+        if (s_.find(k) != s_.end()) {
             auto items = mm_.equal_range(k);
 
             for (auto item = items.first; item != items.second; ++item) {
@@ -131,14 +131,11 @@ class CoapClient {
 private:
     int quit = 0;
     coap_context_t *context = nullptr;
-    std::thread runner;
 
     static int resolve_address(const char *host, const char *service, coap_address_t *dst);
 
     coap_session_t *open_session(const char *dst_host, const char *dst_port, coap_proto_t protocol);
 
-    void destroyClient();
-
 public:
     static ThreadSafeMap<int, coap_pdu_t *> *messages;
     static ThreadSafeStorage<std::string, coap_pdu_t *> *multicast_messages;
@@ -147,48 +144,38 @@ public:
 
     CoapClient();
 
+    void destroy_client();
+
     int get_quit() const;
 
     void set_quit(int value);
 
     coap_context_t *get_context();
 
-    int initClient();
+    int init_client();
 
     static coap_response_t
-    message_handler(coap_session_t *session,
-                    const coap_pdu_t *sent,
-                    const coap_pdu_t *received,
+    message_handler(coap_session_t *session, const coap_pdu_t *sent, const coap_pdu_t *received,
                     coap_mid_t id);
 
-    coap_mid_t send_get_request(const char *dst_host,
-                                const char *dst_port,
-                                const char *dst_resource,
-                                const char *query,
-                                unsigned char *data,
-                                size_t data_length);
-
-    std::string send_get_request_non_confirmable(const char *destination,
-                                                           const char *query,
-                                                           unsigned char *data,
-                                                           size_t data_length);
-
-    coap_mid_t send_post_request(const char *dst_host,
-                                 const char *dst_port,
-                                 const char *dst_resource,
-                                 const char *query);
-
-    coap_mid_t send_delete_request(const char *dst_host,
-                                   const char *dst_port,
-                                   const char *res_to_delete);
-
-    coap_mid_t send_put_request(const char *dst_host,
-                                const char *dst_port,
-                                const char *dst_resource,
-                                const char *query,
-                                const char *data);
-
-    int run();
+    coap_mid_t
+    send_get_request(const char *dst_host, const char *dst_port, const char *dst_resource,
+                     const char *query);
+
+    std::string
+    send_get_nc_request(const char *dst_host, const char *query, unsigned char *data,
+                        size_t data_len);
+
+    coap_mid_t
+    send_post_request(const char *dst_host, const char *dst_port, const char *dst_resource,
+                      const char *query, const char *data);
+
+    coap_mid_t
+    send_delete_request(const char *dst_host, const char *dst_port, const char *res_to_delete);
+
+    coap_mid_t
+    send_put_request(const char *dst_host, const char *dst_port, const char *dst_resource,
+                     const char *query, const char *data);
 };
 
 #endif //EDDIE_COAPCLIENT_H