Revert "fix: 保留用户/规则高级设置并增强节点运行时恢复 (#468 )"

This reverts commit 3f374df724.
Revert "feat: 批量设置用户最大连接数"
2026-11-13 16:24:24 +08:00 · 2026-04-25 22:45:27 +08:00 · 2026-04-25 22:45:23 +08:00 · 2026-04-25 22:03:42 +08:00 · 2026-04-25 18:12:13 +08:00 · 2026-04-24 21:56:46 +08:00
4 changed files with 89 additions and 84 deletions
@@ -1,6 +1,6 @@
 # 最大连接数限制实现计划

-> **For agentic workers:** REQUIRED SUB-SKILL: Use superpowers:subagent-driven-development (recommended) or superpowers:executing-plans to implement this plan task-by-task. Steps use checkbox (`- [ ]`) syntax for tracking.
+> **For agentic workers:** REQUIRED SUB-SKILL: Use superpowers:subagent-driven-development (recommended) or superpowers:executing-plans to implement this plan task-by-task. Steps use checkbox (`[x]`) syntax for tracking.

 **Goal:** 在 FLVX 中实现基于用户的全局最大连接数限制和基于单条规则的独立最大连接数限制功能。前端输入框为 0 或空时表示不限制。

@@ -27,7 +27,7 @@
 - Modify: `go-gost/x/socket/limiter.go`
 - Modify: `go-gost/x/socket/websocket_reporter.go`

- [ ] **Step 1: 实现 `createConnLimiter` 等功能**
+[x] **Step 1: 实现 `createConnLimiter` 等功能**

 在 `go-gost/x/socket/limiter.go` 中参考现有 `createLimiter` 添加对 `CLimiters` 的支持：

@@ -101,7 +101,7 @@ func deleteConnLimiter(req deleteLimiterRequest) error {
 }
 ```

- [ ] **Step 2: 在 `WebSocketReporter` 注册命令**
+[x] **Step 2: 在 `WebSocketReporter` 注册命令**

 在 `go-gost/x/socket/websocket_reporter.go` 的 `ProcessCommand` 中添加 case：

@@ -120,7 +120,7 @@ func deleteConnLimiter(req deleteLimiterRequest) error {
 		needSaveConfig = true
 ```

- [ ] **Step 3: 实现 Handler 方法**
+[x] **Step 3: 实现 Handler 方法**

 在 `go-gost/x/socket/websocket_reporter.go` 中添加：

@@ -187,7 +187,7 @@ func (w *WebSocketReporter) handleDeleteCLimiter(data interface{}) error {
 }
 ```

- [ ] **Step 4: Commit**
+[x] **Step 4: Commit**

 ```bash
 cd go-gost
@@ -204,7 +204,7 @@ cd ..
 - Modify: `go-backend/internal/store/model/model.go`
 - Modify: `go-backend/internal/store/repo/repository.go`

- [ ] **Step 1: 更新数据库模型**
+[x] **Step 1: 更新数据库模型**

 在 `go-backend/internal/store/model/model.go` 的 `User` 和 `Forward` 结构体中添加 `MaxConn` 字段。

@@ -224,7 +224,7 @@ type Forward struct {
 }
 ```

- [ ] **Step 2: 编写数据库迁移**
+[x] **Step 2: 编写数据库迁移**

 在 `go-backend/internal/store/repo/repository.go` 的 `AutoMigrate` 逻辑前（如果有自定义迁移）或利用 gorm 自动迁移机制，由于这是 autoMigrate，添加字段只要 `db.AutoMigrate(&model.User{}, &model.Forward{})` 被调用就能自动加上。确认已执行迁移。由于 `FLVX` 通常会自动执行迁移，只需修改模型即可。我们需要处理默认值，由于使用了 `default:0`，GORM 会处理新增字段的默认值，但为了安全起见，如果在旧环境中，可能直接 alter table。

@@ -232,11 +232,11 @@ type Forward struct {
 // 无需手动编写 SQL，依赖现有的 gorm AutoMigrate 即可。
 ```

- [ ] **Step 3: 运行并验证迁移通过**
+[x] **Step 3: 运行并验证迁移通过**

 Run: `make build` (在 go-backend 中)，或者运行一个相关的存储单元测试。

