1 import { Injectable, Inject } from '@angular/core';
2 import { HttpClient, HttpHeaders, HttpErrorResponse } from '@angular/common/http';
3 import { DOCUMENT } from '@angular/common';
4 import { Observable } from 'rxjs/Observable';
5 import { Subject } from 'rxjs/Subject';
6 import { BehaviorSubject } from 'rxjs/BehaviorSubject';
7 import * as io from 'socket.io-client';
9 import { AlertService } from './alert.service';
10 import { ISdk } from './sdk.service';
11 import { ProjectType, ProjectTypeEnum } from './project.service';
13 // Import RxJs required methods
14 import 'rxjs/add/operator/map';
15 import 'rxjs/add/operator/catch';
16 import 'rxjs/add/observable/throw';
17 import 'rxjs/add/operator/mergeMap';
18 import 'rxjs/add/observable/of';
19 import 'rxjs/add/operator/retryWhen';
22 export interface IXDSConfigProject {
25 clientSyncThingID: string;
28 defaultSdkID?: string;
31 interface IXDSBuilderConfig {
37 export interface IXDSProjectConfig {
43 type: ProjectTypeEnum;
49 export interface IXDSVer {
56 export interface IXDSVersions {
61 export interface IXDServerCfg {
70 export interface IXDSConfig {
71 servers: IXDServerCfg[];
74 export interface ISdkMessage {
80 export interface ICmdOutput {
87 export interface ICmdExit {
94 export interface IServerStatus {
99 export interface IAgentStatus {
101 servers: IServerStatus[];
106 export class XDSAgentService {
108 public XdsConfig$: Observable<IXDSConfig>;
109 public Status$: Observable<IAgentStatus>;
110 public ProjectState$ = <Subject<IXDSProjectConfig>>new Subject();
111 public CmdOutput$ = <Subject<ICmdOutput>>new Subject();
112 public CmdExit$ = <Subject<ICmdExit>>new Subject();
114 private baseUrl: string;
115 private wsUrl: string;
116 private _config = <IXDSConfig>{ servers: [] };
117 private _status = { connected: false, servers: [] };
119 private configSubject = <BehaviorSubject<IXDSConfig>>new BehaviorSubject(this._config);
120 private statusSubject = <BehaviorSubject<IAgentStatus>>new BehaviorSubject(this._status);
122 private socket: SocketIOClient.Socket;
124 constructor( @Inject(DOCUMENT) private document: Document,
125 private http: HttpClient, private alert: AlertService) {
127 this.XdsConfig$ = this.configSubject.asObservable();
128 this.Status$ = this.statusSubject.asObservable();
130 const originUrl = this.document.location.origin;
131 this.baseUrl = originUrl + '/api/v1';
133 const re = originUrl.match(/http[s]?:\/\/([^\/]*)[\/]?/);
134 if (re === null || re.length < 2) {
135 console.error('ERROR: cannot determine Websocket url');
137 this.wsUrl = 'ws://' + re[1];
138 this._handleIoSocket();
139 this._RegisterEvents();
143 private _NotifyXdsAgentState(sts: boolean) {
144 this._status.connected = sts;
145 this.statusSubject.next(Object.assign({}, this._status));
147 // Update XDS config including XDS Server list when connected
149 this.getConfig().subscribe(c => {
151 this._NotifyXdsServerState();
152 this.configSubject.next(Object.assign({ servers: [] }, this._config));
157 private _NotifyXdsServerState() {
158 this._status.servers = this._config.servers.map(svr => {
159 return { id: svr.id, connected: svr.connected };
161 this.statusSubject.next(Object.assign({}, this._status));
164 private _handleIoSocket() {
165 this.socket = io(this.wsUrl, { transports: ['websocket'] });
167 this.socket.on('connect_error', (res) => {
168 this._NotifyXdsAgentState(false);
169 console.error('XDS Agent WebSocket Connection error !');
172 this.socket.on('connect', (res) => {
173 this._NotifyXdsAgentState(true);
176 this.socket.on('disconnection', (res) => {
177 this._NotifyXdsAgentState(false);
178 this.alert.error('WS disconnection: ' + res);
181 this.socket.on('error', (err) => {
182 console.error('WS error:', err);
185 this.socket.on('make:output', data => {
186 this.CmdOutput$.next(Object.assign({}, <ICmdOutput>data));
189 this.socket.on('make:exit', data => {
190 this.CmdExit$.next(Object.assign({}, <ICmdExit>data));
193 this.socket.on('exec:output', data => {
194 this.CmdOutput$.next(Object.assign({}, <ICmdOutput>data));
197 this.socket.on('exec:exit', data => {
198 this.CmdExit$.next(Object.assign({}, <ICmdExit>data));
202 // (project-add and project-delete events are managed by project.service)
203 this.socket.on('event:server-config', ev => {
205 const cfg: IXDServerCfg = ev.data;
206 const idx = this._config.servers.findIndex(el => el.id === cfg.id);
208 this._config.servers[idx] = Object.assign({}, cfg);
209 this._NotifyXdsServerState();
211 this.configSubject.next(Object.assign({}, this._config));
215 this.socket.on('event:project-state-change', ev => {
217 this.ProjectState$.next(Object.assign({}, ev.data));
226 addEventListener(ev: string, fn: Function): SocketIOClient.Emitter {
227 return this.socket.addEventListener(ev, fn);
233 getVersion(): Observable<IXDSVersions> {
234 return this._get('/version');
240 getConfig(): Observable<IXDSConfig> {
241 return this._get('/config');
244 setConfig(cfg: IXDSConfig): Observable<IXDSConfig> {
245 return this._post('/config', cfg);
248 setServerRetry(serverID: string, retry: number): Observable<IXDSConfig> {
249 const svr = this._getServer(serverID);
251 return Observable.throw('Unknown server ID');
253 if (retry < 0 || Number.isNaN(retry) || retry == null) {
254 return Observable.throw('Not a valid number');
256 svr.connRetry = retry;
257 return this._setConfig();
260 setServerUrl(serverID: string, url: string, retry: number): Observable<IXDSConfig> {
261 const svr = this._getServer(serverID);
263 return Observable.throw('Unknown server ID');
265 svr.connected = false;
267 if (!Number.isNaN(retry) && retry > 0) {
268 svr.connRetry = retry;
270 this._NotifyXdsServerState();
271 return this._setConfig();
274 private _setConfig(): Observable<IXDSConfig> {
275 return this.setConfig(this._config)
277 this._config = newCfg;
278 this.configSubject.next(Object.assign({}, this._config));
286 getSdks(serverID: string): Observable<ISdk[]> {
287 const svr = this._getServer(serverID);
288 if (!svr || !svr.connected) {
289 return Observable.of([]);
292 return this._get(svr.partialUrl + '/sdks');
298 getProjects(): Observable<IXDSProjectConfig[]> {
299 return this._get('/projects');
302 addProject(cfg: IXDSProjectConfig): Observable<IXDSProjectConfig> {
303 return this._post('/projects', cfg);
306 deleteProject(id: string): Observable<IXDSProjectConfig> {
307 return this._delete('/projects/' + id);
310 syncProject(id: string): Observable<string> {
311 return this._post('/projects/sync/' + id, {});
317 exec(prjID: string, dir: string, cmd: string, sdkid?: string, args?: string[], env?: string[]): Observable<any> {
318 return this._post('/exec',
333 private _RegisterEvents() {
334 // Register to all existing events
335 this._post('/events/register', { 'name': 'event:all' })
339 this.alert.error('ERROR while registering to all events: ' + error);
344 private _getServer(ID: string): IXDServerCfg {
345 const svr = this._config.servers.filter(item => item.id === ID);
346 if (svr.length < 1) {
352 private _attachAuthHeaders(options?: any) {
353 options = options || {};
354 const headers = options.headers || new HttpHeaders();
355 // headers.append('Authorization', 'Basic ' + btoa('username:password'));
356 headers.append('Accept', 'application/json');
357 headers.append('Content-Type', 'application/json');
358 // headers.append('Access-Control-Allow-Origin', '*');
360 options.headers = headers;
364 private _get(url: string): Observable<any> {
365 return this.http.get(this.baseUrl + url, this._attachAuthHeaders())
366 .catch(this._decodeError);
368 private _post(url: string, body: any): Observable<any> {
369 return this.http.post(this.baseUrl + url, JSON.stringify(body), this._attachAuthHeaders())
371 return this._decodeError(error);
374 private _delete(url: string): Observable<any> {
375 return this.http.delete(this.baseUrl + url, this._attachAuthHeaders())
376 .catch(this._decodeError);
379 private _decodeError(err: any) {
381 if (err instanceof HttpErrorResponse) {
382 e = (err.error && err.error.error) ? err.error.error : err.message || 'Unknown error';
383 } else if (typeof err === 'object') {
384 if (err.statusText) {
386 } else if (err.error) {
387 e = String(err.error);
389 e = JSON.stringify(err);
392 e = err.message ? err.message : err.toString();
394 console.log('xdsagent.service - ERROR: ', e);
395 return Observable.throw(e);