gns3-web-ui/src/app/shared/services/symbol.service.ts

import { Injectable } from '@angular/core';
import { Observable } from 'rxjs/Observable';
import { BehaviorSubject } from "rxjs/BehaviorSubject";

import 'rxjs/add/operator/map';
import 'rxjs/add/observable/forkJoin';
import 'rxjs/add/observable/of';

import { Symbol } from '../models/symbol';
import { Server } from "../models/server";
import { HttpServer } from "./http-server.service";


@Injectable()
export class SymbolService {
  public symbols: BehaviorSubject<Symbol[]> = new BehaviorSubject<Symbol[]>([]);

  constructor(private httpServer: HttpServer) { }

  get(symbol_id: string): Symbol {
    return this.symbols
      .getValue()
      .find((symbol: Symbol) => symbol.symbol_id === symbol_id);
  }

  load(server: Server): Observable<Symbol[]> {
    this.list(server).subscribe((symbols: Symbol[]) => {
      const streams = symbols.map(symbol => this.raw(server, symbol.symbol_id));
      Observable.forkJoin(streams).subscribe((results: string[]) => {
        symbols.forEach((symbol: Symbol, i: number) => {
          symbol.raw = results[i];
        });
        this.symbols.next(symbols);
      });
    });
    return this.symbols.asObservable();
  }

  list(server: Server): Observable<Symbol[]> {
    return this.httpServer
                .get(server, '/symbols')
                .map(response => response.json() as Symbol[]);
  }

  raw(server: Server, symbol_id: string): Observable<string> {
    const encoded_uri = encodeURI(symbol_id);
    return this.httpServer
                .get(server, `/symbols/${encoded_uri}/raw`)
                .map(response => response.text() as string);
  }
}