New Case Study:See how Anthropic automated 95% of dependency reviews with Socket.Learn More →
Socket
Sign inDemoInstall
Socket
Sign inDemoInstall

nuclide-watchman-helpers

Package Overview
Dependencies
Maintainers
4
Versions
29
Alerts
File Explorer

Advanced tools

License
Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

nuclide-watchman-helpers - npm Package Compare versions

Comparing version 0.0.35 to 0.5.0

lib/path.js
PATENTS

63

lib/main.js

@@ -1,55 +0,18 @@

/*
* Copyright (c) 2015-present, Facebook, Inc.
/**
* Copyright (c) 2017-present, Facebook, Inc.
* All rights reserved.
*
* This source code is licensed under the license found in the LICENSE file in
* the root directory of this source tree.
* This source code is licensed under the BSD-style license found in the
* LICENSE file in the root directory of this source tree. An additional grant
* of patent rights can be found in the PATENTS file in the same directory.
*
* @flow
* @format
*/
var getWatchmanBinaryPath = _asyncToGenerator(function* () {
try {
var stats = yield fsPromise.stat(WATCHMAN_DEFAULT_PATH);
// `stats` contains a `mode` property, a number which can be used to determine
// whether this file is executable. However, the number is platform-dependent.
if (stats && stats.isFile()) {
return WATCHMAN_DEFAULT_PATH;
}
} catch (e) {}
// Suppress the error.
import type {FileChange} from './WatchmanClient';
import WatchmanClient from './WatchmanClient';
import WatchmanSubscription from './WatchmanSubscription';
// Let the watchman Client find the watchman binary via the default env PATH.
return 'watchman';
});
function _asyncToGenerator(fn) { return function () { var gen = fn.apply(this, arguments); return new Promise(function (resolve, reject) { var callNext = step.bind(null, 'next'); var callThrow = step.bind(null, 'throw'); function step(key, arg) { try { var info = gen[key](arg); var value = info.value; } catch (error) { reject(error); return; } if (info.done) { resolve(value); } else { Promise.resolve(value).then(callNext, callThrow); } } callNext(); }); }; }
var _require = require('nuclide-commons');
var fsPromise = _require.fsPromise;
var WATCHMAN_DEFAULT_PATH = '/usr/local/bin/watchman';
module.exports = Object.defineProperties({
getWatchmanBinaryPath: getWatchmanBinaryPath
}, {
WatchmanClient: {
get: function get() {
return require('./WatchmanClient');
},
configurable: true,
enumerable: true
},
WatchmanSubscription: {
// Exposed for testing.
get: function get() {
return require('./WatchmanSubscription');
},
configurable: true,
enumerable: true
}
});
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJzb3VyY2VzIjpbIi92YXIvZm9sZGVycy94Zi9yc3BoNF9jNTczMTVyczU3eHhzZHNrcnhudjM2dDAvVC90bXBwZmw1Mm5wdWJsaXNoX3BhY2thZ2VzL25wbS9udWNsaWRlLXdhdGNobWFuLWhlbHBlcnMvbGliL21haW4uanMiXSwibmFtZXMiOltdLCJtYXBwaW5ncyI6IkFBQUEsV0FBVyxDQUFDOzs7Ozs7Ozs7O0lBZUcscUJBQXFCLHFCQUFwQyxhQUF3RDtBQUN0RCxNQUFJO0FBQ0YsUUFBTSxLQUFLLEdBQUcsTUFBTSxTQUFTLENBQUMsSUFBSSxDQUFDLHFCQUFxQixDQUFDLENBQUM7OztBQUcxRCxRQUFJLEtBQUssSUFBSSxLQUFLLENBQUMsTUFBTSxFQUFFLEVBQUU7QUFDM0IsYUFBTyxxQkFBcUIsQ0FBQztLQUM5QjtHQUNGLENBQUMsT0FBTyxDQUFDLEVBQUUsRUFFWDs7OztBQUFBLEFBRUQsU0FBTyxVQUFVLENBQUM7Q0FDbkI7Ozs7ZUFqQm1CLE9BQU8sQ0FBQyxpQkFBaUIsQ0FBQzs7SUFBdkMsU0FBUyxZQUFULFNBQVM7O0FBRWhCLElBQU0scUJBQXFCLEdBQUcseUJBQXlCLENBQUM7O0FBaUJ4RCxNQUFNLENBQUMsT0FBTywyQkFBRztBQUNmLHVCQUFxQixFQUFyQixxQkFBcUI7O0NBVXRCO0FBUkssZ0JBQWM7U0FBQSxlQUFHO0FBQ25CLGFBQU8sT0FBTyxDQUFDLGtCQUFrQixDQUFDLENBQUM7S0FDcEM7Ozs7QUFHRyxzQkFBb0I7Ozs7U0FBQSxlQUFHO0FBQ3pCLGFBQU8sT0FBTyxDQUFDLHdCQUF3QixDQUFDLENBQUM7S0FDMUM7Ozs7RUFDRixDQUFDIiwiZmlsZSI6Ii92YXIvZm9sZGVycy94Zi9yc3BoNF9jNTczMTVyczU3eHhzZHNrcnhudjM2dDAvVC90bXBwZmw1Mm5wdWJsaXNoX3BhY2thZ2VzL25wbS9udWNsaWRlLXdhdGNobWFuLWhlbHBlcnMvbGliL21haW4uanMiLCJzb3VyY2VzQ29udGVudCI6WyIndXNlIGJhYmVsJztcbi8qIEBmbG93ICovXG5cbi8qXG4gKiBDb3B5cmlnaHQgKGMpIDIwMTUtcHJlc2VudCwgRmFjZWJvb2ssIEluYy5cbiAqIEFsbCByaWdodHMgcmVzZXJ2ZWQuXG4gKlxuICogVGhpcyBzb3VyY2UgY29kZSBpcyBsaWNlbnNlZCB1bmRlciB0aGUgbGljZW5zZSBmb3VuZCBpbiB0aGUgTElDRU5TRSBmaWxlIGluXG4gKiB0aGUgcm9vdCBkaXJlY3Rvcnkgb2YgdGhpcyBzb3VyY2UgdHJlZS5cbiAqL1xuXG5jb25zdCB7ZnNQcm9taXNlfSA9IHJlcXVpcmUoJ251Y2xpZGUtY29tbW9ucycpO1xuXG5jb25zdCBXQVRDSE1BTl9ERUZBVUxUX1BBVEggPSAnL3Vzci9sb2NhbC9iaW4vd2F0Y2htYW4nO1xuXG5hc3luYyBmdW5jdGlvbiBnZXRXYXRjaG1hbkJpbmFyeVBhdGgoKTogUHJvbWlzZTxzdHJpbmc+IHtcbiAgdHJ5IHtcbiAgICBjb25zdCBzdGF0cyA9IGF3YWl0IGZzUHJvbWlzZS5zdGF0KFdBVENITUFOX0RFRkFVTFRfUEFUSCk7XG4gICAgLy8gYHN0YXRzYCBjb250YWlucyBhIGBtb2RlYCBwcm9wZXJ0eSwgYSBudW1iZXIgd2hpY2ggY2FuIGJlIHVzZWQgdG8gZGV0ZXJtaW5lXG4gICAgLy8gd2hldGhlciB0aGlzIGZpbGUgaXMgZXhlY3V0YWJsZS4gSG93ZXZlciwgdGhlIG51bWJlciBpcyBwbGF0Zm9ybS1kZXBlbmRlbnQuXG4gICAgaWYgKHN0YXRzICYmIHN0YXRzLmlzRmlsZSgpKSB7XG4gICAgICByZXR1cm4gV0FUQ0hNQU5fREVGQVVMVF9QQVRIO1xuICAgIH1cbiAgfSBjYXRjaCAoZSkge1xuICAgIC8vIFN1cHByZXNzIHRoZSBlcnJvci5cbiAgfVxuICAvLyBMZXQgdGhlIHdhdGNobWFuIENsaWVudCBmaW5kIHRoZSB3YXRjaG1hbiBiaW5hcnkgdmlhIHRoZSBkZWZhdWx0IGVudiBQQVRILlxuICByZXR1cm4gJ3dhdGNobWFuJztcbn1cblxubW9kdWxlLmV4cG9ydHMgPSB7XG4gIGdldFdhdGNobWFuQmluYXJ5UGF0aCxcblxuICBnZXQgV2F0Y2htYW5DbGllbnQoKSB7XG4gICAgcmV0dXJuIHJlcXVpcmUoJy4vV2F0Y2htYW5DbGllbnQnKTtcbiAgfSxcblxuICAvLyBFeHBvc2VkIGZvciB0ZXN0aW5nLlxuICBnZXQgV2F0Y2htYW5TdWJzY3JpcHRpb24oKSB7XG4gICAgcmV0dXJuIHJlcXVpcmUoJy4vV2F0Y2htYW5TdWJzY3JpcHRpb24nKTtcbiAgfSxcbn07XG4iXX0=
export type {FileChange};
export {WatchmanClient, WatchmanSubscription};

520

lib/WatchmanClient.js

@@ -1,294 +0,302 @@

