From aff7ddf41edcd9ea8e46cf23ddd342eb2b23224b Mon Sep 17 00:00:00 2001
From: xream <xream@icloud.com>
Date: Sat, 13 Jan 2024 13:55:07 +0800
Subject: [PATCH] =?UTF-8?q?feat:=20=E8=84=9A=E6=9C=AC=E7=AD=9B=E9=80=89?=
 =?UTF-8?q?=E7=9A=84=E5=BF=AB=E6=8D=B7=E6=93=8D=E4=BD=9C=E6=94=AF=E6=8C=81?=
 =?UTF-8?q?=20await?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 backend/package.json                           |  2 +-
 .../src/core/proxy-utils/processors/index.js   | 18 ++++++++++++------
 2 files changed, 13 insertions(+), 7 deletions(-)

diff --git a/backend/package.json b/backend/package.json
index 2bf9d2e..575558e 100644
--- a/backend/package.json
+++ b/backend/package.json
@@ -1,6 +1,6 @@
 {
   "name": "sub-store",
-  "version": "2.14.149",
+  "version": "2.14.150",
   "description": "Advanced Subscription Manager for QX, Loon, Surge, Stash and ShadowRocket.",
   "main": "src/main.js",
   "scripts": {
diff --git a/backend/src/core/proxy-utils/processors/index.js b/backend/src/core/proxy-utils/processors/index.js
index ee04aac..edbc0b8 100644
--- a/backend/src/core/proxy-utils/processors/index.js
+++ b/backend/src/core/proxy-utils/processors/index.js
@@ -319,10 +319,10 @@ function ScriptOperator(script, targetPlatform, $arguments, source) {
                 const operator = createDynamicFunction(
                     'operator',
                     `async function operator(input = []) {
-                        let proxies
                         if (Array.isArray(input)) {
+                            let proxies = input
                             let list = []
-                            for await (let $server of input) {
+                            for await (let $server of proxies) {
                                 ${script}
                                 list.push($server)
                             }
@@ -622,10 +622,16 @@ function ScriptFilter(script, targetPlatform, $arguments, source) {
             await (async function () {
                 const filter = createDynamicFunction(
                     'filter',
-                    `async function filter(proxies = []) {
-                        return proxies.filter(($server = {}) => {
-                          ${script}
-                        })
+                    `async function filter(input = []) {
+                        let proxies = input
+                        let list = []
+                        const fn = async ($server) => {
+                            ${script}
+                        }
+                        for await (let $server of proxies) {
+                            list.push(await fn($server))
+                        }
+                        return list
                       }`,
                     $arguments,
                 );