1 | "use strict";
|
2 |
|
3 | var _interopRequireDefault = require("@babel/runtime-corejs2/helpers/interopRequireDefault");
|
4 |
|
5 | var _regenerator = _interopRequireDefault(require("@babel/runtime-corejs2/regenerator"));
|
6 |
|
7 | var _asyncToGenerator2 = _interopRequireDefault(require("@babel/runtime-corejs2/helpers/asyncToGenerator"));
|
8 |
|
9 | var _bluebird = require("bluebird");
|
10 |
|
11 | var _asyncExitHook = _interopRequireDefault(require("async-exit-hook"));
|
12 |
|
13 | var _checkSetup = require("@sharyn/check-setup");
|
14 |
|
15 | var _env = require("@sharyn/env");
|
16 |
|
17 |
|
18 |
|
19 |
|
20 |
|
21 | var Redis = (0, _checkSetup.hasPackage)('redis', true) && require("".concat(_checkSetup.appRoot, "/node_modules/redis"));
|
22 |
|
23 | (0, _bluebird.promisifyAll)(Redis);
|
24 | var DEFAULT_REDIS_URL = 'redis://localhost:8379';
|
25 | var DEFAULT_TEST_REDIS_URL = 'redis://localhost:8380';
|
26 | var redis = Redis.createClient(_env.NODE_ENV === 'test' ? _env.TEST_REDIS_URL || DEFAULT_TEST_REDIS_URL : _env.REDIS_URL || DEFAULT_REDIS_URL);
|
27 |
|
28 | redis.on('error', function (err) {
|
29 | return console.error(err);
|
30 | });
|
31 | (0, _asyncExitHook.default)(
|
32 |
|
33 | function () {
|
34 | var _ref = (0, _asyncToGenerator2.default)(
|
35 |
|
36 | _regenerator.default.mark(function _callee(callback) {
|
37 | return _regenerator.default.wrap(function _callee$(_context) {
|
38 | while (1) {
|
39 | switch (_context.prev = _context.next) {
|
40 | case 0:
|
41 | _context.next = 2;
|
42 | return redis.quit();
|
43 |
|
44 | case 2:
|
45 | callback();
|
46 |
|
47 | case 3:
|
48 | case "end":
|
49 | return _context.stop();
|
50 | }
|
51 | }
|
52 | }, _callee, this);
|
53 | }));
|
54 |
|
55 | return function (_x) {
|
56 | return _ref.apply(this, arguments);
|
57 | };
|
58 | }());
|
59 | module.exports = redis; |
\ | No newline at end of file |