From 944b98d4d0848fbbca2eb1b65aee64419df57de5 Mon Sep 17 00:00:00 2001 From: ryan Date: Fri, 29 May 2026 10:37:23 +0800 Subject: [PATCH] =?UTF-8?q?[=E6=96=B0=E5=A2=9E]=20=E5=AE=9E=E7=8E=B0?= =?UTF-8?q?=E8=8A=82=E7=82=B9=E5=BC=BA=E5=88=B6=E5=90=8C=E6=AD=A5=E5=8A=9F?= =?UTF-8?q?=E8=83=BD=EF=BC=8C=E5=85=81=E8=AE=B8=E9=80=9A=E8=BF=87=20API=20?= =?UTF-8?q?=E8=AF=B7=E6=B1=82=E5=BC=BA=E5=88=B6=E5=90=8C=E6=AD=A5=E9=85=8D?= =?UTF-8?q?=E7=BD=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- openflare_agent/internal/agent/runner_test.go | 16 ++++++++++++++++ openflare_server/router/api-router.go | 1 - 2 files changed, 16 insertions(+), 1 deletion(-) diff --git a/openflare_agent/internal/agent/runner_test.go b/openflare_agent/internal/agent/runner_test.go index 5f169116..be47a1e8 100644 --- a/openflare_agent/internal/agent/runner_test.go +++ b/openflare_agent/internal/agent/runner_test.go @@ -119,6 +119,22 @@ func (f *fakeSyncService) SyncOnce(ctx context.Context, target *protocol.ActiveC return f.syncOnceErr } +func (f *fakeSyncService) ForceSyncOnce(ctx context.Context, target *protocol.ActiveConfigMeta) error { + f.mu.Lock() + f.syncOnceCalls++ + if target != nil { + copied := *target + f.lastTarget = &copied + } + callIndex := f.syncOnceCalls + callback := f.onSyncOnceCall + f.mu.Unlock() + if callback != nil { + callback(callIndex) + } + return f.syncOnceErr +} + type fakeWebSocketConnection struct { pongCalls int } diff --git a/openflare_server/router/api-router.go b/openflare_server/router/api-router.go index a0cde9e3..1bb405c5 100644 --- a/openflare_server/router/api-router.go +++ b/openflare_server/router/api-router.go @@ -170,7 +170,6 @@ func SetApiRouter(router *gin.Engine) { nodeRoute.POST("/:id/agent-update", controller.RequestNodeAgentUpdate) nodeRoute.POST("/:id/openresty-restart", controller.RequestNodeOpenrestyRestart) nodeRoute.POST("/:id/force-sync", controller.RequestNodeForceSync) - nodeRoute.GET("/:id/agent-release", controller.GetNodeAgentRelease) nodeRoute.GET("/:id/observability", controller.GetNodeObservability) nodeRoute.POST("/:id/observability/cleanup", controller.CleanupNodeHealthEvents) }