- [ ] **Step 4: Commit**
+[x] **Step 4: Commit**

 ```bash
 cd go-backend
@@ -253,13 +253,13 @@ cd ..
 - Modify: `go-backend/internal/http/handler/control_plane.go`
 - Modify: `go-backend/internal/store/repo/repository_control.go`

- [ ] **Step 1: 更新存储层以获取 User 的 MaxConn**
+[x] **Step 1: 更新存储层以获取 User 的 MaxConn**

 在 `go-backend/internal/store/repo/repository_control.go` 中：

 需要一个方法获取 User，或者如果已经有，确保可以拿到 `MaxConn`。

- [ ] **Step 2: 编写下发 CLimiter 到节点的辅助函数**
+[x] **Step 2: 编写下发 CLimiter 到节点的辅助函数**

 在 `go-backend/internal/http/handler/control_plane.go`，参考 `ensureLimiterOnNode` 和 `upsertLimiterOnNode`：

@@ -288,7 +288,7 @@ func (h *Handler) ensureConnLimiterOnNode(nodeID int64, limiterName string, maxC
 }
 ```

- [ ] **Step 3: 更新组装配置逻辑以绑定 `climiter`**
+[x] **Step 3: 更新组装配置逻辑以绑定 `climiter`**

 在 `control_plane.go` 的 `syncForwardServicesWithWarnings` 及其辅助函数 `buildForwardServiceConfigs` 附近：

@@ -305,7 +305,7 @@ func buildForwardServiceConfigs(baseName string, forward *model.Forward, tunnel
 }
 ```

- [ ] **Step 4: 在转发服务同步主流程中决定并下发 `climiter`**
+[x] **Step 4: 在转发服务同步主流程中决定并下发 `climiter`**

 在 `syncForwardServicesWithWarnings` (可能在多个重载/处理入口处，如 `ensureForwardServices`)，查出转发所属 user 的 `MaxConn`，以及转发本身的 `MaxConn`。

@@ -340,7 +340,7 @@ func buildForwardServiceConfigs(baseName string, forward *model.Forward, tunnel
 ```
 *(注意：需要确保更新涉及 `buildForwardServiceConfigs` 的所有调用点)*

- [ ] **Step 5: Commit**
+[x] **Step 5: Commit**

 ```bash
 cd go-backend
@@ -357,7 +357,7 @@ cd ..
 - Modify: `go-backend/internal/http/handler/admin_user.go`
 - Modify: `go-backend/internal/http/handler/forward.go`

- [ ] **Step 1: 用户接口更新**
+[x] **Step 1: 用户接口更新**

 在 `go-backend/internal/http/handler/admin_user.go`，修改用户创建和更新请求的结构体（如果有），接收 `MaxConn`，并在保存到数据库时赋值。

@@ -374,17 +374,17 @@ if req.MaxConn != nil {

 在获取用户列表时，确保 `MaxConn` 返回给前端。

- [ ] **Step 2: 规则接口更新**
+[x] **Step 2: 规则接口更新**

 在 `go-backend/internal/http/handler/forward.go` 中，更新 `CreateForwardReq` 和 `UpdateForwardReq` 结构体，增加 `MaxConn`，并在创建/更新 Forward 时保存到数据库。

 如果转发规则的 `MaxConn` 或相关信息改变，触发节点上的规则重载（重新下发服务）。这一步由于更改了数据库，复用现有的 `syncForwardServices` 就会带上最新的配置。

- [ ] **Step 3: 测试接口**
+[x] **Step 3: 测试接口**

 Run: 可以启动后使用 curl 测试。

- [ ] **Step 4: Commit**
+[x] **Step 4: Commit**

 ```bash
 cd go-backend
@@ -402,12 +402,12 @@ cd ..
 - Modify: `vite-frontend/src/api/index.ts`
 - Modify: `vite-frontend/src/pages/users.tsx` (或者对应的用户管理页面文件)

- [ ] **Step 1: 类型更新**
+[x] **Step 1: 类型更新**

 在 `vite-frontend/src/api/types.ts` 中：
 为 `UserApiItem` 和相关的 mutation payload 增加 `maxConn?: number` 属性。

- [ ] **Step 2: UI 修改**
+[x] **Step 2: UI 修改**

 在用户创建/编辑弹窗中，增加“最大连接数”输入框：
 (假设使用 `@nextui-org/react` 的 `Input`)
@@ -426,9 +426,9 @@ cd ..
 ```
 并在用户的表格列中展示 `最大连接数`（值为 0 显示“不限制”）。

- [ ] **Step 3: 运行 Vite 进行验证**
+[x] **Step 3: 运行 Vite 进行验证**

- [ ] **Step 4: Commit**
+[x] **Step 4: Commit**

 ```bash
 cd vite-frontend
@@ -444,11 +444,11 @@ cd ..
 **Files:**
 - Modify: `vite-frontend/src/pages/forward.tsx`

- [ ] **Step 1: 类型更新**
+[x] **Step 1: 类型更新**

 在 `api/types.ts` 中 `ForwardMutationPayload` 和 `ForwardApiItem` 中增加 `maxConn?: number`。

