Implement the flow the agent that we don't send the updates over to c…

…onsole.dot

Signed-off-by: Aviel Segev <[email protected]>

api/v1alpha1/openapi.yaml

@@ -661,7 +661,7 @@ components:
           type: string
         status:
           type: string
-          enum: [not-connected, waiting-for-credentials, error, gathering-initial-inventory, up-to-date, source-gone]
+          enum: [not-connected, not-connected-to-service, waiting-for-credentials, error, gathering-initial-inventory, up-to-date, source-gone]
         statusInfo:
           type: string
         credentialUrl:

internal/agent/agent.go

@@ -135,6 +135,7 @@ func (a *Agent) start(ctx context.Context, plannerClient client.Planner) {
 
 	// TODO refactor health checker to call it from the main goroutine
 	healthChecker.Start(ctx, a.healtCheckStopCh)
+	statusUpdater.HealthChecker = healthChecker
 
 	collector := service.NewCollector(a.config.DataDir)
 	collector.Collect(ctx)

internal/agent/service/status.go

@@ -20,11 +20,12 @@ const (
 )
 
 type StatusUpdater struct {
-	agentID uuid.UUID
-	version string
-	config  *config.Config
-	client  client.Planner
-	credUrl string
+	agentID       uuid.UUID
+	version       string
+	config        *config.Config
+	client        client.Planner
+	credUrl       string
+	HealthChecker *HealthChecker
 }
 
 func NewStatusUpdater(agentID uuid.UUID, version, credUrl string, config *config.Config, client client.Planner) *StatusUpdater {
@@ -77,5 +78,10 @@ func (s *StatusUpdater) CalculateStatus() (api.AgentStatus, string, *api.Invento
 	if len(inventory.Error) > 0 {
 		return api.AgentStatusError, inventory.Error, &inventory.Inventory
 	}
+
+	if s.HealthChecker != nil && s.HealthChecker.State() == HealthCheckStateConsoleUnreachable {
+		return api.AgentStatusNotConnectedToService, "Migration Planner service is unreachable", &inventory.Inventory
+	}
+
 	return api.AgentStatusUpToDate, "Inventory successfully collected", &inventory.Inventory
 }