Rsync events

che-theia-init-sources.yml

@@ -14,6 +14,7 @@ sources:
     - extensions/eclipse-che-theia-git-provisioner
     - extensions/eclipse-che-theia-logging
     - extensions/eclipse-che-theia-messaging
+    - extensions/eclipse-che-theia-sync-file-tracker
   plugins:
     - plugins/containers-plugin
     - plugins/workspace-plugin

extensions/eclipse-che-theia-sync-file-tracker/.gitignore

@@ -0,0 +1 @@
+lib/

extensions/eclipse-che-theia-sync-file-tracker/README.md

@@ -0,0 +1,13 @@
+# theia-file-sync-tracker extension
+
+This extension tracks events of file synchronization progress during workspace startup.
+
+### How does the extension work?
+
+If workspace configured to use asynchronous storage extension will open websocket connection to special service and show progress in status bar. In case some error, error message will show in status bar after clicking will appear popup with error details. After successfully file synchronization status bar also will update with corresponding message, in this case message will disappear in 5 seconds.
+
+## Technical info
+
+TBD
+
+

extensions/eclipse-che-theia-sync-file-tracker/package.json

@@ -0,0 +1,30 @@
+{
+  "name": "@eclipse-che/theia-file-sync-tracker",
+  "keywords": [
+    "theia-extension"
+  ],
+  "version": "1.0.0",
+  "files": [
+    "lib",
+    "src"
+  ],
+  "dependencies": {
+    "@theia/core": "next",
+    "@eclipse-che/theia-plugin-ext": "^0.0.1"
+  },
+  "scripts": {
+    "prepare": "yarn clean && yarn build",
+    "clean": "rimraf lib",
+    "format": "tsfmt -r --useTsfmt ../../configs/tsfmt.json",
+    "lint": "eslint --cache=true --no-error-on-unmatched-pattern=true \"{src,test}/**/*.{ts,tsx}\"",
+    "compile": "tsc",
+    "build": "concurrently -n \"format,lint,compile\" -c \"red,green,blue\" \"yarn format\" \"yarn lint\" \"yarn compile\"",
+    "watch": "tsc -w"
+  },
+  "license": "EPL-2.0",
+  "theiaExtensions": [
+    {
+      "frontend": "lib/browser/che-theia-sync-file-frontend-module"
+    }
+  ]
+}

extensions/eclipse-che-theia-sync-file-tracker/src/browser/che-theia-sync-file-frontend-module.ts

@@ -0,0 +1,24 @@
+/********************************************************************************
+ * Copyright (C) 2020 Red Hat, Inc. and others.
+ *
+ * This program and the accompanying materials are made available under the
+ * terms of the Eclipse Public License v. 2.0 which is available at
+ * http://www.eclipse.org/legal/epl-2.0.
+ *
+ * This Source Code may also be made available under the following Secondary
+ * Licenses when the conditions for such availability set forth in the Eclipse
+ * Public License v. 2.0 are satisfied: GNU General Public License, version 2
+ * with the GNU Classpath Exception which is available at
+ * https://www.gnu.org/software/classpath/license.html.
+ *
+ * SPDX-License-Identifier: EPL-2.0 OR GPL-2.0 WITH Classpath-exception-2.0
+ ********************************************************************************/
+
+import { ContainerModule } from 'inversify';
+import { FrontendApplicationContribution } from '@theia/core/lib/browser';
+import { StatusBarFrontendContribution } from './status-bar-contribution';
+
+export default new ContainerModule(bind => {
+
+    bind(FrontendApplicationContribution).to(StatusBarFrontendContribution).inSingletonScope();
+});

extensions/eclipse-che-theia-sync-file-tracker/src/browser/status-bar-contribution.ts

