/usr/lib/nodejs/gulp-plumber/index.js is in node-gulp-plumber 1.1.0-1.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 | 'use strict';
var through2 = require('through2');
var EE = require('events').EventEmitter;
var gutil = require('gulp-util');
function removeDefaultHandler(stream, event) {
var found = false;
stream.listeners(event).forEach(function (item) {
if (item.name === 'on' + event) {
found = item;
this.removeListener(event, item);
}
}, stream);
return found;
}
function wrapPanicOnErrorHandler(stream) {
var oldHandler = removeDefaultHandler(stream, 'error');
if (oldHandler) {
stream.on('error', function onerror2(er) {
if (EE.listenerCount(stream, 'error') === 1) {
this.removeListener('error', onerror2);
oldHandler.call(stream, er);
}
});
}
}
function defaultErrorHandler(error) {
// onerror2 and this handler
if (EE.listenerCount(this, 'error') < 3) {
gutil.log(
gutil.colors.cyan('Plumber') + gutil.colors.red(' found unhandled error:\n'),
error.toString()
);
}
}
function plumber(opts) {
opts = opts || {};
if (typeof opts === 'function') {
opts = {errorHandler: opts};
}
var through = through2.obj();
through._plumber = true;
if (opts.errorHandler !== false) {
through.errorHandler = (typeof opts.errorHandler === 'function') ?
opts.errorHandler :
defaultErrorHandler;
}
function patchPipe(stream) {
if (stream.pipe2) {
wrapPanicOnErrorHandler(stream);
stream._pipe = stream._pipe || stream.pipe;
stream.pipe = stream.pipe2;
stream._plumbed = true;
}
}
through.pipe2 = function pipe2(dest) {
if (!dest) {
throw new gutil.PluginError('plumber', 'Can\'t pipe to undefined');
}
this._pipe.apply(this, arguments);
if (dest._unplumbed) {
return dest;
}
removeDefaultHandler(this, 'error');
if (dest._plumber) {
return dest;
}
dest.pipe2 = pipe2;
// Patching pipe method
if (opts.inherit !== false) {
patchPipe(dest);
}
// Placing custom on error handler
if (this.errorHandler) {
dest.errorHandler = this.errorHandler;
dest.on('error', this.errorHandler.bind(dest));
}
dest._plumbed = true;
return dest;
};
patchPipe(through);
return through;
}
module.exports = plumber;
module.exports.stop = function () {
var through = through2.obj();
through._unplumbed = true;
return through;
};
|