X-Git-Url: https://gerrit.automotivelinux.org/gerrit/gitweb?a=blobdiff_plain;f=webapp%2Fsrc%2Fapp%2Fservices%2Fxdsagent.service.ts;fp=webapp%2Fsrc%2Fapp%2Fservices%2Fxdsagent.service.ts;h=0000000000000000000000000000000000000000;hb=38c0c21a969e621c725245ce91c78e77076c5ce7;hp=55653c72c5dfc070e57c575f72d27d55c8f1a7e0;hpb=b0d130807fb9bf36f5ac1abe21cbd558eb86d5cc;p=src%2Fxds%2Fxds-agent.git

diff --git a/webapp/src/app/services/xdsagent.service.ts b/webapp/src/app/services/xdsagent.service.ts
deleted file mode 100644
index 55653c7..0000000
--- a/webapp/src/app/services/xdsagent.service.ts
+++ /dev/null
@@ -1,384 +0,0 @@
-import { Injectable, Inject } from '@angular/core';
-import { HttpClient, HttpHeaders, HttpErrorResponse } from '@angular/common/http';
-import { DOCUMENT } from '@angular/common';
-import { Observable } from 'rxjs/Observable';
-import { Subject } from 'rxjs/Subject';
-import { BehaviorSubject } from 'rxjs/BehaviorSubject';
-import * as io from 'socket.io-client';
-
-import { AlertService } from './alert.service';
-import { ISdk } from './sdk.service';
-import { ProjectType } from './project.service';
-
-// Import RxJs required methods
-import 'rxjs/add/operator/map';
-import 'rxjs/add/operator/catch';
-import 'rxjs/add/observable/throw';
-import 'rxjs/add/operator/mergeMap';
-import 'rxjs/add/observable/of';
-import 'rxjs/add/operator/retryWhen';
-
-
-export interface IXDSConfigProject {
-    id: string;
-    path: string;
-    clientSyncThingID: string;
-    type: string;
-    label?: string;
-    defaultSdkID?: string;
-}
-
-interface IXDSBuilderConfig {
-    ip: string;
-    port: string;
-    syncThingID: string;
-}
-
-export interface IXDSProjectConfig {
-    id: string;
-    serverId: string;
-    label: string;
-    clientPath: string;
-    serverPath?: string;
-    type: ProjectType;
-    status?: string;
-    isInSync?: boolean;
-    defaultSdkID: string;
-}
-
-export interface IXDSVer {
-    id: string;
-    version: string;
-    apiVersion: string;
-    gitTag: string;
-}
-
-export interface IXDSVersions {
-    client: IXDSVer;
-    servers: IXDSVer[];
-}
-
-export interface IXDServerCfg {
-    id: string;
-    url: string;
-    apiUrl: string;
-    partialUrl: string;
-    connRetry: number;
-    connected: boolean;
-}
-
-export interface IXDSConfig {
-    servers: IXDServerCfg[];
-}
-
-export interface ISdkMessage {
-    wsID: string;
-    msgType: string;
-    data: any;
-}
-
-export interface ICmdOutput {
-    cmdID: string;
-    timestamp: string;
-    stdout: string;
-    stderr: string;
-}
-
-export interface ICmdExit {
-    cmdID: string;
-    timestamp: string;
-    code: number;
-    error: string;
-}
-
-export interface IAgentStatus {
-    WS_connected: boolean;
-}
-
-
-@Injectable()
-export class XDSAgentService {
-
-    public XdsConfig$: Observable<IXDSConfig>;
-    public Status$: Observable<IAgentStatus>;
-    public ProjectState$ = <Subject<IXDSProjectConfig>>new Subject();
-    public CmdOutput$ = <Subject<ICmdOutput>>new Subject();
-    public CmdExit$ = <Subject<ICmdExit>>new Subject();
-
-    private baseUrl: string;
-    private wsUrl: string;
-    private _config = <IXDSConfig>{ servers: [] };
-    private _status = { WS_connected: false };
-
-    private configSubject = <BehaviorSubject<IXDSConfig>>new BehaviorSubject(this._config);
-    private statusSubject = <BehaviorSubject<IAgentStatus>>new BehaviorSubject(this._status);
-
-    private socket: SocketIOClient.Socket;
-
-    constructor( @Inject(DOCUMENT) private document: Document,
-        private http: HttpClient, private alert: AlertService) {
-
-        this.XdsConfig$ = this.configSubject.asObservable();
-        this.Status$ = this.statusSubject.asObservable();
-
-        const originUrl = this.document.location.origin;
-        this.baseUrl = originUrl + '/api/v1';
-
-        const re = originUrl.match(/http[s]?:\/\/([^\/]*)[\/]?/);
-        if (re === null || re.length < 2) {
-            console.error('ERROR: cannot determine Websocket url');
-        } else {
-            this.wsUrl = 'ws://' + re[1];
-            this._handleIoSocket();
-            this._RegisterEvents();
-        }
-    }
-
-    private _WSState(sts: boolean) {
-        this._status.WS_connected = sts;
-        this.statusSubject.next(Object.assign({}, this._status));
-
-        // Update XDS config including XDS Server list when connected
-        if (sts) {
-            this.getConfig().subscribe(c => {
-                this._config = c;
-                this.configSubject.next(
-                    Object.assign({ servers: [] }, this._config)
-                );
-            });
-        }
-    }
-
-    private _handleIoSocket() {
-        this.socket = io(this.wsUrl, { transports: ['websocket'] });
-
-        this.socket.on('connect_error', (res) => {
-            this._WSState(false);
-            console.error('XDS Agent WebSocket Connection error !');
-        });
-
-        this.socket.on('connect', (res) => {
-            this._WSState(true);
-        });
-
-        this.socket.on('disconnection', (res) => {
-            this._WSState(false);
-            this.alert.error('WS disconnection: ' + res);
-        });
-
-        this.socket.on('error', (err) => {
-            console.error('WS error:', err);
-        });
-
-        this.socket.on('make:output', data => {
-            this.CmdOutput$.next(Object.assign({}, <ICmdOutput>data));
-        });
-
-        this.socket.on('make:exit', data => {
-            this.CmdExit$.next(Object.assign({}, <ICmdExit>data));
-        });
-
-        this.socket.on('exec:output', data => {
-            this.CmdOutput$.next(Object.assign({}, <ICmdOutput>data));
-        });
-
-        this.socket.on('exec:exit', data => {
-            this.CmdExit$.next(Object.assign({}, <ICmdExit>data));
-        });
-
-        // Events
-        // (project-add and project-delete events are managed by project.service)
-        this.socket.on('event:server-config', ev => {
-            if (ev && ev.data) {
-                const cfg: IXDServerCfg = ev.data;
-                const idx = this._config.servers.findIndex(el => el.id === cfg.id);
-                if (idx >= 0) {
-                    this._config.servers[idx] = Object.assign({}, cfg);
-                }
-                this.configSubject.next(Object.assign({}, this._config));
-            }
-        });
-
-        this.socket.on('event:project-state-change', ev => {
-            if (ev && ev.data) {
-                this.ProjectState$.next(Object.assign({}, ev.data));
-            }
-        });
-
-    }
-
-    /**
-    ** Events
-    ***/
-    addEventListener(ev: string, fn: Function): SocketIOClient.Emitter {
-        return this.socket.addEventListener(ev, fn);
-    }
-
-    /**
-    ** Misc / Version
-    ***/
-    getVersion(): Observable<IXDSVersions> {
-        return this._get('/version');
-    }
-
-    /***
-    ** Config
-    ***/
-    getConfig(): Observable<IXDSConfig> {
-        return this._get('/config');
-    }
-
-    setConfig(cfg: IXDSConfig): Observable<IXDSConfig> {
-        return this._post('/config', cfg);
-    }
-
-    setServerRetry(serverID: string, r: number) {
-        const svr = this._getServer(serverID);
-        if (!svr) {
-            return Observable.of([]);
-        }
-
-        svr.connRetry = r;
-        this.setConfig(this._config).subscribe(
-            newCfg => {
-                this._config = newCfg;
-                this.configSubject.next(Object.assign({}, this._config));
-            },
-            err => {
-                this.alert.error(err);
-            }
-        );
-    }
-
-    setServerUrl(serverID: string, url: string) {
-        const svr = this._getServer(serverID);
-        if (!svr) {
-            return Observable.of([]);
-        }
-        svr.url = url;
-        this.setConfig(this._config).subscribe(
-            newCfg => {
-                this._config = newCfg;
-                this.configSubject.next(Object.assign({}, this._config));
-            },
-            err => {
-                this.alert.error(err);
-            }
-        );
-    }
-
-    /***
-    ** SDKs
-    ***/
-    getSdks(serverID: string): Observable<ISdk[]> {
-        const svr = this._getServer(serverID);
-        if (!svr || !svr.connected) {
-            return Observable.of([]);
-        }
-
-        return this._get(svr.partialUrl + '/sdks');
-    }
-
-    /***
-    ** Projects
-    ***/
-    getProjects(): Observable<IXDSProjectConfig[]> {
-        return this._get('/projects');
-    }
-
-    addProject(cfg: IXDSProjectConfig): Observable<IXDSProjectConfig> {
-        return this._post('/projects', cfg);
-    }
-
-    deleteProject(id: string): Observable<IXDSProjectConfig> {
-        return this._delete('/projects/' + id);
-    }
-
-    syncProject(id: string): Observable<string> {
-        return this._post('/projects/sync/' + id, {});
-    }
-
-    /***
-    ** Exec
-    ***/
-    exec(prjID: string, dir: string, cmd: string, sdkid?: string, args?: string[], env?: string[]): Observable<any> {
-        return this._post('/exec',
-            {
-                id: prjID,
-                rpath: dir,
-                cmd: cmd,
-                sdkID: sdkid || '',
-                args: args || [],
-                env: env || [],
-            });
-    }
-
-    /**
-    ** Private functions
-    ***/
-
-    private _RegisterEvents() {
-        // Register to all existing events
-        this._post('/events/register', { 'name': 'event:all' })
-            .subscribe(
-            res => { },
-            error => {
-                this.alert.error('ERROR while registering to all events: ' + error);
-            }
-            );
-    }
-
-    private _getServer(ID: string): IXDServerCfg {
-        const svr = this._config.servers.filter(item => item.id === ID);
-        if (svr.length < 1) {
-            return null;
-        }
-        return svr[0];
-    }
-
-    private _attachAuthHeaders(options?: any) {
-        options = options || {};
-        const headers = options.headers || new HttpHeaders();
-        // headers.append('Authorization', 'Basic ' + btoa('username:password'));
-        headers.append('Accept', 'application/json');
-        headers.append('Content-Type', 'application/json');
-        // headers.append('Access-Control-Allow-Origin', '*');
-
-        options.headers = headers;
-        return options;
-    }
-
-    private _get(url: string): Observable<any> {
-        return this.http.get(this.baseUrl + url, this._attachAuthHeaders())
-            .catch(this._decodeError);
-    }
-    private _post(url: string, body: any): Observable<any> {
-        return this.http.post(this.baseUrl + url, JSON.stringify(body), this._attachAuthHeaders())
-            .catch((error) => {
-                return this._decodeError(error);
-            });
-    }
-    private _delete(url: string): Observable<any> {
-        return this.http.delete(this.baseUrl + url, this._attachAuthHeaders())
-            .catch(this._decodeError);
-    }
-
-    private _decodeError(err: any) {
-        let e: string;
-        if (err instanceof HttpErrorResponse) {
-            e = (err.error && err.error.error) ? err.error.error : err.message || 'Unknown error';
-        } else if (typeof err === 'object') {
-            if (err.statusText) {
-                e = err.statusText;
-            } else if (err.error) {
-                e = String(err.error);
-            } else {
-                e = JSON.stringify(err);
-            }
-        } else {
-            e = err.message ? err.message : err.toString();
-        }
-        console.log('xdsagent.service - ERROR: ', e);
-        return Observable.throw(e);
-    }
-}