Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
'use strict';
var os = require('os');
var path = require('path');
var fs = require('graceful-fs');
var miss = require('mississippi');
var expect = require('expect');
var rimraf = require('rimraf');
var mkdirpStream = require('../');
var pipe = miss.pipe;
var from = miss.from;
var concat = miss.concat;
describe('mkdirpStream', function() {
var MASK_MODE = parseInt('7777', 8);
var isWindows = (os.platform() === 'win32');
var outputBase = path.join(__dirname, './out-fixtures');
var outputDirpath = path.join(outputBase, './foo');
function cleanup(done) {
this.timeout(20000);
expect.restoreSpies();
// Async del to get sort-of-fix for https://github.com/isaacs/rimraf/issues/72
/* global it, describe */
var expect = require('expect');
var miss = require('mississippi');
var OrderedStreams = require('..');
var to = miss.to;
var from = miss.from;
var pipe = miss.pipe;
var concat = miss.concat;
function fromOnce(fn) {
var called = false;
return from.obj(function(size, next) {
if (called) {
return next(null, null);
}
called = true;
fn.apply(this, arguments);
});
}
describe('ordered-read-streams', function () {
'use strict';
var mocha = require('mocha');
var assert = require('power-assert');
var Vinyl = require('vinyl');
var uglifyjs = require('uglify-js');
var mississippi = require('mississippi');
var gulpUglify = require('../');
var pipe = mississippi.pipe;
var to = mississippi.to;
var from = mississippi.from;
var describe = mocha.describe;
var it = mocha.it;
describe('no-compress', function() {
it('should not compress files when `compress: false`', function(done) {
var testContentsInput =
'"use strict"; (function(console, first, second) {\n\tconsole.log(first + second)\n}(5, 10))';
var testContentsExpected = uglifyjs.minify(testContentsInput, {
compress: false
}).code;
var testFile1 = new Vinyl({
cwd: '/home/terin/broken-promises/',
base: '/home/terin/broken-promises/test',
path: '/home/terin/broken-promises/test/test1.js',
'use strict';
var mocha = require('mocha');
var assert = require('power-assert');
var Vinyl = require('vinyl');
var td = require('testdouble');
var mississippi = require('mississippi');
var minifer = require('../minifier');
var pipe = mississippi.pipe;
var from = mississippi.from;
var to = mississippi.to;
var describe = mocha.describe;
var it = mocha.it;
describe('injecting mocha', function() {
it('should minify files', function(done) {
var testContentsOutput = 'function abs(a, b) {\n return a > b; }';
var testContentsInput = 'function testInput() {}';
var testFile = new Vinyl({
cwd: '/home/terin/broken-promises/',
base: '/home/terin/broken-promises/test',
path: '/home/terin/broken-promises/test/test1.js',
contents: new Buffer(testContentsInput)
});
'use strict';
var path = require('path');
var fs = require('graceful-fs');
var File = require('vinyl');
var expect = require('expect');
var miss = require('mississippi');
var vfs = require('../');
var testConstants = require('./utils/test-constants');
var pipe = miss.pipe;
var from = miss.from;
var concat = miss.concat;
var through = miss.through;
var inputBase = testConstants.inputBase;
var inputPath = testConstants.inputPath;
var inputDirpath = testConstants.inputDirpath;
var bomInputPath = testConstants.bomInputPath;
var beEncodedInputPath = testConstants.beEncodedInputPath;
var leEncodedInputPath = testConstants.leEncodedInputPath;
var contents = testConstants.contents;
describe('.src()', function() {
it('throws on invalid glob (empty)', function(done) {
var stream;
try {
'use strict';
var fs = require('graceful-fs');
var File = require('vinyl');
var expect = require('expect');
var miss = require('mississippi');
var vfs = require('../');
var cleanup = require('./utils/cleanup');
var isWindows = require('./utils/is-windows');
var testConstants = require('./utils/test-constants');
var from = miss.from;
var pipe = miss.pipe;
var concat = miss.concat;
var inputBase = testConstants.inputBase;
var outputBase = testConstants.outputBase;
var inputPath = testConstants.inputPath;
var outputPath = testConstants.outputPath;
var contents = testConstants.contents;
var clean = cleanup(outputBase);
describe('.dest() with custom times', function() {
beforeEach(clean);
afterEach(clean);
var isOwner = fo.isOwner;
var writeFile = fo.writeFile;
var getModeDiff = fo.getModeDiff;
var getTimesDiff = fo.getTimesDiff;
var getOwnerDiff = fo.getOwnerDiff;
var isValidUnixId = fo.isValidUnixId;
var getFlags = fo.getFlags;
var isFatalOverwriteError = fo.isFatalOverwriteError;
var isFatalUnlinkError = fo.isFatalUnlinkError;
var reflectStat = fo.reflectStat;
var reflectLinkStat = fo.reflectLinkStat;
var updateMetadata = fo.updateMetadata;
var createWriteStream = fo.createWriteStream;
var pipe = miss.pipe;
var from = miss.from;
var string = testStreams.string;
var outputBase = testConstants.outputBase;
var inputPath = testConstants.inputPath;
var neInputDirpath = testConstants.neInputDirpath;
var outputPath = testConstants.outputPath;
var symlinkPath = testConstants.symlinkDirpath;
var contents = testConstants.contents;
var clean = cleanup(outputBase);
function noop() {}
describe('isOwner', function() {
'use strict';
var miss = require('mississippi');
var expect = require('expect');
var to = miss.to;
var from = miss.from;
var through = miss.through;
function string(length) {
return from(function(size, next) {
if (length <= 0) {
next(null, null);
return;
}
var chunkSize = size <= length ? size : length;
length -= size;
var chunk = '';
for (var x = 0; x < chunkSize; x++) {
chunk += 'a';
for (let [index, row] of rows.entries()) {
rows[index] = await Promise.resolve(argv.transformOut(row, { index, rows, config }))
}
}
let serializer
if (argv.classicJson) {
serializer = streams.classicJsonOutputStream()
} else if (argv.json) {
serializer = ndjson.serialize()
} else {
serializer = csvWriter(csvOptions)
}
miss.from.obj(rows)
.pipe(serializer)
.pipe(outputStream)
}
MetadataContainer.prototype.getStream = function() {
var stream = miss.from.obj();
stream.push(this);
stream.push(null);
return stream;
}