Server IP : 85.214.239.14 / Your IP : 18.191.189.119 Web Server : Apache/2.4.62 (Debian) System : Linux h2886529.stratoserver.net 4.9.0 #1 SMP Tue Jan 9 19:45:01 MSK 2024 x86_64 User : www-data ( 33) PHP Version : 7.4.18 Disable Function : pcntl_alarm,pcntl_fork,pcntl_waitpid,pcntl_wait,pcntl_wifexited,pcntl_wifstopped,pcntl_wifsignaled,pcntl_wifcontinued,pcntl_wexitstatus,pcntl_wtermsig,pcntl_wstopsig,pcntl_signal,pcntl_signal_get_handler,pcntl_signal_dispatch,pcntl_get_last_error,pcntl_strerror,pcntl_sigprocmask,pcntl_sigwaitinfo,pcntl_sigtimedwait,pcntl_exec,pcntl_getpriority,pcntl_setpriority,pcntl_async_signals,pcntl_unshare, MySQL : OFF | cURL : OFF | WGET : ON | Perl : ON | Python : ON | Sudo : ON | Pkexec : OFF Directory : /lib/node_modules/npm/node_modules/proggy/lib/ |
Upload File : |
const EE = require('events') const onProgress = Symbol('onProgress') const bars = Symbol('bars') const listener = Symbol('listener') const normData = Symbol('normData') class Client extends EE { constructor ({ normalize = false, stopOnDone = false } = {}) { super() this.normalize = !!normalize this.stopOnDone = !!stopOnDone this[bars] = new Map() this[listener] = null } get size () { return this[bars].size } get listening () { return !!this[listener] } addListener (...args) { return this.on(...args) } on (ev, ...args) { if (ev === 'progress' && !this[listener]) { this.start() } return super.on(ev, ...args) } off (ev, ...args) { return this.removeListener(ev, ...args) } removeListener (ev, ...args) { const ret = super.removeListener(ev, ...args) if (ev === 'progress' && this.listeners(ev).length === 0) { this.stop() } return ret } stop () { if (this[listener]) { process.removeListener('progress', this[listener]) this[listener] = null } } start () { if (!this[listener]) { this[listener] = (...args) => this[onProgress](...args) process.on('progress', this[listener]) } } [onProgress] (key, data) { data = this[normData](key, data) if (!this[bars].has(key)) { this.emit('bar', key, data) } this[bars].set(key, data) this.emit('progress', key, data) if (data.done) { this[bars].delete(key) this.emit('barDone', key, data) if (this.size === 0) { if (this.stopOnDone) { this.stop() } this.emit('done') } } } [normData] (key, data) { const actualValue = data.value const actualTotal = data.total let value = actualValue let total = actualTotal const done = data.done || value >= total if (this.normalize) { const bar = this[bars].get(key) total = 100 if (done) { value = 100 } else { // show value as a portion of 100 const pct = 100 * actualValue / actualTotal if (bar) { // don't ever go backwards, and don't stand still // move at least 1% of the remaining value if it wouldn't move. value = (pct > bar.value) ? pct : (100 - bar.value) / 100 + bar.value } } } // include the key return { ...data, key, name: data.name || key, value, total, actualValue, actualTotal, done, } } } module.exports = Client