- [ ] **Step 2: UI 修改**
+[x] **Step 2: UI 修改**

 在 `vite-frontend/src/pages/forward.tsx` 的创建/编辑规则弹窗（在 "规则限速" 附近）增加“最大连接数”输入框：

@@ -468,11 +468,11 @@ cd ..

 如果是在列表/卡片中展示，可以增加一个小标签或者 Tooltip 显示其最大连接数设置。

- [ ] **Step 3: 验证**
+[x] **Step 3: 验证**

 在前端验证该功能能正确读写规则的连接限制字段。

- [ ] **Step 4: Commit**
+[x] **Step 4: Commit**

 ```bash
 cd vite-frontend
@@ -54,6 +54,7 @@ import { Switch } from "@/shadcn-bridge/heroui/switch";
 import { Alert } from "@/shadcn-bridge/heroui/alert";
 import { Progress } from "@/shadcn-bridge/heroui/progress";
 import { Checkbox } from "@/shadcn-bridge/heroui/checkbox";
+import { Accordion, AccordionItem } from "@/shadcn-bridge/heroui/accordion";
 import {
  createForward,
  getForwardList,
@@ -118,6 +119,7 @@ interface Forward {
  outFlow: number;
  serviceRunning: boolean;
  federationShareFlow?: number;
+  maxConn?: number;
  createdTime: string;
  userName?: string;
  userId?: number;
@@ -2115,6 +2117,7 @@ export default function ForwardPage() {
      interfaceName: forward.interfaceName || "",
      strategy: forward.strategy || "fifo",
      speedId: normalizeSpeedId(forward.speedId),
+      maxConn: forward.maxConn || 0,
    });
    setErrors({});
    setModalOpen(true);
@@ -2243,6 +2246,7 @@ export default function ForwardPage() {
          remoteAddr: processedRemoteAddr,
          strategy: addressCount > 1 ? form.strategy : "fifo",
          speedId: normalizedSpeedId,
+          maxConn: form.maxConn,
        };

        res = await updateForward(updateData);
@@ -2255,6 +2259,7 @@ export default function ForwardPage() {
          remoteAddr: processedRemoteAddr,
          strategy: addressCount > 1 ? form.strategy : "fifo",
          speedId: normalizedSpeedId,
+          maxConn: form.maxConn,
        };

        res = await createForward(createData);
@@ -4725,20 +4730,6 @@ export default function ForwardPage() {
              </ModalHeader>
              <ModalBody>
                <div className="space-y-4 pb-4">
-                  <Input
-                    label="最大连接数"
-                    placeholder="0 或空表示不限制"
-                    type="number"
-                    min="0"
-                    value={form.maxConn === 0 ? "" : String(form.maxConn || "")}
-                    onChange={(e) => {
-                      const value = Math.max(Number(e.target.value) || 0, 0);
-                      setForm((prev) => ({ ...prev, maxConn: value }));
-                    }}
-                    description="此设置优先于用户的全局连接数限制。0 表示不限制。"
-                    variant="bordered"
-                  />
-
                  <Input
                    errorMessage={errors.name}
                    isInvalid={!!errors.name}
@@ -4751,37 +4742,7 @@ export default function ForwardPage() {
                    }
                  />

-                  {isAdmin && (
-                    <Select
-                      label="规则限速"
-                      placeholder="不限速"
-                      selectedKeys={
-                        selectedSpeedId !== null
-                          ? [selectedSpeedId.toString()]
-                          : []
-                      }
-                      variant="bordered"
-                      onSelectionChange={(keys) => {
-                        const selectedKey = Array.from(keys)[0] as
-                          | string
-                          | undefined;
-
-                        setForm((prev) => ({
-                          ...prev,
-                          speedId: selectedKey ? Number(selectedKey) : null,
-                        }));
-                      }}
-                    >
-                      {availableSpeedLimits.map((speedLimit) => (
-                        <SelectItem
-                          key={speedLimit.id.toString()}
-                          textValue={speedLimit.name}
-                        >
-                          {speedLimit.name}
-                        </SelectItem>
-                      ))}
-                    </Select>
-                  )}
+                  

                  <Select
                    description={
@@ -4910,7 +4871,61 @@ export default function ForwardPage() {
                      <SelectItem key="hash">哈希模式 - IP哈希</SelectItem>
                    </Select>
                  )}
-                </div>
+                                  <Accordion className="px-0" variant="light">
+                    <AccordionItem
+                      key="advanced"
+                      aria-label="高级设置"
+                      title={<span className="text-small text-default-500 font-medium">高级设置</span>}
+                    >
+                      <div className="space-y-4 pb-2">
+                        <Input
+                          label="最大连接数"
+                          placeholder="0 或空表示不限制"
+                          type="number"
+                          min="0"
+                          value={form.maxConn === 0 ? "" : String(form.maxConn || "")}
+                          onChange={(e) => {
+                            const value = Math.max(Number(e.target.value) || 0, 0);
+                            setForm((prev) => ({ ...prev, maxConn: value }));
+                          }}
+                          description="此设置优先于用户的全局连接数限制。0 表示不限制。"
+                          variant="bordered"
+                        />
+                        {isAdmin && (
+                          <Select
+                            label="规则限速"
+                            placeholder="不限速"
+                            selectedKeys={
+                              selectedSpeedId !== null
+                                ? [selectedSpeedId.toString()]
+                                : []
+                            }
+                            variant="bordered"
+                            onSelectionChange={(keys) => {
+                              const selectedKey = Array.from(keys)[0] as
+                                | string
+                                | undefined;
+
+                              setForm((prev) => ({
+                                ...prev,
+                                speedId: selectedKey ? Number(selectedKey) : null,
+                              }));
+                            }}
+                          >
+                            {availableSpeedLimits.map((speedLimit) => (
+                              <SelectItem
+                                key={speedLimit.id.toString()}
+                                textValue={speedLimit.name}
+                              >
+                                {speedLimit.name}
+                              </SelectItem>
+                            ))}
+                          </Select>
+                        )}
+                      </div>
+                    </AccordionItem>
+                  </Accordion>
+</div>
              </ModalBody>
              <ModalFooter>
                <Button variant="light" onPress={onClose}>
@@ -1529,17 +1529,6 @@ export default function UserPage() {
                  setUserForm((prev) => ({ ...prev, maxConn: value }));
                }}
              />
-              <Input
-                label="最大连接数"
-                placeholder="0 或空表示不限制"
-                type="number"
-                min="0"
-                value={userForm.maxConn === 0 ? "" : String(userForm.maxConn || "")}
-                onChange={(e) => {
-                  const value = Math.max(Number(e.target.value) || 0, 0);
-                  setUserForm((prev) => ({ ...prev, maxConn: value }));
-                }}
-              />
              <Input
                isRequired
                label="规则数量"
@@ -2,8 +2,9 @@ import { clearSession } from "@/utils/session";

 /**
 * 安全退出登录函数
- * 清除登录相关数据，但保留用户偏好设置（如主题）
+ * 清除登录相关数据，并强制刷新跳转到首页
 */
 export const safeLogout = () => {
  clearSession();
+  window.location.href = "/";
 };
Author	SHA1	Message	Date
sagitchu	a5c33c68d9	Revert "fix: 保留用户/规则高级设置并增强节点运行时恢复 (#468 )" This reverts commit `3f374df724`.	2026-04-25 22:45:27 +08:00
sagitchu	325baa8adc	Revert "feat: 批量设置用户最大连接数" This reverts commit `28568244bb`.	2026-04-25 22:45:23 +08:00
sagitchu	28568244bb	feat: 批量设置用户最大连接数前端: - 用户列表添加 checkbox 多选（表格和网格视图） - 选中用户后显示「批量设置连接数」按钮 - 批量设置对话框，输入连接数后批量应用后端: - 新增 BatchUpdateUserMaxConn repo 方法 - 新增 /api/v1/user/batch-set-max-conn API - 返回成功/失败计数 - 加入 admin-only 路由白名单	2026-04-25 22:03:42 +08:00
sagit	3f374df724	fix: 保留用户/规则高级设置并增强节点运行时恢复 (#468 ) * fix: 用户编辑时 maxConn 字段未正确回填 - User 接口添加 maxConn 类型定义 - handleEdit 中回填 maxConn 值 - normalizeUserItem 添加 maxConn 字段处理解决编辑用户时最大连接数显示为 0 的问题 * fix: 保留转发设置并增强节点运行时恢复	2026-04-25 18:12:13 +08:00
sagit	9b923a2d0b	fix: remove duplicate maxConn input in user form (#467 )	2026-04-24 21:56:46 +08:00
sagit	d9f28f53c7	style: move advanced settings to bottom and optimize UI (#466 )	2026-04-24 19:10:36 +08:00
sagit	1d08a1ccfc	fix: ensure page refresh to login page upon logout (#465 )	2026-04-23 20:43:27 +08:00
sagit	db25ba2cbe	style: move maxConn and speed limit inputs to advanced settings accordion (#464 )	2026-04-23 20:29:52 +08:00
sagit	a498067261	fix: properly initialize maxConn in forward rules (#463 ) * fix: initialize maxConn in forward creation and edit forms * fix: add maxConn to Forward interface	2026-04-23 20:23:18 +08:00
sagit	b5922dccf2	fix: include maxConn when submitting forward forms (#462 ) * fix: frontend missing maxConn setting during forward creation * docs: check off plan	2026-04-23 20:11:20 +08:00