From 99fbb3155416efb10d7d703f8d226cbf75cf918f Mon Sep 17 00:00:00 2001 From: yusing Date: Sat, 15 Feb 2025 09:10:42 +0800 Subject: [PATCH] fix routes not started after adding agent --- internal/config/agent_pool.go | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/internal/config/agent_pool.go b/internal/config/agent_pool.go index 9fe203d..9884211 100644 --- a/internal/config/agent_pool.go +++ b/internal/config/agent_pool.go @@ -3,6 +3,7 @@ package config import ( "github.com/yusing/go-proxy/agent/pkg/agent" "github.com/yusing/go-proxy/internal/gperr" + "github.com/yusing/go-proxy/internal/logging" "github.com/yusing/go-proxy/internal/route/provider" "github.com/yusing/go-proxy/internal/utils/functional" ) @@ -36,12 +37,16 @@ func (cfg *Config) AddAgent(host string, ca agent.PEMPair, client agent.PEMPair) if err != nil { return 0, gperr.Wrap(err, "failed to start agent") } + addAgent(&agentCfg) provider := provider.NewAgentProvider(&agentCfg) if err := cfg.errIfExists(provider); err != nil { return 0, err } + provider.LoadRoutes() + provider.Start(cfg.Task()) cfg.storeProvider(provider) + logging.Info().Msgf("Added agent %s with %d routes", host, provider.NumRoutes()) return provider.NumRoutes(), nil }