var gulp = require('gulp');
var path = require('path');
var fs = require('fs');
var $ = require('gulp-load-plugins')();
var colors = require('colors');
var runSequence = require('run-sequence')
var through = require('through2');
var filter = require('gulp-filter');
var gutil = require('gulp-util');
var spritesmith = require('gulp.spritesmith');
var del = require('del');
var gulpif = require('gulp-if');
var less = require('gulp-less');
var watch = require('gulp-watch');
var connect = require('gulp-connect');
var webpack = require('webpack-stream');
var uglify = require('gulp-uglify');
var cssmin = require('gulp-cssmin');
var htmlmin = require('gulp-htmlmin');
var imagemin = require('gulp-imagemin');
var rev = require('gulp-rev');
var revReplace = require('gulp-rev-replace');
var print = require('gulp-print');
var replace = require('gulp-replace');
var prefix = require('gulp-prefix');
var Ftp = require('ftp');
var Pem = require('pem');
var slash = require('slash');
var debug = require('gulp-debug');

var packageJson = JSON.parse(fs.readFileSync('./package.json'));

var projectDirPath = packageJson.sftp.dirPath + packageJson.project;

var cdnPath = packageJson.cdnDomain + projectDirPath;

gulp.task('sprite', function() {
   var spriteOptions = require('./gulp/options/sprites')();
   Object.keys(spriteOptions).map(function(key, index) {
      var item = spriteOptions[key];
      // console.log('--------------------------------------------');
      // console.log(item);
      var spriteData = gulp.src(item.src).pipe(spritesmith(item));

      spriteData.img.pipe(gulp.dest('image'));
      spriteData.css.pipe(gulp.dest('less'));
   });
});

gulp.task('less', function() {
   // var cssStream = gulp.src(['../less/**/*.less', '!../less/include/*.less'])

   // var lessModifyVars = createLessMofifyVars('../image/sprites/*.png');
   // var lessModifyVars = createLessMofifyVars(['../image/sprites/**/*', '../image/page/**/*']);
   return gulp.src('less/**/*.less')
               .pipe(less({
                  // paths: [path.join(__dirname, '../less', 'include')],
                  modifyVars: {
                     "imgPath": "\"/image\""
                  }
               }))
               .pipe(gulp.dest('style'))
               .pipe(connect.reload());
});

gulp.task('webpack', function() {
   return gulp.src('script/page/index.js')
              .pipe(webpack(require('./gulp/webpack.config.js')))
              .pipe(gulp.dest('script/dest/'))
              .pipe(connect.reload());
});

gulp.task('watch', function () {
   // livereload.listen();
   gulp.watch('less/**/*.less', ['less']);

   gulp.watch(['script/index.js', 'script/module/**/*.js'], ['webpack']);
});

gulp.task('webserver:dev', function() {
   connect.server({
      root: './',
      port: 8081,
      livereload: true
   });
});

gulp.task('webserver:deploy', function() {
   connect.server({
      root: './dist',
      port: 8081,
      livereload: false
   });
});

gulp.task('minifyHtml', function() {
   return gulp.src('html/*.html')
              .pipe(htmlmin({
                  minifyCSS: true,
                  minifyJS: true,
                  collapseWhitespace: false
               }))
              .pipe(gulp.dest('dist/html'));
});

gulp.task('clean', function (cb) {
   return del([
      'dist/**',
      'style/**',
      'script/dest/**',
   ], {force: true}, cb);
});

gulp.task('dev', function (done) {
   runSequence(
      ['clean'],
      ['sprite'],
      ['less'],
      ['webpack'],
      ['webserver:dev'],
      ['watch'],
   done);
});

gulp.task('deploy', function (done) {
   runSequence(
      ['clean'],
      ['sprite'],
      ['less'],
      ['webpack'],
      ['minifyHtml'],
      ['rev'],
      ['htmlReplace'],
      ['cssReplace'],
      // ['sftp:files'],
      // ['sftp:upload'],
      ['webserver:deploy'],
   done);
});

gulp.task('rev', function(){
   var cssFilter = filter('**/*.css', { restore: true });
   var jsFilter = filter('**/*.js', { restore: true });
   var imageFilter = filter('**/*.png', { restore: true });

   return gulp.src(['style/**/*', 'script/dest/**/*', 'image/page/**/*', 'image/sprites/**/*'], {base: '.'})
              .pipe(cssFilter)
              // .pipe(print())
              .pipe(cssmin())
              .pipe(cssFilter.restore)
              .pipe(jsFilter)
              .pipe(uglify())
              .pipe(jsFilter.restore)
              .pipe(imageFilter)
              .pipe(imagemin())
              .pipe(imageFilter.restore)
              .pipe(rev())
              .pipe(gulp.dest('dist'))
              .pipe(rev.manifest())
              .pipe(gulp.dest('dist'))
});

