const fs = require('fs') const shelljs = require('shelljs') const path = require('path') const request = require('request') const checksum = require('checksum') const Zip = require('adm-zip') const child = require('child_process') let counter = 0 class Handler { constructor (client) { this.client = client this.options = client.options this.baseRequest = request.defaults({ pool: { maxSockets: this.options.overrides.maxSockets || 2 }, timeout: this.options.timeout || 10000 }) } checkJava (java) { return new Promise(resolve => { child.exec(`"${java}" -version`, (error, stdout, stderr) => { if (error) { resolve({ run: false, message: error }) } else { this.client.emit('debug', `[MCLC]: Using Java version ${stderr.match(/"(.*?)"/).pop()} ${stderr.includes('64-Bit') ? '64-bit' : '32-Bit'}`) resolve({ run: true }) } }) }) } downloadAsync (url, directory, name, retry, type) { return new Promise(resolve => { shelljs.mkdir('-p', directory) const _request = this.baseRequest(url) let receivedBytes = 0 let totalBytes = 0 _request.on('response', (data) => { if (data.statusCode === 404) { this.client.emit('debug', `[MCLC]: Failed to download ${url} due to: File not found...`) resolve(false) } totalBytes = parseInt(data.headers['content-length']) }) _request.on('error', async (error) => { this.client.emit('debug', `[MCLC]: Failed to download asset to ${path.join(directory, name)} due to\n${error}.` + ` Retrying... ${retry}`) if (retry) await this.downloadAsync(url, directory, name, false, type) resolve() }) _request.on('data', (data) => { receivedBytes += data.length this.client.emit('download-status', { name: name, type: type, current: receivedBytes, total: totalBytes }) }) const file = fs.createWriteStream(path.join(directory, name)) _request.pipe(file) file.once('finish', () => { this.client.emit('download', name) resolve({ failed: false, asset: null }) }) file.on('error', async (e) => { this.client.emit('debug', `[MCLC]: Failed to download asset to ${path.join(directory, name)} due to\n${e}.` + ` Retrying... ${retry}`) if (fs.existsSync(path.join(directory, name))) shelljs.rm(path.join(directory, name)) if (retry) await this.downloadAsync(url, directory, name, false, type) resolve() }) }) } checkSum (hash, file) { return new Promise((resolve, reject) => { checksum.file(file, (err, sum) => { if (err) { this.client.emit('debug', `[MCLC]: Failed to check file hash due to ${err}`) resolve(false) } else { resolve(hash === sum) } }) }) } getVersion () { return new Promise(resolve => { const versionJsonPath = this.options.overrides.versionJson || path.join(this.options.directory, `${this.options.version.number}.json`) if (fs.existsSync(versionJsonPath)) { this.version = JSON.parse(fs.readFileSync(versionJsonPath)) return resolve(this.version) } const manifest = `${this.options.overrides.url.meta}/mc/game/version_manifest.json` request.get(manifest, (error, response, body) => { if (error) resolve(error) const parsed = JSON.parse(body) for (const desiredVersion in parsed.versions) { if (parsed.versions[desiredVersion].id === this.options.version.number) { request.get(parsed.versions[desiredVersion].url, (error, response, body) => { if (error) resolve(error) this.client.emit('debug', '[MCLC]: Parsed version from version manifest') this.version = JSON.parse(body) return resolve(this.version) }) } } }) }) } async getJar () { await this.downloadAsync(this.version.downloads.client.url, this.options.directory, `${this.options.version.number}.jar`, true, 'version-jar') fs.writeFileSync(path.join(this.options.directory, `${this.options.version.number}.json`), JSON.stringify(this.version, null, 4)) return this.client.emit('debug', '[MCLC]: Downloaded version jar and wrote version json') } async getAssets () { const assetDirectory = path.resolve(this.options.overrides.assetRoot || path.join(this.options.root, 'assets')) if (!fs.existsSync(path.join(assetDirectory, 'indexes', `${this.version.assetIndex.id}.json`))) { await this.downloadAsync(this.version.assetIndex.url, path.join(assetDirectory, 'indexes'), `${this.version.assetIndex.id}.json`, true, 'asset-json') } const index = JSON.parse(fs.readFileSync(path.join(assetDirectory, 'indexes', `${this.version.assetIndex.id}.json`), { encoding: 'utf8' })) this.client.emit('progress', { type: 'assets', task: 0, total: Object.keys(index.objects).length }) await Promise.all(Object.keys(index.objects).map(async asset => { const hash = index.objects[asset].hash const subhash = hash.substring(0, 2) const subAsset = path.join(assetDirectory, 'objects', subhash) if (!fs.existsSync(path.join(subAsset, hash)) || !await this.checkSum(hash, path.join(subAsset, hash))) { await this.downloadAsync(`${this.options.overrides.url.resource}/${subhash}/${hash}`, subAsset, hash, true, 'assets') counter++ this.client.emit('progress', { type: 'assets', task: counter, total: Object.keys(index.objects).length }) } })) counter = 0 // Copy assets to legacy if it's an older Minecraft version. if (this.isLegacy()) { this.client.emit('debug', `[MCLC]: Copying assets over to ${path.join(assetDirectory, 'legacy')}`) this.client.emit('progress', { type: 'assets-copy', task: 0, total: Object.keys(index.objects).length }) await Promise.all(Object.keys(index.objects).map(async asset => { const hash = index.objects[asset].hash const subhash = hash.substring(0, 2) const subAsset = path.join(assetDirectory, 'objects', subhash) const legacyAsset = asset.split('/') legacyAsset.pop() if (!fs.existsSync(path.join(assetDirectory, 'legacy', legacyAsset.join('/')))) { shelljs.mkdir('-p', path.join(assetDirectory, 'legacy', legacyAsset.join('/'))) } if (!fs.existsSync(path.join(assetDirectory, 'legacy', asset))) { fs.copyFileSync(path.join(subAsset, hash), path.join(assetDirectory, 'legacy', asset)) } counter++ this.client.emit('progress', { type: 'assets-copy', task: counter, total: Object.keys(index.objects).length }) })) } counter = 0 this.client.emit('debug', '[MCLC]: Downloaded assets') } parseRule (lib) { if (lib.rules) { if (lib.rules.length > 1) { if (lib.rules[0].action === 'allow' && lib.rules[1].action === 'disallow' && lib.rules[1].os.name === 'osx') { return this.getOS() === 'osx' } else { return true } } else { if (lib.rules[0].action === 'allow' && lib.rules[0].os) return this.getOS() !== 'osx' } } else { return false } } async getNatives () { const nativeDirectory = path.resolve(this.options.overrides.natives || path.join(this.options.root, 'natives', this.version.id)) if (!fs.existsSync(nativeDirectory) || !fs.readdirSync(nativeDirectory).length) { shelljs.mkdir('-p', nativeDirectory) const natives = async () => { const natives = [] await Promise.all(this.version.libraries.map(async (lib) => { if (!lib.downloads.classifiers) return if (this.parseRule(lib)) return const native = this.getOS() === 'osx' ? lib.downloads.classifiers['natives-osx'] || lib.downloads.classifiers['natives-macos'] : lib.downloads.classifiers[`natives-${this.getOS()}`] natives.push(native) })) return natives } const stat = await natives() this.client.emit('progress', { type: 'natives', task: 0, total: stat.length }) await Promise.all(stat.map(async (native) => { if (!native) return const name = native.path.split('/').pop() await this.downloadAsync(native.url, nativeDirectory, name, true, 'natives') if (!await this.checkSum(native.sha1, path.join(nativeDirectory, name))) { await this.downloadAsync(native.url, nativeDirectory, name, true, 'natives') } try { new Zip(path.join(nativeDirectory, name)).extractAllTo(nativeDirectory, true) } catch (e) { // Only doing a console.warn since a stupid error happens. You can basically ignore this. // if it says Invalid file name, just means two files were downloaded and both were deleted. // All is well. console.warn(e) } shelljs.rm(path.join(nativeDirectory, name)) counter++ this.client.emit('progress', { type: 'natives', task: counter, total: stat.length }) })) this.client.emit('debug', '[MCLC]: Downloaded and extracted natives') } counter = 0 this.client.emit('debug', `[MCLC]: Set native path to ${nativeDirectory}`) return nativeDirectory } // Not bothering to rewrite this. async getForgeDependenciesLegacy () { if (!fs.existsSync(path.join(this.options.root, 'forge'))) { shelljs.mkdir('-p', path.join(this.options.root, 'forge')) } const zipFile = new Zip(this.options.forge) if (zipFile.getEntry('install_profile.json')) { this.client.emit('debug', '[MCLC]: Detected Forge installer, will treat as custom with ForgeWrapper') return false } try { await zipFile.extractEntryTo('version.json', path.join(this.options.root, 'forge', `${this.version.id}`), false, true) } catch (e) { this.client.emit('debug', `[MCLC]: Unable to extract version.json from the forge jar due to ${e}`) return null } const forge = JSON.parse(fs.readFileSync(path.join(this.options.root, 'forge', `${this.version.id}`, 'version.json'), { encoding: 'utf8' })) const paths = [] this.client.emit('progress', { type: 'forge', task: 0, total: forge.libraries.length }) const libraryDirectory = path.resolve(this.options.overrides.libraryRoot || path.join(this.options.root, 'libraries')) await Promise.all(forge.libraries.map(async library => { const lib = library.name.split(':') if (lib[0] === 'net.minecraftforge' && lib[1].includes('forge')) return let url = this.options.overrides.url.mavenForge const jarPath = path.join(libraryDirectory, `${lib[0].replace(/\./g, '/')}/${lib[1]}/${lib[2]}`) const name = `${lib[1]}-${lib[2]}.jar` if (!library.url) { if (library.serverreq || library.clientreq) { url = this.options.overrides.url.defaultRepoForge } else { return } } const downloadLink = `${url}${lib[0].replace(/\./g, '/')}/${lib[1]}/${lib[2]}/${name}` if (fs.existsSync(path.join(jarPath, name))) { paths.push(`${jarPath}${path.sep}${name}`) counter++ this.client.emit('progress', { type: 'forge', task: counter, total: forge.libraries.length }) return } if (!fs.existsSync(jarPath)) shelljs.mkdir('-p', jarPath) const download = await this.downloadAsync(downloadLink, jarPath, name, true, 'forge') if (!download) await this.downloadAsync(`${this.options.overrides.url.fallbackMaven}${lib[0].replace(/\./g, '/')}/${lib[1]}/${lib[2]}/${name}`, jarPath, name, true, 'forge') paths.push(`${jarPath}${path.sep}${name}`) counter++ this.client.emit('progress', { type: 'forge', task: counter, total: forge.libraries.length }) })) counter = 0 this.client.emit('debug', '[MCLC]: Downloaded Forge dependencies') return { paths, forge } } getForgedWrapped () { return new Promise(resolve => { const libraryDirectory = path.resolve(this.options.overrides.libraryRoot || path.join(this.options.root, 'libraries')) const launchArgs = `"${this.options.javaPath ? this.options.javaPath : 'java'}" -jar ${path.resolve(this.options.forgeWrapper.jar)}` + ` --installer=${this.options.forge} --instance=${this.options.root} ` + `--saveTo=${path.join(libraryDirectory, 'io', 'github', 'zekerzhayard', 'ForgeWrapper', this.options.forgeWrapper.version)}` const fw = child.exec(launchArgs) const forgeJson = path.join(this.options.root, 'forge', this.version.id, 'version.json') fw.on('close', (e) => { if (!fs.existsSync(forgeJson)) { this.client.emit('debug', '[MCLC]: ForgeWrapper did not produce a version file, using Vanilla') resolve(null) } else { resolve(JSON.parse(fs.readFileSync(forgeJson, { encoding: 'utf8' }))) } }) }) } runInstaller (path) { return new Promise(resolve => { const installer = child.exec(path) installer.on('close', (code) => resolve()) }) } async downloadToDirectory (directory, libraries, eventName) { const libs = [] await Promise.all(libraries.map(async library => { if (!library) return const lib = library.name.split(':') let jarPath let name if (library.downloads && library.downloads.artifact && library.downloads.artifact.path) { name = library.downloads.artifact.path.split('/')[library.downloads.artifact.path.split('/').length - 1] jarPath = path.join(directory, this.popString(library.downloads.artifact.path)) } else { name = `${lib[1]}-${lib[2]}${lib[3] ? '-' + lib[3] : ''}.jar` jarPath = path.join(directory, `${lib[0].replace(/\./g, '/')}/${lib[1]}/${lib[2]}`) } if (!fs.existsSync(path.join(jarPath, name))) { // Simple lib support, forgot which addon needed this but here you go, Mr special. if (library.url) { const url = `${library.url}${lib[0].replace(/\./g, '/')}/${lib[1]}/${lib[2]}/${name}` await this.downloadAsync(url, jarPath, name, true, eventName) } else if (library.downloads && library.downloads.artifact) { await this.downloadAsync(library.downloads.artifact.url, jarPath, name, true, eventName) } } counter++ this.client.emit('progress', { type: eventName, task: counter, total: libraries.length }) libs.push(`${jarPath}${path.sep}${name}`) })) counter = 0 return libs } async getClasses (classJson) { let libs = [] const libraryDirectory = path.resolve(this.options.overrides.libraryRoot || path.join(this.options.root, 'libraries')) if (classJson) { if (classJson.mavenFiles) { await this.downloadToDirectory(libraryDirectory, classJson.mavenFiles, 'classes-maven-custom') } libs = (await this.downloadToDirectory(libraryDirectory, classJson.libraries, 'classes-custom')) } const parsed = this.version.libraries.map(lib => { if (lib.downloads.artifact && !this.parseRule(lib)) return lib }) libs = libs.concat((await this.downloadToDirectory(libraryDirectory, parsed, 'classes'))) counter = 0 this.client.emit('debug', '[MCLC]: Collected class paths') return libs } popString (path) { const tempArray = path.split('/') tempArray.pop() return tempArray.join('/') } cleanUp (array) { const newArray = [] for (const classPath in array) { if (newArray.includes(array[classPath])) continue newArray.push(array[classPath]) } return newArray } async getLaunchOptions (modification) { const type = modification || this.version let args = type.minecraftArguments ? type.minecraftArguments.split(' ') : type.arguments.game const assetRoot = path.resolve(this.options.overrides.assetRoot || path.join(this.options.root, 'assets')) const assetPath = this.isLegacy() ? path.join(assetRoot, 'legacy') : path.join(assetRoot) const minArgs = this.options.overrides.minArgs || this.isLegacy() ? 5 : 11 if (args.length < minArgs) args = args.concat(this.version.minecraftArguments ? this.version.minecraftArguments.split(' ') : this.version.arguments.game) this.options.authorization = await Promise.resolve(this.options.authorization) const fields = { '${auth_access_token}': this.options.authorization.access_token, '${auth_session}': this.options.authorization.access_token, '${auth_player_name}': this.options.authorization.name, '${auth_uuid}': this.options.authorization.uuid, '${user_properties}': this.options.authorization.user_properties, '${user_type}': 'mojang', '${version_name}': this.options.version.number, '${assets_index_name}': this.version.assetIndex.id, '${game_directory}': this.options.root, '${assets_root}': assetPath, '${game_assets}': assetPath, '${version_type}': this.options.version.type } for (let index = 0; index < args.length; index++) { if (typeof args[index] === 'object') args.splice(index, 2) if (Object.keys(fields).includes(args[index])) { args[index] = fields[args[index]] } } if (this.options.window) { this.options.window.fullscreen ? args.push('--fullscreen') : args.push('--width', this.options.window.width, '--height', this.options.window.height) } if (this.options.server) args.push('--server', this.options.server.host, '--port', this.options.server.port || '25565') if (this.options.proxy) { args.push( '--proxyHost', this.options.proxy.host, '--proxyPort', this.options.proxy.port || '8080', '--proxyUser', this.options.proxy.username, '--proxyPass', this.options.proxy.password ) } if (this.options.customLaunchArgs) args = args.concat(this.options.customLaunchArgs) this.client.emit('debug', '[MCLC]: Set launch options') return args } async getJVM () { const opts = { windows: '-XX:HeapDumpPath=MojangTricksIntelDriversForPerformance_javaw.exe_minecraft.exe.heapdump', osx: '-XstartOnFirstThread', linux: '-Xss1M' } return opts[this.getOS()] } isLegacy () { return this.version.assets === 'legacy' || this.version.assets === 'pre-1.6' } getOS () { if (this.options.os) { return this.options.os } else { switch (process.platform) { case 'win32': return 'windows' case 'darwin': return 'osx' default: return 'linux' } } } async extractPackage (options = this.options) { if (options.clientPackage.startsWith('http')) { await this.downloadAsync(options.clientPackage, options.root, 'clientPackage.zip', true, 'client-package') options.clientPackage = path.join(options.root, 'clientPackage.zip') } new Zip(options.clientPackage).extractAllTo(options.root, true) if (options.removePackage) shelljs.rm(options.clientPackage) return this.client.emit('package-extract', true) } } module.exports = Handler