index.js

var through = require('through2');
var gutil = require('gulp-util');
var path = require('path');

var csvjson = require('./lib/index');

var extendOptions = function(optionsObject) {
	var defaultOptions = {
		parserOptions: {
			auto_parse: true
		},
		processValue: function(key, value) {
			if (key !== '') {
				return value;
			}
		}
	};

	if (typeof optionsObject !== 'object') {
		return defaultOptions;
	}

	for (var k in optionsObject) {
		defaultOptions[k] = optionsObject[k];
	}
	return defaultOptions;
};

module.exports = function(options) {
	options = extendOptions(options);

	return through.obj(function(file, enc, cb) {

		if (file.isNull()) {
			return cb(null, file);
		}

		if (file.isStream()) {
			return cb(new gutil.PluginError('gulp-csv2json', 'Streaming not supported'));
		}

		if (['.csv'].indexOf(path.extname(file.path)) === -1) {
			gutil.log('gulp-csv-to-json: Skipping unsupported csv ' + gutil.colors.blue(file.relative));
			return cb(null, file);
		}


		csvjson.process(file.contents, options, function(err, sets) {
			sets.forEach(function(set) {
				
				file.contents = new Buffer(JSON.stringify(set.data), 'utf8');
				file.path = gutil.replaceExtension(file.path, '.json');

				cb(null, file);
			});
		});	
	});
};