From 125285e696b7631e33d3f10e375e7c64ad16d660 Mon Sep 17 00:00:00 2001 From: Ziya SARIKAYA Date: Mon, 25 Jan 2016 23:29:58 +0200 Subject: [PATCH] delete lib folder --- lib/consul-provider.js | 204 -------------------------------------- lib/consul-rest-client.js | 171 -------------------------------- 2 files changed, 375 deletions(-) delete mode 100644 lib/consul-provider.js delete mode 100644 lib/consul-rest-client.js diff --git a/lib/consul-provider.js b/lib/consul-provider.js deleted file mode 100644 index 3e8f14d..0000000 --- a/lib/consul-provider.js +++ /dev/null @@ -1,204 +0,0 @@ -'use strict'; - -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; }; }(); - -Object.defineProperty(exports, "__esModule", { - value: true -}); - -var _microphoneCore = require('microphone-core'); - -var _cron = require('cron'); - -function _classCallCheck(instance, Constructor) { if (!(instance instanceof Constructor)) { throw new TypeError("Cannot call a class as a function"); } } - -function _possibleConstructorReturn(self, call) { if (!self) { throw new ReferenceError("this hasn't been initialised - super() hasn't been called"); } return call && (typeof call === "object" || typeof call === "function") ? call : self; } - -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; } - -var ConsulProvider = function (_ClusterProvider) { - _inherits(ConsulProvider, _ClusterProvider); - - function ConsulProvider(client, logger) { - _classCallCheck(this, ConsulProvider); - - var _this = _possibleConstructorReturn(this, Object.getPrototypeOf(ConsulProvider).call(this)); - - _this._client = client; - _this._logger = logger; - - _this._serviceName = ""; - _this._serviceId = ""; - _this._version = ""; - _this._uri = ""; - _this._useEbayFabio = false; - return _this; - } - - _createClass(ConsulProvider, [{ - key: 'findServiceInstancesAsync', - value: function findServiceInstancesAsync(name) { - return regeneratorRuntime.async(function findServiceInstancesAsync$(_context) { - while (1) { - switch (_context.prev = _context.next) { - case 0: - if (!(this._useEbayFabio === true)) { - _context.next = 2; - break; - } - - return _context.abrupt('return', [new _microphoneCore.ServiceInformation("http://localhost", 9999)]); - - case 2: - return _context.abrupt('return', this._client.findServiceAsync(name)); - - case 3: - case 'end': - return _context.stop(); - } - } - }, null, this); - } - }, { - key: 'registerServiceAsync', - value: function registerServiceAsync(serviceName, serviceId, version, uri) { - return regeneratorRuntime.async(function registerServiceAsync$(_context2) { - while (1) { - switch (_context2.prev = _context2.next) { - case 0: - this._serviceName = serviceName; - this._serviceId = serviceId; - this._version = version; - this._uri = uri; - _context2.next = 6; - return regeneratorRuntime.awrap(this._client.registerServiceAsync(serviceName, serviceId, uri)); - - case 6: - - this.__startReaper(); - - case 7: - case 'end': - return _context2.stop(); - } - } - }, null, this); - } - }, { - key: 'bootstrapClientAsync', - value: function bootstrapClientAsync() { - return regeneratorRuntime.async(function bootstrapClientAsync$(_context3) { - while (1) { - switch (_context3.prev = _context3.next) { - case 0: - this.__startReaper(); - - //Task.FromResult(0); - return _context3.abrupt('return', new Promise(function (resolve, reject) { - return resolve({}); - })); - - case 2: - case 'end': - return _context3.stop(); - } - } - }, null, this); - } - }, { - key: '__startReaper', - value: function __startReaper() { - function actionCompleteHandler(err, httpResponse, body) { - //noop - } - - var lookup = []; - - function onTick() { - var res, criticalServiceId; - return regeneratorRuntime.async(function onTick$(_context4) { - while (1) { - switch (_context4.prev = _context4.next) { - case 0: - if (this._port > 0) this._client.setPort(this._port); - - _context4.prev = 1; - _context4.next = 4; - return regeneratorRuntime.awrap(this._client.getCriticalServicesAsync()); - - case 4: - res = _context4.sent; - _context4.t0 = regeneratorRuntime.keys(res); - - case 6: - if ((_context4.t1 = _context4.t0()).done) { - _context4.next = 18; - break; - } - - criticalServiceId = _context4.t1.value; - - if (!(lookup.indexOf(criticalServiceId) !== -1)) { - _context4.next = 14; - break; - } - - _context4.next = 11; - return regeneratorRuntime.awrap(c.unRegisterServiceAsync(criticalServiceId)); - - case 11: - this._logger.info('Reaper: Removing ' + criticalServiceId); - _context4.next = 16; - break; - - case 14: - lookup.push(criticalServiceId); - this._logger.info('Reaper: Marking ' + criticalServiceId); - - case 16: - _context4.next = 6; - break; - - case 18: - - //remove entries that are no longer critical - lookup.filter(function (serviceId) { - return !(lookup.indexOf(serviceId) !== -1); - }); - - _context4.next = 24; - break; - - case 21: - _context4.prev = 21; - _context4.t2 = _context4['catch'](1); - - this._logger.error(_context4.t2, "Crashed"); - - case 24: - case 'end': - return _context4.stop(); - } - } - }, null, this, [[1, 21]]); - } - - try { - var job = new _cron.CronJob({ - cronTime: "*/5 * * * * *" /*every 5 seconds*/ - , onTick: onTick.bind(this), - start: false - }); - - job.start(); - this._logger.info("Reaper: started.."); - } catch (ex) { - this._logger.error(ex); - } - } - }]); - - return ConsulProvider; -}(_microphoneCore.ClusterProvider); - -exports.default = ConsulProvider; \ No newline at end of file diff --git a/lib/consul-rest-client.js b/lib/consul-rest-client.js deleted file mode 100644 index 5cfd9ea..0000000 --- a/lib/consul-rest-client.js +++ /dev/null @@ -1,171 +0,0 @@ -'use strict'; - -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; }; }(); - -Object.defineProperty(exports, "__esModule", { - value: true -}); - -var _request = require('request'); - -var _request2 = _interopRequireDefault(_request); - -var _os = require('os'); - -var _os2 = _interopRequireDefault(_os); - -var _microphoneCore = require('microphone-core'); - -function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; } - -function _classCallCheck(instance, Constructor) { if (!(instance instanceof Constructor)) { throw new TypeError("Cannot call a class as a function"); } } - -var DEFAULT_PORT = 8500; -var DEFAULT_HOST = 'http://localhost'; - -var ConsulRestClient = function () { - function ConsulRestClient(address, port) { - _classCallCheck(this, ConsulRestClient); - - this._address = address || DEFAULT_HOST; - this._port = port || DEFAULT_PORT; - } - - _createClass(ConsulRestClient, [{ - key: 'registerServiceAsync', - value: function registerServiceAsync(serviceName, serviceId, address) { - var payload, options; - return regeneratorRuntime.async(function registerServiceAsync$(_context) { - while (1) { - switch (_context.prev = _context.next) { - case 0: - payload = { - ID: serviceId, - Name: serviceName, - Tags: ['urlprefix-/' + serviceName], - Address: _os2.default.hostname(), - Port: address.Port, - Check: { - HTTP: address + 'status', - Interval: "1s" - } - }; - options = { - uri: this._address + ':' + this._port + '/v1/agent/service/register', - type: 'POST', - json: payload - }; - _context.next = 4; - return regeneratorRuntime.awrap(this.__request(options, "Could not register service")); - - case 4: - case 'end': - return _context.stop(); - } - } - }, null, this); - } - }, { - key: 'findServiceAsync', - value: function findServiceAsync(serviceName) { - var options, serviceArray; - return regeneratorRuntime.async(function findServiceAsync$(_context2) { - while (1) { - switch (_context2.prev = _context2.next) { - case 0: - options = { - uri: this._address + ':' + this._port + '/v1/health/service/' + serviceName, - type: 'GET' - }; - _context2.t0 = JSON; - _context2.next = 4; - return regeneratorRuntime.awrap(this.__request(options, "Could not find services")); - - case 4: - _context2.t1 = _context2.sent; - serviceArray = _context2.t0.parse.call(_context2.t0, _context2.t1); - return _context2.abrupt('return', serviceArray.map(function (svcItem) { - return new _microphoneCore.ServiceInformation(svcItem["Service"]["Address"], svcItem["Service"]["Port"]); - })); - - case 7: - case 'end': - return _context2.stop(); - } - } - }, null, this); - } - }, { - key: 'getCriticalServicesAsync', - value: function getCriticalServicesAsync() { - var options, serviceArray; - return regeneratorRuntime.async(function getCriticalServicesAsync$(_context3) { - while (1) { - switch (_context3.prev = _context3.next) { - case 0: - options = { - uri: this._address + ':' + this._port + '/v1/health/state/critical', - type: 'GET' - }; - _context3.t0 = JSON; - _context3.next = 4; - return regeneratorRuntime.awrap(this.__request(options, "Could not get service health")); - - case 4: - _context3.t1 = _context3.sent; - serviceArray = _context3.t0.parse.call(_context3.t0, _context3.t1); - return _context3.abrupt('return', serviceArray.map(function (svcItem) { - return svcItem["ServiceID"]; - })); - - case 7: - case 'end': - return _context3.stop(); - } - } - }, null, this); - } - }, { - key: 'unRegisterServiceAsync', - value: function unRegisterServiceAsync(serviceId) { - var options; - return regeneratorRuntime.async(function unRegisterServiceAsync$(_context4) { - while (1) { - switch (_context4.prev = _context4.next) { - case 0: - options = { - uri: this._address + ':' + this._port + '/v1/agent/service/deregister/' + serviceId, - type: 'GET' - }; - _context4.next = 3; - return regeneratorRuntime.awrap(this.__request(options, "Could not de register service")); - - case 3: - case 'end': - return _context4.stop(); - } - } - }, null, this); - } - }, { - key: 'setPort', - value: function setPort(port) { - this._port = port || DEFAULT_PORT; - } - }, { - key: '__request', - value: function __request(options, message) { - return new Promise(function (resolve, reject) { - (0, _request2.default)(options, function (error, response, body) { - if (error) return reject(new Error(message)); - - resolve(body); - }); - }); - } - }]); - - return ConsulRestClient; -}(); - -exports.default = ConsulRestClient; \ No newline at end of file