'use strict';

var combined = require('combined-stream'),
    gulp     = require('gulp'),
    gutil    = require('gulp-util'),
    spigot   = require('stream-spigot'),
    defaults = require('lodash.defaults'),
    flatten  = require('lodash.flatten'),
    through  = require('through2'),
    path     = require('path'),
    fs       = require('fs');

/**
 * Create a gulp.src() method that emits the bower main files and optional version manifest.
 * @param {{pattern:string, base:boolean, manifest:boolean, dev:boolean}} Options
 */
module.exports = function create(options) {
  defaults(options, {
    pattern : '*',
    base    : false,
    manifest: false,
    dev     : false
  });

  /**
   * Get a gulp.src() stream for the bower main files.
   * @param {object} options Options for <code>gulp.src()</code> stream
   */
  return function src(gulpSrcOptions) {

    // create result list
    var parsed        = json(options.dev, options.context),
        manifestFile  = !!options.manifest && manifest((options.manifest === 'comment'), options.dev),
        bowerPackages = [];
    for (var packageName in parsed) {
      var config = parsed[packageName],
          list   = []
            .concat(config.main)
            .filter(Boolean)
            .map(toAbsoluteForPackage(packageName))
            .filter(testExtension);
      if (list.length) {
        var base = list.reduce(greatestCommonBase, null);
        bowerPackages.push({
          name   : packageName,
          options: defaults({base: base || options.base}, gulpSrcOptions),  // use our base over that given
          list   : list
        });
      }
    }

    // represent list as a readable stream, even if empty
    var stream;

    //  degenerate stream
    if (!bowerPackages.length) {
      stream = spigot({objectMode: true}, []);
      stream._read = function () {
      };
      stream.push(null);
    }
    //  combination of source streams with specific base path for each package
    else {
      stream = combined.create();
      if (manifestFile) {
        stream.append(manifestFile);
      }
      bowerPackages.reduce(eachPackage, stream);
    }

    // add the list to the stream as a sidecar
    stream.list = flatten(bowerPackages);

    // complete
    return stream;
  };

  function greatestCommonBase(candidate, absolute) {
    if (candidate) {
      var i = 0;
      while (candidate[i] === absolute[i]) {
        i++;
      }
      return candidate.slice(0, i);
    } else if (options.base === true) {
      return path.dirname(absolute);
    } else {
      return null;
    }
  }

  function eachPackage(stream, bowerPackage) {
    return stream.append(
      gulp.src(bowerPackage.list, bowerPackage.options)
        .pipe(through.obj(transform))
    );

    function transform(file, encoding, done) {
      /* jshint validthis:true */
      if ((options.base === true) && (bowerPackage.name)) {
        file.path = path.join(file.base, bowerPackage.name, file.relative);
      }
      this.push(file);
      done();
    }
  }

  function testExtension(filename) {
    var pattern = options.pattern,
        ext     = path.extname(filename).slice(1);
    return (
      ((typeof pattern === 'string') && (pattern.split('|').indexOf(ext) >= 0)) ||
      ((typeof pattern === 'object') && ('test' in pattern) && pattern.test(ext)) ||
      (pattern === '*')
    );
  }
};

function toAbsoluteForPackage(packageName) {
  return function toAbsolute(relative) {
    return path.resolve(path.join('bower_components', packageName, ''), relative);
  };
}

/**
 * Retrieve version details of bower files as a stream.
 * @param {boolean} includeDev Determines whether dev dependencies are included
 * @param {string} context Key used to determine overrides
 * @returns {stream.Readable} A readable stream containing only the manifest file
 */
function json(includeDev, context) {
  var root     = read('bower.json'),
      packages = reduceJsonToPackages(root, includeDev);
  return processOverrides(packages, root.overrides);

  function read(filename) {
    try {
      return fs.existsSync(filename) && require(path.resolve(filename));
    } catch (error) {
      gutil.log('Error parsing bower.json at ' + filename);
    }
  }

  function reduceJsonToPackages(json, includeDev) {
    var isValid      = (json && (typeof json === 'object')),
        dependencies = isValid && defaults(json.dependencies, includeDev && json.devDependencies) || {};
    return Object.keys(dependencies)
      .reduce(reduceDependencies, {});

    function reduceDependencies(result, packageName) {
      var contents = read(path.join('bower_components', packageName, 'bower.json'));
      defaults(result, reduceJsonToPackages(contents, false));  // current items' dependencies precede the current item
      result[packageName] = contents;
      return result;
    }
  }

  function processOverrides(packages, overrides) {
    return Object.keys(packages)
      .reduce(reducePackages, {});

    function reducePackages(result, packageName) {
      var item     = packages[packageName],
          override = overrides[packageName + '.' + context] || overrides[packageName];
      result[packageName] = defaults({}, override, item);
      return result;
    }
  }
}

/**
 * Retrieve version details of bower files as a stream.
 * @param {boolean} useComment Determines whether the output is wrapped in a comment
 * @param {boolean} includeDev Determines whether dev dependencies are included
 * @returns {stream.Readable} A readable stream containing only the manifest file
 */
function manifest(useComment, includeDev) {
  var bower    = json(includeDev),
      versions = {};
  for (var key in bower) {
    versions[key] = bower[key].version;
  }
  var text      = JSON.stringify(versions, null, 2),
      commented = (useComment) ? ['/*', text, '*/'].join('\n') : text,
      cwd       = process.cwd();
  return spigot({objectMode: true}, [
    new gutil.File({
      cwd     : cwd,
      base    : cwd,
      path    : path.join(cwd, 'manifest.json'),
      contents: new Buffer(commented)
    })
  ]);
}
@@ -4903,32 +4903,44 @@
 es) %7B%0A    return
+ overrides ?
  Object.keys(pac
@@ -4945,23 +4945,16 @@
 ackages)
-%0A      
 .reduce(
@@ -4968,24 +4968,35 @@
 ackages, %7B%7D)
+ : packages
 ;%0A%0A    funct
@@ -5101,16 +5101,27 @@
 erride =
+ context &&
  overrid

fix case where no `overrides` exist