Function executeFlowsForPack

src/packFileSerializer.ts:1355–1451

(
  pathSource: string,
  pathTarget: string,
  userFlowOptions: UserFlowOptions,
  packName: string,
  sourcePack?: Pick<Pack, "packedFiles">,
)

  };
};
export const executeFlowsForPack = async (
  pathSource: string,
  pathTarget: string,
  userFlowOptions: UserFlowOptions,
  packName: string,
  sourcePack?: Pick<Pack, "packedFiles">,
): Promise<{ createdPackPaths: string[]; hadErrors: boolean }> => {
  void pathTarget;
  const createdPackPaths = new Set<string>();
  let hadErrors = false;
  const packStartTime = performance.now();
  const isDebug = isFlowExecutionDebugEnabled();
  const executionContext = createFlowExecutionContext(isDebug);
  try {
    console.log("Executing flows for pack:", packName);
    // Note: Counter tracking is NOT reset here - it's reset once at game launch level
    // This ensures counters are unique across all flows in all packs
    // Read the pack to get flow files
    const sourceMod = sourcePack ?? (await readPack(pathSource, { readFlows: true, skipParsingTables: true }));
    // Filter for flow files
    const flowFiles = sourceMod.packedFiles.filter((file) => file.name.startsWith("whmmflows\\"));
    if (flowFiles.length === 0) {
      console.log("No flow files found in pack");
      return { createdPackPaths: Array.from(createdPackPaths), hadErrors };
    }
    console.log(`Found ${flowFiles.length} flow files in pack`);
    // Get user options for this pack
    const packFlowOptions = userFlowOptions[packName] || {};
    const preparedFlows: PreparedFlow[] = [];
    const prepareStartTime = performance.now();
    for (const flowFile of flowFiles) {
      try {
        const flowContent = flowFile.text || (flowFile.buffer ? flowFile.buffer.toString("utf-8") : "");
        if (!flowContent) {
          console.warn(`Flow file ${flowFile.name} has no content`);
          continue;
        }
        const flowFileName = flowFile.name;
        const flowData: SerializedNodeGraph = JSON.parse(flowContent);
        const flowOptions = packFlowOptions[flowFileName];
        if (flowData.isGraphEnabled && flowOptions?.graphEnabled === false) {
          console.log(`Flow ${flowFileName} is disabled by user, skipping`);
          continue;
        }
        preparedFlows.push(prepareFlow(flowFileName, flowData, packName, flowOptions, isDebug));
      } catch (error) {
        console.error(`Error preparing flow ${flowFile.name}:`, error);
        hadErrors = true;
      }
    }
    console.log(
      `Prepared ${preparedFlows.length}/${flowFiles.length} flow(s) in ${(performance.now() - prepareStartTime).toFixed(2)}ms`,
    );
    for (const preparedFlow of preparedFlows) {
      const flowStartTime = performance.now();
      try {
        const result = await executeNodeGraph({
          nodes: preparedFlow.nodes,