|
|
|
|
@@ -61,10 +61,18 @@ const ensureDir = (dir) => {
|
|
|
|
|
if (!fs.existsSync(dir)) fs.mkdirSync(dir);
|
|
|
|
|
};
|
|
|
|
|
const DOWNLOAD_PATH = config.global.downloadPath || "downloads";
|
|
|
|
|
const isDownloaded = (filename) => fs.existsSync(path.join(DOWNLOAD_PATH, filename));
|
|
|
|
|
const PLUGIN_PATH = path.join(DOWNLOAD_PATH, "Plugins");
|
|
|
|
|
const SERVEREXEC_PATH = path.join(DOWNLOAD_PATH, "Serverexec");
|
|
|
|
|
|
|
|
|
|
[DOWNLOAD_PATH, PLUGIN_PATH, SERVEREXEC_PATH].forEach(ensureDir);
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
const downloadJar = async (url, name) => {
|
|
|
|
|
if (isDownloaded(name)) {
|
|
|
|
|
const isServerJar = name === "server.jar";
|
|
|
|
|
const destDir = isServerJar ? SERVEREXEC_PATH : PLUGIN_PATH;
|
|
|
|
|
const filePath = path.join(destDir, name);
|
|
|
|
|
|
|
|
|
|
if (fs.existsSync(filePath)) {
|
|
|
|
|
console.log(`🟡 Skipped (already exists): ${name}`);
|
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
@@ -84,12 +92,12 @@ const downloadJar = async (url, name) => {
|
|
|
|
|
response.data.on("data", (chunk) => bar.increment(chunk.length));
|
|
|
|
|
response.data.on("end", () => bar.stop());
|
|
|
|
|
|
|
|
|
|
const filePath = path.join(DOWNLOAD_PATH, name);
|
|
|
|
|
await pipeline(response.data, fs.createWriteStream(filePath));
|
|
|
|
|
console.log(`✔️ Saved: ${name}`);
|
|
|
|
|
console.log(`✔️ Saved: ${filePath}`);
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
// --- Source handlers ---
|
|
|
|
|
|
|
|
|
|
// --- Handle Jenkins ---
|
|
|
|
|
const handleJenkins = async (url) => {
|
|
|
|
|
const html = await axios.get(url).then((res) => res.data);
|
|
|
|
|
const $ = cheerio.load(html);
|
|
|
|
|
@@ -98,7 +106,7 @@ const handleJenkins = async (url) => {
|
|
|
|
|
|
|
|
|
|
const base = new URL(url);
|
|
|
|
|
const preferred = ["paper", "spigot", "bukkit"];
|
|
|
|
|
const skip = ["javadoc", "sources", "cli", "bootstrap", "mojangapi", "nashorn", "remapper"];
|
|
|
|
|
const skip = ["javadoc", "sources", "cli", "bootstrap", "mojangapi", "nashorn", "remapper", "fabric", "neoforge"];
|
|
|
|
|
const essentialsOK = ["EssentialsX", "EssentialsXChat", "EssentialsXSpawn", "EssentialsXGeoIP"];
|
|
|
|
|
|
|
|
|
|
const valid = links
|
|
|
|
|
@@ -125,11 +133,11 @@ const handleJenkins = async (url) => {
|
|
|
|
|
|
|
|
|
|
// Fallback: all valid jars
|
|
|
|
|
for (const f of valid) {
|
|
|
|
|
const finalURL = new URL(f.href, base).href;
|
|
|
|
|
await downloadJar(finalURL, path.basename(f.href));
|
|
|
|
|
await downloadJar(new URL(f.href, base).href, path.basename(f.href));
|
|
|
|
|
}
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
// --- Handle GitHub ---
|
|
|
|
|
const handleGitHub = async (url) => {
|
|
|
|
|
const match = url.match(/github\.com\/([^/]+\/[^/]+)/);
|
|
|
|
|
if (!match) throw new Error("Invalid GitHub URL format");
|
|
|
|
|
@@ -146,6 +154,7 @@ const handleGitHub = async (url) => {
|
|
|
|
|
await downloadJar(chosen.browser_download_url, chosen.name);
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
// --- Handle Modrinth ---
|
|
|
|
|
const handleModrinth = async (url) => {
|
|
|
|
|
const match = url.match(/modrinth\.com\/plugin\/([^/]+)/);
|
|
|
|
|
if (!match) throw new Error("Invalid Modrinth URL format");
|
|
|
|
|
@@ -155,13 +164,22 @@ const handleModrinth = async (url) => {
|
|
|
|
|
.get(`https://api.modrinth.com/v2/project/${project}/version`)
|
|
|
|
|
.then((res) => res.data);
|
|
|
|
|
|
|
|
|
|
const latest = versions[0];
|
|
|
|
|
const file = latest.files.find((f) => f.filename.endsWith(".jar"));
|
|
|
|
|
if (!file) throw new Error("No .jar file in latest version");
|
|
|
|
|
// Filter to only versions compatible with Spigot/Paper/etc
|
|
|
|
|
const compatible = versions.find((v) =>
|
|
|
|
|
(v.loaders || []).some((loader) =>
|
|
|
|
|
["spigot", "paper", "bukkit", "purpur", "folia"].includes(loader.toLowerCase())
|
|
|
|
|
)
|
|
|
|
|
);
|
|
|
|
|
|
|
|
|
|
if (!compatible) throw new Error("No compatible Spigot/Paper version found");
|
|
|
|
|
|
|
|
|
|
const file = compatible.files.find((f) => f.filename.endsWith(".jar"));
|
|
|
|
|
if (!file) throw new Error("No .jar file in compatible version");
|
|
|
|
|
|
|
|
|
|
await downloadJar(file.url, file.filename);
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
// --- Handle Direct (Mainly for Floodgate) ---
|
|
|
|
|
const handleDirect = async (url) => {
|
|
|
|
|
let name = path.basename(url.split("?")[0]);
|
|
|
|
|
|
|
|
|
|
@@ -182,16 +200,21 @@ const handleDirect = async (url) => {
|
|
|
|
|
|
|
|
|
|
// --- Handle PaperMC ---
|
|
|
|
|
const handlePaperMC = async (url) => {
|
|
|
|
|
const versionMatch = url.match(/papermc.io\/download\/(.*?)(?:\/|$)/);
|
|
|
|
|
if (!versionMatch) throw new Error("Invalid PaperMC URL format");
|
|
|
|
|
const version = versionMatch[1];
|
|
|
|
|
if (url.includes("hangar.papermc.io")) {
|
|
|
|
|
const { data: html } = await axios.get(url);
|
|
|
|
|
const $ = cheerio.load(html);
|
|
|
|
|
|
|
|
|
|
const apiURL = `https://api.papermc.io/v2/projects/paper/versions/${version}/builds`;
|
|
|
|
|
const builds = await axios.get(apiURL).then((res) => res.data.builds);
|
|
|
|
|
const latestBuild = builds[0];
|
|
|
|
|
const jarLink = $('a[href$=".jar"]').first().attr("href");
|
|
|
|
|
if (!jarLink) throw new Error("❌ No .jar link found on Hangar page");
|
|
|
|
|
|
|
|
|
|
const downloadURL = latestBuild.downloads.application.url;
|
|
|
|
|
await downloadJar(downloadURL, `paper-${version}-${latestBuild.build}.jar`);
|
|
|
|
|
const downloadURL = jarLink.startsWith("http")
|
|
|
|
|
? jarLink
|
|
|
|
|
: `https://hangar.papermc.io${jarLink}`;
|
|
|
|
|
|
|
|
|
|
const fileName = path.basename(downloadURL);
|
|
|
|
|
await downloadJar(downloadURL, fileName);
|
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
// --- Handle dev.bukkit.org ---
|
|
|
|
|
@@ -235,6 +258,26 @@ const handleBukkit = async (url) => {
|
|
|
|
|
await downloadJar(fullDownloadLink, filename);
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
// --- Handle PaperMC Server DL ---
|
|
|
|
|
const downloadLatestPaperMC = async () => {
|
|
|
|
|
console.log("📥 Downloading latest PaperMC server jar...");
|
|
|
|
|
|
|
|
|
|
const projectURL = 'https://api.papermc.io/v2/projects/paper';
|
|
|
|
|
const { data: versionsData } = await axios.get(projectURL);
|
|
|
|
|
const latestVersion = versionsData.versions[versionsData.versions.length - 1];
|
|
|
|
|
|
|
|
|
|
const buildsURL = `${projectURL}/versions/${latestVersion}`;
|
|
|
|
|
const { data: buildsData } = await axios.get(buildsURL);
|
|
|
|
|
const latestBuild = buildsData.builds[buildsData.builds.length - 1];
|
|
|
|
|
|
|
|
|
|
const jarInfoURL = `${projectURL}/versions/${latestVersion}/builds/${latestBuild}`;
|
|
|
|
|
const { data: jarInfo } = await axios.get(jarInfoURL);
|
|
|
|
|
|
|
|
|
|
const jarPath = jarInfo.downloads.application.name;
|
|
|
|
|
const downloadURL = `https://api.papermc.io/v2/projects/paper/versions/${latestVersion}/builds/${latestBuild}/downloads/${jarPath}`;
|
|
|
|
|
|
|
|
|
|
await downloadJar(downloadURL, "server.jar");
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
// --- Upload to SFTP ---
|
|
|
|
|
const uploadToSFTP = async () => {
|
|
|
|
|
@@ -245,8 +288,6 @@ const uploadToSFTP = async () => {
|
|
|
|
|
|
|
|
|
|
const sftp = new SftpClient();
|
|
|
|
|
const remote = sftpConfig.remotePath || "/";
|
|
|
|
|
const files = fs.readdirSync(DOWNLOAD_PATH).filter((f) => f.endsWith(".jar"));
|
|
|
|
|
|
|
|
|
|
const connectOptions = {
|
|
|
|
|
host: sftpConfig.host,
|
|
|
|
|
port: sftpConfig.port || 22,
|
|
|
|
|
@@ -261,28 +302,62 @@ const uploadToSFTP = async () => {
|
|
|
|
|
throw new Error("Missing SFTP password or private key.");
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
const extractBaseName = (filename) => {
|
|
|
|
|
return filename.replace(/[-_.](v?\d.*)?\.jar$/, "").trim();
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
try {
|
|
|
|
|
await sftp.connect(connectOptions);
|
|
|
|
|
const remoteFiles = await sftp.list(remote);
|
|
|
|
|
for (const file of remoteFiles) {
|
|
|
|
|
if (file.name.endsWith(".jar") && files.includes(file.name)) {
|
|
|
|
|
const remoteFilePath = path.posix.join(remote, file.name);
|
|
|
|
|
console.log(`🗑️ Deleting remote file: ${remoteFilePath}`);
|
|
|
|
|
await sftp.delete(remoteFilePath);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
const uploadFolder = async (localDir, remoteDir) => {
|
|
|
|
|
const files = fs.readdirSync(localDir).filter(f => f.endsWith(".jar"));
|
|
|
|
|
const remoteFiles = await sftp.list(remoteDir);
|
|
|
|
|
const remoteJars = remoteFiles.filter(f => f.name.endsWith(".jar"));
|
|
|
|
|
|
|
|
|
|
for (const file of files) {
|
|
|
|
|
const baseName = extractBaseName(file);
|
|
|
|
|
const toDelete = remoteJars.filter(r => extractBaseName(r.name) === baseName);
|
|
|
|
|
for (const del of toDelete) {
|
|
|
|
|
const fullPath = path.posix.join(remoteDir, del.name);
|
|
|
|
|
await sftp.delete(fullPath);
|
|
|
|
|
console.log(`🗑️ Deleted remote: ${fullPath}`);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
// 🚀 Upload new files
|
|
|
|
|
for (const file of files) {
|
|
|
|
|
const local = path.join(DOWNLOAD_PATH, file);
|
|
|
|
|
const remoteFile = path.posix.join(remote, file);
|
|
|
|
|
console.log(`🚀 Uploading ${file} → ${remoteFile}`);
|
|
|
|
|
await sftp.put(local, remoteFile);
|
|
|
|
|
const localPath = path.join(localDir, file);
|
|
|
|
|
const remotePath = path.posix.join(remoteDir, file);
|
|
|
|
|
await sftp.fastPut(localPath, remotePath);
|
|
|
|
|
console.log(`⬆️ Uploaded to ${remoteDir}: ${file}`);
|
|
|
|
|
}
|
|
|
|
|
await sftp.end();
|
|
|
|
|
console.log("✅ SFTP upload finished.");
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
await uploadFolder(PLUGIN_PATH, path.posix.join(remote, "plugins"));
|
|
|
|
|
await uploadFolder(SERVEREXEC_PATH, remote);
|
|
|
|
|
|
|
|
|
|
} catch (err) {
|
|
|
|
|
console.error("❌ SFTP upload failed:", err.message);
|
|
|
|
|
console.error("❌ SFTP Error:", err.message);
|
|
|
|
|
} finally {
|
|
|
|
|
const timeout = new Promise((_, reject) =>
|
|
|
|
|
setTimeout(() => reject(new Error("Timeout closing SFTP connection")), 5000)
|
|
|
|
|
);
|
|
|
|
|
try {
|
|
|
|
|
await Promise.race([sftp.end(), timeout]);
|
|
|
|
|
console.log("🔌 SFTP connection closed.");
|
|
|
|
|
// Clean up local files after upload
|
|
|
|
|
const deleteFilesInDir = (dir) => {
|
|
|
|
|
fs.readdirSync(dir).forEach(file => {
|
|
|
|
|
const filePath = path.join(dir, file);
|
|
|
|
|
if (fs.lstatSync(filePath).isFile()) {
|
|
|
|
|
fs.unlinkSync(filePath);
|
|
|
|
|
console.log(`🧹 Deleted: ${filePath}`);
|
|
|
|
|
}
|
|
|
|
|
});
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
deleteFilesInDir(PLUGIN_PATH);
|
|
|
|
|
deleteFilesInDir(SERVEREXEC_PATH);
|
|
|
|
|
} catch (e) {
|
|
|
|
|
console.warn("⚠️ Error or timeout closing SFTP:", e.message);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
@@ -296,6 +371,9 @@ const uploadToSFTP = async () => {
|
|
|
|
|
console.log(`🗑️ Deleted local file: ${file}`);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
await downloadLatestPaperMC();
|
|
|
|
|
|
|
|
|
|
console.log("\n🔍 Starting plugin downloads from configured URLs...");
|
|
|
|
|
for (const url of config.urls) {
|
|
|
|
|
console.log(`\n📥 ${url}`);
|
|
|
|
|
try {
|
|
|
|
|
|