Object.defineProperty(exports, '__esModule', {
value: true
});
/**
* Copyright (c) 2017-present, Facebook, Inc.
* All rights reserved.
*
* This source code is licensed under the BSD-style license found in the
* LICENSE file in the root directory of this source tree. An additional grant
* of patent rights can be found in the PATENTS file in the same directory.
*
* @flow
* @format
*/
var _createClass = (function () { function defineProperties(target, props) { for (var i = 0; i < props.length; i++) { var descriptor = props[i]; descriptor.enumerable = descriptor.enumerable || false; descriptor.configurable = true; if ('value' in descriptor) descriptor.writable = true; Object.defineProperty(target, descriptor.key, descriptor); } } return function (Constructor, protoProps, staticProps) { if (protoProps) defineProperties(Constructor.prototype, protoProps); if (staticProps) defineProperties(Constructor, staticProps); return Constructor; }; })();
import nuclideUri from 'nuclide-commons/nuclideUri';
import watchman from 'fb-watchman';
import {serializeAsyncCall, sleep} from 'nuclide-commons/promise';
import {maybeToString} from 'nuclide-commons/string';
import {getWatchmanBinaryPath} from './path';
import WatchmanSubscription from './WatchmanSubscription';
import {getLogger} from 'log4js';
function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { 'default': obj }; }
const logger = getLogger('nuclide-watchman-helpers');
const WATCHMAN_SETTLE_TIME_MS = 2500;
function _asyncToGenerator(fn) { return function () { var gen = fn.apply(this, arguments); return new Promise(function (resolve, reject) { var callNext = step.bind(null, 'next'); var callThrow = step.bind(null, 'throw'); function step(key, arg) { try { var info = gen[key](arg); var value = info.value; } catch (error) { reject(error); return; } if (info.done) { resolve(value); } else { Promise.resolve(value).then(callNext, callThrow); } } callNext(); }); }; }
import type {WatchmanSubscriptionOptions} from './WatchmanSubscription';
function _classCallCheck(instance, Constructor) { if (!(instance instanceof Constructor)) { throw new TypeError('Cannot call a class as a function'); } }
type WatchmanSubscriptionResponse = {
root: string,
subscription: string,
files?: Array<FileChange>,
'state-enter'?: string,
'state-leave'?: string,
metadata?: Object,
canceled?: boolean,
};
var _WatchmanSubscription = require('./WatchmanSubscription');
export type FileChange = {
name: string,
new: boolean,
exists: boolean,
mode: number,
};
var _WatchmanSubscription2 = _interopRequireDefault(_WatchmanSubscription);
export default class WatchmanClient {
_subscriptions: Map<string, WatchmanSubscription>;
_clientPromise: Promise<watchman.Client>;
_serializedReconnect: () => Promise<void>;
'use babel';
constructor() {
this._initWatchmanClient();
this._serializedReconnect = serializeAsyncCall(() =>
this._reconnectClient(),
);
this._subscriptions = new Map();
}
/*
* Copyright (c) 2015-present, Facebook, Inc.
* All rights reserved.
*
* This source code is licensed under the license found in the LICENSE file in
* the root directory of this source tree.
*/
async dispose(): Promise<void> {
const client = await this._clientPromise;
client.removeAllListeners(); // disable reconnection
client.end();
}
var watchman = require('fb-watchman');
async _initWatchmanClient(): Promise<void> {
this._clientPromise = this._createClientPromise();
var isEmpty = require('nuclide-commons').object.isEmpty;
const client = await this._clientPromise;
client.on('end', () => {
logger.info('Watchman client ended');
client.removeAllListeners();
this._serializedReconnect();
});
client.on('error', error => {
logger.error('Error while talking to watchman: ', error);
// If Watchman encounters an error in the middle of a command, it may never finish!
// The client must be immediately killed here so that the command fails and
// `serializeAsyncCall` can be unblocked. Otherwise, we end up in a deadlock.
client.removeAllListeners();
client.end();
// Those are errors in deserializing a stream of changes.
// The only possible recovery here is reconnecting a new client,
// but the failed to serialize events will be missed.
// t9353878
this._serializedReconnect();
});
client.on('subscription', this._onSubscriptionResult.bind(this));
}
var logger = require('nuclide-logging').getLogger();
async _createClientPromise(): Promise<watchman.Client> {
return new watchman.Client({
watchmanBinaryPath: await getWatchmanBinaryPath(),
});
}
var _require = require('./main');
async _reconnectClient(): Promise<void> {
logger.error('Watchman client disconnected, reconnecting a new client!');
await this._initWatchmanClient();
logger.info('Watchman client re-initialized, restoring subscriptions');
await this._restoreSubscriptions();
}
var getWatchmanBinaryPath = _require.getWatchmanBinaryPath;
async _restoreSubscriptions(): Promise<void> {
const watchSubscriptions = Array.from(this._subscriptions.values());
await Promise.all(
watchSubscriptions.map(async (subscription: WatchmanSubscription) => {
await this._watchProject(subscription.path);
// We have already missed the change events from the disconnect time,
// watchman could have died, so the last clock result is not valid.
await sleep(WATCHMAN_SETTLE_TIME_MS);
// Register the subscriptions after the filesystem settles.
subscription.options.since = await this._clock(subscription.root);
await this._subscribe(
subscription.root,
subscription.name,
subscription.options,
);
}),
);
}
var path = require('path');
_getSubscription(entryPath: string): ?WatchmanSubscription {
return this._subscriptions.get(nuclideUri.normalize(entryPath));
}
var WatchmanClient = (function () {
function WatchmanClient() {
_classCallCheck(this, WatchmanClient);
_setSubscription(
entryPath: string,
subscription: WatchmanSubscription,
): void {
this._subscriptions.set(nuclideUri.normalize(entryPath), subscription);
}
this._initWatchmanClient();
this._subscriptions = Object.create(null);
this._watchmanVersionPromise = this.version();
_deleteSubscription(entryPath: string): void {
this._subscriptions.delete(nuclideUri.normalize(entryPath));
}
_createClass(WatchmanClient, [{
key: 'dispose',
value: function dispose() {
var _this = this;
return new Promise(function (resolve, reject) {
if (_this._clientPromise) {
_this._clientPromise.then(function (client) {
client.once('end', function () {
resolve();
});
client.end();
});
} else {
reject();
}
});
_onSubscriptionResult(response: WatchmanSubscriptionResponse): void {
const subscription = this._getSubscription(response.subscription);
if (subscription == null) {
logger.error('Subscription not found for response:!', response);
return;
}
}, {
key: '_initWatchmanClient',
value: function _initWatchmanClient() {
var _this2 = this;
this._clientPromise = this._createClientPromise();
this._clientPromise.then(function (client) {
client.on('end', function () {
return _this2._onClientEnd();
});
client.on('error', function (error) {
return logger.error('Error while talking to watchman: ', error);
});
client.on('subscription', function (response) {
return _this2._onSubscriptionResult(response);
});
});
if (!Array.isArray(response.files)) {
if (response.canceled === true) {
logger.info(`Watch for ${response.root} was deleted.`);
// Ending the client will trigger a reconnect.
this._clientPromise.then(client => client.end());
return;
}
// TODO(most): use state messages to decide on when to send updates.
const stateEnter = response['state-enter'];
const stateLeave = response['state-leave'];
const stateMessage =
stateEnter != null
? `Entering ${stateEnter}`
: `Leaving ${maybeToString(stateLeave)}`;
logger.info(`Subscription state: ${stateMessage}`);
return;
}
}, {
key: '_createClientPromise',
value: _asyncToGenerator(function* () {
return new watchman.Client({
watchmanBinaryPath: yield getWatchmanBinaryPath()
});
})
}, {
key: '_onClientEnd',
value: function _onClientEnd() {
logger.warn('Watchman client ended, creating a new client!');
this._clientPromise.then(function (client) {
client.removeAllListeners('end');
client.removeAllListeners('error');
client.removeAllListeners('subscription');
});
this._initWatchmanClient();
this._restoreSubscriptions();
}
}, {
key: '_restoreSubscriptions',
value: _asyncToGenerator(function* () {
var _this3 = this;
subscription.emit('change', response.files);
}
var watchSubscriptions = [];
for (var _key in this._subscriptions) {
watchSubscriptions.push(this._subscriptions[_key]);
async watchDirectoryRecursive(
localDirectoryPath: string,
subscriptionName?: string = localDirectoryPath,
subscriptionOptions?: WatchmanSubscriptionOptions,
): Promise<WatchmanSubscription> {
const existingSubscription = this._getSubscription(subscriptionName);
if (existingSubscription) {
existingSubscription.subscriptionCount++;
return existingSubscription;
} else {
const {
watch: watchRoot,
relative_path: relativePath,
} = await this._watchProject(localDirectoryPath);
const clock = await this._clock(watchRoot);
const options: WatchmanSubscriptionOptions = {
...subscriptionOptions,
fields: ['name', 'new', 'exists', 'mode'],
since: clock,
};
if (relativePath && !options.expression) {
options.relative_root = relativePath;
}
yield Promise.all(watchSubscriptions.map(_asyncToGenerator(function* (subscription) {
subscription.options.since = yield _this3._clock(subscription.root);
yield _this3._watchProject(subscription.path);
yield _this3._subscribe(subscription.root, subscription.name, subscription.options);
})));
})
}, {
key: '_getSubscription',
value: function _getSubscription(entryPath) {
return this._subscriptions[path.normalize(entryPath)];
}
}, {
key: '_setSubscription',
value: function _setSubscription(entryPath, subscription) {
this._subscriptions[path.normalize(entryPath)] = subscription;
// Try this thing out where we always set empty_on_fresh_instance. Eden will be a lot happier
// if we never ask Watchman to do something that results in a glob(**) near the root.
options.empty_on_fresh_instance = true;
// relativePath is undefined if watchRoot is the same as directoryPath.
const subscription = new WatchmanSubscription(
/* subscriptionRoot */ watchRoot,
/* pathFromSubscriptionRootToSubscriptionPath */ relativePath,
/* subscriptionPath */ localDirectoryPath,
/* subscriptionName */ subscriptionName,
/* subscriptionCount */ 1,
/* subscriptionOptions */ options,
);
this._setSubscription(subscriptionName, subscription);
await this._subscribe(watchRoot, subscriptionName, options);
return subscription;
}
}, {
key: '_deleteSubscription',
value: function _deleteSubscription(entryPath) {
delete this._subscriptions[path.normalize(entryPath)];
}
}, {
key: '_onSubscriptionResult',
value: function _onSubscriptionResult(response) {
var subscription = this._getSubscription(response.subscription);
if (!subscription) {
return logger.error('Subscription not found for response:!', response);
}
subscription.emit('change', response.files);
}
}, {
key: 'watchDirectoryRecursive',
value: _asyncToGenerator(function* (localDirectoryPath) {
var existingSubscription = this._getSubscription(localDirectoryPath);
if (existingSubscription) {
existingSubscription.subscriptionCount++;
return existingSubscription;
} else {
var _ref = yield this._watchProject(localDirectoryPath);
}
var watchRoot = _ref.watch;
var relativePath = _ref.relative_path;
hasSubscription(entryPath: string): boolean {
return Boolean(this._getSubscription(entryPath));
}
var clock = yield this._clock(watchRoot);
var options = {
fields: ['name', 'new', 'exists', 'mode'],
since: clock
};
if (relativePath) {
// Passing an 'undefined' expression causes an exception in fb-watchman.
options.expression = ['dirname', relativePath];
}
// relativePath is undefined if watchRoot is the same as directoryPath.
var _subscription = this._setSubscription(localDirectoryPath, new _WatchmanSubscription2['default'](
/*subscriptionRoot*/watchRoot,
/*pathFromSubscriptionRootToSubscriptionPath*/relativePath,
/*subscriptionPath*/localDirectoryPath,
/*subscriptionCount*/1,
/*subscriptionOptions*/options));
yield this._subscribe(watchRoot, localDirectoryPath, options);
return _subscription;
}
})
}, {
key: 'hasSubscription',
value: function hasSubscription(entryPath) {
return !!this._getSubscription(entryPath);
async unwatch(entryPath: string): Promise<void> {
const subscription = this._getSubscription(entryPath);
if (subscription == null) {
logger.error('No watcher entity found with path:', entryPath);
return;
}
}, {
key: 'unwatch',
value: _asyncToGenerator(function* (entryPath) {
var subscription = this._getSubscription(entryPath);
if (!subscription) {
return logger.error('No watcher entity found with path:', entryPath);
}
if (--subscription.subscriptionCount === 0) {
await this._unsubscribe(subscription.path, subscription.name);
this._deleteSubscription(entryPath);
}
}
if (--subscription.subscriptionCount === 0) {
/**
* List all (watched) files in the given directory.
* Paths will be relative.
*/
async listFiles(
entryPath: string,
options?: {[name: string]: any} = {},
): Promise<Array<string>> {
const {watch, relative_path} = await this._watchProject(entryPath);
const result = await this._command('query', watch, {
expression: [
'allof',
['type', 'f'], // all files
['exists'],
],
// Providing `path` will let watchman use path generator, and will perform
// a tree walk with respect to the relative_root and path provided.
// Path generator will do less work unless the root path of the repository
// is passed in as an entry path.
path: [''],
fields: ['name'], // names only
relative_root: relative_path,
...options,
});
return result.files;
}
yield this._unsubscribe(subscription.path, subscription.name);
// Don't delete the watcher if there are other users for it.
if (!subscription.pathFromSubscriptionRootToSubscriptionPath) {
yield this._deleteWatcher(entryPath);
}
this._deleteSubscription(entryPath);
async _watchList(): Promise<Array<string>> {
const {roots} = await this._command('watch-list');
return roots;
}
if (isEmpty(this._subscriptions)) {
yield this.dispose();
}
}
})
}, {
key: '_watchList',
value: _asyncToGenerator(function* () {
var _ref2 = yield this._command('watch-list');
_unsubscribe(
subscriptionPath: string,
subscriptionName: string,
): Promise<any> {
return this._command('unsubscribe', subscriptionPath, subscriptionName);
}
var roots = _ref2.roots;
return roots;
})
}, {
key: '_deleteWatcher',
value: function _deleteWatcher(entryPath) {
return this._command('watch-del', entryPath);
async _watch(directoryPath: string): Promise<any> {
const response = await this._command('watch', directoryPath);
if (response.warning) {
logger.error('watchman warning: ', response.warning);
}
}, {
key: '_unsubscribe',
value: function _unsubscribe(subscriptionPath, subscriptionName) {
return this._command('unsubscribe', subscriptionPath, subscriptionName);
}
}, {
key: '_watch',
value: _asyncToGenerator(function* (directoryPath) {
var response = yield this._command('watch', directoryPath);
if (response.warning) {
logger.warn('watchman warning: ', response.warning);
}
})
}, {
key: '_watchProject',
value: _asyncToGenerator(function* (directoryPath) {
var watchmanVersion = yield this._watchmanVersionPromise;
if (!watchmanVersion || watchmanVersion < '3.1.0') {
throw new Error('Watchman version: ' + watchmanVersion + ' does not support watch-project');
}
var response = yield this._command('watch-project', directoryPath);
if (response.warning) {
logger.warn('watchman warning: ', response.warning);
}
return response;
})
}, {
key: '_clock',
value: _asyncToGenerator(function* (directoryPath) {
var _ref3 = yield this._command('clock', directoryPath);
}
var clock = _ref3.clock;
return clock;
})
}, {
key: 'version',
value: _asyncToGenerator(function* () {
var _ref4 = yield this._command('version');
var version = _ref4.version;
return version;
})
}, {
key: '_subscribe',
value: function _subscribe(watchRoot, subscriptionName, options) {
return this._command('subscribe', watchRoot, subscriptionName, options);
async _watchProject(directoryPath: string): Promise<any> {
const response = await this._command('watch-project', directoryPath);
if (response.warning) {
logger.error('watchman warning: ', response.warning);
}
return response;
}
/*
* Promisify calls to watchman client.
*/
}, {
key: '_command',
value: function _command() {
var _this4 = this;
async _clock(directoryPath: string): Promise<string> {
const {clock} = await this._command('clock', directoryPath);
return clock;
}
for (var _len = arguments.length, args = Array(_len), _key2 = 0; _key2 < _len; _key2++) {
args[_key2] = arguments[_key2];
}
_subscribe(
watchRoot: string,
subscriptionName: ?string,
options: WatchmanSubscriptionOptions,
): Promise<WatchmanSubscription> {
return this._command('subscribe', watchRoot, subscriptionName, options);
}
return new Promise(function (resolve, reject) {
_this4._clientPromise.then(function (client) {
client.command(args, function (error, response) {
return error ? reject(error) : resolve(response);
});
})['catch'](reject);
});
}
}]);
return WatchmanClient;
})();
module.exports = WatchmanClient;
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJzb3VyY2VzIjpbIi92YXIvZm9sZGVycy94Zi9yc3BoNF9jNTczMTVyczU3eHhzZHNrcnhudjM2dDAvVC90bXBwZmw1Mm5wdWJsaXNoX3BhY2thZ2VzL25wbS9udWNsaWRlLXdhdGNobWFuLWhlbHBlcnMvbGliL1dhdGNobWFuQ2xpZW50LmpzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiI7Ozs7Ozs7Ozs7OztvQ0FrQmlDLHdCQUF3Qjs7OztBQWxCekQsV0FBVyxDQUFDOzs7Ozs7Ozs7O0FBV1osSUFBTSxRQUFRLEdBQUcsT0FBTyxDQUFDLGFBQWEsQ0FBQyxDQUFDOztJQUVqQyxPQUFPLEdBQUksT0FBTyxDQUFDLGlCQUFpQixDQUFDLENBQUMsTUFBTSxDQUE1QyxPQUFPOztBQUNkLElBQU0sTUFBTSxHQUFHLE9BQU8sQ0FBQyxpQkFBaUIsQ0FBQyxDQUFDLFNBQVMsRUFBRSxDQUFDOztlQUN0QixPQUFPLENBQUMsUUFBUSxDQUFDOztJQUExQyxxQkFBcUIsWUFBckIscUJBQXFCOztBQUM1QixJQUFNLElBQUksR0FBRyxPQUFPLENBQUMsTUFBTSxDQUFDLENBQUM7O0lBa0J2QixjQUFjO0FBSVAsV0FKUCxjQUFjLEdBSUo7MEJBSlYsY0FBYzs7QUFLaEIsUUFBSSxDQUFDLG1CQUFtQixFQUFFLENBQUM7QUFDM0IsUUFBSSxDQUFDLGNBQWMsR0FBRyxNQUFNLENBQUMsTUFBTSxDQUFDLElBQUksQ0FBQyxDQUFDO0FBQzFDLFFBQUksQ0FBQyx1QkFBdUIsR0FBRyxJQUFJLENBQUMsT0FBTyxFQUFFLENBQUM7R0FDL0M7O2VBUkcsY0FBYzs7V0FVWCxtQkFBWTs7O0FBQ2pCLGFBQU8sSUFBSSxPQUFPLENBQUMsVUFBQyxPQUFPLEVBQUUsTUFBTSxFQUFLO0FBQ3RDLFlBQUksTUFBSyxjQUFjLEVBQUU7QUFDdkIsZ0JBQUssY0FBYyxDQUFDLElBQUksQ0FBQyxVQUFBLE1BQU0sRUFBSTtBQUNqQyxrQkFBTSxDQUFDLElBQUksQ0FBQyxLQUFLLEVBQUUsWUFBTTtBQUN2QixxQkFBTyxFQUFFLENBQUM7YUFDWCxDQUFDLENBQUM7QUFDSCxrQkFBTSxDQUFDLEdBQUcsRUFBRSxDQUFDO1dBQ2QsQ0FBQyxDQUFDO1NBQ0osTUFBTTtBQUNMLGdCQUFNLEVBQUUsQ0FBQztTQUNWO09BQ0YsQ0FBQyxDQUFDO0tBQ0o7OztXQUVrQiwrQkFBRzs7O0FBQ3BCLFVBQUksQ0FBQyxjQUFjLEdBQUcsSUFBSSxDQUFDLG9CQUFvQixFQUFFLENBQUM7QUFDbEQsVUFBSSxDQUFDLGNBQWMsQ0FBQyxJQUFJLENBQUMsVUFBQSxNQUFNLEVBQUk7QUFDakMsY0FBTSxDQUFDLEVBQUUsQ0FBQyxLQUFLLEVBQUU7aUJBQU0sT0FBSyxZQUFZLEVBQUU7U0FBQSxDQUFDLENBQUM7QUFDNUMsY0FBTSxDQUFDLEVBQUUsQ0FBQyxPQUFPLEVBQUUsVUFBQSxLQUFLO2lCQUFJLE1BQU0sQ0FBQyxLQUFLLENBQUMsbUNBQW1DLEVBQUUsS0FBSyxDQUFDO1NBQUEsQ0FBQyxDQUFDO0FBQ3RGLGNBQU0sQ0FBQyxFQUFFLENBQUMsY0FBYyxFQUFFLFVBQUEsUUFBUTtpQkFBSSxPQUFLLHFCQUFxQixDQUFDLFFBQVEsQ0FBQztTQUFBLENBQUMsQ0FBQztPQUM3RSxDQUFDLENBQUM7S0FDSjs7OzZCQUV5QixhQUE2QjtBQUNyRCxhQUFPLElBQUksUUFBUSxDQUFDLE1BQU0sQ0FBQztBQUN6QiwwQkFBa0IsRUFBRSxNQUFNLHFCQUFxQixFQUFFO09BQ2xELENBQUMsQ0FBQztLQUNKOzs7V0FFVyx3QkFBRztBQUNiLFlBQU0sQ0FBQyxJQUFJLENBQUMsK0NBQStDLENBQUMsQ0FBQztBQUM3RCxVQUFJLENBQUMsY0FBYyxDQUFDLElBQUksQ0FBQyxVQUFBLE1BQU0sRUFBSTtBQUNqQyxjQUFNLENBQUMsa0JBQWtCLENBQUMsS0FBSyxDQUFDLENBQUM7QUFDakMsY0FBTSxDQUFDLGtCQUFrQixDQUFDLE9BQU8sQ0FBQyxDQUFDO0FBQ25DLGNBQU0sQ0FBQyxrQkFBa0IsQ0FBQyxjQUFjLENBQUMsQ0FBQztPQUMzQyxDQUFDLENBQUM7QUFDSCxVQUFJLENBQUMsbUJBQW1CLEVBQUUsQ0FBQztBQUMzQixVQUFJLENBQUMscUJBQXFCLEVBQUUsQ0FBQztLQUM5Qjs7OzZCQUUwQixhQUFZOzs7QUFDckMsVUFBTSxrQkFBK0MsR0FBRyxFQUFFLENBQUM7QUFDM0QsV0FBSyxJQUFNLElBQUcsSUFBSSxJQUFJLENBQUMsY0FBYyxFQUFFO0FBQ3JDLDBCQUFrQixDQUFDLElBQUksQ0FBQyxJQUFJLENBQUMsY0FBYyxDQUFDLElBQUcsQ0FBQyxDQUFDLENBQUM7T0FDbkQ7QUFDRCxZQUFNLE9BQU8sQ0FBQyxHQUFHLENBQUMsa0JBQWtCLENBQUMsR0FBRyxtQkFBQyxXQUFPLFlBQVksRUFBMkI7QUFDckYsb0JBQVksQ0FBQyxPQUFPLENBQUMsS0FBSyxHQUFHLE1BQU0sT0FBSyxNQUFNLENBQUMsWUFBWSxDQUFDLElBQUksQ0FBQyxDQUFDO0FBQ2xFLGNBQU0sT0FBSyxhQUFhLENBQUMsWUFBWSxDQUFDLElBQUksQ0FBQyxDQUFDO0FBQzVDLGNBQU0sT0FBSyxVQUFVLENBQUMsWUFBWSxDQUFDLElBQUksRUFBRSxZQUFZLENBQUMsSUFBSSxFQUFFLFlBQVksQ0FBQyxPQUFPLENBQUMsQ0FBQztPQUNuRixFQUFDLENBQUMsQ0FBQztLQUNMOzs7V0FFZSwwQkFBQyxTQUFpQixFQUF5QjtBQUN6RCxhQUFPLElBQUksQ0FBQyxjQUFjLENBQUMsSUFBSSxDQUFDLFNBQVMsQ0FBQyxTQUFTLENBQUMsQ0FBQyxDQUFDO0tBQ3ZEOzs7V0FFZSwwQkFBQyxTQUFpQixFQUFFLFlBQWtDLEVBQXdCO0FBQzVGLFVBQUksQ0FBQyxjQUFjLENBQUMsSUFBSSxDQUFDLFNBQVMsQ0FBQyxTQUFTLENBQUMsQ0FBQyxHQUFHLFlBQVksQ0FBQztBQUM5RCxhQUFPLFlBQVksQ0FBQztLQUNyQjs7O1dBRWtCLDZCQUFDLFNBQWlCLEVBQVE7QUFDM0MsYUFBTyxJQUFJLENBQUMsY0FBYyxDQUFDLElBQUksQ0FBQyxTQUFTLENBQUMsU0FBUyxDQUFDLENBQUMsQ0FBQztLQUN2RDs7O1dBRW9CLCtCQUFDLFFBQXNDLEVBQUU7QUFDNUQsVUFBTSxZQUFZLEdBQUcsSUFBSSxDQUFDLGdCQUFnQixDQUFDLFFBQVEsQ0FBQyxZQUFZLENBQUMsQ0FBQztBQUNsRSxVQUFJLENBQUMsWUFBWSxFQUFFO0FBQ2pCLGVBQU8sTUFBTSxDQUFDLEtBQUssQ0FBQyx1Q0FBdUMsRUFBRSxRQUFRLENBQUMsQ0FBQztPQUN4RTtBQUNELGtCQUFZLENBQUMsSUFBSSxDQUFDLFFBQVEsRUFBRSxRQUFRLENBQUMsS0FBSyxDQUFDLENBQUM7S0FDN0M7Ozs2QkFFNEIsV0FBQyxrQkFBMEIsRUFBa0M7QUFDeEYsVUFBTSxvQkFBb0IsR0FBRyxJQUFJLENBQUMsZ0JBQWdCLENBQUMsa0JBQWtCLENBQUMsQ0FBQztBQUN2RSxVQUFJLG9CQUFvQixFQUFFO0FBQ3hCLDRCQUFvQixDQUFDLGlCQUFpQixFQUFFLENBQUM7QUFDekMsZUFBTyxvQkFBb0IsQ0FBQztPQUM3QixNQUFNO21CQUNtRCxNQUFNLElBQUksQ0FBQyxhQUFhLENBQUMsa0JBQWtCLENBQUM7O1lBQXRGLFNBQVMsUUFBaEIsS0FBSztZQUE0QixZQUFZLFFBQTNCLGFBQWE7O0FBQ3RDLFlBQU0sS0FBSyxHQUFHLE1BQU0sSUFBSSxDQUFDLE1BQU0sQ0FBQyxTQUFTLENBQUMsQ0FBQztBQUMzQyxZQUFNLE9BQW9DLEdBQUc7QUFDM0MsZ0JBQU0sRUFBRSxDQUFDLE1BQU0sRUFBRSxLQUFLLEVBQUUsUUFBUSxFQUFFLE1BQU0sQ0FBQztBQUN6QyxlQUFLLEVBQUUsS0FBSztTQUNiLENBQUM7QUFDRixZQUFJLFlBQVksRUFBRTs7QUFFaEIsaUJBQU8sQ0FBQyxVQUFVLEdBQUcsQ0FBQyxTQUFTLEVBQUUsWUFBWSxDQUFDLENBQUM7U0FDaEQ7O0FBRUQsWUFBTSxhQUFZLEdBQUcsSUFBSSxDQUFDLGdCQUFnQixDQUFDLGtCQUFrQixFQUN6RDs0QkFDdUIsU0FBUztzREFDaUIsWUFBWTs0QkFDdEMsa0JBQWtCOzZCQUNqQixDQUFDOytCQUNDLE9BQU8sQ0FDaEMsQ0FBQyxDQUFDO0FBQ1AsY0FBTSxJQUFJLENBQUMsVUFBVSxDQUFDLFNBQVMsRUFBRSxrQkFBa0IsRUFBRSxPQUFPLENBQUMsQ0FBQztBQUM5RCxlQUFPLGFBQVksQ0FBQztPQUNyQjtLQUNGOzs7V0FFYyx5QkFBQyxTQUFpQixFQUFXO0FBQzFDLGFBQU8sQ0FBQyxDQUFDLElBQUksQ0FBQyxnQkFBZ0IsQ0FBQyxTQUFTLENBQUMsQ0FBQztLQUMzQzs7OzZCQUVZLFdBQUMsU0FBaUIsRUFBVztBQUN4QyxVQUFNLFlBQVksR0FBRyxJQUFJLENBQUMsZ0JBQWdCLENBQUMsU0FBUyxDQUFDLENBQUM7O0FBRXRELFVBQUksQ0FBQyxZQUFZLEVBQUU7QUFDakIsZUFBTyxNQUFNLENBQUMsS0FBSyxDQUFDLG9DQUFvQyxFQUFFLFNBQVMsQ0FBQyxDQUFDO09BQ3RFOztBQUVELFVBQUksRUFBRSxZQUFZLENBQUMsaUJBQWlCLEtBQUssQ0FBQyxFQUFFOztBQUUxQyxjQUFNLElBQUksQ0FBQyxZQUFZLENBQUMsWUFBWSxDQUFDLElBQUksRUFBRSxZQUFZLENBQUMsSUFBSSxDQUFDLENBQUM7O0FBRTlELFlBQUksQ0FBQyxZQUFZLENBQUMsMENBQTBDLEVBQUU7QUFDNUQsZ0JBQU0sSUFBSSxDQUFDLGNBQWMsQ0FBQyxTQUFTLENBQUMsQ0FBQztTQUN0QztBQUNELFlBQUksQ0FBQyxtQkFBbUIsQ0FBQyxTQUFTLENBQUMsQ0FBQzs7QUFFcEMsWUFBSSxPQUFPLENBQUMsSUFBSSxDQUFDLGNBQWMsQ0FBQyxFQUFFO0FBQ2hDLGdCQUFNLElBQUksQ0FBQyxPQUFPLEVBQUUsQ0FBQztTQUN0QjtPQUNGO0tBQ0Y7Ozs2QkFFZSxhQUEyQjtrQkFDekIsTUFBTSxJQUFJLENBQUMsUUFBUSxDQUFDLFlBQVksQ0FBQzs7VUFBMUMsS0FBSyxTQUFMLEtBQUs7O0FBQ1osYUFBTyxLQUFLLENBQUM7S0FDZDs7O1dBRWEsd0JBQUMsU0FBaUIsRUFBVztBQUN6QyxhQUFPLElBQUksQ0FBQyxRQUFRLENBQUMsV0FBVyxFQUFFLFNBQVMsQ0FBQyxDQUFDO0tBQzlDOzs7V0FFVyxzQkFBQyxnQkFBd0IsRUFBRSxnQkFBd0IsRUFBVztBQUN4RSxhQUFPLElBQUksQ0FBQyxRQUFRLENBQUMsYUFBYSxFQUFFLGdCQUFnQixFQUFFLGdCQUFnQixDQUFDLENBQUM7S0FDekU7Ozs2QkFFVyxXQUFDLGFBQXFCLEVBQVc7QUFDM0MsVUFBTSxRQUFRLEdBQUcsTUFBTSxJQUFJLENBQUMsUUFBUSxDQUFDLE9BQU8sRUFBRSxhQUFhLENBQUMsQ0FBQztBQUM3RCxVQUFJLFFBQVEsQ0FBQyxPQUFPLEVBQUU7QUFDcEIsY0FBTSxDQUFDLElBQUksQ0FBQyxvQkFBb0IsRUFBRSxRQUFRLENBQUMsT0FBTyxDQUFDLENBQUM7T0FDckQ7S0FDRjs7OzZCQUVrQixXQUFDLGFBQXFCLEVBQWdCO0FBQ3ZELFVBQU0sZUFBZSxHQUFHLE1BQU0sSUFBSSxDQUFDLHVCQUF1QixDQUFDO0FBQzNELFVBQUksQ0FBQyxlQUFlLElBQUksZUFBZSxHQUFHLE9BQU8sRUFBRTtBQUNqRCxjQUFNLElBQUksS0FBSyxDQUFDLG9CQUFvQixHQUFHLGVBQWUsR0FBRyxpQ0FBaUMsQ0FBQyxDQUFDO09BQzdGO0FBQ0QsVUFBTSxRQUFRLEdBQUcsTUFBTSxJQUFJLENBQUMsUUFBUSxDQUFDLGVBQWUsRUFBRSxhQUFhLENBQUMsQ0FBQztBQUNyRSxVQUFJLFFBQVEsQ0FBQyxPQUFPLEVBQUU7QUFDcEIsY0FBTSxDQUFDLElBQUksQ0FBQyxvQkFBb0IsRUFBRSxRQUFRLENBQUMsT0FBTyxDQUFDLENBQUM7T0FDckQ7QUFDRCxhQUFPLFFBQVEsQ0FBQztLQUNqQjs7OzZCQUVXLFdBQUMsYUFBcUIsRUFBbUI7a0JBQ25DLE1BQU0sSUFBSSxDQUFDLFFBQVEsQ0FBQyxPQUFPLEVBQUUsYUFBYSxDQUFDOztVQUFwRCxLQUFLLFNBQUwsS0FBSzs7QUFDWixhQUFPLEtBQUssQ0FBQztLQUNkOzs7NkJBRVksYUFBb0I7a0JBQ2IsTUFBTSxJQUFJLENBQUMsUUFBUSxDQUFDLFNBQVMsQ0FBQzs7VUFBekMsT0FBTyxTQUFQLE9BQU87O0FBQ2QsYUFBTyxPQUFPLENBQUM7S0FDaEI7OztXQUVTLG9CQUNKLFNBQWlCLEVBQ2pCLGdCQUF5QixFQUN6QixPQUFvQyxFQUNMO0FBQ25DLGFBQU8sSUFBSSxDQUFDLFFBQVEsQ0FBQyxXQUFXLEVBQUUsU0FBUyxFQUFFLGdCQUFnQixFQUFFLE9BQU8sQ0FBQyxDQUFDO0tBQ3pFOzs7Ozs7O1dBS08sb0JBQW9DOzs7d0NBQWhDLElBQUk7QUFBSixZQUFJOzs7QUFDZCxhQUFPLElBQUksT0FBTyxDQUFDLFVBQUMsT0FBTyxFQUFFLE1BQU0sRUFBSztBQUN0QyxlQUFLLGNBQWMsQ0FBQyxJQUFJLENBQUMsVUFBQSxNQUFNLEVBQUk7QUFDakMsZ0JBQU0sQ0FBQyxPQUFPLENBQUMsSUFBSSxFQUFFLFVBQUMsS0FBSyxFQUFFLFFBQVE7bUJBQ2pDLEtBQUssR0FBRyxNQUFNLENBQUMsS0FBSyxDQUFDLEdBQUcsT0FBTyxDQUFDLFFBQVEsQ0FBQztXQUFBLENBQUMsQ0FBQztTQUNoRCxDQUFDLFNBQU0sQ0FBQyxNQUFNLENBQUMsQ0FBQztPQUNsQixDQUFDLENBQUM7S0FDSjs7O1NBeE1HLGNBQWM7OztBQTJNcEIsTUFBTSxDQUFDLE9BQU8sR0FBRyxjQUFjLENBQUMiLCJmaWxlIjoiL3Zhci9mb2xkZXJzL3hmL3JzcGg0X2M1NzMxNXJzNTd4eHNkc2tyeG52MzZ0MC9UL3RtcHBmbDUybnB1Ymxpc2hfcGFja2FnZXMvbnBtL251Y2xpZGUtd2F0Y2htYW4taGVscGVycy9saWIvV2F0Y2htYW5DbGllbnQuanMiLCJzb3VyY2VzQ29udGVudCI6WyIndXNlIGJhYmVsJztcbi8qIEBmbG93ICovXG5cbi8qXG4gKiBDb3B5cmlnaHQgKGMpIDIwMTUtcHJlc2VudCwgRmFjZWJvb2ssIEluYy5cbiAqIEFsbCByaWdodHMgcmVzZXJ2ZWQuXG4gKlxuICogVGhpcyBzb3VyY2UgY29kZSBpcyBsaWNlbnNlZCB1bmRlciB0aGUgbGljZW5zZSBmb3VuZCBpbiB0aGUgTElDRU5TRSBmaWxlIGluXG4gKiB0aGUgcm9vdCBkaXJlY3Rvcnkgb2YgdGhpcyBzb3VyY2UgdHJlZS5cbiAqL1xuXG5jb25zdCB3YXRjaG1hbiA9IHJlcXVpcmUoJ2ZiLXdhdGNobWFuJyk7XG5cbmNvbnN0IHtpc0VtcHR5fSA9IHJlcXVpcmUoJ251Y2xpZGUtY29tbW9ucycpLm9iamVjdDtcbmNvbnN0IGxvZ2dlciA9IHJlcXVpcmUoJ251Y2xpZGUtbG9nZ2luZycpLmdldExvZ2dlcigpO1xuY29uc3Qge2dldFdhdGNobWFuQmluYXJ5UGF0aH0gPSByZXF1aXJlKCcuL21haW4nKTtcbmNvbnN0IHBhdGggPSByZXF1aXJlKCdwYXRoJyk7XG5cbmltcG9ydCBXYXRjaG1hblN1YnNjcmlwdGlvbiBmcm9tICcuL1dhdGNobWFuU3Vic2NyaXB0aW9uJztcbmltcG9ydCB0eXBlIHtXYXRjaG1hblN1YnNjcmlwdGlvbk9wdGlvbnN9IGZyb20gJy4vV2F0Y2htYW5TdWJzY3JpcHRpb24nO1xuXG50eXBlIFdhdGNobWFuU3Vic2NyaXB0aW9uUmVzcG9uc2UgPSB7XG4gIHJvb3Q6IHN0cmluZztcbiAgc3Vic2NyaXB0aW9uOiBzdHJpbmc7XG4gIGZpbGVzOiBBcnJheTxGaWxlQ2hhbmdlPjtcbn07XG5cbmV4cG9ydCB0eXBlIEZpbGVDaGFuZ2UgPSB7XG4gIG5hbWU6IHN0cmluZztcbiAgbmV3OiBib29sZWFuO1xuICBleGlzdHM6IGJvb2xlYW47XG4gIG1vZGU6IG51bWJlcjtcbn07XG5cbmNsYXNzIFdhdGNobWFuQ2xpZW50IHtcbiAgX3N1YnNjcmlwdGlvbnM6IHtba2V5OiBzdHJpbmddOiBXYXRjaG1hblN1YnNjcmlwdGlvbn07XG4gIF9jbGllbnRQcm9taXNlOiBQcm9taXNlPHdhdGNobWFuLkNsaWVudD47XG4gIF93YXRjaG1hblZlcnNpb25Qcm9taXNlOiBQcm9taXNlPHN0cmluZz47XG4gIGNvbnN0cnVjdG9yKCkge1xuICAgIHRoaXMuX2luaXRXYXRjaG1hbkNsaWVudCgpO1xuICAgIHRoaXMuX3N1YnNjcmlwdGlvbnMgPSBPYmplY3QuY3JlYXRlKG51bGwpO1xuICAgIHRoaXMuX3dhdGNobWFuVmVyc2lvblByb21pc2UgPSB0aGlzLnZlcnNpb24oKTtcbiAgfVxuXG4gIGRpc3Bvc2UoKTogUHJvbWlzZSB7XG4gICAgcmV0dXJuIG5ldyBQcm9taXNlKChyZXNvbHZlLCByZWplY3QpID0+IHtcbiAgICAgIGlmICh0aGlzLl9jbGllbnRQcm9taXNlKSB7XG4gICAgICAgIHRoaXMuX2NsaWVudFByb21pc2UudGhlbihjbGllbnQgPT4ge1xuICAgICAgICAgIGNsaWVudC5vbmNlKCdlbmQnLCAoKSA9PiB7XG4gICAgICAgICAgICByZXNvbHZlKCk7XG4gICAgICAgICAgfSk7XG4gICAgICAgICAgY2xpZW50LmVuZCgpO1xuICAgICAgICB9KTtcbiAgICAgIH0gZWxzZSB7XG4gICAgICAgIHJlamVjdCgpO1xuICAgICAgfVxuICAgIH0pO1xuICB9XG5cbiAgX2luaXRXYXRjaG1hbkNsaWVudCgpIHtcbiAgICB0aGlzLl9jbGllbnRQcm9taXNlID0gdGhpcy5fY3JlYXRlQ2xpZW50UHJvbWlzZSgpO1xuICAgIHRoaXMuX2NsaWVudFByb21pc2UudGhlbihjbGllbnQgPT4ge1xuICAgICAgY2xpZW50Lm9uKCdlbmQnLCAoKSA9PiB0aGlzLl9vbkNsaWVudEVuZCgpKTtcbiAgICAgIGNsaWVudC5vbignZXJyb3InLCBlcnJvciA9PiBsb2dnZXIuZXJyb3IoJ0Vycm9yIHdoaWxlIHRhbGtpbmcgdG8gd2F0Y2htYW46ICcsIGVycm9yKSk7XG4gICAgICBjbGllbnQub24oJ3N1YnNjcmlwdGlvbicsIHJlc3BvbnNlID0+IHRoaXMuX29uU3Vic2NyaXB0aW9uUmVzdWx0KHJlc3BvbnNlKSk7XG4gICAgfSk7XG4gIH1cblxuICBhc3luYyBfY3JlYXRlQ2xpZW50UHJvbWlzZSgpOiBQcm9taXNlPHdhdGNobWFuLkNsaWVudD4ge1xuICAgIHJldHVybiBuZXcgd2F0Y2htYW4uQ2xpZW50KHtcbiAgICAgIHdhdGNobWFuQmluYXJ5UGF0aDogYXdhaXQgZ2V0V2F0Y2htYW5CaW5hcnlQYXRoKCksXG4gICAgfSk7XG4gIH1cblxuICBfb25DbGllbnRFbmQoKSB7XG4gICAgbG9nZ2VyLndhcm4oJ1dhdGNobWFuIGNsaWVudCBlbmRlZCwgY3JlYXRpbmcgYSBuZXcgY2xpZW50IScpO1xuICAgIHRoaXMuX2NsaWVudFByb21pc2UudGhlbihjbGllbnQgPT4ge1xuICAgICAgY2xpZW50LnJlbW92ZUFsbExpc3RlbmVycygnZW5kJyk7XG4gICAgICBjbGllbnQucmVtb3ZlQWxsTGlzdGVuZXJzKCdlcnJvcicpO1xuICAgICAgY2xpZW50LnJlbW92ZUFsbExpc3RlbmVycygnc3Vic2NyaXB0aW9uJyk7XG4gICAgfSk7XG4gICAgdGhpcy5faW5pdFdhdGNobWFuQ2xpZW50KCk7XG4gICAgdGhpcy5fcmVzdG9yZVN1YnNjcmlwdGlvbnMoKTtcbiAgfVxuXG4gIGFzeW5jIF9yZXN0b3JlU3Vic2NyaXB0aW9ucygpOiBQcm9taXNlIHtcbiAgICBjb25zdCB3YXRjaFN1YnNjcmlwdGlvbnM6IEFycmF5PFdhdGNobWFuU3Vic2NyaXB0aW9uPiA9IFtdO1xuICAgIGZvciAoY29uc3Qga2V5IGluIHRoaXMuX3N1YnNjcmlwdGlvbnMpIHtcbiAgICAgIHdhdGNoU3Vic2NyaXB0aW9ucy5wdXNoKHRoaXMuX3N1YnNjcmlwdGlvbnNba2V5XSk7XG4gICAgfVxuICAgIGF3YWl0IFByb21pc2UuYWxsKHdhdGNoU3Vic2NyaXB0aW9ucy5tYXAoYXN5bmMgKHN1YnNjcmlwdGlvbjogV2F0Y2htYW5TdWJzY3JpcHRpb24pID0+IHtcbiAgICAgIHN1YnNjcmlwdGlvbi5vcHRpb25zLnNpbmNlID0gYXdhaXQgdGhpcy5fY2xvY2soc3Vic2NyaXB0aW9uLnJvb3QpO1xuICAgICAgYXdhaXQgdGhpcy5fd2F0Y2hQcm9qZWN0KHN1YnNjcmlwdGlvbi5wYXRoKTtcbiAgICAgIGF3YWl0IHRoaXMuX3N1YnNjcmliZShzdWJzY3JpcHRpb24ucm9vdCwgc3Vic2NyaXB0aW9uLm5hbWUsIHN1YnNjcmlwdGlvbi5vcHRpb25zKTtcbiAgICB9KSk7XG4gIH1cblxuICBfZ2V0U3Vic2NyaXB0aW9uKGVudHJ5UGF0aDogc3RyaW5nKTogP1dhdGNobWFuU3Vic2NyaXB0aW9uIHtcbiAgICByZXR1cm4gdGhpcy5fc3Vic2NyaXB0aW9uc1twYXRoLm5vcm1hbGl6ZShlbnRyeVBhdGgpXTtcbiAgfVxuXG4gIF9zZXRTdWJzY3JpcHRpb24oZW50cnlQYXRoOiBzdHJpbmcsIHN1YnNjcmlwdGlvbjogV2F0Y2htYW5TdWJzY3JpcHRpb24pOiBXYXRjaG1hblN1YnNjcmlwdGlvbiB7XG4gICAgdGhpcy5fc3Vic2NyaXB0aW9uc1twYXRoLm5vcm1hbGl6ZShlbnRyeVBhdGgpXSA9IHN1YnNjcmlwdGlvbjtcbiAgICByZXR1cm4gc3Vic2NyaXB0aW9uO1xuICB9XG5cbiAgX2RlbGV0ZVN1YnNjcmlwdGlvbihlbnRyeVBhdGg6IHN0cmluZyk6IHZvaWQge1xuICAgIGRlbGV0ZSB0aGlzLl9zdWJzY3JpcHRpb25zW3BhdGgubm9ybWFsaXplKGVudHJ5UGF0aCldO1xuICB9XG5cbiAgX29uU3Vic2NyaXB0aW9uUmVzdWx0KHJlc3BvbnNlOiBXYXRjaG1hblN1YnNjcmlwdGlvblJlc3BvbnNlKSB7XG4gICAgY29uc3Qgc3Vic2NyaXB0aW9uID0gdGhpcy5fZ2V0U3Vic2NyaXB0aW9uKHJlc3BvbnNlLnN1YnNjcmlwdGlvbik7XG4gICAgaWYgKCFzdWJzY3JpcHRpb24pIHtcbiAgICAgIHJldHVybiBsb2dnZXIuZXJyb3IoJ1N1YnNjcmlwdGlvbiBub3QgZm91bmQgZm9yIHJlc3BvbnNlOiEnLCByZXNwb25zZSk7XG4gICAgfVxuICAgIHN1YnNjcmlwdGlvbi5lbWl0KCdjaGFuZ2UnLCByZXNwb25zZS5maWxlcyk7XG4gIH1cblxuICBhc3luYyB3YXRjaERpcmVjdG9yeVJlY3Vyc2l2ZShsb2NhbERpcmVjdG9yeVBhdGg6IHN0cmluZykgOiBQcm9taXNlPFdhdGNobWFuU3Vic2NyaXB0aW9uPiB7XG4gICAgY29uc3QgZXhpc3RpbmdTdWJzY3JpcHRpb24gPSB0aGlzLl9nZXRTdWJzY3JpcHRpb24obG9jYWxEaXJlY3RvcnlQYXRoKTtcbiAgICBpZiAoZXhpc3RpbmdTdWJzY3JpcHRpb24pIHtcbiAgICAgIGV4aXN0aW5nU3Vic2NyaXB0aW9uLnN1YnNjcmlwdGlvbkNvdW50Kys7XG4gICAgICByZXR1cm4gZXhpc3RpbmdTdWJzY3JpcHRpb247XG4gICAgfSBlbHNlIHtcbiAgICAgIGNvbnN0IHt3YXRjaDogd2F0Y2hSb290LCByZWxhdGl2ZV9wYXRoOiByZWxhdGl2ZVBhdGh9ID0gYXdhaXQgdGhpcy5fd2F0Y2hQcm9qZWN0KGxvY2FsRGlyZWN0b3J5UGF0aCk7XG4gICAgICBjb25zdCBjbG9jayA9IGF3YWl0IHRoaXMuX2Nsb2NrKHdhdGNoUm9vdCk7XG4gICAgICBjb25zdCBvcHRpb25zOiBXYXRjaG1hblN1YnNjcmlwdGlvbk9wdGlvbnMgPSB7XG4gICAgICAgIGZpZWxkczogWyduYW1lJywgJ25ldycsICdleGlzdHMnLCAnbW9kZSddLFxuICAgICAgICBzaW5jZTogY2xvY2ssXG4gICAgICB9O1xuICAgICAgaWYgKHJlbGF0aXZlUGF0aCkge1xuICAgICAgICAvLyBQYXNzaW5nIGFuICd1bmRlZmluZWQnIGV4cHJlc3Npb24gY2F1c2VzIGFuIGV4Y2VwdGlvbiBpbiBmYi13YXRjaG1hbi5cbiAgICAgICAgb3B0aW9ucy5leHByZXNzaW9uID0gWydkaXJuYW1lJywgcmVsYXRpdmVQYXRoXTtcbiAgICAgIH1cbiAgICAgIC8vIHJlbGF0aXZlUGF0aCBpcyB1bmRlZmluZWQgaWYgd2F0Y2hSb290IGlzIHRoZSBzYW1lIGFzIGRpcmVjdG9yeVBhdGguXG4gICAgICBjb25zdCBzdWJzY3JpcHRpb24gPSB0aGlzLl9zZXRTdWJzY3JpcHRpb24obG9jYWxEaXJlY3RvcnlQYXRoLFxuICAgICAgICAgIG5ldyBXYXRjaG1hblN1YnNjcmlwdGlvbihcbiAgICAgICAgICAgIC8qc3Vic2NyaXB0aW9uUm9vdCovIHdhdGNoUm9vdCxcbiAgICAgICAgICAgIC8qcGF0aEZyb21TdWJzY3JpcHRpb25Sb290VG9TdWJzY3JpcHRpb25QYXRoKi8gcmVsYXRpdmVQYXRoLFxuICAgICAgICAgICAgLypzdWJzY3JpcHRpb25QYXRoKi8gbG9jYWxEaXJlY3RvcnlQYXRoLFxuICAgICAgICAgICAgLypzdWJzY3JpcHRpb25Db3VudCovIDEsXG4gICAgICAgICAgICAvKnN1YnNjcmlwdGlvbk9wdGlvbnMqLyBvcHRpb25zXG4gICAgICAgICAgKSk7XG4gICAgICBhd2FpdCB0aGlzLl9zdWJzY3JpYmUod2F0Y2hSb290LCBsb2NhbERpcmVjdG9yeVBhdGgsIG9wdGlvbnMpO1xuICAgICAgcmV0dXJuIHN1YnNjcmlwdGlvbjtcbiAgICB9XG4gIH1cblxuICBoYXNTdWJzY3JpcHRpb24oZW50cnlQYXRoOiBzdHJpbmcpOiBib29sZWFuIHtcbiAgICByZXR1cm4gISF0aGlzLl9nZXRTdWJzY3JpcHRpb24oZW50cnlQYXRoKTtcbiAgfVxuXG4gIGFzeW5jIHVud2F0Y2goZW50cnlQYXRoOiBzdHJpbmcpOiBQcm9taXNlIHtcbiAgICBjb25zdCBzdWJzY3JpcHRpb24gPSB0aGlzLl9nZXRTdWJzY3JpcHRpb24oZW50cnlQYXRoKTtcblxuICAgIGlmICghc3Vic2NyaXB0aW9uKSB7XG4gICAgICByZXR1cm4gbG9nZ2VyLmVycm9yKCdObyB3YXRjaGVyIGVudGl0eSBmb3VuZCB3aXRoIHBhdGg6JywgZW50cnlQYXRoKTtcbiAgICB9XG5cbiAgICBpZiAoLS1zdWJzY3JpcHRpb24uc3Vic2NyaXB0aW9uQ291bnQgPT09IDApIHtcblxuICAgICAgYXdhaXQgdGhpcy5fdW5zdWJzY3JpYmUoc3Vic2NyaXB0aW9uLnBhdGgsIHN1YnNjcmlwdGlvbi5uYW1lKTtcbiAgICAgIC8vIERvbid0IGRlbGV0ZSB0aGUgd2F0Y2hlciBpZiB0aGVyZSBhcmUgb3RoZXIgdXNlcnMgZm9yIGl0LlxuICAgICAgaWYgKCFzdWJzY3JpcHRpb24ucGF0aEZyb21TdWJzY3JpcHRpb25Sb290VG9TdWJzY3JpcHRpb25QYXRoKSB7XG4gICAgICAgIGF3YWl0IHRoaXMuX2RlbGV0ZVdhdGNoZXIoZW50cnlQYXRoKTtcbiAgICAgIH1cbiAgICAgIHRoaXMuX2RlbGV0ZVN1YnNjcmlwdGlvbihlbnRyeVBhdGgpO1xuXG4gICAgICBpZiAoaXNFbXB0eSh0aGlzLl9zdWJzY3JpcHRpb25zKSkge1xuICAgICAgICBhd2FpdCB0aGlzLmRpc3Bvc2UoKTtcbiAgICAgIH1cbiAgICB9XG4gIH1cblxuICBhc3luYyBfd2F0Y2hMaXN0KCk6IFByb21pc2U8QXJyYXk8c3RyaW5nPj4ge1xuICAgIGNvbnN0IHtyb290c30gPSBhd2FpdCB0aGlzLl9jb21tYW5kKCd3YXRjaC1saXN0Jyk7XG4gICAgcmV0dXJuIHJvb3RzO1xuICB9XG5cbiAgX2RlbGV0ZVdhdGNoZXIoZW50cnlQYXRoOiBzdHJpbmcpOiBQcm9taXNlIHtcbiAgICByZXR1cm4gdGhpcy5fY29tbWFuZCgnd2F0Y2gtZGVsJywgZW50cnlQYXRoKTtcbiAgfVxuXG4gIF91bnN1YnNjcmliZShzdWJzY3JpcHRpb25QYXRoOiBzdHJpbmcsIHN1YnNjcmlwdGlvbk5hbWU6IHN0cmluZyk6IFByb21pc2Uge1xuICAgIHJldHVybiB0aGlzLl9jb21tYW5kKCd1bnN1YnNjcmliZScsIHN1YnNjcmlwdGlvblBhdGgsIHN1YnNjcmlwdGlvbk5hbWUpO1xuICB9XG5cbiAgYXN5bmMgX3dhdGNoKGRpcmVjdG9yeVBhdGg6IHN0cmluZyk6IFByb21pc2Uge1xuICAgIGNvbnN0IHJlc3BvbnNlID0gYXdhaXQgdGhpcy5fY29tbWFuZCgnd2F0Y2gnLCBkaXJlY3RvcnlQYXRoKTtcbiAgICBpZiAocmVzcG9uc2Uud2FybmluZykge1xuICAgICAgbG9nZ2VyLndhcm4oJ3dhdGNobWFuIHdhcm5pbmc6ICcsIHJlc3BvbnNlLndhcm5pbmcpO1xuICAgIH1cbiAgfVxuXG4gIGFzeW5jIF93YXRjaFByb2plY3QoZGlyZWN0b3J5UGF0aDogc3RyaW5nKTogUHJvbWlzZTxhbnk+IHtcbiAgICBjb25zdCB3YXRjaG1hblZlcnNpb24gPSBhd2FpdCB0aGlzLl93YXRjaG1hblZlcnNpb25Qcm9taXNlO1xuICAgIGlmICghd2F0Y2htYW5WZXJzaW9uIHx8IHdhdGNobWFuVmVyc2lvbiA8ICczLjEuMCcpIHtcbiAgICAgIHRocm93IG5ldyBFcnJvcignV2F0Y2htYW4gdmVyc2lvbjogJyArIHdhdGNobWFuVmVyc2lvbiArICcgZG9lcyBub3Qgc3VwcG9ydCB3YXRjaC1wcm9qZWN0Jyk7XG4gICAgfVxuICAgIGNvbnN0IHJlc3BvbnNlID0gYXdhaXQgdGhpcy5fY29tbWFuZCgnd2F0Y2gtcHJvamVjdCcsIGRpcmVjdG9yeVBhdGgpO1xuICAgIGlmIChyZXNwb25zZS53YXJuaW5nKSB7XG4gICAgICBsb2dnZXIud2Fybignd2F0Y2htYW4gd2FybmluZzogJywgcmVzcG9uc2Uud2FybmluZyk7XG4gICAgfVxuICAgIHJldHVybiByZXNwb25zZTtcbiAgfVxuXG4gIGFzeW5jIF9jbG9jayhkaXJlY3RvcnlQYXRoOiBzdHJpbmcpOiBQcm9taXNlPHN0cmluZz4ge1xuICAgIGNvbnN0IHtjbG9ja30gPSBhd2FpdCB0aGlzLl9jb21tYW5kKCdjbG9jaycsIGRpcmVjdG9yeVBhdGgpO1xuICAgIHJldHVybiBjbG9jaztcbiAgfVxuXG4gIGFzeW5jIHZlcnNpb24oKTogUHJvbWlzZTxzdHJpbmc+IHtcbiAgICBjb25zdCB7dmVyc2lvbn0gPSBhd2FpdCB0aGlzLl9jb21tYW5kKCd2ZXJzaW9uJyk7XG4gICAgcmV0dXJuIHZlcnNpb247XG4gIH1cblxuICBfc3Vic2NyaWJlKFxuICAgICAgICB3YXRjaFJvb3Q6IHN0cmluZyxcbiAgICAgICAgc3Vic2NyaXB0aW9uTmFtZTogP3N0cmluZyxcbiAgICAgICAgb3B0aW9uczogV2F0Y2htYW5TdWJzY3JpcHRpb25PcHRpb25zXG4gICAgICApOiBQcm9taXNlPFdhdGNobWFuU3Vic2NyaXB0aW9uPiB7XG4gICAgcmV0dXJuIHRoaXMuX2NvbW1hbmQoJ3N1YnNjcmliZScsIHdhdGNoUm9vdCwgc3Vic2NyaXB0aW9uTmFtZSwgb3B0aW9ucyk7XG4gIH1cblxuICAvKlxuICAgKiBQcm9taXNpZnkgY2FsbHMgdG8gd2F0Y2htYW4gY2xpZW50LlxuICAgKi9cbiAgX2NvbW1hbmQoLi4uYXJnczogQXJyYXk8YW55Pik6IFByb21pc2U8YW55PiB7XG4gICAgcmV0dXJuIG5ldyBQcm9taXNlKChyZXNvbHZlLCByZWplY3QpID0+IHtcbiAgICAgIHRoaXMuX2NsaWVudFByb21pc2UudGhlbihjbGllbnQgPT4ge1xuICAgICAgICBjbGllbnQuY29tbWFuZChhcmdzLCAoZXJyb3IsIHJlc3BvbnNlKSA9PlxuICAgICAgICAgICAgZXJyb3IgPyByZWplY3QoZXJyb3IpIDogcmVzb2x2ZShyZXNwb25zZSkpO1xuICAgICAgfSkuY2F0Y2gocmVqZWN0KTtcbiAgICB9KTtcbiAgfVxufVxuXG5tb2R1bGUuZXhwb3J0cyA9IFdhdGNobWFuQ2xpZW50O1xuIl19
/*
* Promisify calls to watchman client.
*/
_command(...args: Array<any>): Promise<any> {
return new Promise((resolve, reject) => {
this._clientPromise
.then(client => {
client.command(
args,
(error, response) => (error ? reject(error) : resolve(response)),
);
})
.catch(reject);
});
}
}

81

lib/WatchmanSubscription.js

@@ -1,25 +0,37 @@

/*
* Copyright (c) 2015-present, Facebook, Inc.
/**
* Copyright (c) 2017-present, Facebook, Inc.
* All rights reserved.
*
* This source code is licensed under the license found in the LICENSE file in
* the root directory of this source tree.
* This source code is licensed under the BSD-style license found in the
* LICENSE file in the root directory of this source tree. An additional grant
* of patent rights can be found in the PATENTS file in the same directory.
*
* @flow
* @format
*/
Object.defineProperty(exports, '__esModule', {
value: true
});
import {Emitter} from 'event-kit';
var _get = function get(_x, _x2, _x3) { var _again = true; _function: while (_again) { var object = _x, property = _x2, receiver = _x3; desc = parent = getter = undefined; _again = false; if (object === null) object = Function.prototype; var desc = Object.getOwnPropertyDescriptor(object, property); if (desc === undefined) { var parent = Object.getPrototypeOf(object); if (parent === null) { return undefined; } else { _x = parent; _x2 = property; _x3 = receiver; _again = true; continue _function; } } else if ('value' in desc) { return desc.value; } else { var getter = desc.get; if (getter === undefined) { return undefined; } return getter.call(receiver); } } };
export type WatchmanSubscriptionOptions = {
expression: ?Array<string>, // e.g. ['match', '*.js'],
fields?: Array<string>, // e.g. ['name', 'size', 'exists', 'mode']
expression?: Array<mixed>, // e.g. ['dirname', relativePath]
since?: string, // e.g. "c:1439492655:58601:1:14195"
defer_vcs?: boolean,
function _classCallCheck(instance, Constructor) { if (!(instance instanceof Constructor)) { throw new TypeError('Cannot call a class as a function'); } }
/**
* For performance reasons, prefer:
*
* "relative_root": "relative/path"
*
* over:
*
* "expression": ["dirname", "relative/path"]
*/
relative_root?: string,
function _inherits(subClass, superClass) { if (typeof superClass !== 'function' && superClass !== null) { throw new TypeError('Super expression must either be null or a function, not ' + typeof superClass); } subClass.prototype = Object.create(superClass && superClass.prototype, { constructor: { value: subClass, enumerable: false, writable: true, configurable: true } }); if (superClass) Object.setPrototypeOf ? Object.setPrototypeOf(subClass, superClass) : subClass.__proto__ = superClass; }
/** If true, no files will be returned for fresh instances. */
empty_on_fresh_instance?: boolean,
};
var _require = require('events');
var EventEmitter = _require.EventEmitter;
// e.g. "c:1439492655:58601:1:14195"
/**

@@ -32,24 +44,25 @@ * @param pathFromSubscriptionRootToSubscriptionPath The relative path from

*/
var WatchmanSubscription = (function (_EventEmitter) {
_inherits(WatchmanSubscription, _EventEmitter);
function WatchmanSubscription(subscriptionRoot, pathFromSubscriptionRootToSubscriptionPath, subscriptionPath, subscriptionCount, subscriptionOptions) {
_classCallCheck(this, WatchmanSubscription);
_get(Object.getPrototypeOf(WatchmanSubscription.prototype), 'constructor', this).call(this);
export default class WatchmanSubscription extends Emitter {
subscriptionCount: number;
root: string;
path: string;
pathFromSubscriptionRootToSubscriptionPath: ?string;
name: string;
options: WatchmanSubscriptionOptions;
constructor(
subscriptionRoot: string,
pathFromSubscriptionRootToSubscriptionPath: ?string,
subscriptionPath: string,
subscriptionName: string,
subscriptionCount: number,
subscriptionOptions: WatchmanSubscriptionOptions,
) {
super();
this.root = subscriptionRoot;
this.pathFromSubscriptionRootToSubscriptionPath = pathFromSubscriptionRootToSubscriptionPath;
this.path = this.name = subscriptionPath;
this.path = subscriptionPath;
this.name = subscriptionName;
this.subscriptionCount = subscriptionCount;
this.options = subscriptionOptions;
}
return WatchmanSubscription;
})(EventEmitter);
module.exports = WatchmanSubscription;
// e.g. ['match', '*.js'],
// e.g. ['name', 'size', 'exists', 'mode']
// e.g. ['dirname', relativePath]
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJzb3VyY2VzIjpbIi92YXIvZm9sZGVycy94Zi9yc3BoNF9jNTczMTVyczU3eHhzZHNrcnhudjM2dDAvVC90bXBwZmw1Mm5wdWJsaXNoX3BhY2thZ2VzL25wbS9udWNsaWRlLXdhdGNobWFuLWhlbHBlcnMvbGliL1dhdGNobWFuU3Vic2NyaXB0aW9uLmpzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiJBQUFBLFdBQVcsQ0FBQzs7Ozs7Ozs7Ozs7Ozs7Ozs7Ozs7ZUFXVyxPQUFPLENBQUMsUUFBUSxDQUFDOztJQUFqQyxZQUFZLFlBQVosWUFBWTs7Ozs7Ozs7Ozs7SUFnQmIsb0JBQW9CO1lBQXBCLG9CQUFvQjs7QUFPYixXQVBQLG9CQUFvQixDQVFwQixnQkFBd0IsRUFDeEIsMENBQW1ELEVBQ25ELGdCQUF3QixFQUN4QixpQkFBeUIsRUFDekIsbUJBQWdELEVBQzlDOzBCQWJGLG9CQUFvQjs7QUFjdEIsK0JBZEUsb0JBQW9CLDZDQWNkO0FBQ1IsUUFBSSxDQUFDLElBQUksR0FBRyxnQkFBZ0IsQ0FBQztBQUM3QixRQUFJLENBQUMsMENBQTBDLEdBQUcsMENBQTBDLENBQUM7QUFDN0YsUUFBSSxDQUFDLElBQUksR0FBRyxJQUFJLENBQUMsSUFBSSxHQUFHLGdCQUFnQixDQUFDO0FBQ3pDLFFBQUksQ0FBQyxpQkFBaUIsR0FBRyxpQkFBaUIsQ0FBQztBQUMzQyxRQUFJLENBQUMsT0FBTyxHQUFHLG1CQUFtQixDQUFDO0dBQ3BDOztTQXBCRyxvQkFBb0I7R0FBUyxZQUFZOztBQXNCL0MsTUFBTSxDQUFDLE9BQU8sR0FBRyxvQkFBb0IsQ0FBQyIsImZpbGUiOiIvdmFyL2ZvbGRlcnMveGYvcnNwaDRfYzU3MzE1cnM1N3h4c2Rza3J4bnYzNnQwL1QvdG1wcGZsNTJucHVibGlzaF9wYWNrYWdlcy9ucG0vbnVjbGlkZS13YXRjaG1hbi1oZWxwZXJzL2xpYi9XYXRjaG1hblN1YnNjcmlwdGlvbi5qcyIsInNvdXJjZXNDb250ZW50IjpbIid1c2UgYmFiZWwnO1xuLyogQGZsb3cgKi9cblxuLypcbiAqIENvcHlyaWdodCAoYykgMjAxNS1wcmVzZW50LCBGYWNlYm9vaywgSW5jLlxuICogQWxsIHJpZ2h0cyByZXNlcnZlZC5cbiAqXG4gKiBUaGlzIHNvdXJjZSBjb2RlIGlzIGxpY2Vuc2VkIHVuZGVyIHRoZSBsaWNlbnNlIGZvdW5kIGluIHRoZSBMSUNFTlNFIGZpbGUgaW5cbiAqIHRoZSByb290IGRpcmVjdG9yeSBvZiB0aGlzIHNvdXJjZSB0cmVlLlxuICovXG5cbmNvbnN0IHtFdmVudEVtaXR0ZXJ9ID0gcmVxdWlyZSgnZXZlbnRzJyk7XG5cbmV4cG9ydCB0eXBlIFdhdGNobWFuU3Vic2NyaXB0aW9uT3B0aW9ucyA9IHtcbiAgZXhwcmVzc2lvbjogP0FycmF5PHN0cmluZz47IC8vIGUuZy4gWydtYXRjaCcsICcqLmpzJ10sXG4gIGZpZWxkczogP0FycmF5PHN0cmluZz47IC8vIGUuZy4gWyduYW1lJywgJ3NpemUnLCAnZXhpc3RzJywgJ21vZGUnXVxuICBleHByZXNzaW9uPzogQXJyYXk8c3RyaW5nPjsgLy8gZS5nLiBbJ2Rpcm5hbWUnLCByZWxhdGl2ZVBhdGhdXG4gIHNpbmNlOiBzdHJpbmc7IC8vIGUuZy4gXCJjOjE0Mzk0OTI2NTU6NTg2MDE6MToxNDE5NVwiXG59O1xuXG4vKipcbiAqIEBwYXJhbSBwYXRoRnJvbVN1YnNjcmlwdGlvblJvb3RUb1N1YnNjcmlwdGlvblBhdGggVGhlIHJlbGF0aXZlIHBhdGggZnJvbVxuICogICBzdWJzY3JpcHRpb25Sb290IHRvIHN1YnNjcmlwdGlvblBhdGguIFRoaXMgaXMgdGhlICdyZWxhdGl2ZV9wYXRoJyBhcyBkZXNjcmliZWQgYXRcbiAqICAgaHR0cHM6Ly9mYWNlYm9vay5naXRodWIuaW8vd2F0Y2htYW4vZG9jcy9jbWQvd2F0Y2gtcHJvamVjdC5odG1sI3VzaW5nLXdhdGNoLXByb2plY3QuXG4gKiAgIE5vdGFibHksIHRoaXMgdmFsdWUgc2hvdWxkIGJlIHVuZGVmaW5lZCBpZiBzdWJzY3JpcHRpb25Sb290IGlzIHRoZSBzYW1lIGFzXG4gKiAgIHN1YnNjcmlwdGlvblBhdGguXG4gKi9cbmNsYXNzIFdhdGNobWFuU3Vic2NyaXB0aW9uIGV4dGVuZHMgRXZlbnRFbWl0dGVyIHtcbiAgc3Vic2NyaXB0aW9uQ291bnQ6IG51bWJlcjtcbiAgcm9vdDogc3RyaW5nO1xuICBwYXRoOiBzdHJpbmc7XG4gIHBhdGhGcm9tU3Vic2NyaXB0aW9uUm9vdFRvU3Vic2NyaXB0aW9uUGF0aDogP3N0cmluZztcbiAgbmFtZTogc3RyaW5nO1xuICBvcHRpb25zOiBXYXRjaG1hblN1YnNjcmlwdGlvbk9wdGlvbnM7XG4gIGNvbnN0cnVjdG9yKFxuICAgICAgc3Vic2NyaXB0aW9uUm9vdDogc3RyaW5nLFxuICAgICAgcGF0aEZyb21TdWJzY3JpcHRpb25Sb290VG9TdWJzY3JpcHRpb25QYXRoOiA/c3RyaW5nLFxuICAgICAgc3Vic2NyaXB0aW9uUGF0aDogc3RyaW5nLFxuICAgICAgc3Vic2NyaXB0aW9uQ291bnQ6IG51bWJlcixcbiAgICAgIHN1YnNjcmlwdGlvbk9wdGlvbnM6IFdhdGNobWFuU3Vic2NyaXB0aW9uT3B0aW9uc1xuICAgICAgKSB7XG4gICAgc3VwZXIoKTtcbiAgICB0aGlzLnJvb3QgPSBzdWJzY3JpcHRpb25Sb290O1xuICAgIHRoaXMucGF0aEZyb21TdWJzY3JpcHRpb25Sb290VG9TdWJzY3JpcHRpb25QYXRoID0gcGF0aEZyb21TdWJzY3JpcHRpb25Sb290VG9TdWJzY3JpcHRpb25QYXRoO1xuICAgIHRoaXMucGF0aCA9IHRoaXMubmFtZSA9IHN1YnNjcmlwdGlvblBhdGg7XG4gICAgdGhpcy5zdWJzY3JpcHRpb25Db3VudCA9IHN1YnNjcmlwdGlvbkNvdW50O1xuICAgIHRoaXMub3B0aW9ucyA9IHN1YnNjcmlwdGlvbk9wdGlvbnM7XG4gIH1cbn1cbm1vZHVsZS5leHBvcnRzID0gV2F0Y2htYW5TdWJzY3JpcHRpb247XG4iXX0=
}

32

package.json
{
"dependencies": {
"fb-watchman": "1.1.0",
"nuclide-commons": "0.0.35",
"nuclide-logging": "0.0.35"
},
"name": "nuclide-watchman-helpers",
"publisher": "Facebook",
"main": "./lib/main.js",
"version": "0.5.0",
"description": "Helper methods for interacting with fb-watchman",
"devDependencies": {
"nuclide-jasmine": "0.0.35",
"temp": "0.8.3"
},
"license": "SEE LICENSE IN LICENSE",
"main": "./lib/main",
"name": "nuclide-watchman-helpers",
"author": "NEEDS OWNER",
"license": "BSD-3-Clause",
"nuclide": {
"excludeTestsFromContinuousIntegration": true,
"packageType": "Node",
"testsCannotBeRunInParallel": true,
"testRunner": "npm"
},
"repository": "https://github.com/facebook/nuclide",
"repository": "https://github.com/facebook/nuclide/tree/master/modules/nuclide-watchman-helpers",
"scripts": {
"test": "node --harmony node_modules/.bin/jasmine-node-transpiled spec"
"test": "node ../nuclide-jasmine/bin/jasmine-node-transpiled spec"
},
"version": "0.0.35"
"dependencies": {
"async-to-generator": "1.1.0",
"event-kit": "2.2.0",
"fb-watchman": "2.0.0",
"log4js": "1.1.1",
"nuclide-commons": "0.5.0"
}
}

179

spec/WatchmanClient-spec.js

@@ -1,17 +0,18 @@

'use babel';
/* @flow */
/*
* Copyright (c) 2015-present, Facebook, Inc.
/**
* Copyright (c) 2017-present, Facebook, Inc.
* All rights reserved.
*
* This source code is licensed under the license found in the LICENSE file in
* the root directory of this source tree.
* This source code is licensed under the BSD-style license found in the
* LICENSE file in the root directory of this source tree. An additional grant
* of patent rights can be found in the PATENTS file in the same directory.
*
* @flow
* @format
*/
const fs = require('fs');
const path = require('path');
const invariant = require('assert');
const temp = require('temp').track();
const WatchmanClient = require('../lib/WatchmanClient');
import fs from 'fs';
import nuclideUri from 'nuclide-commons/nuclideUri';
import watchman from 'fb-watchman';
import WatchmanClient from '../lib/WatchmanClient';
import {generateFixture} from 'nuclide-commons/test-helpers';

@@ -21,6 +22,4 @@ const FILE_MODE = 33188;

describe('WatchmanClient test suite', () => {
let dirPath: string = '';
let client: any;
let filePath: string = '';
let client: WatchmanClient = (null: any);

@@ -30,11 +29,21 @@ beforeEach(() => {

client = new WatchmanClient();
dirPath = temp.mkdirSync();
filePath = path.join(dirPath, 'test.txt');
fs.writeFileSync(filePath, 'abc');
// Many people use restrict_root_files so watchman only will watch folders
// that have those listed files in them. This list of root files almost
// always has .git in it.
const watchmanRootPath = path.join(dirPath, '.git');
fs.mkdirSync(watchmanRootPath);
waits(1010);
waitsForPromise(async () => {
dirPath = await generateFixture(
'watchman_helpers_test',
new Map([
// Many people use restrict_root_files so watchman only will watch folders
// that have those listed files in them. watchmanconfig is always a root
// file.
['.watchmanconfig', '{}'],
['test.txt', 'abc'],
['non-used-file.txt', 'def'],
['nested/nested-test.txt', 'ghi'],
]),
);
// TODO(hansonw): This is a big change in Watchman behavior- figure out what
// this means for Nuclide's use.
dirPath = fs.realpathSync(dirPath);
waits(1010);
});
});

@@ -47,5 +56,13 @@

describe('restore subscriptions', () => {
it('restores subscriptions on client end', () => {
waitsForPromise(async () => {
const watcher = await client.watchDirectoryRecursive(dirPath);
function testRestoreSubscriptions(
onRestoreChange: (watchmanClient: watchman.Client) => void,
) {
// First watchman init can be slow and flaky.
waitsForPromise({timeout: 15000}, async () => {
const filePath = nuclideUri.join(dirPath, 'test.txt');
const watcher = await client
.watchDirectoryRecursive(dirPath)
// Give it two retries.
.catch(() => client.watchDirectoryRecursive(dirPath))
.catch(() => client.watchDirectoryRecursive(dirPath));
const changeHandler = jasmine.createSpy();

@@ -58,8 +75,17 @@ watcher.on('change', changeHandler);

expect(changeHandler.callCount).toBe(1);
expect(changeHandler.argsForCall[0][0]).toEqual([{name: 'test.txt', mode: FILE_MODE, new: false, exists: true}]);
// End the socket client to watchman to trigger restore subscriptions.
expect(changeHandler.argsForCall[0][0]).toEqual([
{
name: 'test.txt',
mode: FILE_MODE,
new: false,
exists: true,
},
]);
const internalClient = await client._clientPromise;
onRestoreChange(internalClient);
internalClient.end();
});
waits(1000); // Wait for WatchmanClient to restore subscriptions.
waits(1000); // Wait for watchman to watch the directory.
runs(() => advanceClock(3000)); // Pass the settle filesystem time.
waits(1000); // Wait for the client to restore subscriptions.
runs(() => fs.unlinkSync(filePath));

@@ -69,3 +95,10 @@ waitsFor(() => changeHandler.callCount > 1);

expect(changeHandler.callCount).toBe(2);
expect(changeHandler.argsForCall[1][0]).toEqual([{name: 'test.txt', mode: FILE_MODE, new: false, exists: false}]);
expect(changeHandler.argsForCall[1][0]).toEqual([
{
name: 'test.txt',
mode: FILE_MODE,
new: false,
exists: false,
},
]);
});

@@ -75,7 +108,45 @@ });

waitsForPromise(() => client.unwatch(dirPath));
}
it('restores subscriptions on client end', () => {
testRestoreSubscriptions(watchmanClient => {
// End the socket client to watchman to trigger restore subscriptions.
watchmanClient.end();
});
});
it('restores subscriptions on client error', () => {
testRestoreSubscriptions(watchmanClient => {
// End the socket client to watchman to trigger restore subscriptions.
watchmanClient.emit('error', new Error('fake error'));
});
});
/**
* This simulates the case where:
* 1. watchman fails, and then
* 2. the reconnection fails on startup
* 3. subsequent reconnections can still succeed.
*
* We need to make sure we don't end up in a deadlock where the first reconnection
* attempt blocks subsequent ones.
*/
it('restores subscriptions on client startup failure', () => {
testRestoreSubscriptions(watchmanClient => {
let counter = 0;
const oldConnect = watchman.Client.prototype.connect;
spyOn(watchman.Client.prototype, 'connect').andCallFake(function() {
if (counter++ === 0) {
this.emit('error', new Error('startup error'));
} else {
oldConnect.apply(this);
}
});
watchmanClient.emit('error', new Error('fake error'));
});
});
});
describe('cleanup watchers after unwatch', () => {
it('unwatch cleans up watchman watchlist resources', () => {
it('unwatch cleans up watchman subscriptions resources', () => {
waitsForPromise(async () => {

@@ -86,5 +157,9 @@ const dirRealPath = fs.realpathSync(dirPath);

expect(watchList.indexOf(dirRealPath)).not.toBe(-1);
// $FlowIssue
client.dispose = () => {};
await client.unwatch(dirPath);
const afterCleanupWatchList = await client._watchList();
expect(afterCleanupWatchList.indexOf(dirRealPath)).toBe(-1);
expect(client.hasSubscription(dirPath)).toBeFalsy();
// Didn't remove it from the watched directories.
const noWatchListCleanup = await client._watchList();
expect(noWatchListCleanup.indexOf(dirRealPath)).not.toBe(-1);
});

@@ -94,11 +169,2 @@ });

describe('version()', () => {
it('We need version 3.1.0 or bigger', () => {
waitsForPromise(async () => {
const version = await client.version();
expect(version > '3.0.999').toBe(true);
});
});
});
describe('watchProject()', () => {

@@ -108,29 +174,12 @@ it('should be able to watch nested project folders, but cleanup watchRoot', () => {

const dirRealPath = fs.realpathSync(dirPath);
// The .watchmanconfig file, amonst others that could also be configured
// define the project root directory.
fs.writeFileSync(path.join(dirPath, '.watchmanconfig'), '');
const nestedDirPath = path.join(dirPath, 'nested');
fs.mkdirSync(nestedDirPath);
const {watch: watchRoot, relative_path: relativePath} = await client._watchProject(nestedDirPath);
const nestedDirPath = nuclideUri.join(dirPath, 'nested');
const {
watch: watchRoot,
relative_path: relativePath,
} = await client._watchProject(nestedDirPath);
expect(watchRoot).toBe(dirRealPath);
expect(relativePath).toBe('nested');
await client._deleteWatcher(watchRoot);
});
});
it('fails with meaningful error when the version is < 3.1.0', () => {
client._watchmanVersionPromise = Promise.resolve('1.0.0');
waitsForPromise(async () => {
let watchVersionError;
try {
await client._watchProject(dirPath)
} catch (error) {
watchVersionError = error;
}
expect(watchVersionError).toBeDefined();
invariant(watchVersionError);
expect(watchVersionError.message).toMatch(/^Watchman version/);
});
});
});
});
.babelrc
LICENSE

Sorry, the diff of this file is not supported yet

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

About

Packages

npm

Go

Maven

PyPI

Rubygems

Stay in touch

Get open source security insights delivered straight into your inbox.

  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc