Compare commits
18 Commits
ba8c21cd6c
...
main
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
9afbc993ba | ||
|
|
f65dea29f5 | ||
|
|
9d77fa53c7 | ||
|
|
d8d8c4051a | ||
|
|
32f7473533 | ||
|
|
9f9cfc3e17 | ||
|
|
777d8e43aa | ||
|
|
5ddcaf9b45 | ||
|
|
40492b8bd0 | ||
|
|
bb860b2c4a | ||
|
|
9dcc4e6c83 | ||
|
|
cfa97c8715 | ||
|
|
0acd64ae86 | ||
|
|
2f518e4487 | ||
|
|
1e35fac53b | ||
|
|
63d318772a | ||
|
|
f2fa0c8bdf | ||
|
|
f0ead136fe |
15
Untitled-2.js
Normal file
15
Untitled-2.js
Normal file
@@ -0,0 +1,15 @@
|
||||
import got from 'got';
|
||||
const res = await got.post('https://api.modrinth.com/v2/version_files', {
|
||||
headers: {
|
||||
'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64; rv:91.0) Gecko/20100101 Firefox/91.0',
|
||||
},
|
||||
json: {
|
||||
hashes: [
|
||||
"ea0f38408102e4d2efd53c2cc11b88b711996b48d8922f76ea6abf731219c5bd1efe39ddf9cce77c54d49a62ff10fb685c00d2e4c524ab99d20f6296677ab2c4",
|
||||
"925a5c4899affa4098d997dfa4a4cb52c636d539e94bc489d1fa034218cb96819a70eb8b01647a39316a59fcfe223c1a8c05ed2e2ae5f4c1e75fa48f6af1c961"
|
||||
],
|
||||
algorithm: 'sha512',
|
||||
}
|
||||
}).json()
|
||||
|
||||
console.log(res)
|
||||
85
package-lock.json
generated
85
package-lock.json
generated
@@ -10,7 +10,6 @@
|
||||
"license": "ISC",
|
||||
"dependencies": {
|
||||
"adm-zip": "^0.5.16",
|
||||
"chalk": "^5.4.1",
|
||||
"cli-progress": "^3.12.0",
|
||||
"dotenv": "^17.0.1",
|
||||
"fs-extra": "^11.3.0",
|
||||
@@ -18,16 +17,19 @@
|
||||
"inquirer": "^12.6.3",
|
||||
"p-map": "^7.0.3",
|
||||
"p-retry": "^6.2.1",
|
||||
"toml": "^3.0.0",
|
||||
"picocolors": "^1.1.1",
|
||||
"smol-toml": "^1.4.1",
|
||||
"yauzl": "^3.2.0"
|
||||
},
|
||||
"devDependencies": {
|
||||
"@rollup/plugin-commonjs": "^28.0.6",
|
||||
"@rollup/plugin-json": "^6.1.0",
|
||||
"@rollup/plugin-node-resolve": "^16.0.1",
|
||||
"@rollup/plugin-typescript": "^12.1.4",
|
||||
"@types/adm-zip": "^0.5.7",
|
||||
"@types/cli-progress": "^3.11.6",
|
||||
"@types/fs-extra": "^11.0.4",
|
||||
"@types/inquirer": "^9.0.8",
|
||||
"@types/yauzl": "^2.10.3",
|
||||
"nexe": "^5.0.0-beta.4",
|
||||
"rollup": "^4.44.1",
|
||||
@@ -556,6 +558,33 @@
|
||||
}
|
||||
}
|
||||
},
|
||||
"node_modules/@rollup/plugin-typescript": {
|
||||
"version": "12.1.4",
|
||||
"resolved": "https://registry.npmmirror.com/@rollup/plugin-typescript/-/plugin-typescript-12.1.4.tgz",
|
||||
"integrity": "sha512-s5Hx+EtN60LMlDBvl5f04bEiFZmAepk27Q+mr85L/00zPDn1jtzlTV6FWn81MaIwqfWzKxmOJrBWHU6vtQyedQ==",
|
||||
"dev": true,
|
||||
"license": "MIT",
|
||||
"dependencies": {
|
||||
"@rollup/pluginutils": "^5.1.0",
|
||||
"resolve": "^1.22.1"
|
||||
},
|
||||
"engines": {
|
||||
"node": ">=14.0.0"
|
||||
},
|
||||
"peerDependencies": {
|
||||
"rollup": "^2.14.0||^3.0.0||^4.0.0",
|
||||
"tslib": "*",
|
||||
"typescript": ">=3.7.0"
|
||||
},
|
||||
"peerDependenciesMeta": {
|
||||
"rollup": {
|
||||
"optional": true
|
||||
},
|
||||
"tslib": {
|
||||
"optional": true
|
||||
}
|
||||
}
|
||||
},
|
||||
"node_modules/@rollup/pluginutils": {
|
||||
"version": "5.2.0",
|
||||
"resolved": "https://registry.npmmirror.com/@rollup/pluginutils/-/pluginutils-5.2.0.tgz",
|
||||
@@ -975,6 +1004,17 @@
|
||||
"integrity": "sha512-1m0bIFVc7eJWyve9S0RnuRgcQqF/Xd5QsUZAZeQFr1Q3/p9JWoQQEqmVy+DPTNpGXwhgIetAoYF8JSc33q29QA==",
|
||||
"license": "MIT"
|
||||
},
|
||||
"node_modules/@types/inquirer": {
|
||||
"version": "9.0.8",
|
||||
"resolved": "https://registry.npmmirror.com/@types/inquirer/-/inquirer-9.0.8.tgz",
|
||||
"integrity": "sha512-CgPD5kFGWsb8HJ5K7rfWlifao87m4ph8uioU7OTncJevmE/VLIqAAjfQtko578JZg7/f69K4FgqYym3gNr7DeA==",
|
||||
"dev": true,
|
||||
"license": "MIT",
|
||||
"dependencies": {
|
||||
"@types/through": "*",
|
||||
"rxjs": "^7.2.0"
|
||||
}
|
||||
},
|
||||
"node_modules/@types/json-schema": {
|
||||
"version": "7.0.15",
|
||||
"resolved": "https://registry.npmmirror.com/@types/json-schema/-/json-schema-7.0.15.tgz",
|
||||
@@ -1029,6 +1069,16 @@
|
||||
"dev": true,
|
||||
"license": "MIT"
|
||||
},
|
||||
"node_modules/@types/through": {
|
||||
"version": "0.0.33",
|
||||
"resolved": "https://registry.npmmirror.com/@types/through/-/through-0.0.33.tgz",
|
||||
"integrity": "sha512-HsJ+z3QuETzP3cswwtzt2vEIiHBk/dCcHGhbmG5X3ecnwFD/lPrMpliGXxSCg03L9AhrdwA4Oz/qfspkDW+xGQ==",
|
||||
"dev": true,
|
||||
"license": "MIT",
|
||||
"dependencies": {
|
||||
"@types/node": "*"
|
||||
}
|
||||
},
|
||||
"node_modules/@types/uglify-js": {
|
||||
"version": "3.17.5",
|
||||
"resolved": "https://registry.npmmirror.com/@types/uglify-js/-/uglify-js-3.17.5.tgz",
|
||||
@@ -1887,18 +1937,6 @@
|
||||
"node": ">=4"
|
||||
}
|
||||
},
|
||||
"node_modules/chalk": {
|
||||
"version": "5.4.1",
|
||||
"resolved": "https://registry.npmmirror.com/chalk/-/chalk-5.4.1.tgz",
|
||||
"integrity": "sha512-zgVZuo2WcZgfUEmsn6eO3kINexW8RAE4maiQ8QNs8CtpPCSyMiYsULR3HQYkm3w8FIA3SberyMJMSldGsW+U3w==",
|
||||
"license": "MIT",
|
||||
"engines": {
|
||||
"node": "^12.17.0 || ^14.13 || >=16.0.0"
|
||||
},
|
||||
"funding": {
|
||||
"url": "https://github.com/chalk/chalk?sponsor=1"
|
||||
}
|
||||
},
|
||||
"node_modules/chardet": {
|
||||
"version": "0.7.0",
|
||||
"resolved": "https://registry.npmmirror.com/chardet/-/chardet-0.7.0.tgz",
|
||||
@@ -4823,7 +4861,6 @@
|
||||
"version": "1.1.1",
|
||||
"resolved": "https://registry.npmmirror.com/picocolors/-/picocolors-1.1.1.tgz",
|
||||
"integrity": "sha512-xceH2snhtb5M9liqDsmEw56le376mTZkEX/jEb/RxNFyegNul7eNslCXP9FDj/Lcu0X8KEyMceP2ntpaHrDEVA==",
|
||||
"dev": true,
|
||||
"license": "ISC"
|
||||
},
|
||||
"node_modules/picomatch": {
|
||||
@@ -5432,6 +5469,18 @@
|
||||
"node": ">=8"
|
||||
}
|
||||
},
|
||||
"node_modules/smol-toml": {
|
||||
"version": "1.4.1",
|
||||
"resolved": "https://registry.npmmirror.com/smol-toml/-/smol-toml-1.4.1.tgz",
|
||||
"integrity": "sha512-CxdwHXyYTONGHThDbq5XdwbFsuY4wlClRGejfE2NtwUtiHYsP1QtNsHb/hnj31jKYSchztJsaA8pSQoVzkfCFg==",
|
||||
"license": "BSD-3-Clause",
|
||||
"engines": {
|
||||
"node": ">= 18"
|
||||
},
|
||||
"funding": {
|
||||
"url": "https://github.com/sponsors/cyyynthia"
|
||||
}
|
||||
},
|
||||
"node_modules/sort-keys": {
|
||||
"version": "1.1.2",
|
||||
"resolved": "https://registry.npmmirror.com/sort-keys/-/sort-keys-1.1.2.tgz",
|
||||
@@ -5788,12 +5837,6 @@
|
||||
"node": ">=8.0"
|
||||
}
|
||||
},
|
||||
"node_modules/toml": {
|
||||
"version": "3.0.0",
|
||||
"resolved": "https://registry.npmmirror.com/toml/-/toml-3.0.0.tgz",
|
||||
"integrity": "sha512-y/mWCZinnvxjTKYhJ+pYxwD0mRLVvOtdS2Awbgxln6iEnt4rk0yBxeSBHkGJcPucRiG0e55mwWp+g/05rsrd6w==",
|
||||
"license": "MIT"
|
||||
},
|
||||
"node_modules/trim-repeated": {
|
||||
"version": "1.0.0",
|
||||
"resolved": "https://registry.npmmirror.com/trim-repeated/-/trim-repeated-1.0.0.tgz",
|
||||
|
||||
12
package.json
12
package.json
@@ -9,14 +9,13 @@
|
||||
"scripts": {
|
||||
"tsbuild": "tsc",
|
||||
"rollup": "rollup -c rollup.config.js",
|
||||
"nexe": "nexe -i ./ndist/bundle.js --ico Dex.ico --build -t x86-22.13.0 --output ./ndist/DeEarthX.exe",
|
||||
"upx": ".\\dist_modules\\upx.exe .\\ndist\\DeEarthX.exe",
|
||||
"build": "npm run tsbuild&&npm run rollup&&npm run nexe&&npm run upx",
|
||||
"nexe": "nexe -i ./dist/bundle.js --ico Dex.ico --build -t x86-22.13.0 --output ./dist/DeEarthX.exe",
|
||||
"upx": ".\\dist_modules\\upx.exe .\\dist\\DeEarthX.exe",
|
||||
"build": "npm run rollup&&npm run nexe&&npm run upx",
|
||||
"test": "tsc&&node dist/main.js"
|
||||
},
|
||||
"dependencies": {
|
||||
"adm-zip": "^0.5.16",
|
||||
"chalk": "^5.4.1",
|
||||
"cli-progress": "^3.12.0",
|
||||
"dotenv": "^17.0.1",
|
||||
"fs-extra": "^11.3.0",
|
||||
@@ -24,16 +23,19 @@
|
||||
"inquirer": "^12.6.3",
|
||||
"p-map": "^7.0.3",
|
||||
"p-retry": "^6.2.1",
|
||||
"toml": "^3.0.0",
|
||||
"picocolors": "^1.1.1",
|
||||
"smol-toml": "^1.4.1",
|
||||
"yauzl": "^3.2.0"
|
||||
},
|
||||
"devDependencies": {
|
||||
"@rollup/plugin-commonjs": "^28.0.6",
|
||||
"@rollup/plugin-json": "^6.1.0",
|
||||
"@rollup/plugin-node-resolve": "^16.0.1",
|
||||
"@rollup/plugin-typescript": "^12.1.4",
|
||||
"@types/adm-zip": "^0.5.7",
|
||||
"@types/cli-progress": "^3.11.6",
|
||||
"@types/fs-extra": "^11.0.4",
|
||||
"@types/inquirer": "^9.0.8",
|
||||
"@types/yauzl": "^2.10.3",
|
||||
"nexe": "^5.0.0-beta.4",
|
||||
"rollup": "^4.44.1",
|
||||
|
||||
@@ -1,16 +1,18 @@
|
||||
import typescript from '@rollup/plugin-typescript'
|
||||
import resolve from '@rollup/plugin-node-resolve';
|
||||
import commonjs from '@rollup/plugin-commonjs'
|
||||
import json from '@rollup/plugin-json';
|
||||
/** @type {import('rollup').RollupOptions} */
|
||||
// ---cut---
|
||||
export default {
|
||||
input: 'dist/main.js',
|
||||
input: 'src/main.ts',
|
||||
output: {
|
||||
file: 'ndist/bundle.js',
|
||||
format: 'es'
|
||||
file: 'dist/bundle.js',
|
||||
format: 'esm'
|
||||
},
|
||||
plugins:[
|
||||
resolve({preferBuiltins: false}),
|
||||
typescript(),
|
||||
resolve({preferBuiltins: true}),
|
||||
commonjs(),
|
||||
json()
|
||||
]
|
||||
|
||||
167
src/main copy.ts
Normal file
167
src/main copy.ts
Normal file
@@ -0,0 +1,167 @@
|
||||
import inquirer from "inquirer";
|
||||
import yauzl, { Entry, ZipFile } from "yauzl";
|
||||
import process, { emit } from "node:process";
|
||||
import fs from "node:fs";
|
||||
import fse from "fs-extra";
|
||||
import { exec } from "node:child_process";
|
||||
import { join, basename, dirname } from "node:path";
|
||||
import { platform, what_platform } from "./platform/index.js";
|
||||
import { isDevelopment, readzipentry } from "./utils/utils.js";
|
||||
import fabric from "./ml_install/fabric.js";
|
||||
import forge from "./ml_install/forge.js";
|
||||
import neoforge from "./ml_install/neoforge.js";
|
||||
import { DeEarthMain } from "./utils/DeEarth.js";
|
||||
import { LOGGER } from "./utils/logger.js";
|
||||
import { fileURLToPath } from "node:url";
|
||||
interface Answers {
|
||||
modpack_path: string | undefined;
|
||||
}
|
||||
let unzip_path: string = "";
|
||||
if (isDevelopment) {
|
||||
unzip_path = join("./", "instance/");
|
||||
} else {
|
||||
unzip_path = join(getCurrnetDir().replace("dist", ""), "instance");
|
||||
}
|
||||
let zipnamew: string = "";
|
||||
const argv = process.argv.slice(2)[0];
|
||||
|
||||
if (!argv) {
|
||||
const answer: Answers = await inquirer.prompt([
|
||||
{ type: "input", name: "modpack_path", message: "请输入整合包路径" },
|
||||
]);
|
||||
if (answer.modpack_path) {
|
||||
initdir();
|
||||
await main(answer.modpack_path);
|
||||
}
|
||||
} else {
|
||||
initdir();
|
||||
await main(argv);
|
||||
}
|
||||
|
||||
function initdir() {
|
||||
if (!fs.existsSync(unzip_path)) {
|
||||
fse.ensureDirSync(join(unzip_path, "rubbish"));
|
||||
}
|
||||
}
|
||||
|
||||
async function main(modpack_path: string) {
|
||||
const zipname = basename(modpack_path)
|
||||
.replace(".zip", "")
|
||||
.replace(".mrpack", "");
|
||||
zipnamew = zipname;
|
||||
let dud_files: Array<string> = [];
|
||||
let pack_info: object | undefined = undefined;
|
||||
let entry_arr: Entry[] = [];
|
||||
//unzip
|
||||
const zipfile: ZipFile = await new Promise((resolve, reject) => {
|
||||
yauzl.open(modpack_path, { lazyEntries: true }, (err, zipfile) => {
|
||||
if (err) {
|
||||
reject(err);
|
||||
}
|
||||
resolve(zipfile);
|
||||
});
|
||||
});
|
||||
zipfile.readEntry(); //首次读取
|
||||
zipfile.on("entry", (entry) => {
|
||||
entry_arr.push(entry);
|
||||
zipfile.readEntry();
|
||||
});
|
||||
await new Promise((resolve) => zipfile.on("end", async () => resolve));
|
||||
for (let i = 0; i < entry_arr.length; i++) {
|
||||
const entry = entry_arr[i];
|
||||
const name: string = entry.fileName;
|
||||
if (/\/$/.test(name)) {
|
||||
continue;
|
||||
} else if (name.includes("overrides/")) {
|
||||
const zipfilex = join(
|
||||
unzip_path,
|
||||
zipname,
|
||||
name.replace("overrides/", "")
|
||||
);
|
||||
if (!fs.existsSync(zipfilex)) {
|
||||
zipfile.openReadStream(entry, (err, stream) => {
|
||||
//读取overrides文件夹下的所有文件和文件夹
|
||||
const dir = dirname(zipfilex);
|
||||
fse.ensureDirSync(dir);
|
||||
console.log(zipfilex);
|
||||
stream.pipe(fse.createWriteStream(zipfilex));
|
||||
});
|
||||
}
|
||||
} else if (name.endsWith(".json") || name.includes("mcbbs.packmeta")) {
|
||||
dud_files.push(name);
|
||||
if (
|
||||
name.includes("manifest.json") ||
|
||||
name.includes("modrinth.index.json")
|
||||
) {
|
||||
pack_info = JSON.parse((await readzipentry(zipfile, entry)).toString());
|
||||
}
|
||||
}
|
||||
}
|
||||
//zipfile.on("end", async () => {
|
||||
//zip
|
||||
//try {
|
||||
const dirx = join(unzip_path, zipname);
|
||||
const plat = platform(what_platform(dud_files));
|
||||
if (typeof pack_info !== "object") throw new Error("未找到manifest.json");
|
||||
const info = await plat.getinfo(pack_info);
|
||||
await plat.downloadfile(pack_info, dirx);
|
||||
await DeEarthMain(join(dirx, "mods"), join(unzip_path, "rubbish"));
|
||||
await install(info.loader, info.minecraft, info.loader_version, dirx);
|
||||
fs.writeFileSync(
|
||||
join(dirx, "eula.txt"),
|
||||
"#By changing the setting below to TRUE you are indicating your agreement to our EULA (https://aka.ms/MinecraftEULA).\n#This serverpack created by DeEarthX(QQ_Group:559349662)\neula=true"
|
||||
);
|
||||
LOGGER.info("DeEarthX已将服务端制作完成!");
|
||||
zipfile.close();
|
||||
//} catch (e) {
|
||||
//LOGGER.error(e);
|
||||
//}
|
||||
//});
|
||||
//});
|
||||
//})
|
||||
}
|
||||
|
||||
async function install(
|
||||
type: string,
|
||||
minecraft: string,
|
||||
loaderver: string,
|
||||
path: string
|
||||
) {
|
||||
if (await checkJava()) {
|
||||
LOGGER.error(
|
||||
"未安装Java或系统环境变量不存在Java,已跳过自动安装模组加载器服务端!"
|
||||
);
|
||||
return;
|
||||
}
|
||||
switch (type) {
|
||||
case "fabric":
|
||||
await fabric(minecraft, loaderver, path);
|
||||
break;
|
||||
case "fabric-loader":
|
||||
await fabric(minecraft, loaderver, path);
|
||||
break;
|
||||
case "forge":
|
||||
await forge(minecraft, loaderver, path);
|
||||
break;
|
||||
case "neoforge":
|
||||
await neoforge(minecraft, loaderver, path);
|
||||
break;
|
||||
}
|
||||
}
|
||||
|
||||
function checkJava() {
|
||||
return new Promise((resolve) => {
|
||||
exec("java -version", (err) => {
|
||||
if (err) {
|
||||
resolve(false);
|
||||
} else {
|
||||
resolve(true);
|
||||
}
|
||||
});
|
||||
});
|
||||
}
|
||||
|
||||
function getCurrnetDir() {
|
||||
const url = new URL(".", import.meta.url);
|
||||
return fileURLToPath(url);
|
||||
}
|
||||
164
src/main.ts
164
src/main.ts
@@ -1,26 +1,27 @@
|
||||
import inquirer from "inquirer";
|
||||
import yauzl from "yauzl";
|
||||
import process from "node:process";
|
||||
import fs from "node:fs";
|
||||
import fse from "fs-extra";
|
||||
import { join, basename, dirname } from "node:path";
|
||||
import { platform, what_platform } from "./platform/index.js";
|
||||
import { isDevelopment, readzipentry } from "./utils/utils.js";
|
||||
import fabric from "./ml_install/fabric.js"
|
||||
import forge from "./ml_install/forge.js"
|
||||
import neoforge from "./ml_install/neoforge.js"
|
||||
import { type ForgeInfo, isDevelopment, isInstallJava, readzipentry } from "./utils/utils.js";
|
||||
import fabric from "./ml_install/fabric.js";
|
||||
import forge from "./ml_install/forge.js";
|
||||
import neoforge from "./ml_install/neoforge.js";
|
||||
import { DeEarthMain } from "./utils/DeEarth.js";
|
||||
import { LOGGER } from "./utils/logger.js";
|
||||
import { fileURLToPath } from "node:url";
|
||||
interface Answers {
|
||||
modpack_path: string | undefined;
|
||||
}
|
||||
let unzip_path:string = ""
|
||||
if(isDevelopment){
|
||||
unzip_path = join("./","instance/")
|
||||
}else{
|
||||
unzip_path = join(getCurrnetDir().replace("ndist",""),"instance")
|
||||
let unzip_path: string = "";
|
||||
if (isDevelopment) {
|
||||
unzip_path = join("./", "instance/");
|
||||
} else {
|
||||
unzip_path = join(getCurrnetDir().replace("dist", ""), "instance");
|
||||
}
|
||||
let zipnamew: string = ""
|
||||
let zipnamew: string = "";
|
||||
const argv = process.argv.slice(2)[0];
|
||||
|
||||
if (!argv) {
|
||||
@@ -28,86 +29,127 @@ if (!argv) {
|
||||
{ type: "input", name: "modpack_path", message: "请输入整合包路径" },
|
||||
]);
|
||||
if (answer.modpack_path) {
|
||||
initdir()
|
||||
initdir();
|
||||
await main(answer.modpack_path);
|
||||
}
|
||||
} else {
|
||||
initdir()
|
||||
initdir();
|
||||
await main(argv);
|
||||
}
|
||||
|
||||
function initdir(){
|
||||
if(!fse.existsSync(unzip_path)){
|
||||
fse.ensureDirSync(join(unzip_path,"rubbish"))
|
||||
function initdir() {
|
||||
if (!fs.existsSync(unzip_path)) {
|
||||
fse.ensureDirSync(join(unzip_path, ".rubbish"));
|
||||
}
|
||||
}
|
||||
|
||||
async function main(modpack_path: string) {
|
||||
const zipname= basename(modpack_path)
|
||||
const zipname = basename(modpack_path)
|
||||
.replace(".zip", "")
|
||||
.replace(".mrpack", "");
|
||||
zipnamew=zipname
|
||||
zipnamew = zipname;
|
||||
let dud_files: Array<string> = [];
|
||||
let pack_info: object;
|
||||
//unzip
|
||||
yauzl.open(modpack_path, { lazyEntries: true }, (err, zipfile) => {
|
||||
zipfile.readEntry(); //首次读取
|
||||
zipfile.on("entry", async (entry) => {
|
||||
if (/\/$/.test(entry.fileName)) {
|
||||
} else if (entry.fileName.includes("overrides/")) {
|
||||
const zipfilex = join(unzip_path, zipname,entry.fileName.replace("overrides/",""))
|
||||
if(!fse.existsSync(zipfilex)){
|
||||
zipfile.openReadStream(entry,(err,stream)=>{ //读取overrides文件夹下的所有文件和文件夹
|
||||
const dir = dirname(zipfilex)
|
||||
fse.ensureDirSync(dir);
|
||||
console.log(zipfilex)
|
||||
stream.pipe(fse.createWriteStream(zipfilex))
|
||||
})
|
||||
//console.log(entry.fileName)
|
||||
}
|
||||
} else {
|
||||
const name: string = entry.fileName;
|
||||
dud_files.push(name);
|
||||
if (name.endsWith(".json")) {
|
||||
pack_info = JSON.parse(
|
||||
(await readzipentry(zipfile, entry)).toString()
|
||||
);
|
||||
|
||||
const name: string = entry.fileName;
|
||||
if (/\/$/.test(name)) {
|
||||
} else if (name.includes("overrides/")) {
|
||||
const zipfilex = join(
|
||||
unzip_path,
|
||||
zipname,
|
||||
name.replace("overrides/", "")
|
||||
);
|
||||
if (!fs.existsSync(zipfilex)) {
|
||||
zipfile.openReadStream(entry, (err, stream) => {
|
||||
//读取overrides文件夹下的所有文件和文件夹
|
||||
const dir = dirname(zipfilex);
|
||||
fse.ensureDirSync(dir);
|
||||
console.log(zipfilex);
|
||||
stream.pipe(fse.createWriteStream(zipfilex));
|
||||
});
|
||||
}
|
||||
} else if (name.endsWith(".json")||name.endsWith("mcbbs.packmeta")) {
|
||||
dud_files.push(name);
|
||||
//console.log((await readzipentry(zipfile, entry)))
|
||||
if(name.endsWith("modrinth.index.json")|| name.endsWith("manifest.json")){
|
||||
pack_info = JSON.parse(
|
||||
(await readzipentry(zipfile, entry)).toString()
|
||||
);
|
||||
}
|
||||
}
|
||||
}
|
||||
zipfile.readEntry();
|
||||
});
|
||||
zipfile.on("end", async () => {
|
||||
//zip
|
||||
const dirx = join(unzip_path,zipname)
|
||||
const plat = platform(what_platform(dud_files))
|
||||
const dirx = join(unzip_path, zipname);
|
||||
const plat = platform(what_platform(dud_files));
|
||||
const info = await plat.getinfo(pack_info);
|
||||
await plat.downloadfile(pack_info,dirx)
|
||||
await DeEarthMain(join(dirx,"mods"),join(unzip_path,"rubbish"))
|
||||
await install(info.loader,info.minecraft,info.loader_version,dirx)
|
||||
await plat.downloadfile(pack_info, dirx);
|
||||
await DeEarthMain(join(dirx, "mods"), join(unzip_path, ".rubbish"));
|
||||
await install(info.loader, info.minecraft, info.loader_version, dirx);
|
||||
fs.writeFileSync(
|
||||
join(dirx, "eula.txt"),
|
||||
"#By changing the setting below to TRUE you are indicating your agreement to our EULA (https://aka.ms/MinecraftEULA).\n#This serverpack created by DeEarthX(QQ_Group:559349662)\neula=true"
|
||||
);
|
||||
await garcol(dirx,{minecraft_verison: info.minecraft, forge_verison: info.loader_version}).catch((e)=>{});
|
||||
LOGGER.info("DeEarthX已将服务端制作完成!");
|
||||
zipfile.close();
|
||||
});
|
||||
});
|
||||
}
|
||||
|
||||
async function install(type: string,minecraft:string,loaderver:string,path:string){
|
||||
switch(type){
|
||||
case "fabric":
|
||||
await fabric(minecraft,loaderver,path)
|
||||
break;
|
||||
case "fabric-loader":
|
||||
await fabric(minecraft,loaderver,path)
|
||||
break;
|
||||
case "forge":
|
||||
await forge(minecraft,loaderver,path)
|
||||
break;
|
||||
case "neoforge":
|
||||
await neoforge(minecraft,loaderver,path)
|
||||
break;
|
||||
}
|
||||
async function install(
|
||||
type: string,
|
||||
minecraft: string,
|
||||
loaderver: string,
|
||||
path: string
|
||||
) {
|
||||
if (!(await isInstallJava)){
|
||||
LOGGER.error("请先安装Java!")
|
||||
return;
|
||||
}
|
||||
switch (type) {
|
||||
case "fabric":
|
||||
await fabric(minecraft, loaderver, path);
|
||||
break;
|
||||
case "fabric-loader":
|
||||
await fabric(minecraft, loaderver, path);
|
||||
const com = "java -jar fabric-server-launch.jar"
|
||||
fs.writeFileSync(join(path,'run.bat'),com)
|
||||
fs.writeFileSync(join(path,'run.sh'),com)
|
||||
break;
|
||||
case "forge":
|
||||
await forge(minecraft, loaderver, path);
|
||||
break;
|
||||
case "neoforge":
|
||||
await neoforge(minecraft, loaderver, path);
|
||||
break;
|
||||
}
|
||||
}
|
||||
|
||||
function getCurrnetDir () {
|
||||
const url = new URL(".", import.meta.url);
|
||||
return fileURLToPath(url);
|
||||
}
|
||||
async function garcol(p:string,fi:ForgeInfo): Promise<void> {
|
||||
return new Promise((resolve,reject)=>{
|
||||
try{
|
||||
LOGGER.info("正在删除垃圾文件......")
|
||||
const x = [`Forge-${fi.minecraft_verison}-${fi.forge_verison}.jar`,`installer.log`,`installer.jar`,`fabric-installer-1.0.3.jar`,`options.txt`,`shaderpacks/`,`resourcepacks/`,'essential/']
|
||||
for (let i=0;i<x.length;i++){
|
||||
try{
|
||||
fs.rmSync(join(p, x[i]),{recursive: true, force: true})
|
||||
}catch(e){}
|
||||
}
|
||||
resolve()
|
||||
}catch(err){
|
||||
reject(err)
|
||||
}
|
||||
})
|
||||
|
||||
}
|
||||
|
||||
function getCurrnetDir() {
|
||||
const url = new URL(".", import.meta.url);
|
||||
return fileURLToPath(url);
|
||||
}
|
||||
|
||||
@@ -1,6 +1,7 @@
|
||||
import cp from "child_process";
|
||||
import fsExtra from "fs-extra/esm";
|
||||
import fsExtra from "fs-extra";
|
||||
import got from "got";
|
||||
import { usemirror } from "../utils/utils.js";
|
||||
export default async function install(
|
||||
mcver: string,
|
||||
fabricver: string,
|
||||
@@ -8,12 +9,12 @@ export default async function install(
|
||||
) {
|
||||
const data = (
|
||||
await got.get(
|
||||
`https://maven.fabricmc.net/net/fabricmc/fabric-installer/1.0.1/fabric-installer-1.0.1.jar`
|
||||
`https://maven.fabricmc.net/net/fabricmc/fabric-installer/1.0.3/fabric-installer-1.0.3.jar`
|
||||
)
|
||||
).rawBody;
|
||||
fsExtra.outputFileSync(path+"/fabric-installer-1.0.1.jar", data);
|
||||
fsExtra.outputFileSync(path+"/fabric-installer-1.0.3.jar", data);
|
||||
cp.execSync(
|
||||
`java -jar fabric-installer-1.0.1.jar server -mcver ${mcver} -loader ${fabricver}`,
|
||||
`java -jar fabric-installer-1.0.3.jar server -mcver ${mcver} -loader ${fabricver}`,
|
||||
{ cwd: path, stdio: "ignore" }
|
||||
);
|
||||
}
|
||||
}
|
||||
@@ -9,7 +9,7 @@ import { LOGGER } from "../utils/logger.js";
|
||||
|
||||
const gotx = got.extend({
|
||||
prefixUrl: "https://bmclapi2.bangbang93.com",
|
||||
headers: { "User-Agent": "DeEarthX V2" },
|
||||
headers: { "User-Agent": "DeEarthX" },
|
||||
});
|
||||
|
||||
interface mcinfoX {
|
||||
@@ -24,12 +24,12 @@ export default async function install(
|
||||
) {
|
||||
//instance
|
||||
const mcinfo = (await gotx
|
||||
.get(`version/${minecraftversion}/json`)
|
||||
.get(`version/${minecraftversion}/json`,{ headers: { "User-Agent": "DeEarthX" } })
|
||||
.json()) as mcinfoX; //获取Minecraft版本JSON
|
||||
const forgepath = path;
|
||||
const forgedata = (
|
||||
await gotx.get(
|
||||
`forge/download?mcversion=${minecraftversion}&version=${loaderversion}&category=installer&format=jar`
|
||||
`forge/download?mcversion=${minecraftversion}&version=${loaderversion}&category=installer&format=jar`,
|
||||
)
|
||||
).rawBody;
|
||||
fse.outputFileSync(
|
||||
|
||||
@@ -1,12 +1,12 @@
|
||||
import AdmZip from "adm-zip";
|
||||
import fsExtra from "fs-extra/esm";
|
||||
import fsExtra from "fs-extra";
|
||||
import gotx from "got";
|
||||
import { xfastdownload } from "../utils/utils.js";
|
||||
import { LOGGER } from "../utils/logger.js";
|
||||
import cp from "child_process";
|
||||
const got = gotx.extend({
|
||||
prefixUrl: "https://bmclapi2.bangbang93.com",
|
||||
headers: { "User-Agent": "DeEarthX V2" },
|
||||
headers: { "User-Agent": "DeEarthX" },
|
||||
});
|
||||
|
||||
interface mcinfoX {
|
||||
@@ -19,7 +19,7 @@ export default async function install(
|
||||
neoforge: string,
|
||||
path: string
|
||||
) {
|
||||
const mcinfo = (await gotx
|
||||
const mcinfo = (await got
|
||||
.get(`version/${minecraft}/json`)
|
||||
.json()) as mcinfoX; //获取Minecraft版本JSON
|
||||
const installer = (
|
||||
@@ -35,7 +35,7 @@ export default async function install(
|
||||
//下载依赖1
|
||||
const t = fvdata[c].downloads.artifact;
|
||||
await xfastdownload(
|
||||
`maven${new URL(t.url).pathname}`,
|
||||
`https://bmclapi2.bangbang93.com/maven${new URL(t.url).pathname.replace("/releases","")}`,
|
||||
`${path}/libraries/${t.path}`,
|
||||
16
|
||||
);
|
||||
@@ -47,7 +47,7 @@ export default async function install(
|
||||
//下载依赖2
|
||||
const t = fvdata[c].downloads.artifact;
|
||||
await xfastdownload(
|
||||
`maven${new URL(t.url).pathname}`,
|
||||
`https://bmclapi2.bangbang93.com/maven${new URL(t.url).pathname.replace("/releases","")}`,
|
||||
`${path}/libraries/${t.path}`,
|
||||
16
|
||||
);
|
||||
@@ -57,13 +57,13 @@ export default async function install(
|
||||
for (let d = 0; d < mcinfo.libraries.length; d++) {
|
||||
const g = mcinfo.libraries[d].downloads.artifact;
|
||||
await xfastdownload(
|
||||
`maven${new URL(g.url).pathname}`,
|
||||
`https://bmclapi2.bangbang93.com/maven${new URL(g.url).pathname}`,
|
||||
`${path}/libraries/${g.path}`,
|
||||
16
|
||||
);
|
||||
}
|
||||
await xfastdownload(
|
||||
`version/${minecraft}/server`,
|
||||
`https://bmclapi2.bangbang93.com/version/${minecraft}/server`,
|
||||
`${path}/libraries/net/minecraft/server/${minecraft}/server-${minecraft}.jar`,
|
||||
1
|
||||
);
|
||||
@@ -73,4 +73,4 @@ export default async function install(
|
||||
stdio: "ignore",
|
||||
});
|
||||
LOGGER.info("安装NeoForge完成!");
|
||||
}
|
||||
}
|
||||
@@ -46,6 +46,7 @@ export class CurseForge implements XPlatform {
|
||||
"Content-Type": "application/json",
|
||||
"x-api-key":
|
||||
"$2a$10$ydk0TLDG/Gc6uPMdz7mad.iisj2TaMDytVcIW4gcVP231VKngLBKy",
|
||||
"User-Agent": "DeEarthX",
|
||||
},
|
||||
})
|
||||
.json()
|
||||
|
||||
@@ -1,25 +1,27 @@
|
||||
/* Power by.Tianpao
|
||||
* 本工具可能会判断失误,但也能为您节省不少时间!
|
||||
* DeEarth V2 From StarNet.X
|
||||
* Writing in 03.29.2025(latest)
|
||||
* Writing in 07.10.2025(latest)
|
||||
* ©2024-2025
|
||||
*/
|
||||
import AdmZip from "adm-zip";
|
||||
import got from "got";
|
||||
import fs from "fs";
|
||||
import toml from 'toml';
|
||||
import crypto from "crypto";
|
||||
import toml from 'smol-toml'
|
||||
import path from 'path';
|
||||
import pMap from "p-map";
|
||||
import { usemirror } from "./utils.js";
|
||||
import { LOGGER } from "./logger.js";
|
||||
import { MultiBar } from "cli-progress";
|
||||
|
||||
export async function DeEarthMain(modspath: string, movepath: any) {
|
||||
if(!fs.existsSync(movepath)){
|
||||
fs.mkdirSync(movepath)
|
||||
if (!fs.existsSync(movepath)) {
|
||||
fs.mkdirSync(movepath)
|
||||
}
|
||||
LOGGER.info(`DeEarth V1.0.0`)
|
||||
LOGGER.info(`如有无法筛选的mods,请前往 https://dearth.0771010.xyz/ 提交未成功筛选的模组的modid`)
|
||||
LOGGER.info(`Probejs 7.0.0以上版本为非客户端mod,如rubbish中有请自行添加回去`)
|
||||
LOGGER.info(`Probejs 7.0.0以上版本为非客户端mod,如.rubbish中有请自行添加回去`)
|
||||
const resaddr = fs.readdirSync(modspath)
|
||||
LOGGER.info(`获取目录列表,一共${resaddr.length}个jar文件。`)
|
||||
const totalBar = multibar.create(resaddr.length, 0, { filename: '总文件数' })
|
||||
@@ -35,93 +37,113 @@ fs.mkdirSync(movepath)
|
||||
}
|
||||
|
||||
export async function DeEarth(modpath: string, movepath: string) {
|
||||
const zip = new AdmZip(modpath).getEntries();
|
||||
//for (let i = 0; i < zip.length; i++) {
|
||||
//const e = zip[i]
|
||||
let mrurl = "https://api.modrinth.com"
|
||||
if (usemirror){
|
||||
mrurl = "https://mod.mcimirror.top/modrinth"
|
||||
}
|
||||
|
||||
let pid:string|undefined = undefined
|
||||
try {
|
||||
const data = fs.readFileSync(modpath)
|
||||
const hash = crypto.createHash('sha1').update(data).digest('hex')
|
||||
const pjson = await got.get(`${mrurl}/v2/version_file/${hash}?algorithm=sha1`,{
|
||||
headers:{
|
||||
"User-Agent": "DeEarth"
|
||||
}
|
||||
}).json<{project_id:string}>()
|
||||
pid = pjson.project_id
|
||||
//console.log("哈希命中成功,正在查询Modrinth")
|
||||
}catch(e){}
|
||||
|
||||
const zipinfo = ZipInfo(modpath)
|
||||
let modid:string = ""
|
||||
if(zipinfo){
|
||||
if(zipinfo.modinfo.type === "forge"){
|
||||
modid = zipinfo.modinfo.data.mods[0].modId
|
||||
}else if(zipinfo.modinfo.type === "fabric"){
|
||||
modid = zipinfo.modinfo.data.id
|
||||
}
|
||||
|
||||
try { //Modrinth
|
||||
for (let i = 0; i < zip.length; i++) {
|
||||
const e = zip[i]
|
||||
if (e.entryName == "META-INF/mods.toml") { //Forge,NeoForge
|
||||
const modid = toml.parse(e.getData().toString('utf-8')).mods[0].modId
|
||||
//const body = await got.get(`https://api.modrinth.com/v2/project/${modid}`, { headers: { "User-Agent": "DeEarth" } }).json()
|
||||
const body = JSON.parse(await FastGot(`https://api.modrinth.com/v2/project/${modid}`))
|
||||
if (body.client_side == "required" && body.server_side == "unsupported") {
|
||||
fs.renameSync(modpath, `${movepath}/${path.basename(modpath)}`)
|
||||
}
|
||||
} else if (e.entryName == "fabric.mod.json") { //Fabric
|
||||
const modid = JSON.parse(e.getData().toString('utf-8')).id
|
||||
//const body = await got.get(`https://api.modrinth.com/v2/project/${modid}`, { headers: { "User-Agent": "DeEarth" } }).json()
|
||||
const body = JSON.parse(await FastGot(`https://api.modrinth.com/v2/project/${modid}`))
|
||||
if (body.client_side == "required" && body.server_side == "unsupported") {
|
||||
fs.renameSync(modpath, `${movepath}/${path.basename(modpath)}`)
|
||||
}
|
||||
}
|
||||
let body:any
|
||||
if (pid){
|
||||
body = JSON.parse(await FastGot(`${mrurl}/v2/project/${pid}`))
|
||||
}else{
|
||||
body = JSON.parse(await FastGot(`${mrurl}/v2/project/${modid}`))
|
||||
}
|
||||
if(body.client_side == "required" && body.server_side !== "required"){
|
||||
fs.renameSync(modpath, `${movepath}/${path.basename(modpath)}`)
|
||||
}
|
||||
} catch (error) { //DeEarthPublic
|
||||
try {
|
||||
if (JSON.parse(await FastGot(`https://dearth.0771010.xyz/api/modid?modid=${modid}`)).isClient) {
|
||||
fs.renameSync(modpath, `${movepath}/${path.basename(modpath)}`)
|
||||
}else{
|
||||
throw new Error("DeEarthPublic Not Found This Mod")
|
||||
}
|
||||
} catch (error) { //mods.toml或fabric.mod.json判断
|
||||
try{//DeEarthPublic
|
||||
for (let i = 0; i < zip.length; i++) {
|
||||
const e = zip[i]
|
||||
if (e.entryName == "META-INF/mods.toml") { //Forge,Neoforge
|
||||
const modid = toml.parse(e.getData().toString('utf-8')).mods[0].modId
|
||||
const body = JSON.parse(await FastGot(`https://dearth.0771010.xyz/api/modid?modid=${modid}`))
|
||||
if (body.isClient) {
|
||||
fs.renameSync(modpath, `${movepath}/${path.basename(modpath)}`)
|
||||
}
|
||||
} else if (e.entryName == "fabric.mod.json") { //Fabric
|
||||
const modid = JSON.parse(e.getData().toString('utf-8')).id
|
||||
const body = JSON.parse(await FastGot(`https://dearth.0771010.xyz/api/modid?modid=${modid}`))
|
||||
if (body.isClient) {
|
||||
fs.renameSync(modpath, `${movepath}/${path.basename(modpath)}`)
|
||||
}
|
||||
}
|
||||
try{
|
||||
if(zipinfo.modinfo.type === "forge"){
|
||||
const mcside = zipinfo.modinfo.data.dependencies[modid].find((mod: { modId: string; }) => mod.modId === "minecraft").side //Minecraft
|
||||
if (mcside == "CLIENT") {
|
||||
fs.renameSync(modpath, `${movepath}/${path.basename(modpath)}`)
|
||||
}
|
||||
}catch(errorr){
|
||||
for (let i = 0; i < zip.length; i++) {
|
||||
const e = zip[i]
|
||||
try {
|
||||
if (e.entryName == "META-INF/mods.toml") { //Forge,Neoforge
|
||||
const tr = toml.parse(e.getData().toString('utf-8'))
|
||||
const mcside = tr.dependencies[tr.mods[0].modId].find((mod: { modId: string; }) => mod.modId === "minecraft").side
|
||||
if (mcside == "CLIENT"){ //从Minecraft判断
|
||||
fs.renameSync(modpath, `${movepath}/${path.basename(modpath)}`)
|
||||
}
|
||||
const forgeside = tr.dependencies[tr.mods[0].modId].find((mod: { modId: string; }) => mod.modId === "forge").side
|
||||
if (forgeside == "CLIENT") { //从Forge判断
|
||||
fs.renameSync(modpath, `${movepath}/${path.basename(modpath)}`)
|
||||
}
|
||||
} else if (e.entryName == "fabric.mod.json") { //Fabric
|
||||
const fmj = JSON.parse(e.getData().toString('utf-8')).environment
|
||||
if (fmj == "client") {
|
||||
fs.renameSync(modpath, `${movepath}/${path.basename(modpath)}`)
|
||||
}
|
||||
}
|
||||
} catch (erro) {//从Mixin判断 但是可能为不准确
|
||||
for (let i = 0; i < zip.length; i++) {
|
||||
const e = zip[i]
|
||||
try {
|
||||
if (!e.entryName.includes("/") && e.entryName.endsWith(".json") && !e.entryName.endsWith("refmap.json") && !e.entryName.endsWith("mod.json")) {
|
||||
LOGGER.info(e.entryName)
|
||||
const resx = JSON.parse(e.getData().toString('utf-8'))
|
||||
if (e.entryName.includes("common.mixins.json")) { //第一步从common mixins文件判断,判断失败后再使用modid.mixins.json进行判断
|
||||
if (resx.mixins == null || Object.keys(resx.mixins).length == 0 && Object.keys(resx.client).length !== 0) {
|
||||
fs.renameSync(modpath, `${movepath}/${path.basename(modpath)}`)
|
||||
}
|
||||
} else {
|
||||
if (resx.mixins == null || Object.keys(resx.mixins).length == 0 && Object.keys(resx.client).length !== 0) {
|
||||
fs.renameSync(modpath, `${movepath}/${path.basename(modpath)}`)
|
||||
}
|
||||
}
|
||||
}
|
||||
} catch (err:any) {//避免有傻逼JSON写注释(虽然GSON可以这样 但是这样一点也不人道)
|
||||
if (err.errno !== -4058) {
|
||||
LOGGER.error(`大天才JSON写注释了估计,模组路径:${modpath},过滤失败`)
|
||||
}
|
||||
}
|
||||
}
|
||||
const forgeside = zipinfo.modinfo.data.dependencies[modid].find((mod: { modId: string; }) => mod.modId === "forge").side //Forge
|
||||
if (forgeside == "CLIENT") {
|
||||
fs.renameSync(modpath, `${movepath}/${path.basename(modpath)}`)
|
||||
}
|
||||
const neoside = zipinfo.modinfo.data.dependencies[modid].find((mod: { modId: string; }) => mod.modId === "neoforge").side //NeoForge
|
||||
if (neoside == "CLIENT") {
|
||||
fs.renameSync(modpath, `${movepath}/${path.basename(modpath)}`)
|
||||
}
|
||||
}else if(zipinfo.modinfo.type === "fabric"){ //Fabric
|
||||
const fmj = zipinfo.modinfo.data.environment
|
||||
if (fmj == "client") {
|
||||
fs.renameSync(modpath, `${movepath}/${path.basename(modpath)}`)
|
||||
}
|
||||
}
|
||||
}catch(error){
|
||||
try{
|
||||
for (let i = 0; i < zipinfo.mixins.length; i++) {
|
||||
const e = zipinfo.mixins[i]
|
||||
const info = JSON.parse(e.info)
|
||||
if (isMixin(info)) {
|
||||
fs.renameSync(modpath, `${movepath}/${path.basename(modpath)}`)
|
||||
}
|
||||
}
|
||||
}catch(error){
|
||||
LOGGER.error(`大天才JSON写注释了估计,模组路径:${modpath},过滤失败`)
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
function ZipInfo(modpath: string) {
|
||||
interface ZipInfo {
|
||||
mixins: { filename: string, info: string }[]
|
||||
modinfo: {type:string,data:any};
|
||||
}
|
||||
try{
|
||||
let zipinfo: ZipInfo = { mixins: [], modinfo: {type: "",data: {}} }
|
||||
const zip = new AdmZip(modpath).getEntries();
|
||||
for (let i = 0; i < zip.length; i++) {
|
||||
const e = zip[i]
|
||||
if (isMixinFile(e.entryName)) {
|
||||
zipinfo.mixins.push({ filename: e.entryName, info: e.getData().toString('utf-8') })
|
||||
} else if (isForge(e.entryName)) {
|
||||
zipinfo.modinfo.type = "forge"
|
||||
zipinfo.modinfo.data = toml.parse(e.getData().toString('utf-8'))
|
||||
} else if (e.entryName.endsWith("fabric.mod.json")) {
|
||||
zipinfo.modinfo.type = "fabric"
|
||||
zipinfo.modinfo.data = JSON.parse(e.getData().toString('utf-8'))
|
||||
}
|
||||
}
|
||||
return zipinfo;
|
||||
}catch(error){
|
||||
LOGGER.error(error)
|
||||
}
|
||||
}
|
||||
|
||||
async function FastGot(url: string) {
|
||||
@@ -131,7 +153,7 @@ async function FastGot(url: string) {
|
||||
try {
|
||||
if (e[0] !== null) { //防止URL为空
|
||||
//if(isChinaIpAddress((await got.get("https://4.ipw.cn/")).body)){
|
||||
return (await got.get(e[0], { headers: { "User-Agent": "DeEarth" } })).body
|
||||
return (await got.get(e[0], { headers: { "User-Agent": "DeEarthX" } })).body
|
||||
//}else{
|
||||
//return (await got.get(`https://mod.mcimirror.top/modrinth/${new URL(e[0]).pathname}`, { headers: { "User-Agent": "DeEarth" } })).body //MCIM源
|
||||
//}
|
||||
@@ -148,7 +170,7 @@ async function FastGot(url: string) {
|
||||
})
|
||||
if (fastgot[0] !== undefined) {
|
||||
return fastgot[0]
|
||||
}else{
|
||||
} else {
|
||||
return "null"
|
||||
}
|
||||
}
|
||||
@@ -156,9 +178,21 @@ async function FastGot(url: string) {
|
||||
const multibar = new MultiBar({
|
||||
format: ' {bar} | {filename} | {value}/{total}',
|
||||
noTTYOutput: true,
|
||||
notTTYSchedule: 10*1000,
|
||||
notTTYSchedule: 10 * 1000,
|
||||
})
|
||||
|
||||
function isMixin(resx: { mixins: {} | null; client: {}; }) {
|
||||
return resx.mixins == null || Object.keys(resx.mixins).length == 0 && Object.keys(resx.client).length !== 0
|
||||
}
|
||||
|
||||
function isForge(name: string): boolean {
|
||||
return name.endsWith("mods.toml") || name.endsWith("neoforge.mod.toml")
|
||||
}
|
||||
|
||||
function isMixinFile(name: string): boolean {
|
||||
return !name.includes("/") && name.endsWith(".json") && !name.endsWith("refmap.json") && !name.endsWith("mod.json")
|
||||
}
|
||||
|
||||
function isChinaIpAddress(ipAddress: string) {
|
||||
const chinaRegex = /^((?:(?:1(?:0|1|2[0-7]|[3-9][0-9])|2(?:[0-4][0-9]|5[0-5])|[3-9][0-9]{2})\.){3}(?:(?:1(?:0|1|2[0-7]|[3-9][0-9])|2(?:[0-4][0-9]|5[0-5])|[3-9][0-9]{2})))$/;
|
||||
return chinaRegex.test(ipAddress);
|
||||
|
||||
@@ -1,4 +1,4 @@
|
||||
import chalk from "chalk";
|
||||
import pc from "picocolors"
|
||||
export const LOGGER = {
|
||||
info(text: string) {
|
||||
info(text);
|
||||
@@ -6,39 +6,39 @@ export const LOGGER = {
|
||||
warn(text: string) {
|
||||
warn(text);
|
||||
},
|
||||
error(text: string | object) {
|
||||
error(text: string | object | unknown) {
|
||||
error(text);
|
||||
},
|
||||
};
|
||||
function info(text: string) {
|
||||
console.log(
|
||||
`[${chalk.blue(
|
||||
`[${pc.blue(
|
||||
new Date().toLocaleDateString() + " " + new Date().toLocaleTimeString()
|
||||
)}](${process.pid})[${chalk.green("INFO")}]:${chalk.cyan(text)}`
|
||||
)}](${process.pid})[${pc.green("INFO")}]:${pc.cyan(text)}`
|
||||
);
|
||||
}
|
||||
|
||||
function warn(text: string) {
|
||||
console.log(
|
||||
`[${chalk.blue(
|
||||
`[${pc.blue(
|
||||
new Date().toLocaleDateString() + " " + new Date().toLocaleTimeString()
|
||||
)}](${process.pid})[${chalk.yellowBright("WARN")}]:${chalk.yellowBright(
|
||||
)}](${process.pid})[${pc.yellowBright("WARN")}]:${pc.yellowBright(
|
||||
text
|
||||
)}`
|
||||
);
|
||||
}
|
||||
function error(error: object | string) {
|
||||
function error(error: object | string | unknown) {
|
||||
if (typeof error === "object") {
|
||||
console.log(
|
||||
`[${chalk.blue(
|
||||
`[${pc.blue(
|
||||
new Date().toLocaleDateString() + " " + new Date().toLocaleTimeString()
|
||||
)}](${process.pid})[${chalk.red("ERROR")}:${JSON.stringify(error)}`
|
||||
)}](${process.pid})[${pc.red("ERROR")}:${JSON.stringify(error)}`
|
||||
);
|
||||
} else {
|
||||
console.log(
|
||||
`[${chalk.blue(
|
||||
`[${pc.blue(
|
||||
new Date().toLocaleDateString() + " " + new Date().toLocaleTimeString()
|
||||
)}](${process.pid})[${chalk.red("ERROR")}:${error}`
|
||||
)}](${process.pid})[${pc.red("ERROR")}:${error}`
|
||||
);
|
||||
}
|
||||
}
|
||||
|
||||
@@ -1,139 +1,203 @@
|
||||
import pMap from "p-map";
|
||||
import pRetry from "p-retry";
|
||||
import fse from "fs-extra"
|
||||
import fs from "node:fs";
|
||||
import fse from "fs-extra";
|
||||
import yauzl from "yauzl";
|
||||
import got from "got";
|
||||
import env from "dotenv"
|
||||
import env from "dotenv";
|
||||
import { MultiBar } from "cli-progress";
|
||||
import {URL, fileURLToPath } from "node:url";
|
||||
import { URL, fileURLToPath } from "node:url";
|
||||
import { LOGGER } from "./logger.js";
|
||||
import { exec } from "node:child_process";
|
||||
|
||||
export async function readzipentry(zipfile: yauzl.ZipFile, entry: yauzl.Entry):Promise<string|Buffer> {
|
||||
export interface ForgeInfo{
|
||||
minecraft_verison: string,
|
||||
forge_verison: string
|
||||
}
|
||||
|
||||
export async function readzipentry(
|
||||
zipfile: yauzl.ZipFile,
|
||||
entry: yauzl.Entry
|
||||
): Promise<string> {
|
||||
const data: Buffer<ArrayBufferLike>[] = [];
|
||||
return await new Promise((reslove, reject) => {
|
||||
zipfile.openReadStream(entry, (err, e) => {
|
||||
e.on("data", (chunk: Buffer) => {
|
||||
data.push(chunk);
|
||||
}).on("end", () => {
|
||||
reslove(data.toString());
|
||||
if (data.length !== 0 && typeof data !== "string") {
|
||||
reslove(Buffer.concat(data).toString());
|
||||
}
|
||||
});
|
||||
});
|
||||
});
|
||||
}
|
||||
|
||||
export async function fastdownload(data:[string,string]){
|
||||
export async function fastdownload(data: [string, string]) {
|
||||
const multibar = new MultiBar({
|
||||
format: ' {bar} | {filename} | {value}/{total}',
|
||||
noTTYOutput: true,
|
||||
notTTYSchedule: 10*1000,
|
||||
})
|
||||
const totalBar = multibar.create(data.length, 0, {filename: '总文件数'})
|
||||
return await pMap(data,async(e)=>{
|
||||
const size:number = await (async()=>{const head = (await got.head(e[0].replace("https://mod.mcimirror.top","https://edge.forgecdn.net"))).headers['content-length'];if(head){return Number(head)}else{return 0}})()
|
||||
const bar = multibar.create(size, 0, {filename: e[1]})
|
||||
try{
|
||||
await pRetry(async()=>{
|
||||
if(!fse.existsSync(e[1])){
|
||||
await got.get(e[0],{
|
||||
responseType:"buffer",
|
||||
}).on('downloadProgress',(progress)=>{
|
||||
bar.update(progress.transferred)
|
||||
}).then((res)=>{
|
||||
fse.outputFileSync(e[1],res.rawBody)
|
||||
})
|
||||
}
|
||||
},{retries:3})
|
||||
}catch(e){
|
||||
LOGGER.error({err:e})
|
||||
}finally{
|
||||
bar.stop()
|
||||
totalBar.increment()
|
||||
multibar.remove(bar)
|
||||
format: " {bar} | {filename} | {value}/{total}",
|
||||
noTTYOutput: true,
|
||||
notTTYSchedule: 10 * 1000,
|
||||
});
|
||||
const totalBar = multibar.create(data.length, 0, { filename: "总文件数" });
|
||||
return await pMap(
|
||||
data,
|
||||
async (e) => {
|
||||
const size: number = await (async () => {
|
||||
const head = (
|
||||
await got.head(
|
||||
e[0] /*.replace("https://mod.mcimirror.top","https://edge.forgecdn.net")*/,
|
||||
{ headers: { "user-agent": "DeEarthX" } }
|
||||
)
|
||||
).headers["content-length"];
|
||||
if (head) {
|
||||
return Number(head);
|
||||
} else {
|
||||
return 0;
|
||||
}
|
||||
})();
|
||||
const bar = multibar.create(size, 0, { filename: e[1] });
|
||||
try {
|
||||
await pRetry(
|
||||
async () => {
|
||||
if (!fs.existsSync(e[1])) {
|
||||
await got
|
||||
.get(e[0], {
|
||||
responseType: "buffer",
|
||||
headers: {
|
||||
"user-agent": "DeEarthX",
|
||||
},
|
||||
})
|
||||
.on("downloadProgress", (progress) => {
|
||||
bar.update(progress.transferred);
|
||||
})
|
||||
.then((res) => {
|
||||
fse.outputFileSync(e[1], res.rawBody);
|
||||
});
|
||||
}
|
||||
},
|
||||
{ retries: 3 }
|
||||
);
|
||||
} catch (e) {
|
||||
LOGGER.error({ err: e });
|
||||
} finally {
|
||||
bar.stop();
|
||||
totalBar.increment();
|
||||
multibar.remove(bar);
|
||||
}
|
||||
},{concurrency:16})
|
||||
},
|
||||
{ concurrency: 16 }
|
||||
);
|
||||
}
|
||||
|
||||
export async function mr_fastdownload(data:[string,string,string]){
|
||||
export async function mr_fastdownload(data: [string, string, string]) {
|
||||
const multibar = new MultiBar({
|
||||
format: ' {bar} | {filename} | {value}/{total}',
|
||||
noTTYOutput: true,
|
||||
notTTYSchedule: 10*1000,
|
||||
format: " {bar} | {filename} | {value}/{total}",
|
||||
noTTYOutput: true,
|
||||
notTTYSchedule: 10 * 1000,
|
||||
});
|
||||
const totalBar = multibar.create(data.length, 0, { filename: '总文件数' });
|
||||
return await pMap(data, async (e) => {
|
||||
const totalBar = multibar.create(data.length, 0, { filename: "总文件数" });
|
||||
return await pMap(
|
||||
data,
|
||||
async (e) => {
|
||||
const bar = multibar.create(Number(e[2]), 0, { filename: e[1] });
|
||||
try {
|
||||
await pRetry(async () => {
|
||||
if (!fse.existsSync(e[1])) {
|
||||
await got.get(e[0], {
|
||||
responseType: "buffer",
|
||||
}).on('downloadProgress', (progress) => {
|
||||
bar.update(progress.transferred);
|
||||
}).then((res) => {
|
||||
fse.outputFileSync(e[1], res.rawBody);
|
||||
});
|
||||
}
|
||||
}, { retries: 3 });
|
||||
await pRetry(
|
||||
async () => {
|
||||
if (!fse.existsSync(e[1])) {
|
||||
await got
|
||||
.get(e[0], {
|
||||
responseType: "buffer",
|
||||
headers: {
|
||||
"user-agent": "DeEarthX",
|
||||
},
|
||||
})
|
||||
.on("downloadProgress", (progress) => {
|
||||
bar.update(progress.transferred);
|
||||
})
|
||||
.then((res) => {
|
||||
fse.outputFileSync(e[1], res.rawBody);
|
||||
});
|
||||
}
|
||||
},
|
||||
{ retries: 3 }
|
||||
);
|
||||
} catch (e) {
|
||||
LOGGER.error({ err: e });
|
||||
} finally {
|
||||
bar.stop();
|
||||
totalBar.increment();
|
||||
multibar.remove(bar);
|
||||
}
|
||||
catch (e) {
|
||||
LOGGER.error({ err: e });
|
||||
}
|
||||
finally {
|
||||
bar.stop();
|
||||
totalBar.increment();
|
||||
multibar.remove(bar);
|
||||
}
|
||||
}, { concurrency: 16 });
|
||||
},
|
||||
{ concurrency: 16 }
|
||||
);
|
||||
}
|
||||
|
||||
export async function xfastdownload(
|
||||
url: string,
|
||||
path: string,
|
||||
concurrency: number = 1
|
||||
) {
|
||||
let e = [];
|
||||
e.push([url, path]);
|
||||
await pMap(
|
||||
e,
|
||||
async (e) => {
|
||||
try {
|
||||
return await pRetry(
|
||||
async () => {
|
||||
if (
|
||||
url !== null &&
|
||||
url !== "" &&
|
||||
path !== null &&
|
||||
!fse.existsSync(e[1])
|
||||
) {
|
||||
const res = (await got.get(e[0])).rawBody; //下载文件
|
||||
await fse.outputFile(e[1], res); //保存文件
|
||||
}
|
||||
},
|
||||
{
|
||||
retries: 2,
|
||||
url: string,
|
||||
path: string,
|
||||
concurrency: number = 1
|
||||
) {
|
||||
let e = [];
|
||||
e.push([url, path]);
|
||||
await pMap(
|
||||
e,
|
||||
async (e) => {
|
||||
try {
|
||||
return await pRetry(
|
||||
async () => {
|
||||
if (
|
||||
url !== null &&
|
||||
url !== "" &&
|
||||
path !== null &&
|
||||
!fs.existsSync(e[1])
|
||||
) {
|
||||
const res = (await got.get(e[0],{
|
||||
headers: {
|
||||
"user-agent": "DeEarthX"
|
||||
}
|
||||
})).rawBody; //下载文件
|
||||
await fse.outputFile(e[1], res); //保存文件
|
||||
}
|
||||
);
|
||||
} catch (error) {
|
||||
LOGGER.error({ err: error });
|
||||
}
|
||||
},
|
||||
{
|
||||
concurrency: concurrency,
|
||||
},
|
||||
{
|
||||
retries: 2,
|
||||
}
|
||||
);
|
||||
} catch (error) {
|
||||
LOGGER.error({ err: error });
|
||||
}
|
||||
);
|
||||
}
|
||||
|
||||
export const usemirror = (()=>{
|
||||
env.config({debug:false})
|
||||
const mirror = process.env.MIRROR
|
||||
if(mirror){
|
||||
return false
|
||||
}else{
|
||||
return true
|
||||
},
|
||||
{
|
||||
concurrency: concurrency,
|
||||
}
|
||||
})()
|
||||
);
|
||||
}
|
||||
|
||||
export const isDevelopment = (()=>{
|
||||
env.config()
|
||||
return process.env.DEVELOPMENT
|
||||
})()
|
||||
export const usemirror = (() => {
|
||||
env.config({ debug: false });
|
||||
const mirror = process.env.MIRROR;
|
||||
if (mirror) {
|
||||
return false;
|
||||
} else {
|
||||
return true;
|
||||
}
|
||||
})();
|
||||
|
||||
export const isDevelopment = (() => {
|
||||
env.config();
|
||||
return process.env.DEVELOPMENT;
|
||||
})();
|
||||
|
||||
export const isInstallJava:Promise<boolean> = (() => {
|
||||
return new Promise((resolve) => {
|
||||
exec("java -version", (err) => {
|
||||
if (err) {
|
||||
resolve(false);
|
||||
} else {
|
||||
resolve(true);
|
||||
}
|
||||
});
|
||||
});
|
||||
})();
|
||||
|
||||
Reference in New Issue
Block a user