webapp/src/app/@core-xds/services/supervision.service.ts

   1 /**
   2 * @license
   3 * Copyright (C) 2018 "IoT.bzh"
   4 * Author Sebastien Douheret <sebastien@iot.bzh>
   5 *
   6 * Licensed under the Apache License, Version 2.0 (the "License");
   7 * you may not use this file except in compliance with the License.
   8 * You may obtain a copy of the License at
   9 *
  10 *   http://www.apache.org/licenses/LICENSE-2.0
  11 *
  12 * Unless required by applicable law or agreed to in writing, software
  13 * distributed under the License is distributed on an "AS IS" BASIS,
  14 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  15 * See the License for the specific language governing permissions and
  16 * limitations under the License.
  17 */
  18
  19 import { Injectable, SecurityContext, isDevMode } from '@angular/core';
  20 import { Observable } from 'rxjs/Observable';
  21
  22 import { XDSAgentService } from '../services/xdsagent.service';
  23
  24 export interface AglTopology {
  25   name: string;
  26   pid: number;
  27   isClient: boolean;
  28   isServer: boolean;
  29   ws_clients: string[];
  30   ws_servers: string[];
  31   apis: any;
  32 }
  33
  34 @Injectable()
  35 export class SupervisionService {
  36
  37   private curServerID;
  38
  39   constructor(private xdsSvr: XDSAgentService) {
  40     /*
  41     this.xdsSvr.XdsConfig$.subscribe(cfg => {
  42       if (!cfg || cfg.servers.length < 1) {
  43         return;
  44       }
  45     });
  46     */
  47   }
  48
  49   getTopo(): Observable<AglTopology[]> {
  50     return this.xdsSvr.getTopoSupervisor();
  51   }
  52
  53   startTrace(cfg: any): Observable<any> {
  54     return this.xdsSvr.startTraceSupervisor(cfg);
  55   }
  56
  57   stopTrace(cfg: any): Observable<any> {
  58     return this.xdsSvr.stopTraceSupervisor(cfg);
  59   }
  60
  61 }