1 | "use strict";
|
2 |
|
3 |
|
4 |
|
5 |
|
6 |
|
7 |
|
8 |
|
9 |
|
10 |
|
11 |
|
12 |
|
13 |
|
14 |
|
15 |
|
16 |
|
17 | Object.defineProperty(exports, "__esModule", { value: true });
|
18 | exports.ProgressStatusBarItem = void 0;
|
19 | const tslib_1 = require("tslib");
|
20 | const inversify_1 = require("inversify");
|
21 | const common_1 = require("../common");
|
22 | const status_bar_1 = require("./status-bar");
|
23 | const promise_util_1 = require("../common/promise-util");
|
24 | const throttle = require("lodash.throttle");
|
25 | let ProgressStatusBarItem = class ProgressStatusBarItem {
|
26 | constructor() {
|
27 | this.id = 'theia-progress-status-bar-item';
|
28 | this.messagesByProgress = new Map();
|
29 | this.incomingQueue = new Array();
|
30 | this.triggerUpdate = throttle(() => this.update(this.currentProgress), 250, { leading: true, trailing: true });
|
31 | }
|
32 | get currentProgress() {
|
33 | return this.incomingQueue.slice(-1)[0];
|
34 | }
|
35 | showProgress(progressId, message, cancellationToken) {
|
36 | const result = new promise_util_1.Deferred();
|
37 | cancellationToken.onCancellationRequested(() => {
|
38 | this.processEvent(progressId, 'done');
|
39 | result.resolve(common_1.ProgressMessage.Cancel);
|
40 | });
|
41 | this.processEvent(progressId, 'start', message.text);
|
42 | return result.promise;
|
43 | }
|
44 | processEvent(progressId, event, message) {
|
45 | if (event === 'start') {
|
46 | this.incomingQueue.push(progressId);
|
47 | this.messagesByProgress.set(progressId, message);
|
48 | }
|
49 | else {
|
50 | this.incomingQueue = this.incomingQueue.filter(id => id !== progressId);
|
51 | this.messagesByProgress.delete(progressId);
|
52 | }
|
53 | this.triggerUpdate();
|
54 | }
|
55 | async reportProgress(progressId, update, originalMessage, _cancellationToken) {
|
56 | const newMessage = update.message ? `${originalMessage.text}: ${update.message}` : originalMessage.text;
|
57 | this.messagesByProgress.set(progressId, newMessage);
|
58 | this.triggerUpdate();
|
59 | }
|
60 | update(progressId) {
|
61 | const message = progressId && this.messagesByProgress.get(progressId);
|
62 | if (!progressId || !message) {
|
63 | this.statusBar.removeElement(this.id);
|
64 | return;
|
65 | }
|
66 | const text = `$(codicon-sync~spin) ${message}`;
|
67 | this.statusBar.setElement(this.id, {
|
68 | text,
|
69 | alignment: status_bar_1.StatusBarAlignment.LEFT,
|
70 | priority: 1
|
71 | });
|
72 | }
|
73 | };
|
74 | (0, tslib_1.__decorate)([
|
75 | (0, inversify_1.inject)(status_bar_1.StatusBar),
|
76 | (0, tslib_1.__metadata)("design:type", Object)
|
77 | ], ProgressStatusBarItem.prototype, "statusBar", void 0);
|
78 | ProgressStatusBarItem = (0, tslib_1.__decorate)([
|
79 | (0, inversify_1.injectable)()
|
80 | ], ProgressStatusBarItem);
|
81 | exports.ProgressStatusBarItem = ProgressStatusBarItem;
|
82 |
|
\ | No newline at end of file |