Method Start

lib/screentracker/pty_conversation.go:212–310

(ctx context.Context)

}

func (c *PTYConversation) Start(ctx context.Context) {
	// Snapshot loop
	c.cfg.Clock.TickerFunc(ctx, c.cfg.SnapshotInterval, func() error {
		c.lock.Lock()
		screen := c.cfg.AgentIO.ReadScreen()
		c.snapshotLocked(screen)
		status := c.statusLocked()
		messages := c.messagesLocked()

		// Signal send loop if agent is ready and queue has items.
		// We check readiness independently of statusLocked() because
		// statusLocked() returns "changing" when queue has items.
		if !c.initialPromptReady && c.cfg.ReadyForInitialPrompt(screen) {
			c.initialPromptReady = true
		}

		var loadErr string
		if c.initialPromptReady && c.loadStateStatus == LoadStatePending && c.cfg.StatePersistenceConfig.LoadState {
			if err, shouldEmit := c.loadStateLocked(); err != nil {
				c.loadStateStatus = LoadStateFailed
				if shouldEmit {
					c.cfg.Logger.Error("Failed to load state", "error", err)
					loadErr = fmt.Sprintf("Failed to restore previous session: %v", err)
				}
			} else {
				c.loadStateStatus = LoadStateSucceeded
			}
		}

		if c.initialPromptReady && len(c.cfg.InitialPrompt) > 0 && !c.initialPromptSent {
			// Safe to send under lock: the queue is guaranteed empty here because
			// statusLocked blocks Send until the snapshot buffer fills, which
			// cannot happen before this first enqueue completes.
			c.outboundQueue <- outboundMessage{parts: c.cfg.InitialPrompt, errCh: nil}
			c.initialPromptSent = true
			c.dirty = true
		}

		if c.initialPromptReady && len(c.outboundQueue) > 0 && c.isScreenStableLocked() {
			select {
			case c.stableSignal <- struct{}{}:
				c.sendingMessage = true
			default:
				// Signal already pending
			}
		}
		c.lock.Unlock()

		if loadErr != "" {
			c.emitter.EmitError(loadErr, ErrorLevelWarning)
		}
		c.emitter.EmitStatus(status)
		c.emitter.EmitMessages(messages)
		c.emitter.EmitScreen(screen)
		return nil
	}, "snapshot")

	// Send loop - primary call site for sendLocked() in production