gulp.task('htmlReplace', function(){
  var manifest = gulp.src('./dist/rev-manifest.json');

  return gulp.src('./dist/html/**/*.html', {base: '.'})
             .pipe(revReplace({manifest: manifest}))
             // .pipe(prefix(cdnPath, null, '{{'))
             .pipe(replace(/([href|src]+?\=[\"\'])(\.\.)(\/[script|style|image]+)/gi, function ($0, $1, $2, $3) {
                return $1 + cdnPath + $3;
             }))
             .pipe(gulp.dest('./'));
});

gulp.task('cssReplace', function(){
  var manifest = gulp.src('./dist/rev-manifest.json');

  return gulp.src(['./dist/style/**/*.css'], {base: '.'})
             .pipe(revReplace({manifest: manifest}))
             .pipe(replace('/image/', cdnPath + '/image/'))
             .pipe(gulp.dest('./'));
});

var sftpFiles = [];

gulp.task('sftp:files', function(cb){
   return gulp.src(['./dist/style/**', './dist/script/**', './dist/image/**'])
               .pipe(through.obj(function(file, encode, cb) {
                  if (!file.isNull()) {
                     // console.log('--------------------------------------------');
                     // console.log(slash(path.relative(path.resolve(process.cwd(), 'dist'), file.path)));
                     sftpFiles.push(slash(path.relative(path.resolve(process.cwd(), 'dist'), file.path)))
                  }
                  cb(null, file, encode);
               }));
});

gulp.task('sftp:upload', function(cb){
   var ftp = new Ftp();
   var ftpFiles = [];

   ftp.on('ready', function() {
      gutil.log('[INFO] ftp connect ready!!!!');
      ftp.cwd(projectDirPath, function (err) {
         if (err) {
            gutil.log('[INFO] ftp mkdir ' + projectDirPath.green);
            ftp.mkdir(projectDirPath, true, function() {
               startFtp();
            });
         } else {
            startFtp();
         }
      });
   });

   function startFtp() {
      gutil.log('[INFO] ftp start!!!!');
      var walkInto = function (src, callback) {
         gutil.log('[INFO] ftp list src = ' + src);
         ftp.list(src, function (err, files) {
            var pending = files.length;
            if (!pending) return callback();
            files.forEach(function (item) {
               var filePath = src + item.name;
               if (item.type === 'd') {
                  filePath = filePath + '/';
                  walkInto(filePath, function(err, res){
                     if (!--pending) {
                        callback();
                     }
                  });
               } else {
                  ftpFiles.push(filePath.replace(projectDirPath + '/', ''));
                  if (!--pending) {
                     callback();
                  }
               }
            });
         });
      };

      walkInto(projectDirPath + '/', function () {
         var newFiles = sftpFiles.filter(function (file) {
            var flag = true;

            if (ftpFiles.indexOf(file) !== -1) {
               flag = false;
            }
            return flag;
         });
         uploadFiles(newFiles);
      });
   }

   function uploadFiles(newFiles) {
      gutil.log('[INFO] ftp uploading!!!!');
      var i = 0;

      var filesLength = newFiles.length;
      if (newFiles.length != 0) {
         gutil.log("[INFO]" + new String(filesLength) + " 个文件需要上传.");
         newFiles.forEach(function(file) {
            var destPath = projectDirPath + file;
            ftp.mkdir(destPath.match(/(.*)\/.*/)[1], true, function() {
               ftp.put(file, destPath, function(err) {
                  if (err) {
                     gutil.log(err);
                  }
                  i++;
                  gutil.log('[INFO] File ' + destPath.cyan + ' uploaded.' + ' 还有 ' + new String(filesLength - i).cyan + ' 个文件需要上传.');
                  if (i == filesLength) {
                     ftp.end();
                     gutil.log('upload Done!'.green)
                     cb();
                  }
               });
            })
         });
      } else {
         gutil.log('[INFO] no file to upload!'.green)
         ftp.end();
         cb();
      }
   };

   Pem.createCertificate({}, function(err, keys) {
      if (err) {
         gutil.log(err)
      }
      keys = keys || {};

      var options = packageJson.sftp;

      ftp.connect({
         host: options.auth.host,
         port: options.auth.port,
         user: options.auth.user.username,
         password: options.auth.user.password,
         secure: options.auth.secure,
         secureOptions: {
            key: undefined,
            cert: undefined,
            requestCert: true,
            rejectUnauthorized: false
         }
      });
   });
});

gulp.task('default', function() {
   // 将你的默认的任务代码放在这
   console.log('default task');
});