var gulp = require('gulp');
var rename = require('gulp-rename');
var watch = require('gulp-watch');
var shell = require('gulp-shell');
var mergeStreams = require('event-stream').merge;
var connect = require('gulp-connect');
var clean = require('gulp-rimraf');
var runSequence = require('run-sequence');
var glob = require('glob');
var ejs = require('gulp-ejs');
var path = require('path');
var through2 = require('through2');

// import transpiler build tasks
var transpilerTasks = require('./tools/transpiler/gulp-tasks');
transpilerTasks.install(gulp);

var js2es5Options = {
  annotations: true, // parse annotations
  types: true, // parse types
  script: false, // parse as a module
  modules: 'register',
  typeAssertionModule: 'rtts_assert/rtts_assert',
  typeAssertions: true
};

var transpilerOptions = {
  annotations: true, // parse annotations
  types: true, // parse types
  script: false, // parse as a module
  outputLanguage: 'dart'
};

var gulpTraceur = require('./tools/transpiler/gulp-traceur');

function resolveModuleName(fileName) {
  var moduleName = fileName
    .replace(/.*\/modules\//, '')
    .replace(/\/src\//, '/')
    .replace(/\/lib\//, '/')
    .replace(/\/test\//, '/');
  return moduleName;
}


// ---------
// rtts-assert and traceur runtime

gulp.task('jsRuntime/build', function() {
  return createJsRuntimeTask(false);
});

function createJsRuntimeTask(isWatch) {
  var srcFn = isWatch ? watch : gulp.src.bind(gulp);
  var traceurRuntime = srcFn(gulpTraceur.RUNTIME_PATH)
    .pipe(gulp.dest('build/js'));
  return traceurRuntime;
}

// -----------------------
// modules
var sourceTypeConfigs = {
  dart: {
    compiler: function() {
      return gulpTraceur(transpilerOptions, resolveModuleName);
    },
    transpileSrc: ['modules/**/*.js'],
    htmlSrc: ['modules/*/src/**/*.html'],
    copySrc: ['modules/**/*.dart', 'modules/**/*.yaml'],
    outputDir: 'build/dart',
    outputExt: 'dart',
    mimeType: 'application/dart',
    postProcess: function(file, done) {
      if (file.path.match(/pubspec\.yaml/)) {
        console.log(file.path);
        shell.task(['pub get'], {
          cwd: path.dirname(file.path)
        })().on('end', done);
      } else {
        done();
      }
    }
  },
  js: {
    compiler: function() {
      return gulpTraceur(js2es5Options, resolveModuleName);
    },
    transpileSrc: ['modules/**/*.js', 'modules/**/*.es6'],
    htmlSrc: ['modules/*/src/**/*.html'],
    copySrc: ['modules/**/*.es5'],
    outputDir: 'build/js',
    outputExt: 'js',
    postProcess: function() {

    }
  }
};


gulp.task('modules/clean', function() {
  return gulp.src('build', {read: false})
      .pipe(clean());
});

gulp.task('modules/build.dart/src', function() {
  return createModuleTask(sourceTypeConfigs.dart, false);
});

gulp.task('modules/build.dart/analyzer', function() {
  var baseDir = sourceTypeConfigs.dart.outputDir;
  var files = [].slice.call(glob.sync('*/lib/*.dart', {
    cwd: baseDir
  }));
  files = files.filter(function(fileName) {
    return fileName.match(/(\w+)\/lib\/\1/);
  });
  var commands = files.map(function(fileName) {
    return 'dartanalyzer '+baseDir+'/'+fileName
  });
  return shell.task(commands)();
});

gulp.task('modules/build.dart', function(done) {
  runSequence('modules/build.dart/src', 'modules/build.dart/analyzer', done);
});

gulp.task('modules/build.js', function() {
  return createModuleTask(sourceTypeConfigs.js, false);
});

function renameSrcToLib(file) {
  file.dirname = file.dirname.replace(/\bsrc\b/, 'lib');
}

function createModuleTask(sourceTypeConfig, isWatch) {
  var start = isWatch ? watch : gulp.src.bind(gulp);
  var transpile = start(sourceTypeConfig.transpileSrc)
    .pipe(rename({extname: '.'+sourceTypeConfig.outputExt}))
    .pipe(rename(renameSrcToLib))
    .pipe(sourceTypeConfig.compiler())
    .pipe(gulp.dest(sourceTypeConfig.outputDir));
  var copy = start(sourceTypeConfig.copySrc)
    .pipe(rename(renameSrcToLib))
    .pipe(gulp.dest(sourceTypeConfig.outputDir));
  // TODO: provide the list of files to the template
  // automatically!
  var html = start(sourceTypeConfig.htmlSrc)
    .pipe(rename(renameSrcToLib))
    .pipe(ejs({
      type: sourceTypeConfig.outputExt
    }))
    .pipe(gulp.dest(sourceTypeConfig.outputDir));

  var s = mergeStreams(transpile, copy, html);
  return s.pipe(through2.obj(function(file, enc, done) {
    sourceTypeConfig.postProcess(file, done);
  }));
}

// ------------------
// WEB SERVER
gulp.task('serve', connect.server({
  root: [__dirname+'/build'],
  port: 8000,
  livereload: false,
  open: false,
  middleware: function() {
    return [function(req, resp, next){
      if (req.url.match(/\.dart$/)) {
        resp.setHeader("Content-Type", "application/dart");
      }
      next();
    }];
  }
}));

// --------------
// general targets

gulp.task('clean', ['transpiler/clean', 'modules/clean']);

gulp.task('build', ['jsRuntime/build', 'modules/build.dart', 'modules/build.js']);

gulp.task('watch', function() {
  // parallel is important as both streams are infinite!
  runSequence(['transpiler/test/watch', 'transpiler/src/watch']);
  var dartModuleWatch = createModuleTask(sourceTypeConfigs.dart, true);
  var jsModuleWatch = createModuleTask(sourceTypeConfigs.js, true);
  return mergeStreams(dartModuleWatch, jsModuleWatch, createJsRuntimeTask(true));
});