dest.js

'use strict';

var gulp = require('../');
var should = require('should');
var join = require('path').join;
var rimraf = require('rimraf');
var fs = require('graceful-fs');

require('mocha');

var outpath = join(__dirname, "./out-fixtures");

describe('gulp output stream', function() {
  describe('dest()', function() {
    beforeEach(rimraf.bind(null, outpath));
    afterEach(rimraf.bind(null, outpath));

    it('should return a stream', function(done) {
      var stream = gulp.dest(join(__dirname, "./fixtures/"));
      should.exist(stream);
      should.exist(stream.on);
      done();
    });

    it('should return a output stream that writes files', function(done) {
      var instream = gulp.src(join(__dirname, "./fixtures/**/*.txt"));
      var outstream = gulp.dest(outpath);
      instream.pipe(outstream);

      outstream.on('error', done);
      outstream.on('data', function(file) {
        // data should be re-emitted right
        should.exist(file);
        should.exist(file.path);
        should.exist(file.contents);
        join(file.path,'').should.equal(join(outpath, "./copy/example.txt"));
        String(file.contents).should.equal("this is a test");
      });
      outstream.on('end', function() {
        fs.readFile(join(outpath, "copy", "example.txt"), function(err, contents) {
          should.not.exist(err);
          should.exist(contents);
          String(contents).should.equal("this is a test");
          done();
        });
      });
    });

    it('should return a output stream that does not write non-read files', function(done) {
      var instream = gulp.src(join(__dirname, "./fixtures/**/*.txt"), {read:false});
      var outstream = gulp.dest(outpath);
      instream.pipe(outstream);

      outstream.on('error', done);
      outstream.on('data', function(file) {
        // data should be re-emitted right
        should.exist(file);
        should.exist(file.path);
        should.not.exist(file.contents);
        join(file.path,'').should.equal(join(outpath, "./copy/example.txt"));
      });
      outstream.on('end', function() {
        fs.readFile(join(outpath, "copy", "example.txt"), function(err, contents) {
          should.exist(err);
          should.not.exist(contents);
          done();
        });
      });
    });

    it('should return a output stream that writes streaming files', function(done) {
      var instream = gulp.src(join(__dirname, "./fixtures/**/*.txt"), {buffer:false});
      var outstream = instream.pipe(gulp.dest(outpath));

      outstream.on('error', done);
      outstream.on('data', function(file) {
        // data should be re-emitted right
        should.exist(file);
        should.exist(file.path);
        should.exist(file.contents);
        join(file.path,'').should.equal(join(outpath, "./copy/example.txt"));
      });
      outstream.on('end', function() {
        fs.readFile(join(outpath, "copy", "example.txt"), function(err, contents) {
          should.not.exist(err);
          should.exist(contents);
          String(contents).should.equal("this is a test");
          done();
        });
      });
    });

    it('should return a output stream that writes streaming files into new directories', function(done) {
      testWriteDir({}, done);
    });

    it('should return a output stream that writes streaming files into new directories (buffer: false)', function(done) {
      testWriteDir({buffer: false}, done);
    });

    it('should return a output stream that writes streaming files into new directories (read: false)', function(done) {
      testWriteDir({read: false}, done);
    });

    it('should return a output stream that writes streaming files into new directories (read: false, buffer: false)', function(done) {
      testWriteDir({buffer: false, read: false}, done);
    });

    function testWriteDir(srcOptions, done) {
      var instream = gulp.src(join(__dirname, "./fixtures/stuff"), srcOptions);
      var outstream = instream.pipe(gulp.dest(outpath));

      outstream.on('error', done);
      outstream.on('data', function(file) {
        // data should be re-emitted right
        should.exist(file);
        should.exist(file.path);
        join(file.path,'').should.equal(join(outpath, "./stuff"));
      });
      outstream.on('end', function() {
        fs.exists(join(outpath, "stuff"), function(exists) {
          /* stinks that ok is an expression instead of a function call */
          /* jshint expr: true */
          should(exists).be.ok;
          /* jshint expr: false */
          done();
        });
      });
    }

  });
});