Method Run

internal/cli/cli_integration_test.go:3572–3794

(ctx context.Context)

}

func (d *integrationDaemon) Run(ctx context.Context) error {
	registry, err := globaldb.OpenGlobalDB(context.Background(), d.homePaths.DatabaseFile)
	if err != nil {
		return fmt.Errorf("open global db: %w", err)
	}
	defer func() {
		_ = registry.Close(context.Background())
	}()

	fanout := &integrationNotifierFanout{}
	resolver, err := workspacepkg.NewResolver(
		registry,
		workspacepkg.WithHomePaths(d.homePaths),
		workspacepkg.WithLogger(discardLogger()),
		workspacepkg.WithConfigLoader(func(string) (aghconfig.Config, error) { return d.cfg, nil }),
	)
	if err != nil {
		return fmt.Errorf("new workspace resolver: %w", err)
	}
	sandboxRegistry, err := sandboxlocal.NewRegistry()
	if err != nil {
		return fmt.Errorf("new local sandbox registry: %w", err)
	}
	manager, err := session.NewManager(
		session.WithHomePaths(d.homePaths),
		session.WithWorkspaceResolver(resolver),
		session.WithLogger(discardLogger()),
		session.WithDriver(func() *integrationDriver {
			driver := newIntegrationDriver()
			d.mu.Lock()
			d.driver = driver
			d.mu.Unlock()
			return driver
		}()),
		session.WithNotifier(fanout),
		session.WithSandboxRegistry(sandboxRegistry),
		session.WithSoulSnapshotStore(registry),
		session.WithSoulRunActivityChecker(integrationSoulRunActivityChecker{}),
		session.WithSessionHealthStore(registry),
		session.WithSessionHealthConfig(d.cfg.Agents.Heartbeat),
	)
	if err != nil {
		return fmt.Errorf("new session manager: %w", err)
	}
	d.mu.Lock()
	d.manager = manager
	d.mu.Unlock()

	taskManager, err := taskpkg.NewManager(
		taskpkg.WithStore(registry),
		taskpkg.WithSessionExecutor(&integrationTaskExecutor{}),
		taskpkg.WithNetworkChannelValidator(network.ValidateChannel),
	)
	if err != nil {
		return fmt.Errorf("new task manager: %w", err)
	}

	bridgeService := newIntegrationBridgeService(registry)