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) }