Function startAgentLoop

app/src/utils/main_loop.ts:78–205

(agentId: string, getToken?: TokenProvider, skipWhitelistCheck = false)

}

export async function startAgentLoop(agentId: string, getToken?: TokenProvider, skipWhitelistCheck = false): Promise<void> {
  if (activeLoops[agentId]?.isRunning) {
    Logger.warn(agentId, `Agent is already running`);
    return;
  }

  const isFirstAgent = getRunningAgentIds().length === 0;


  try {
    const agent = await getAgent(agentId);
    if (!agent) throw new Error(`Agent ${agentId} not found`);

    // Check phone whitelist before starting (unless explicitly skipped)
    if (!skipWhitelistCheck) {
      const agentCode = await getAgentCode(agentId) || '';
      const { phoneNumbers, hasTools, channel } = await checkPhoneWhitelist(agentCode, getToken);

      // If phone tools are used and there are issues, throw error for UI to handle
      if (hasTools && (phoneNumbers.length === 0 || phoneNumbers.some(p => !p.isWhitelisted))) {
        const error: any = new Error('Phone whitelist check failed');
        error.whitelistCheck = { phoneNumbers, hasTools, channel };
        throw error;
      }
    }

    const requiredStreams = getRequiredStreamsForPrompt(agent.system_prompt);
    
    if (requiredStreams.length > 0) {
      // A single, transactional call to the StreamManager.
      await StreamManager.requestStreamsForAgent(agentId, requiredStreams);
    }
    
    if (isFirstAgent) {
      recordingManager.initialize();
    }

    // Generate sessionId and start new session
    const sessionId = `session_${new Date().toISOString()}_${Math.random().toString(36).substring(2, 9)}`;
    IterationStore.startSession(agentId, sessionId);

    // Clear any previous change detection data for fresh start
    clearAgentChangeData(agentId);

    const intervalMs = agent.loop_interval_seconds * 1000;
    activeLoops[agentId] = {
        intervalId: null,
        isRunning: true,
        isExecuting: false,
        intervalMs,
        getToken
    };

    // Logger dispatches the window event automatically
    Logger.info(agentId, 'Agent started', {
      logType: 'agent-status-changed',
      content: { agentId, status: 'running' }
    });