import { promises as fs } from 'fs';
import { join, resolve } from 'path';
import isPathInside from 'is-path-inside';
import pMap from 'p-map';
import { ARCHIVE_FORMAT } from './archive.js';
import { getFlags } from './feature_flags.js';
import { createManifest } from './manifest.js';
import { getFunctionsFromPaths } from './runtimes/index.js';
import { MODULE_FORMAT } from './runtimes/node/utils/module_format.js';
import { addArchiveSize } from './utils/archive_size.js';
import { RuntimeCache } from './utils/cache.js';
import { formatZipResult } from './utils/format_result.js';
import { listFunctionsDirectories, resolveFunctionsDirectories } from './utils/fs.js';
import { getLogger } from './utils/logger.js';
import { nonNullable } from './utils/non_nullable.js';
const DEFAULT_PARALLEL_LIMIT = 5;
const validateArchiveFormat = (archiveFormat) => {
    if (!Object.values(ARCHIVE_FORMAT).includes(archiveFormat)) {
        throw new Error(`Invalid archive format: ${archiveFormat}`);
    }
};
// Zip `srcFolder/*` (Node.js or Go files) to `destFolder/*.zip` so it can be
// used by AWS Lambda
export const zipFunctions = async function (relativeSrcFolders, destFolder, { archiveFormat = ARCHIVE_FORMAT.ZIP, basePath, branch, config = {}, configFileDirectories, featureFlags: inputFeatureFlags, manifest, parallelLimit = DEFAULT_PARALLEL_LIMIT, repositoryRoot = basePath, systemLog, debug, internalSrcFolder, } = {}) {
    validateArchiveFormat(archiveFormat);
    const logger = getLogger(systemLog, debug);
    const cache = new RuntimeCache();
    const featureFlags = getFlags(inputFeatureFlags);
    const srcFolders = resolveFunctionsDirectories(relativeSrcFolders);
    const internalFunctionsPath = internalSrcFolder && resolve(internalSrcFolder);
    const [paths] = await Promise.all([listFunctionsDirectories(srcFolders), fs.mkdir(destFolder, { recursive: true })]);
    const functions = await getFunctionsFromPaths(paths, {
        cache,
        config,
        configFileDirectories,
        dedupe: true,
        featureFlags,
    });
    const results = await pMap(functions.values(), async (func) => {
        const functionFlags = {
            ...featureFlags,
            // If there's a `nodeModuleFormat` configuration property set to `esm`,
            // extend the feature flags with `zisi_pure_esm_mjs` enabled.
            ...(func.config.nodeModuleFormat === MODULE_FORMAT.ESM ? { zisi_pure_esm_mjs: true } : {}),
        };
        const zipResult = await func.runtime.zipFunction({
            archiveFormat,
            basePath,
            branch,
            cache,
            config: func.config,
            destFolder,
            extension: func.extension,
            featureFlags: functionFlags,
            filename: func.filename,
            isInternal: Boolean(internalFunctionsPath && isPathInside(func.srcPath, internalFunctionsPath)),
            logger,
            mainFile: func.mainFile,
            name: func.name,
            repositoryRoot,
            runtime: func.runtime,
            srcDir: func.srcDir,
            srcPath: func.srcPath,
            stat: func.stat,
        });
        return { ...zipResult, mainFile: func.mainFile, name: func.name, runtime: func.runtime };
    }, {
        concurrency: parallelLimit,
    });
    const formattedResults = await Promise.all(results.filter(nonNullable).map(async (result) => {
        const resultWithSize = await addArchiveSize(result);
        return formatZipResult(resultWithSize);
    }));
    await createManifest({ functions: formattedResults, path: resolve(manifest || join(destFolder, 'manifest.json')) });
    return formattedResults;
};
export const zipFunction = async function (relativeSrcPath, destFolder, { archiveFormat = ARCHIVE_FORMAT.ZIP, basePath, config: inputConfig = {}, featureFlags: inputFeatureFlags, repositoryRoot = basePath, systemLog, debug, internalSrcFolder, } = {}) {
    validateArchiveFormat(archiveFormat);
    const logger = getLogger(systemLog, debug);
    const featureFlags = getFlags(inputFeatureFlags);
    const srcPath = resolve(relativeSrcPath);
    const cache = new RuntimeCache();
    const functions = await getFunctionsFromPaths([srcPath], { cache, config: inputConfig, dedupe: true, featureFlags });
    const internalFunctionsPath = internalSrcFolder && resolve(internalSrcFolder);
    if (functions.size === 0) {
        return;
    }
    const { config, extension, filename, mainFile, name, runtime, srcDir, stat: stats, } = functions.values().next().value;
    await fs.mkdir(destFolder, { recursive: true });
    const functionFlags = {
        ...featureFlags,
        // If there's a `nodeModuleFormat` configuration property set to `esm`,
        // extend the feature flags with `zisi_pure_esm_mjs` enabled.
        ...(config.nodeModuleFormat === MODULE_FORMAT.ESM ? { zisi_pure_esm_mjs: true } : {}),
    };
    const zipResult = await runtime.zipFunction({
        archiveFormat,
        basePath,
        cache,
        config,
        destFolder,
        extension,
        featureFlags: functionFlags,
        filename,
        isInternal: Boolean(internalFunctionsPath && isPathInside(srcPath, internalFunctionsPath)),
        logger,
        mainFile,
        name,
        repositoryRoot,
        runtime,
        srcDir,
        srcPath,
        stat: stats,
    });
    return formatZipResult({ ...zipResult, mainFile, name, runtime });
};