Function verifyStartNewAgent

internal/api/v1/agent/verify.go:227–272

(ctx context.Context, host string, ca agent.PEMPair, client agent.PEMPair, containerRuntime agent.ContainerRuntime)

}

func verifyStartNewAgent(ctx context.Context, host string, ca agent.PEMPair, client agent.PEMPair, containerRuntime agent.ContainerRuntime) (int, error) {
	var agentCfg agent.AgentConfig
	agentCfg.Addr = host
	agentCfg.Runtime = containerRuntime

	// check if agent host exists in the config
	cfgState := configtypes.ActiveState.Load()
	for _, a := range cfgState.Value().Providers.Agents {
		if a.Addr == host {
			return 0, errAgentAlreadyExists
		}
	}
	// check if agent host exists in the agent pool
	if agentpool.Has(&agentCfg) {
		return 0, errAgentAlreadyExists
	}

	err := agentCfg.InitWithCerts(ctx, ca.Cert, client.Cert, client.Key)
	if err != nil {
		return 0, fmt.Errorf("failed to initialize agent config: %w", err)
	}

	provider := provider.NewAgentProvider(&agentCfg)
	if _, loaded := cfgState.LoadOrStoreProvider(provider.String(), provider); loaded {
		return 0, fmt.Errorf("provider %s already exists", provider.String())
	}

	// agent must be added before loading routes
	added := agentpool.Add(&agentCfg)
	if !added {
		return 0, errAgentAlreadyExists
	}
	err = provider.LoadRoutes()
	if err != nil {
		cfgState.DeleteProvider(provider.String())
		agentpool.Remove(&agentCfg)
		return 0, fmt.Errorf("failed to load routes: %w", err)
	}

	err = provider.Start(cfgState.Task())
	if err != nil {
		return 0, fmt.Errorf("failed to start routes: %w", err)
	}

	return provider.NumRoutes(), nil
}