Function processUserInput

src/index.ts:11–82

(
  cli: CLIInterface,
  userInput: string,
  conversation: any,
  availableTools: any[]
)

// Helper function to process user input
async function processUserInput(
  cli: CLIInterface,
  userInput: string,
  conversation: any,
  availableTools: any[]
) {
  // Handle commands
  if (userInput.toLowerCase() === '/exit') {
    cli.displayInfo('Goodbye! 👋');
    return 'exit';
  }

  if (userInput.toLowerCase() === '/help') {
    cli.displayHelp();
    return 'continue';
  }

  if (userInput.toLowerCase() === '/tools') {
    cli.displayTools(availableTools);
    return 'continue';
  }

  // Process user message through the agent
  cli.displayThinking();

  // Load previous conversation history from database (last 10 messages to stay within context limits)
  const conversationHistory = await conversationService.getConversationMessages(
    conversation.id,
    10
  );

  // Create initial state with conversation history + new message
  const initialState = {
    messages: [...conversationHistory, new HumanMessage(userInput)],
    conversationId: conversation.id,
    shouldContinue: true,
    toolResults: {},
    metadata: {
      workingDirectory: process.cwd(),
    },
  };

  // Run the graph with streaming to show tool executions
  const result = await graph.invoke(initialState);

  cli.stopThinking();

  // Find the final AI response (last AIMessage that's not empty)
  let finalResponse = '';
  for (let i = result.messages.length - 1; i >= 0; i--) {
    const msg = result.messages[i];
    if (
      msg instanceof AIMessage &&
      msg.content &&
      typeof msg.content === 'string' &&
      msg.content.trim().length > 0
    ) {
      finalResponse = msg.content;