Function runTaskLoop

packages/spinai/src/taskloop/taskloop.ts:21–307

(
  taskLoopParams: TaskLoopParams<TResponseFormat>
)

import { processAgentFinalResponse } from "./finalResponse";

export async function runTaskLoop<
  TResponseFormat extends "text" | z.ZodType<any> = "text",
  TResponse = InferResponseType<TResponseFormat>,
>(
  taskLoopParams: TaskLoopParams<TResponseFormat>
): Promise<AgentResponse<TResponse>> {
  const {
    actions,
    model,
    input,
    externalCustomerId,
    maxSteps = 10,
    instructions,
    debug,
    sessionId = uuidv4(),
    agentId,
    spinApiKey,
    state = {},
    responseFormat = "text",
    customLoggingEndpoint,
    messages: initialMessages = [],
    fixedSteps,
  } = taskLoopParams;
  const modelId = model.modelId;
  const modelProvider = model.provider;
  const interactionId = uuidv4();

  // Set debug logging based on parameter
  setDebugEnabled(debug ?? "default");

  // Track total cost
  let totalCostCents = 0;
  let totalPromptTokens = 0;
  let totalCompletionTokens = 0;

  // Create system message
  const systemMessage = await createSystemMessage(instructions, actions);
  const userMessage = await createUserMessage(input);
  // Initialize messages array with system message
  const messages: Message[] =
    initialMessages.length === 0
      ? [systemMessage, userMessage]
      : [...initialMessages, userMessage];

  log(`Starting interaction with ${debug ?? "default"} logging`, {
    type: "summary",
  });

  // Initialize logging service
  const taskStartTime = Date.now();

  const logger = new LoggingService({
    agentId: agentId,
    spinApiKey: spinApiKey,
    sessionId,
    interactionId,
    modelId,
    modelProvider,