1 | 'use strict';
|
2 |
|
3 | Object.defineProperty(exports, "__esModule", {
|
4 | value: true
|
5 | });
|
6 |
|
7 | require('cli-engine-config');
|
8 |
|
9 | var _rwlockfile = require('rwlockfile');
|
10 |
|
11 | var _rwlockfile2 = _interopRequireDefault(_rwlockfile);
|
12 |
|
13 | var _path = require('path');
|
14 |
|
15 | var _path2 = _interopRequireDefault(_path);
|
16 |
|
17 | var _cliUx = require('cli-ux');
|
18 |
|
19 | function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
|
20 |
|
21 | class Lock {
|
22 |
|
23 | constructor(config) {
|
24 | this.config = config;
|
25 | this.cli = new _cliUx.CLI({ mock: config.mock });
|
26 | }
|
27 |
|
28 | get updatelockfile() {
|
29 | return _path2.default.join(this.config.cacheDir, 'update.lock');
|
30 | }
|
31 |
|
32 |
|
33 | async read() {
|
34 | return _rwlockfile2.default.read(this.updatelockfile);
|
35 | }
|
36 |
|
37 | async unread() {
|
38 | await _rwlockfile2.default.unread(this.updatelockfile);
|
39 | }
|
40 |
|
41 | async canRead() {
|
42 | let hasWriter = await _rwlockfile2.default.hasWriter(this.updatelockfile);
|
43 | return !hasWriter;
|
44 | }
|
45 |
|
46 |
|
47 | async upgrade() {
|
48 |
|
49 | await this.unread();
|
50 |
|
51 |
|
52 | if (await _rwlockfile2.default.hasReaders(this.updatelockfile)) {
|
53 | this.cli.action.status = `Waiting for all commands to finish`;
|
54 | }
|
55 |
|
56 |
|
57 | let unlock = await _rwlockfile2.default.write(this.updatelockfile);
|
58 |
|
59 |
|
60 | return async () => {
|
61 |
|
62 | await unlock();
|
63 | return _rwlockfile2.default.read(this.updatelockfile);
|
64 | };
|
65 | }
|
66 | }
|
67 | exports.default = Lock; |
\ | No newline at end of file |