Function getCalledActions

lib/edge-runtime/dataAnalysis.ts:213–271

(
  assistantFnMessagePairs: (AssistantMessage & {
    functionMessages: FunctionMessage[];
  })[],
  actions: Action[],
)

}

export function getCalledActions(
  assistantFnMessagePairs: (AssistantMessage & {
    functionMessages: FunctionMessage[];
  })[],
  actions: Action[],
): CalledAction[] {
  console.log(
    "actions",
    actions.map((a) => a === undefined),
  );
  const calledActions = assistantFnMessagePairs
    .map((pair) => {
      const parsedOutput = parseOutput(pair.content);

      // TODO: Remove API calls since last successful data analysis call
      return (
        parsedOutput.commands
          // Remove the data analysis action
          .filter(
            (command) =>
              ![dataAnalysisActionName, "instruct_coder"].includes(
                command?.name,
              ),
          )
          .map((command, idx) => {
            let output: Json = pair.functionMessages[idx]?.content;
            try {
              output = JSON.parse(pair.functionMessages[idx]?.content);
            } catch {}
            console.log(`command ${idx}:`, command);
            return {
              action: actions.find((a) => a.name === command.name)!,
              args: command.args,
              output,
            };
          })
      );
    })
    .flat();
  console.log(
    "calledActions",
    calledActions.map((a) => a === undefined),
  );

  return calledActions
    .reverse()
    .filter((a, idx) => {
      // Keep most recent call if identical calls are made >once
      const earliestCall =
        calledActions.findIndex(
          (otherAction) =>
            otherAction.action?.name === a.action?.name &&
            _.isEqual(otherAction.args, a.args),
        ) ?? idx;
      return idx === earliestCall;
      // Reversed it earlier, so need to re-reverse
    })
    .reverse();