Method maybeEnableLocalHub

cli/hub_local.go:237–270

maybeEnableLocalHub wires a standalone CLI to the on-disk hub unless the session is already connected to a remote hub. The hub is on by default; the `enabled` setting (or CHATCLI_HUB_ENABLED=false) opts out. Returns a closer for the opened database, or nil when local mode is off.

(ctx context.Context)

// `enabled` setting (or CHATCLI_HUB_ENABLED=false) opts out. Returns a closer
// for the opened database, or nil when local mode is off.
func (cli *ChatCLI) maybeEnableLocalHub(ctx context.Context) func() {
	if cli.hubSync != nil || cli.isRemote {
		return nil // a /connect session already owns hub sync
	}
	dbPath, err := hub.DefaultDBPath()
	if err != nil {
		cli.logger.Warn("local hub: cannot resolve db path; disabling", zap.Error(err))
		return nil
	}
	store, err := hub.OpenSQLiteStore(ctx, dbPath, cli.logger)
	if err != nil {
		cli.logger.Warn("local hub: cannot open db; disabling", zap.Error(err))
		return nil
	}
	// The enabled setting lives in the db (so /config hub set enabled off reaches
	// the gateway too); it can only be read once the store is open. Disabling is
	// a legitimate choice but never a silent one — it severs cross-channel
	// continuity with the gateway.
	if !resolveHubEnabled(ctx, store) {
		cli.logger.Warn("local hub: conversation hub DISABLED via setting/env; this session will not share context with the gateway",
			zap.String("source", hubEnabledSource(ctx, store)))
		_ = store.Close()
		return nil
	}
	if n, err := store.PurgeIdle(ctx, resolveHubTTL(ctx, store)); err != nil {
		cli.logger.Warn("local hub: purge idle failed", zap.Error(err))
	} else if n > 0 {
		cli.logger.Info("local hub: purged idle conversations", zap.Int("count", n))
	}
	principal := resolveHubPrincipal(ctx, store)
	cli.hubSync = newHubSync(newLocalHubClient(store, principal), cli.logger)
	cli.logger.Info("local hub mode enabled", zap.String("principal", principal), zap.String("db", dbPath))
	return func() { _ = store.Close() }
}