diff --git a/include/opendht/dht_interface.h b/include/opendht/dht_interface.h index 7f3641968a333fc8e969399e9fed260ec9b82f99..a312a4c6071ee3907242c8cf9e2be25702a6af17 100644 --- a/include/opendht/dht_interface.h +++ b/include/opendht/dht_interface.h @@ -235,11 +235,6 @@ public: * @param notification to process */ virtual void pushNotificationReceived(const std::map<std::string, std::string>& data) = 0; - /** - * Refresh a listen via a token - * @param token - */ - virtual void resubscribe(unsigned token) = 0; protected: bool logFilerEnable_ {}; diff --git a/include/opendht/dhtrunner.h b/include/opendht/dhtrunner.h index 8685acacdcbcfee438e9c16d2a4681e9d83e94d2..89090330f8cb0bdf2a2350a5046615b5417e4434 100644 --- a/include/opendht/dhtrunner.h +++ b/include/opendht/dhtrunner.h @@ -400,11 +400,6 @@ public: * Insert a push notification to process for OpenDHT */ void pushNotificationReceived(const std::map<std::string, std::string>& data) const; - /** - * Refresh a listen via a token - * @param token - */ - void resubscribe(unsigned token); /* Proxy server mothods */ void forwardAllMessages(bool forward); diff --git a/include/opendht/securedht.h b/include/opendht/securedht.h index 7d300fba2a0636935b4e7985706110027d58c738..e1d31a9a4127b472fcd47908c4a9032611abf45a 100644 --- a/include/opendht/securedht.h +++ b/include/opendht/securedht.h @@ -308,13 +308,6 @@ public: void pushNotificationReceived(const std::map<std::string, std::string>& notification) { dht_->pushNotificationReceived(notification); } - /** - * Refresh a listen via a token - * @param token - */ - void resubscribe(const unsigned token) { - dht_->resubscribe(token); - } void setLoggers(LogMethod error = NOLOG, LogMethod warn = NOLOG, LogMethod debug = NOLOG) { diff --git a/src/dhtrunner.cpp b/src/dhtrunner.cpp index 5f8ac96fc7a127357bf81206db8e54e7c8ca126f..892fd111c9afb89780e39654980163354e741208 100644 --- a/src/dhtrunner.cpp +++ b/src/dhtrunner.cpp @@ -952,13 +952,4 @@ DhtRunner::pushNotificationReceived(const std::map<std::string, std::string>& da #endif } -void -DhtRunner::resubscribe(unsigned token) -{ -#if OPENDHT_PROXY_CLIENT && OPENDHT_PUSH_NOTIFICATIONS - if (dht_via_proxy_) - dht_via_proxy_->resubscribe(token); -#endif -} - } diff --git a/tools/dhtnode.cpp b/tools/dhtnode.cpp index 0c12df6267574503d71352c982c9708d2ac27e73..7f0a95b84d6cc78c783e7dc89b82b4e6a1c48c54 100644 --- a/tools/dhtnode.cpp +++ b/tools/dhtnode.cpp @@ -232,13 +232,6 @@ void cmd_loop(std::shared_ptr<DhtRunner>& dht, dht_params& params iss >> value; dht->pushNotificationReceived({{"token", value}}); continue; - } else if (op == "re") { - iss >> value; - try { - unsigned token = std::stoul(value); - dht->resubscribe(token); - } catch (...) { } - continue; } #endif // OPENDHT_PUSH_NOTIFICATIONS #endif //OPENDHT_PROXY_CLIENT