Show busy status when there are incomplete tasks

Signed-off-by: Rome Li <rome.li@microsoft.com>

Author: akaroml

src/extension.ts

@@ -27,6 +27,7 @@ import { logger, initializeLogFile } from './log';
 import glob = require('glob');
 import { serverTasks } from './serverTasks';
 import { serverTaskPresenter } from './serverTaskPresenter';
+import { serverStatus, ServerStatusKind } from './serverStatus';
 
 let languageClient: LanguageClient;
 const jdtEventEmitter = new EventEmitter<Uri>();
@@ -185,6 +186,17 @@ export function activate(context: ExtensionContext): Promise<ExtensionAPI> {
 
 				commands.executeCommand(Commands.SHOW_SERVER_TASK_STATUS);
 
+				serverStatus.initialize();
+				serverStatus.onServerStatusChanged(status => {
+					if (status === ServerStatusKind.Busy) {
+						item.text = '$(sync~spin)';
+					} else if (status === ServerStatusKind.Error) {
+						item.text = '$(thumbsdown)';
+					} else {
+						item.text = '$(thumbsup)';
+					}
+				});
+
 				let serverOptions;
 				const port = process.env['SERVER_PORT'];
 				if (!port) {
@@ -216,7 +228,7 @@ export function activate(context: ExtensionContext): Promise<ExtensionAPI> {
 					languageClient.onNotification(StatusNotification.type, (report) => {
 						switch (report.type) {
 							case 'Started':
-								item.text = '$(thumbsup)';
+								serverStatus.updateServerStatus(ServerStatusKind.Ready);
 								commands.executeCommand('setContext', 'javaLSReady', true);
 								resolve({
 									apiVersion: ExtensionApiVersion,
@@ -227,7 +239,7 @@ export function activate(context: ExtensionContext): Promise<ExtensionAPI> {
 								});
 								break;
 							case 'Error':
-								item.text = '$(thumbsdown)';
+								serverStatus.updateServerStatus(ServerStatusKind.Error);
 								toggleItem(window.activeTextEditor, item);
 								resolve({
 									apiVersion: ExtensionApiVersion,

src/serverStatus.ts

@@ -0,0 +1,47 @@
+import { EventEmitter } from "vscode";
+import { serverTasks } from "./serverTasks";
+
+export enum ServerStatusKind {
+	Ready = "Ready",
+	Error = "Error",
+	Busy = "Busy",
+}
+
+const _emitter = new EventEmitter<ServerStatusKind>();
+let _status: ServerStatusKind = ServerStatusKind.Ready;
+let _isBusy: boolean = false;
+
+function fireEvent() {
+	if (_isBusy) {
+		_emitter.fire(ServerStatusKind.Busy);
+		return;
+	}
+
+	_emitter.fire(_status);
+}
+
+export namespace serverStatus {
+	export enum ServerStatus {
+		Ready = "Ready",
+		Error = "Error",
+		Busy = "Busy",
+	}
+
+	export const onServerStatusChanged = _emitter.event;
+
+	export function initialize() {
+		serverTasks.onDidUpdateServerTask(tasks => {
+			_isBusy = tasks.some(task => !task.complete);
+			fireEvent();
+		});
+	}
+
+	export function updateServerStatus(status: ServerStatusKind) {
+		if (status === ServerStatusKind.Busy) {
+			throw new Error("Busy status cannot be set directly.");
+		}
+
+		_status = status;
+		fireEvent();
+	}
+}