feat: support unsubscribe()

Author: hideakitai

ArduinoOSC/ArduinoOSCCommon.h

@@ -66,6 +66,45 @@ namespace osc {
 #endif
         }
 
+        bool unsubscribe(const uint16_t port, const String& addr) {
+#if defined(ARDUINOOSC_ENABLE_WIFI) && (defined(ESP_PLATFORM) || defined(ARDUINO_ARCH_RP2040))
+            if (WiFi.getMode() != WIFI_OFF)
+                return OscServerManager<S>::getInstance().unsubscribe(port, addr);
+            else {
+                LOG_ERROR(F("WiFi is not enabled. Unsubscribing OSC failed."));
+                return false;
+            }
+#else
+            return OscServerManager<S>::getInstance().unsubscribe(port, addr);
+#endif
+        }
+
+        bool unsubscribe(const uint16_t port) {
+#if defined(ARDUINOOSC_ENABLE_WIFI) && (defined(ESP_PLATFORM) || defined(ARDUINO_ARCH_RP2040))
+            if (WiFi.getMode() != WIFI_OFF)
+                return OscServerManager<S>::getInstance().unsubscribe(port);
+            else {
+                LOG_ERROR(F("WiFi is not enabled. Unsubscribing OSC failed."));
+                return false;
+            }
+#else
+            return OscServerManager<S>::getInstance().unsubscribe(port);
+#endif
+        }
+
+        bool unsubscribe() {
+#if defined(ARDUINOOSC_ENABLE_WIFI) && (defined(ESP_PLATFORM) || defined(ARDUINO_ARCH_RP2040))
+            if (WiFi.getMode() != WIFI_OFF)
+                return OscServerManager<S>::getInstance().unsubscribeAll();
+            else {
+                LOG_ERROR(F("WiFi is not enabled. Unsubscribing OSC failed."));
+                return false;
+            }
+#else
+            return OscServerManager<S>::getInstance().unsubscribeAll();
+#endif
+        }
+
         void parse() {
 #if defined(ARDUINOOSC_ENABLE_WIFI) && (defined(ESP_PLATFORM) || defined(ARDUINO_ARCH_RP2040))
             if (this->isWiFiConnected() || this->isWiFiModeAP()) {

ArduinoOSC/OSCServer.h

@@ -204,6 +204,23 @@ namespace osc {
                 callbacks.insert({addr, ref});
             }
 
+            bool unsubscribe(const String& addr) {
+                auto it = callbacks.find(addr);
+                if (it != callbacks.end()) {
+                    callbacks.erase(it);
+                    return true;
+                }
+                return false;
+            }
+
+            bool unsubscribeAll() {
+                if (!callbacks.empty()) {
+                    callbacks.clear();
+                    return true;
+                }
+                return false;
+            }
+
             bool parse() {
                 auto stream = UdpMapManager<S>::getInstance().getUdp(port);
                 const size_t size = stream->parsePacket();
@@ -263,6 +280,32 @@ namespace osc {
                 getServer(port).subscribe(addr, std::forward<Ts>(ts)...);
             }
 
+            bool unsubscribe(const uint16_t port, const String& addr) {
+                auto it = server_map.find(port);
+                if (it != server_map.end()) {
+                    return it->second->unsubscribe(addr);
+                }
+                return false;
+            }
+
+            bool unsubscribe(const uint16_t port) {
+                auto it = server_map.find(port);
+                if (it != server_map.end()) {
+                    return it->second->unsubscribeAll();
+                }
+                return false;
+            }
+
+            bool unsubscribeAll() {
+                if (!server_map.empty()) {
+                    for (auto& m : server_map) {
+                        m.second->unsubscribeAll();
+                    }
+                    return true;
+                }
+                return false;
+            }
+
             void parse() {
                 for (auto& m : server_map)
                     m.second->parse();