Function runREPL

cmd/aster/session.go:319–374

runREPL runs the read-eval-print loop

(ctx context.Context, ag *agent.Agent, sessionStore session.Service, sessionID string, useColor bool)

// runREPL runs the read-eval-print loop
func runREPL(ctx context.Context, ag *agent.Agent, sessionStore session.Service, sessionID string, useColor bool) error {
	reader := bufio.NewReader(os.Stdin)

	for {
		// Print prompt
		printColored(useColor, colorBold+colorBlue, "\naster> ")

		// Read input
		input, err := reader.ReadString('\n')
		if err != nil {
			if err == io.EOF {
				printColored(useColor, colorYellow, "\n\n👋 Goodbye!\n")
				return nil
			}
			return fmt.Errorf("read input: %w", err)
		}

		input = strings.TrimSpace(input)
		if input == "" {
			continue
		}

		// Handle commands
		if strings.HasPrefix(input, "/") {
			handled, err := handleCommand(ctx, input, ag, sessionStore, sessionID, useColor)
			if err != nil {
				printColored(useColor, colorYellow, "Error: %s\n", err)
			}
			if handled {
				if input == "/exit" || input == "/quit" {
					return nil
				}
				continue
			}
		}

		// Record user message to session
		_ = sessionStore.AppendEvent(ctx, sessionID, &session.Event{
			Author: "user",
			Content: types.Message{
				Role:    types.RoleUser,
				Content: input,
			},
		})

		// Send to agent
		fmt.Println()
		if err := ag.Send(ctx, input); err != nil {
			printColored(useColor, colorYellow, "Error: %s\n", err)
			continue
		}

		// Wait for response to complete
		waitForCompletion(ctx, ag)
	}
}

// handleCommand handles slash commands