Method init

src/parser-includes.ts:74–210

(gitlabData: any, opts: ParserIncludesInitOptions)

    }

    static async init (gitlabData: any, opts: ParserIncludesInitOptions): Promise<any[]> {
        const {argv, inputs: inputsConfig} = opts;
        const fileInputs = inputsConfig._file ?? {};
        const cliGlobalInputs = inputsConfig._cliGlobal ?? {};
        const cliComponentInputs = inputsConfig._cliComponents ?? {};

        const isStructured = Utils.isStructuredInputsFile(fileInputs);
        const globalInputs = {...Utils.getGlobalFileInputs(fileInputs), ...cliGlobalInputs};
        this.count++;
        assert(
            this.count <= opts.maximumIncludes + 1, // 1st init call is not counted
            chalk`This GitLab CI configuration is invalid: Maximum of {blueBright ${opts.maximumIncludes}} nested includes are allowed!. This limit can be increased with the --maximum-includes cli flags.`,
        );
        let includeDatas: any[] = [];
        const promises = [];
        const {stateDir, cwd, fetchIncludes, gitData, expandVariables, writeStreams} = opts;
        // cache the parsed component, because parseIncludeComponent is expensive and we would call it twice otherwise
        const componentParseCache = new Map<number, ParsedComponent>();

        const include = this.expandInclude(gitlabData?.include, opts.variables);

        this.normalizeTriggerInclude(gitlabData, opts);
        // Find files to fetch from remote and place in .gitlab-ci-local/includes
        for (const [index, value] of include.entries()) {
            if (value["rules"]) {
                const include_rules = value["rules"];
                const rulesResult = Utils.getRulesResult({argv, cwd, rules: include_rules, variables: opts.variables}, gitData);
                if (rulesResult.when === "never") {
                    continue;
                }
            }
            if (value["file"]) {
                for (const fileValue of Array.isArray(value["file"]) ? value["file"] : [value["file"]]) {
                    promises.push(this.downloadIncludeProjectFile(opts, value["project"], value["ref"] || "HEAD", fileValue));
                }
            } else if (value["template"]) {
                const {project, ref, file, domain} = this.covertTemplateToProjectFile(value["template"]);
                const url = `https://${domain}/${project}/-/raw/${ref}/${file}`;
                promises.push(this.downloadIncludeRemote(cwd, stateDir, url, fetchIncludes, writeStreams));
            } else if (value["remote"]) {
                promises.push(this.downloadIncludeRemote(cwd, stateDir, value["remote"], fetchIncludes, writeStreams));
            } else if (value["component"]) {
                const component = this.parseIncludeComponent(value["component"], gitData);
                componentParseCache.set(index, component);
                if (!component.isLocal)
                {
                    promises.push(this.downloadIncludeComponent(opts, component.projectPath, component.effectiveRef, component.componentPath));
                }
            }

        }

        await Promise.all(promises);

        for (const [index, value] of include.entries()) {
            if (value["rules"]) {
                const include_rules = value["rules"];
                const rulesResult = Utils.getRulesResult({argv, cwd, rules: include_rules, variables: opts.variables}, gitData);