Using search-index with Gulp.js

addTopicToStream.js

const through = require('through2');
const uuidV4 = require('uuid/v4');

module.exports = () => {
    return through.obj(function (file, encoding, next) {

        this.push({
            id: uuidV4(),
            body: file.contents.toString(encoding)
        });

        next();
    });
};

gulp-db.js

const searchIndex = require('search-index');
const args = require('yargs')
				.usage('gulp db --dbpath PATH_TO_DATABASE --src PATH_TO_FILES_TO_ADD_TO_DATABASE')
				.demand(['dbpath', 'src'])
				.argv;

// gulp db --dbpath "./_db/topics" --src "C:\topics\*.txt"

module.exports.registerTask = (gulp) => {

	gulp.task('db', (done) => {

		const options = { indexPath: args.dbpath };

		searchIndex(options, (openDatabaseError, index) => {

			if (openDatabaseError) {
				console.log(`Error: ${openDatabaseError}`);
				return;
			}

			const addTopicToStream = require('./addTopicToStream.js');

			gulp.src(args.src)
				.on('error', (e) => console.log(e))
				.pipe(addTopicToStream())
				.pipe(index.defaultPipeline())
				.pipe(index.add())
				.on('data', (data) => { console.log(data); })
				.on('end', done);
		});
	});
};

gulpfile.js

const gulp = require('gulp');

require('./gulp/gulp-db.js').registerTask(gulp);

package.json

{
  "dependencies": {
    "gulp": "^3.9.1",
    "search-index": "^0.9.5",
    "through2": "^2.0.3",
    "uuid": "^3.0.1",
    "yargs": "^6.4.0"
  }
}