Demo for query storing
Change-Id: I947bcac841992c3f6cfd01ab337c265b0d01cb70
diff --git a/node_modules/grunt-contrib-watch/tasks/watch.js b/node_modules/grunt-contrib-watch/tasks/watch.js
new file mode 100644
index 0000000..8a8f8b3
--- /dev/null
+++ b/node_modules/grunt-contrib-watch/tasks/watch.js
@@ -0,0 +1,191 @@
+/*
+ * grunt-contrib-watch
+ * http://gruntjs.com/
+ *
+ * Copyright (c) 2018 "Cowboy" Ben Alman, contributors
+ * Licensed under the MIT license.
+ */
+
+'use strict';
+
+var path = require('path');
+var Gaze = require('gaze').Gaze;
+var _ = require('lodash');
+var waiting = 'Waiting...';
+var changedFiles = Object.create(null);
+var watchers = [];
+
+module.exports = function(grunt) {
+
+ var taskrun = require('./lib/taskrunner')(grunt);
+
+ // Default date format logged
+ var dateFormat = function(time) {
+ grunt.log.writeln(String(
+ 'Completed in ' +
+ time.toFixed(3) +
+ 's at ' +
+ (new Date()).toString()
+ ).cyan + ' - ' + waiting);
+ };
+
+ // When task runner has started
+ taskrun.on('start', function() {
+ Object.keys(changedFiles).forEach(function(filepath) {
+ // Log which file has changed, and how.
+ grunt.log.ok('File "' + filepath + '" ' + changedFiles[filepath] + '.');
+ });
+ // Reset changedFiles
+ changedFiles = Object.create(null);
+ });
+
+ // When task runner has ended
+ taskrun.on('end', function(time) {
+ if (time > 0) {
+ dateFormat(time);
+ }
+ });
+
+ // When a task run has been interrupted
+ taskrun.on('interrupt', function() {
+ grunt.log.writeln('').write('Scheduled tasks have been interrupted...'.yellow);
+ });
+
+ // When taskrun is reloaded
+ taskrun.on('reload', function() {
+ taskrun.clearRequireCache(Object.keys(changedFiles));
+ grunt.log.writeln('').writeln('Reloading watch config...'.cyan);
+ });
+
+ grunt.registerTask('watch', 'Run predefined tasks whenever watched files change.', function(target) {
+ var self = this;
+ var name = self.name || 'watch';
+
+ // Close any previously opened watchers
+ watchers.forEach(function(watcher) {
+ watcher.close();
+ });
+ watchers = [];
+
+ // Never gonna give you up, never gonna let you down
+ if (grunt.config([name, 'options', 'forever']) !== false) {
+ taskrun.forever();
+ }
+
+ // If a custom dateFormat function
+ var df = grunt.config([name, 'options', 'dateFormat']);
+ if (typeof df === 'function') {
+ dateFormat = df;
+ }
+
+ if (taskrun.running === false) {
+ grunt.log.writeln(waiting);
+ }
+
+ // Initialize taskrun
+ var targets = taskrun.init(name, {target: target});
+
+ targets.forEach(function(target) {
+ if (typeof target.files === 'string') {
+ target.files = [target.files];
+ }
+
+ // Process into raw patterns
+ var patterns = _.chain(target.files).flatten().map(function(pattern) {
+ return grunt.config.process(pattern);
+ }).value();
+
+ // Validate the event option
+ if (typeof target.options.event === 'string') {
+ target.options.event = [target.options.event];
+ }
+
+ var eventCwd = process.cwd();
+ if (target.options.cwd && target.options.cwd.event) {
+ eventCwd = target.options.cwd.event;
+ }
+
+ // Set cwd if options.cwd.file is set
+ if (typeof target.options.cwd !== 'string' && target.options.cwd.files) {
+ target.options.cwd = target.options.cwd.files;
+ }
+
+ // Create watcher per target
+ watchers.push(new Gaze(patterns, target.options, function(err) {
+ if (err) {
+ if (typeof err === 'string') {
+ err = new Error(err);
+ }
+ grunt.log.writeln('ERROR'.red);
+ grunt.fatal(err);
+ return taskrun.done();
+ }
+
+ // Log all watched files with --verbose set
+ if (grunt.option('verbose')) {
+ var watched = this.watched();
+ Object.keys(watched).forEach(function(watchedDir) {
+ watched[watchedDir].forEach(function(watchedFile) {
+ grunt.log.writeln('Watching ' + path.relative(process.cwd(), watchedFile) + ' for changes.');
+ });
+ });
+ }
+
+ // On changed/added/deleted
+ this.on('all', function(status, filepath) {
+
+ // Skip events not specified
+ if (!_.includes(target.options.event, 'all') &&
+ !_.includes(target.options.event, status)) {
+ return;
+ }
+
+ filepath = path.relative(eventCwd, filepath);
+
+ // Skip empty filepaths
+ if (filepath === '') {
+ return;
+ }
+
+ // If Gruntfile.js changed, reload self task
+ if (target.options.reload || /gruntfile\.(js|coffee)/i.test(filepath)) {
+ taskrun.reload = true;
+ }
+
+ // Emit watch events if anyone is listening
+ if (grunt.event.listeners('watch').length > 0) {
+ grunt.event.emit('watch', status, filepath, target.name);
+ }
+
+ // Group changed files only for display
+ changedFiles[filepath] = status;
+
+ // Add changed files to the target
+ if (taskrun.targets[target.name]) {
+ if (!taskrun.targets[target.name].changedFiles) {
+ taskrun.targets[target.name].changedFiles = Object.create(null);
+ }
+ taskrun.targets[target.name].changedFiles[filepath] = status;
+ }
+
+ // Queue the target
+ if (taskrun.queue.indexOf(target.name) === -1) {
+ taskrun.queue.push(target.name);
+ }
+
+ // Run the tasks
+ taskrun.run();
+ });
+
+ // On watcher error
+ this.on('error', function(err) {
+ if (typeof err === 'string') {
+ err = new Error(err);
+ }
+ grunt.log.error(err.message);
+ });
+ }));
+ });
+
+ });
+};