@xmcl/forge-installer/index.js

import { Installer } from "@xmcl/installer";
import { downloadFileIfAbsentWork, downloadFileWork } from "@xmcl/net";
import Task from "@xmcl/task";
import Unzip from "@xmcl/unzip";
import { MinecraftFolder, JavaExecutor, vfs } from "@xmcl/util";
import { Version } from "@xmcl/version";
import { delimiter, join } from "path";
async function findMainClass(lib) {
    const zip = await Unzip.open(lib, { lazyEntries: true });
    const [manifest] = await zip.filterEntries(["META-INF/MANIFEST.MF"]);
    let mainClass;
    if (manifest) {
        const content = await zip.readEntry(manifest).then((b) => b.toString());
        const mainClassPair = content.split("\n").map((l) => l.split(": ")).filter((arr) => arr[0] === "Main-Class")[0];
        if (mainClassPair) {
            mainClass = mainClassPair[1].trim();
        }
    }
    zip.close();
    return mainClass;
}
/**
 * The forge installer Module to install forge to the game
 */
export var ForgeInstaller;
(function (ForgeInstaller) {
    ForgeInstaller.DEFAULT_FORGE_MAVEN = "http://files.minecraftforge.net";
    /**
     * Diagnose for specific forge version. Majorly for the current installer forge. (mcversion >= 1.13)
     *
     * Don't use this with the version less than 1.13
     * @param versionOrProfile If the version string present, it will try to find the installer profile under version folder. Otherwise it will use presented installer profile to diagnose
     * @param minecraft The minecraft location.
     */
    async function diagnoseForgeVersion(versionOrProfile, minecraft) {
        const version = typeof versionOrProfile === "string" ? versionOrProfile : versionOrProfile.version;
        const mc = MinecraftFolder.from(minecraft);
        const verRoot = mc.getVersionRoot(version);
        const versionJsonPath = mc.getVersionJson(version);
        const diag = {
            badProcessedFiles: [],
            missingInstallDependencies: [],
            badVersionJson: false,
            missingBinpatch: false,
            badInstall: false,
            missingSrgJar: false,
            missingMinecraftExtraJar: false,
            missingForgePatchesJar: false,
        };
        let prof;
        if (typeof versionOrProfile === "string") {
            const installProfPath = join(verRoot, "install_profile.json");
            if (await vfs.exists(installProfPath)) {
                prof = JSON.parse(await vfs.readFile(installProfPath).then((b) => b.toString()));
            }
        }
        else {
            prof = versionOrProfile;
        }
        if (prof) {
            const processedProfile = postProcessInstallProfile(mc, prof);
            for (const proc of processedProfile.processors) {
                if (proc.outputs) {
                    let bad = false;
                    for (const file in proc.outputs) {
                        if (!await vfs.validateSha1(file, proc.outputs[file].replace(/'/g, ""))) {
                            bad = true;
                            break;
                        }
                    }
                    if (bad) {
                        diag.badProcessedFiles.push(proc);
                    }
                }
            }
            // if we have to process file, we have to check if the forge deps are ready
            if (diag.badProcessedFiles.length !== 0) {
                const libValidMask = await Promise.all(processedProfile.libraries.map(async (lib) => {
                    const artifact = lib.downloads.artifact;
                    const libPath = mc.getLibraryByPath(artifact.path);
                    if (await vfs.exists(libPath)) {
                        return artifact.sha1 ? vfs.validateSha1(libPath, artifact.sha1) : true;
                    }
                    return false;
                }));
                const missingLibraries = processedProfile.libraries.filter((_, i) => !libValidMask[i]);
                diag.missingInstallDependencies.push(...missingLibraries);
                const validClient = await vfs.stat(processedProfile.data.BINPATCH.client).then((s) => s.size !== 0).catch((_) => false);
                if (!validClient) {
                    diag.missingBinpatch = true;
                    diag.badInstall = true;
                }
            }
        }
        if (await vfs.exists(versionJsonPath)) {
            const versionJSON = JSON.parse(await vfs.readFile(versionJsonPath).then((b) => b.toString()));
            if (versionJSON.arguments && versionJSON.arguments.game) {
                const args = versionJSON.arguments.game;
                const forgeVersion = args.indexOf("--fml.forgeVersion") + 1;
                const mcVersion = args.indexOf("--fml.mcVersion") + 1;
                const mcpVersion = args.indexOf("--fml.mcpVersion") + 1;
                if (!forgeVersion || !mcVersion || !mcpVersion) {
                    diag.badVersionJson = true;
                    diag.badInstall = true;
                }
                else {
                    const srgPath = mc.getLibraryByPath(`net/minecraft/client/${mcVersion}-${mcpVersion}/client-${mcVersion}-${mcpVersion}-srg.jar`);
                    const extraPath = mc.getLibraryByPath(`net/minecraft/client/${mcVersion}/client-${mcVersion}-extra.jar`);
                    const forgePatchPath = mc.getLibraryByPath(`net/minecraftforge/forge/${mcVersion}-${forgeVersion}/forge-${mcVersion}-${forgeVersion}-client.jar`);
                    diag.missingSrgJar = await vfs.missing(srgPath);
                    diag.missingMinecraftExtraJar = await vfs.missing(extraPath);
                    diag.missingForgePatchesJar = await vfs.missing(forgePatchPath);
                }
            }
            else {
                diag.badVersionJson = true;
                diag.badInstall = true;
            }
        }
        else {
            diag.badVersionJson = true;
            diag.badInstall = true;
        }
        return diag;
    }
    ForgeInstaller.diagnoseForgeVersion = diagnoseForgeVersion;
    /**
     * Post processing function for new forge installer (mcversion >= 1.13). You can use this with `ForgeInstaller.diagnose`.
     *
     * @param mc The minecraft location
     * @param proc The processor
     * @param java The java executor
     */
    async function postProcess(mc, proc, java) {
        const jarRealPath = mc.getLibraryByPath(Version.getLibraryInfo(proc.jar).path);
        const mainClass = await findMainClass(jarRealPath);
        if (!mainClass) {
            throw new Error(`Cannot find main class for processor ${proc.jar}.`);
        }
        const cp = [...proc.classpath, proc.jar].map(Version.getLibraryInfo).map((p) => mc.getLibraryByPath(p.path)).join(delimiter);
        const cmd = ["-cp", cp, mainClass, ...proc.args];
        await java(cmd);
        let failed = false;
        if (proc.outputs) {
            for (const file in proc.outputs) {
                if (!await vfs.validateSha1(file, proc.outputs[file].replace(/'/g, ""))) {
                    console.error(`Fail to process ${proc.jar} @ ${file} since its validation failed.`);
                    failed = true;
                }
            }
        }
        if (failed) {
            console.error(`Java arguments: ${JSON.stringify(cmd)}`);
            throw new Error("Fail to process post processing since its validation failed.");
        }
    }
    ForgeInstaller.postProcess = postProcess;
    function postProcessInstallProfile(mc, installProfile) {
        function processValue(v) {
            if (v.match(/^\[.+\]$/g)) {
                const targetId = v.substring(1, v.length - 1);
                return mc.getLibraryByPath(Version.getLibraryInfo(targetId).path);
            }
            return v;
        }
        function processMapping(data, m) {
            m = processValue(m);
            if (m.match(/^{.+}$/g)) {
                const key = m.substring(1, m.length - 1);
                m = data[key].client;
            }
            return m;
        }
        const profile = JSON.parse(JSON.stringify(installProfile));
        profile.data.MINECRAFT_JAR = {
            client: mc.getVersionJar(profile.minecraft),
            server: "",
        };
        for (const key in profile.data) {
            const value = profile.data[key];
            value.client = processValue(value.client);
            value.server = processValue(value.server);
            if (key === "BINPATCH") {
                const verRoot = mc.getVersionRoot(profile.version);
                value.client = join(verRoot, value.client);
                value.server = join(verRoot, value.server);
            }
        }
        for (const proc of profile.processors) {
            proc.args = proc.args.map((a) => processMapping(profile.data, a));
            if (proc.outputs) {
                const replacedOutput = {};
                for (const key in proc.outputs) {
                    replacedOutput[processMapping(profile.data, key)] = processMapping(profile.data, proc.outputs[key]);
                }
                proc.outputs = replacedOutput;
            }
        }
        return profile;
    }
    /**
     * Install for forge installer step 2 and 3.
     * @param version The version string or installer profile
     * @param minecraft The minecraft location
     */
    function installByInstallerPartialTask(version, minecraft, option = {}) {
        return async function installForge(context) {
            const mc = MinecraftFolder.from(minecraft);
            let prof;
            let ver;
            if (typeof version === "string") {
                const versionRoot = mc.getVersionRoot(version);
                prof = await vfs.readFile(join(versionRoot, "install_profile.json")).then((b) => b.toString()).then(JSON.parse);
            }
            else {
                prof = version;
            }
            ver = await vfs.readFile(mc.getVersionJson(prof.version)).then((b) => b.toString()).then(JSON.parse);
            await installByInstallerPartialWork(mc, prof, ver, option.java || JavaExecutor.createSimple("java"), option)(context);
        };
    }
    ForgeInstaller.installByInstallerPartialTask = installByInstallerPartialTask;
    /**
     * Install for forge installer step 2 and 3.
     * @param version The version string or installer profile
     * @param minecraft The minecraft location
     */
    async function installByInstallerPartial(version, minecraft, option = {}) {
        return Task.execute(installByInstallerPartialTask(version, minecraft, option));
    }
    ForgeInstaller.installByInstallerPartial = installByInstallerPartial;
    function installByInstallerPartialWork(mc, profile, versionJson, java, installLibOption) {
        return async (context) => {
            profile = postProcessInstallProfile(mc, profile);
            const parsedLibs = Version.resolveLibraries([...profile.libraries, ...versionJson.libraries]);
            await context.execute(Installer.installLibrariesDirectTask(parsedLibs, mc, {
                ...installLibOption,
                libraryHost: installLibOption.libraryHost ? (l) => {
                    if (l.artifactId === "forge" && l.groupId === "net.minecraftforge") {
                        return `file://${mc.getLibraryByPath(l.path)}`;
                    }
                    return installLibOption.libraryHost(l);
                } : undefined,
            }));
            await context.execute(async function postProcessing(ctx) {
                ctx.update(0, profile.processors.length);
                let i = 0;
                const errs = [];
                for (const proc of profile.processors) {
                    try {
                        await postProcess(mc, proc, java);
                    }
                    catch (e) {
                        errs.push(e);
                    }
                    ctx.update(i += 1, profile.processors.length);
                }
                i += 1;
                ctx.update(i, profile.processors.length);
                if (errs.length !== 0) {
                    throw new Error("Fail to post processing");
                }
            });
        };
    }
    function installByInstallerTask(version, minecraft, maven, installLibOption, java) {
        return async function installForge(context) {
            const mc = MinecraftFolder.from(minecraft);
            const forgeVersion = `${version.mcversion}-${version.version}`;
            const installerURL = `${maven}${version.installer.path}`;
            const installerURLFallback = `${maven}/maven/net/minecraftforge/forge/${forgeVersion}/forge-${forgeVersion}-installer.jar`;
            const installJar = mc.getLibraryByPath(version.installer.path.substring(version.installer.path.substring(1).indexOf("/") + 1));
            let versionId;
            let profile;
            let versionJson;
            function downloadInstallerTask(installer, dest) {
                return async function downloadInstaller(ctx) {
                    await downloadFileIfAbsentWork({
                        url: installer,
                        destination: dest,
                        checksum: {
                            hash: version.installer.sha1,
                            algorithm: "sha1",
                        },
                    })(ctx);
                    return vfs.createReadStream(dest).pipe(Unzip.createParseStream({ lazyEntries: true })).wait();
                };
            }
            async function processVersion(zip, installProfileEntry, versionEntry, clientDataEntry) {
                profile = await zip.readEntry(installProfileEntry).then((b) => b.toString()).then(JSON.parse);
                versionJson = await zip.readEntry(versionEntry).then((b) => b.toString()).then(JSON.parse);
                versionId = versionJson.id;
                const rootPath = mc.getVersionRoot(versionJson.id);
                const jsonPath = join(rootPath, `${versionJson.id}.json`);
                const installJsonPath = join(rootPath, "install_profile.json");
                const clientDataPath = join(rootPath, profile.data.BINPATCH.client);
                await vfs.ensureFile(jsonPath);
                await vfs.writeFile(installJsonPath, JSON.stringify(profile));
                await vfs.writeFile(jsonPath, JSON.stringify(versionJson));
                await vfs.ensureFile(clientDataPath);
                const stream = await zip.openEntry(clientDataEntry);
                await vfs.waitStream(stream.pipe(vfs.createWriteStream(clientDataPath)));
            }
            async function processExtractLibrary(stream, p) {
                const file = mc.getLibraryByPath(p.substring(p.indexOf("/") + 1));
                await vfs.ensureFile(file);
                await vfs.waitStream(stream.pipe(vfs.createWriteStream(file)));
            }
            try {
                let zip;
                try {
                    zip = await context.execute(downloadInstallerTask(installerURL, installJar));
                }
                catch (_a) {
                    zip = await context.execute(downloadInstallerTask(installerURLFallback, installJar));
                }
                const [forgeEntry, forgeUniversalEntry, clientDataEntry, installProfileEntry, versionEntry] = await zip.filterEntries([
                    `maven/net/minecraftforge/forge/${forgeVersion}/forge-${forgeVersion}.jar`,
                    `maven/net/minecraftforge/forge/${forgeVersion}/forge-${forgeVersion}-universal.jar`,
                    "data/client.lzma",
                    "install_profile.json",
                    "version.json"
                ]);
                if (!forgeEntry) {
                    throw new Error("Missing forge jar entry");
                }
                if (!forgeUniversalEntry) {
                    throw new Error("Missing forge universal entry");
                }
                if (!installProfileEntry) {
                    throw new Error("Missing install profile");
                }
                if (!versionEntry) {
                    throw new Error("Missing version entry");
                }
                await processExtractLibrary(await zip.openEntry(forgeEntry), forgeEntry.fileName);
                await processExtractLibrary(await zip.openEntry(forgeUniversalEntry), forgeUniversalEntry.fileName);
                await processVersion(zip, installProfileEntry, versionEntry, clientDataEntry);
                await installByInstallerPartialWork(mc, profile, versionJson, java, installLibOption)(context);
                return versionId;
            }
            catch (e) {
                console.error(`Cannot install forge by installer ${version.version}`);
                throw e;
            }
        };
    }
    function installByUniversalTask(version, minecraft, maven) {
        return async function installForge(context) {
            const mc = MinecraftFolder.from(minecraft);
            const forgeVersion = `${version.mcversion}-${version.version}`;
            const paths = version.universal.path.split("/");
            const realForgeVersion = paths[paths.length - 2];
            const jarPath = mc.getLibraryByPath(`net/minecraftforge/forge/${realForgeVersion}/forge-${realForgeVersion}.jar`);
            let fullVersion;
            let realJarPath;
            const universalURLFallback = `${maven}/maven/net/minecraftforge/forge/${forgeVersion}/forge-${forgeVersion}-universal.jar`;
            const universalURL = `${maven}${version.universal.path}`;
            await context.execute(async function installForgeJar() {
                if (await vfs.exists(jarPath)) {
                    const valid = await vfs.validate(jarPath, { algorithm: "md5", hash: version.universal.md5 }, { algorithm: "sha1", hash: version.universal.sha1 });
                    if (valid) {
                        return;
                    }
                }
                function downloadJar(ctx) {
                    return downloadFileWork({ url: universalURL, destination: jarPath })(ctx);
                }
                await context.execute(downloadJar);
            });
            await context.execute(async function installForgeJson() {
                const zip = await Unzip.open(jarPath, { lazyEntries: true });
                const [versionEntry] = await zip.filterEntries(["version.json"]);
                if (versionEntry) {
                    const buf = await zip.readEntry(versionEntry);
                    const raw = JSON.parse(buf.toString());
                    const id = raw.id;
                    fullVersion = id;
                    const rootPath = mc.getVersionRoot(fullVersion);
                    realJarPath = mc.getLibraryByPath(Version.getLibraryInfo(raw.libraries.find((l) => l.name.startsWith("net.minecraftforge:forge"))).path);
                    await vfs.ensureDir(rootPath);
                    const jsonPath = join(rootPath, `${id}.json`);
                    if (await vfs.missing(jsonPath)) {
                        await vfs.writeFile(jsonPath, buf);
                    }
                }
                else {
                    throw new Error(`Cannot install forge json for ${version.version} since the version json is missing!`);
                }
            });
            if (realJarPath !== jarPath) {
                await vfs.ensureFile(realJarPath);
                await vfs.copyFile(jarPath, realJarPath);
                await vfs.unlink(jarPath);
            }
            return fullVersion;
        };
    }
    /**
     * Install forge to target location.
     * Installation task for forge with mcversion >= 1.13 requires java installed on your pc.
     * @param version The forge version meta
     */
    function install(version, minecraft, option) {
        return Task.execute(installTask(version, minecraft, option));
    }
    ForgeInstaller.install = install;
    /**
     * Install forge to target location.
     * Installation task for forge with mcversion >= 1.13 requires java installed on your pc.
     * @param version The forge version meta
     */
    function installTask(version, minecraft, option = {}) {
        let byInstaller = true;
        try {
            const minorVersion = Number.parseInt(version.mcversion.split(".")[1], 10);
            byInstaller = minorVersion >= 13;
        }
        catch (_a) { }
        const work = byInstaller
            ? installByInstallerTask(version, minecraft, option.maven || ForgeInstaller.DEFAULT_FORGE_MAVEN, option, option.java || JavaExecutor.createSimple("java"))
            : installByUniversalTask(version, minecraft, option.maven || ForgeInstaller.DEFAULT_FORGE_MAVEN);
        return work;
    }
    ForgeInstaller.installTask = installTask;
})(ForgeInstaller || (ForgeInstaller = {}));
export * from "./forgeweb";
export default ForgeInstaller;
//# sourceMappingURL=index.js.map