listStreamProxy与listStreamPusherProxy支持key筛选参数

server/WebApi.cpp

@@ -1243,19 +1243,19 @@ void installWebApi() {
     });
     api_regist("/index/api/listStreamPusherProxy", [](API_ARGS_MAP) {
         CHECK_SECRET();
-        s_pusher_proxy.for_each([&val](const std::string& key, const PusherProxy::Ptr& p) {
+        s_pusher_proxy.for_each([&val](const std::string &key, const PusherProxy::Ptr &p) {
             Json::Value item = ToJson(p);
             item["key"] = key;
             val["data"].append(item);
-        });
+        }, allArgs["key"]);
     });
     api_regist("/index/api/listStreamProxy", [](API_ARGS_MAP) {
         CHECK_SECRET();
-        s_player_proxy.for_each([&val](const std::string& key, const PlayerProxy::Ptr& p) {
+        s_player_proxy.for_each([&val](const std::string &key, const PlayerProxy::Ptr &p) {
             Json::Value item = ToJson(p);
             item["key"] = key;
             val["data"].append(item);
-        });
+        }, allArgs["key"]);
     });
     // 动态添加rtsp/rtmp拉流代理  [AUTO-TRANSLATED:2616537c]
     // Dynamically add rtsp/rtmp pull stream proxy

server/WebApi.h

@@ -295,12 +295,20 @@ public:
         return it->second;
     }
 
-    void for_each(const std::function<void(const std::string&, const Pointer&)>& cb) {
+    void for_each(const std::function<void(const std::string &, const Pointer &)> &cb, const std::string &key = {}) {
         std::lock_guard<std::recursive_mutex> lck(_mtx);
-        auto it = _map.begin();
+        if (key.empty()) {
-        while (it != _map.end()) {
+            auto it = _map.begin();
-            cb(it->first, it->second);
+            while (it != _map.end()) {
-            it++;
+                cb(it->first, it->second);
+                ++it;
+            }
+        } else {
+            auto it = _map.find(key);
+            if (it == _map.end()) {
+                throw std::invalid_argument("key not found: " + key);
+            }
+            cb(key, it->second);
         }
     }