/**
 * Module dependencies.
 */

var dir = require('../');
var should = require('../node_modules/should');
var path = require('path');
var fs = require('fs');
var exec = require('child_process').exec;
fs.existsSync = fs.existsSync || path.existsSync;
var root = path.resolve('.');

describe('ndir', function () {
  describe('walk()', function () {
    var emptydir = path.join(root, 'test/emptydir');

    before(function () {
      if (!fs.existsSync(emptydir)) {
        fs.mkdirSync(emptydir, '0777');
      }
    });
    after(function () {
      if (fs.existsSync(emptydir)) {
        fs.rmdirSync(emptydir);
      }
    });

    function check(dir, files) {
      fs.statSync(dir).isDirectory().should.be.true;
      files.should.be.an.instanceof(Array);
      files.length.should.equal(fs.readdirSync(dir).length);
      for (var i = 0, l = files.length; i < l; i++) {
        var info = files[i];
        info[0].should.be.a('string');
        info[0].should.include(dir);
        var stats = info[1];
        stats.should.be.an.instanceof(fs.Stats);
      }
    }

    var walkdir = path.join(root, 'test');
    it('should walk dir ' + walkdir, function end(done) {
      var walker = new dir.Walk(walkdir);
      walker.on('dir', check);
      var dirCount = 1;
      var fileCount = 0;
      walker.on('dir', function (dirpath, files) {
        for (var i = 0, l = files.length; i < l; i++) {
          var info = files[i];
          var stats = info[1];
          if (stats.isDirectory()) {
            dirCount++;
          } else if (!stats.isSymbolicLink() && stats.isFile()) {
            fileCount++;
          }
        }
      });
      walker.on('end', function () {
        dirCount.should.equal(2);
        fileCount.should.equal(4);
        done();
      });
    });

    it('should walk "' + root + '" in callback mode', function (done) {
      var walker = new dir.Walk(__dirname, check, done);
    });

    it('should walk "' + root + '" no error', function (done) {
      dir.walk(root, check, done, function (err, p) {
        should.not.exist(err);
        should.not.exist(p);
      });
    });

    it('should success when walk empty dir', function (done) {
      dir.walk(emptydir, check, done, function (err, p) {
        should.not.exist(err);
        should.not.exist(p);
      });
    });

    it('should error when walk not exists dir', function (done) {
      dir.walk('test/not-exists-dir', check, done, function (err) {
        err.should.be.an.instanceof(Error);
        err.message.should.include('ENOENT');
      });
    });

    it('should error when walk a file', function (done) {
      dir.walk('test/ndir.test.js', check, done, function (err) {
        err.should.be.an.instanceof(Error);
        err.message.should.include('ENOTDIR');
      });
    });

    if (fs.existsSync('/.fseventsd')) {
      it('should error when walk noPermission dir', function (done) {
        dir.walk('/.fseventsd', check, done, function (err) {
          err.should.be.an.instanceof(Error);
          err.message.should.include('EACCES');
        });
      });
    }
    
  });

  describe('copyfile()', function () {
    var from = 'test/dir.test.foo.txt';
    var to = 'test/dir.test.bar.txt';
    var toParentNotExists = '/tmp/' + new Date().getTime() + '/dir.test.bar.txt';

    before(function () {
      fs.existsSync(to) && fs.unlinkSync(to);
    });

    it('should worked', function (done) {
      dir.copyfile(from, to, function (err) {
        should.not.exist(err);
        fs.statSync(to).isFile().should.be.true;
        fs.readFileSync(to).toString().should.equal(fs.readFileSync(from).toString());
        dir.copyfile(to, to, function (err) {
          // copy save should callback(err)
          err.should.be.an.instanceof(Error);
          err.message.should.include('not copied');
          fs.statSync(to).isFile().should.be.true;
          fs.readFileSync(to).toString().should.equal(fs.readFileSync(from).toString());
          done();
        });
      });
    });

    it('should copy toParentNotExists', function (done) {
      dir.copyfile(from, toParentNotExists, function (err) {
        should.not.exist(err);
        fs.statSync(toParentNotExists).isFile().should.be.true;
        fs.readFileSync(toParentNotExists).toString().should.equal(fs.readFileSync(from).toString());
        done();
      });
    });

  });

  describe('mkdir()', function () {
    var existsDir = '/tmp/dir.test.exists.dir';
    var notExistsDir = '/tmp/dir.test/not.exists.dir/haha/1/2/3/4/2/3/1/2/3';

    before(function (done) {
      !fs.existsSync(existsDir) && fs.mkdirSync(existsDir, '0777');
      exec('rm -rf /tmp/dir.test', done);
    });

    after(function () {
      fs.rmdirSync(existsDir);
    });

    it('should make exists dir success', function (done) {
      fs.existsSync(existsDir).should.be.true;
      dir.mkdir(existsDir, function (err) {
        fs.existsSync(existsDir).should.be.true;
        done(err);
      });
    });

    it('should make not exists dir success', function (done) {
      fs.existsSync(notExistsDir).should.be.false;
      dir.mkdir(notExistsDir, function (err) {
        fs.existsSync(notExistsDir).should.be.true;
        done(err);
      });
    });

  });

  describe('createLineReader()', function () {
    it('should read line by line', function (done) {
      var logfile = __dirname + '/access.log';
      var lines = fs.readFileSync(logfile, 'utf8').split('\n');
      var index = 0;
      dir.createLineReader(logfile)
      .on('line', function (line) {
        line.should.be.an.instanceof(Buffer);
        var s = line.toString();
        s.should.equal(lines[index++]);
        if (s) {
          s[s.length - 1].should.not.equal('\n');
        }
      })
      .on('end', done)
      .on('error', done);
    });
  });
});