1 import { Injectable, Inject, isDevMode } 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;
50 export interface IXDSVer {
57 export interface IXDSVersions {
62 export interface IXDServerCfg {
71 export interface IXDSConfig {
72 servers: IXDServerCfg[];
75 export interface ISdkMessage {
81 export interface ICmdOutput {
88 export interface ICmdExit {
95 export interface IServerStatus {
100 export interface IAgentStatus {
102 servers: IServerStatus[];
107 export class XDSAgentService {
109 public XdsConfig$: Observable<IXDSConfig>;
110 public Status$: Observable<IAgentStatus>;
111 public CmdOutput$ = <Subject<ICmdOutput>>new Subject();
112 public CmdExit$ = <Subject<ICmdExit>>new Subject();
114 protected projectAdd$ = new Subject<IXDSProjectConfig>();
115 protected projectDel$ = new Subject<IXDSProjectConfig>();
116 protected projectChange$ = new Subject<IXDSProjectConfig>();
118 private baseUrl: string;
119 private wsUrl: string;
120 private httpSessionID: string;
121 private _config = <IXDSConfig>{ servers: [] };
122 private _status = { connected: false, servers: [] };
124 private configSubject = <BehaviorSubject<IXDSConfig>>new BehaviorSubject(this._config);
125 private statusSubject = <BehaviorSubject<IAgentStatus>>new BehaviorSubject(this._status);
127 private socket: SocketIOClient.Socket;
129 constructor( @Inject(DOCUMENT) private document: Document,
130 private http: HttpClient, private alert: AlertService) {
132 this.XdsConfig$ = this.configSubject.asObservable();
133 this.Status$ = this.statusSubject.asObservable();
135 const originUrl = this.document.location.origin;
136 this.baseUrl = originUrl + '/api/v1';
138 // Retrieve Session ID / token
139 this.http.get(this.baseUrl + '/version', { observe: 'response' })
142 this.httpSessionID = resp.headers.get('xds-agent-sid');
144 const re = originUrl.match(/http[s]?:\/\/([^\/]*)[\/]?/);
145 if (re === null || re.length < 2) {
146 console.error('ERROR: cannot determine Websocket url');
148 this.wsUrl = 'ws://' + re[1];
149 this._handleIoSocket();
150 this._RegisterEvents();
154 /* tslint:disable:no-console */
155 console.error('ERROR while retrieving session id:', err);
159 private _NotifyXdsAgentState(sts: boolean) {
160 this._status.connected = sts;
161 this.statusSubject.next(Object.assign({}, this._status));
163 // Update XDS config including XDS Server list when connected
165 this.getConfig().subscribe(c => {
167 this._NotifyXdsServerState();
168 this.configSubject.next(Object.assign({ servers: [] }, this._config));
173 private _NotifyXdsServerState() {
174 this._status.servers = this._config.servers.map(svr => {
175 return { id: svr.id, connected: svr.connected };
177 this.statusSubject.next(Object.assign({}, this._status));
180 private _handleIoSocket() {
181 this.socket = io(this.wsUrl, { transports: ['websocket'] });
183 this.socket.on('connect_error', (res) => {
184 this._NotifyXdsAgentState(false);
185 console.error('XDS Agent WebSocket Connection error !');
188 this.socket.on('connect', (res) => {
189 this._NotifyXdsAgentState(true);
192 this.socket.on('disconnection', (res) => {
193 this._NotifyXdsAgentState(false);
194 this.alert.error('WS disconnection: ' + res);
197 this.socket.on('error', (err) => {
198 console.error('WS error:', err);
201 // XDS Events decoding
203 this.socket.on('make:output', data => {
204 this.CmdOutput$.next(Object.assign({}, <ICmdOutput>data));
207 this.socket.on('make:exit', data => {
208 this.CmdExit$.next(Object.assign({}, <ICmdExit>data));
211 this.socket.on('exec:output', data => {
212 this.CmdOutput$.next(Object.assign({}, <ICmdOutput>data));
215 this.socket.on('exec:exit', data => {
216 this.CmdExit$.next(Object.assign({}, <ICmdExit>data));
219 this.socket.on('event:server-config', ev => {
221 const cfg: IXDServerCfg = ev.data;
222 const idx = this._config.servers.findIndex(el => el.id === cfg.id);
224 this._config.servers[idx] = Object.assign({}, cfg);
225 this._NotifyXdsServerState();
227 this.configSubject.next(Object.assign({}, this._config));
231 this.socket.on('event:project-add', (ev) => {
232 if (ev && ev.data && ev.data.id) {
233 this.projectAdd$.next(Object.assign({}, ev.data));
234 if (ev.sessionID !== this.httpSessionID && ev.data.label) {
235 this.alert.info('Project "' + ev.data.label + '" has been added by another tool.');
237 } else if (isDevMode) {
238 /* tslint:disable:no-console */
239 console.log('Warning: received event:project-add with unknown data: ev=', ev);
243 this.socket.on('event:project-delete', (ev) => {
244 if (ev && ev.data && ev.data.id) {
245 this.projectDel$.next(Object.assign({}, ev.data));
246 if (ev.sessionID !== this.httpSessionID && ev.data.label) {
247 this.alert.info('Project "' + ev.data.label + '" has been deleted by another tool.');
249 } else if (isDevMode) {
250 console.log('Warning: received event:project-delete with unknown data: ev=', ev);
254 this.socket.on('event:project-state-change', ev => {
256 this.projectChange$.next(Object.assign({}, ev.data));
257 } else if (isDevMode) {
258 console.log('Warning: received event:project-state-change with unknown data: ev=', ev);
265 ** Events registration
267 onProjectAdd(): Observable<IXDSProjectConfig> {
268 return this.projectAdd$.asObservable();
271 onProjectDelete(): Observable<IXDSProjectConfig> {
272 return this.projectDel$.asObservable();
275 onProjectChange(): Observable<IXDSProjectConfig> {
276 return this.projectChange$.asObservable();
282 getVersion(): Observable<IXDSVersions> {
283 return this._get('/version');
289 getConfig(): Observable<IXDSConfig> {
290 return this._get('/config');
293 setConfig(cfg: IXDSConfig): Observable<IXDSConfig> {
294 return this._post('/config', cfg);
297 setServerRetry(serverID: string, retry: number): Observable<IXDSConfig> {
298 const svr = this._getServer(serverID);
300 return Observable.throw('Unknown server ID');
302 if (retry < 0 || Number.isNaN(retry) || retry == null) {
303 return Observable.throw('Not a valid number');
305 svr.connRetry = retry;
306 return this._setConfig();
309 setServerUrl(serverID: string, url: string, retry: number): Observable<IXDSConfig> {
310 const svr = this._getServer(serverID);
312 return Observable.throw('Unknown server ID');
314 svr.connected = false;
316 if (!Number.isNaN(retry) && retry > 0) {
317 svr.connRetry = retry;
319 this._NotifyXdsServerState();
320 return this._setConfig();
323 private _setConfig(): Observable<IXDSConfig> {
324 return this.setConfig(this._config)
326 this._config = newCfg;
327 this.configSubject.next(Object.assign({}, this._config));
335 getSdks(serverID: string): Observable<ISdk[]> {
336 const svr = this._getServer(serverID);
337 if (!svr || !svr.connected) {
338 return Observable.of([]);
341 return this._get(svr.partialUrl + '/sdks');
347 getProjects(): Observable<IXDSProjectConfig[]> {
348 return this._get('/projects');
351 addProject(cfg: IXDSProjectConfig): Observable<IXDSProjectConfig> {
352 return this._post('/projects', cfg);
355 deleteProject(id: string): Observable<IXDSProjectConfig> {
356 return this._delete('/projects/' + id);
359 updateProject(cfg: IXDSProjectConfig): Observable<IXDSProjectConfig> {
360 return this._put('/projects/' + cfg.id, cfg);
363 syncProject(id: string): Observable<string> {
364 return this._post('/projects/sync/' + id, {});
370 exec(prjID: string, dir: string, cmd: string, sdkid?: string, args?: string[], env?: string[]): Observable<any> {
371 return this._post('/exec',
386 private _RegisterEvents() {
387 // Register to all existing events
388 this._post('/events/register', { 'name': 'event:all' })
392 this.alert.error('ERROR while registering to all events: ' + error);
397 private _getServer(ID: string): IXDServerCfg {
398 const svr = this._config.servers.filter(item => item.id === ID);
399 if (svr.length < 1) {
405 private _attachAuthHeaders(options?: any) {
406 options = options || {};
407 const headers = options.headers || new HttpHeaders();
408 // headers.append('Authorization', 'Basic ' + btoa('username:password'));
409 headers.append('Accept', 'application/json');
410 headers.append('Content-Type', 'application/json');
411 // headers.append('Access-Control-Allow-Origin', '*');
413 options.headers = headers;
417 private _get(url: string): Observable<any> {
418 return this.http.get(this.baseUrl + url, this._attachAuthHeaders())
419 .catch(this._decodeError);
421 private _post(url: string, body: any): Observable<any> {
422 return this.http.post(this.baseUrl + url, JSON.stringify(body), this._attachAuthHeaders())
424 return this._decodeError(error);
427 private _put(url: string, body: any): Observable<any> {
428 return this.http.put(this.baseUrl + url, JSON.stringify(body), this._attachAuthHeaders())
430 return this._decodeError(error);
433 private _delete(url: string): Observable<any> {
434 return this.http.delete(this.baseUrl + url, this._attachAuthHeaders())
435 .catch(this._decodeError);
438 private _decodeError(err: any) {
440 if (err instanceof HttpErrorResponse) {
441 e = (err.error && err.error.error) ? err.error.error : err.message || 'Unknown error';
442 } else if (typeof err === 'object') {
443 if (err.statusText) {
445 } else if (err.error) {
446 e = String(err.error);
448 e = JSON.stringify(err);
451 e = err.message ? err.message : err.toString();
453 /* tslint:disable:no-console */
455 console.log('xdsagent.service - ERROR: ', e);
457 return Observable.throw(e);