@@ -0,0 +1,116 @@
+/********************************************************************************
+ * Copyright (C) 2020 Red Hat, Inc. and others.
+ *
+ * This program and the accompanying materials are made available under the
+ * terms of the Eclipse Public License v. 2.0 which is available at
+ * http://www.eclipse.org/legal/epl-2.0.
+ *
+ * This Source Code may also be made available under the following Secondary
+ * Licenses when the conditions for such availability set forth in the Eclipse
+ * Public License v. 2.0 are satisfied: GNU General Public License, version 2
+ * with the GNU Classpath Exception which is available at
+ * https://www.gnu.org/software/classpath/license.html.
+ *
+ * SPDX-License-Identifier: EPL-2.0 OR GPL-2.0 WITH Classpath-exception-2.0
+ ********************************************************************************/
+
+import { injectable, inject, postConstruct } from 'inversify';
+import { FrontendApplicationContribution } from '@theia/core/lib/browser';
+import { MessageService } from '@theia/core/lib/common';
+import { StatusBar, StatusBarAlignment, StatusBarEntry } from '@theia/core/lib/browser/status-bar/status-bar';
+import { CheApiService } from '@eclipse-che/theia-plugin-ext/lib/common/che-protocol';
+import URI from '@theia/core/lib/common/uri';
+import ReconnectingWebSocket from 'reconnecting-websocket';
+import { DisposableCollection, Disposable } from '@theia/core';
+
+@injectable()
+export class StatusBarFrontendContribution implements FrontendApplicationContribution {
+
+    @inject(StatusBar)
+    private statusBar: StatusBar;
+    @inject(MessageService)
+    protected readonly messageService: MessageService;
+    @inject(CheApiService)
+    protected cheApiService: CheApiService;
+    private readonly ID = 'file-synchronization-indicator-id';
+    protected readonly statusBarDisposable = new DisposableCollection();
+
+    private readonly tooltip = 'File synchronization progress';
+    private readonly fail = 'File synchronization fail';
+    private readonly done = 'File synchronization done';
+
+    @postConstruct()
+    async initialize(): Promise<void> {
+        const url = await this.getWorkspaceService();
+        this.connect(url);
+    }
+
+    async getWorkspaceService(): Promise<string> {
+        const server = await this.cheApiService.findUniqueServerByAttribute('type', 'rsync');
+        if (server) {
+            return new URI(server.url + '/track').toString();
+        } else {
+            return Promise.reject('Server rsync not found');
+        }
+    }
+
+    private connect(endpointAdress: string): void {
+        const websocket = new ReconnectingWebSocket(endpointAdress, undefined, {
+            maxRetries: Infinity,
+        });
+        websocket.onerror = err => {
+            console.log(err);
+        };
+        websocket.onmessage = ev => {
+            this.updateStatusBar(ev.data, websocket);
+        };
+        websocket.onclose = () => console.log('File synchronization tracking connection closed');
+        websocket.onopen = () => console.log('File synchronization tracking connection opened');
+    };
+
+    private updateStatusBar(data: string, websocket: ReconnectingWebSocket): void {
+        this.statusBarDisposable.dispose();
+        const obj = JSON.parse(data);
+        if (obj.state === 'DONE') {
+            websocket.close();
+            this.setStatusBarEntry(this.ID, {
+                text: this.done,
+                tooltip: this.tooltip,
+                alignment: StatusBarAlignment.LEFT,
+                onclick: (e: MouseEvent) => this.messageService.info(this.done),
+                priority: 150
+            });
+            (async () => {
+                await this.delay(5000); // hide message in 5 sec
+                this.statusBarDisposable.dispose();
+            })();
+        } else if (obj.state === 'ERROR') {
+            websocket.close();
+            this.setStatusBarEntry(this.ID, {
+                text: this.fail,
+                tooltip: this.tooltip,
+                alignment: StatusBarAlignment.LEFT,
+                onclick: (e: MouseEvent) => this.messageService.error(obj.info),
+                priority: 150
+            });
+        } else {
+            const msg = `File synchronization progress: ${obj.info}`;
+            this.setStatusBarEntry(this.ID, {
+                text: msg,
+                tooltip: this.tooltip,
+                alignment: StatusBarAlignment.LEFT,
+                onclick: (e: MouseEvent) => this.messageService.info(msg),
+                priority: 150
+            });
+        }
+    }
+
+    private setStatusBarEntry(id: string, entry: StatusBarEntry): void {
+        this.statusBar.setElement(id, entry);
+        this.statusBarDisposable.push(Disposable.create(() => this.statusBar.removeElement(id)));
+    }
+
+    private delay(ms: number): Promise<void> {
+        return new Promise(resolve => setTimeout(resolve, ms));
+    }
+}

extensions/eclipse-che-theia-sync-file-tracker/tsconfig.json

@@ -0,0 +1,14 @@
+{
+    "extends": "../../configs/base.tsconfig.json",
+    "compilerOptions": {
+        "lib": [
+            "es6",
+            "dom"
+        ],
+        "rootDir": "src",
+        "outDir": "lib"
+    },
+    "include": [
+        "src"
+    ]
+}