New dashboard look & feel

[src/xds/xds-agent.git] / webapp / src / app / @core-xds / services / sdk.service.ts

diff --git a/webapp/src/app/@core-xds/services/sdk.service.ts b/webapp/src/app/@core-xds/services/sdk.service.ts
new file mode 100644 (file)
index 0000000..d1daa86
--- /dev/null
+++ b/webapp/src/app/@core-xds/services/sdk.service.ts
@@ -0,0 +1,66 @@
+import { Injectable, SecurityContext } from '@angular/core';
+import { Observable } from 'rxjs/Observable';
+import { BehaviorSubject } from 'rxjs/BehaviorSubject';
+
+import { XDSAgentService } from '../services/xdsagent.service';
+
+import 'rxjs/add/observable/throw';
+
+export interface ISdk {
+    id: string;
+    profile: string;
+    version: string;
+    arch: number;
+    path: string;
+}
+
+@Injectable()
+export class SdkService {
+    public Sdks$: Observable<ISdk[]>;
+
+    private _sdksList = [];
+    private current: ISdk;
+    private sdksSubject = <BehaviorSubject<ISdk[]>>new BehaviorSubject(this._sdksList);
+
+    constructor(private xdsSvr: XDSAgentService) {
+        this.current = null;
+        this.Sdks$ = this.sdksSubject.asObservable();
+
+        this.xdsSvr.XdsConfig$.subscribe(cfg => {
+            if (!cfg || cfg.servers.length < 1) {
+                return;
+            }
+            // FIXME support multiple server
+            // cfg.servers.forEach(svr => {
+            this.xdsSvr.getSdks(cfg.servers[0].id).subscribe((s) => {
+                this._sdksList = s;
+                this.sdksSubject.next(s);
+            });
+        });
+    }
+
+    public setCurrent(s: ISdk) {
+        this.current = s;
+    }
+
+    public getCurrent(): ISdk {
+        return this.current;
+    }
+
+    public getCurrentId(): string {
+        if (this.current && this.current.id) {
+            return this.current.id;
+        }
+        return '';
+    }
+
+    public add(sdk: ISdk): Observable<ISdk> {
+      // TODO SEB
+      return Observable.throw('Not implement yet');
+    }
+
+    public delete(sdk: ISdk): Observable<ISdk> {
+      // TODO SEB
+      return Observable.throw('Not implement yet');
+    }
+}