blob: e1b26b310eb880a8719396a88fa6f7d22208eaa8 [file] [log] [blame]
Matteo Scandolofb46ae62017-08-08 09:10:50 -07001
2/*
3 * Copyright 2017-present Open Networking Foundation
4
5 * Licensed under the Apache License, Version 2.0 (the "License");
6 * you may not use this file except in compliance with the License.
7 * You may obtain a copy of the License at
8
9 * http://www.apache.org/licenses/LICENSE-2.0
10
11 * Unless required by applicable law or agreed to in writing, software
12 * distributed under the License is distributed on an "AS IS" BASIS,
13 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14 * See the License for the specific language governing permissions and
15 * limitations under the License.
16 */
17
18
Matteo Scandolo63e43eb2016-12-14 14:18:53 -080019/// <reference path="../../../../typings/index.d.ts"/>
20
Matteo Scandolof2c3ed62016-12-15 14:32:50 -080021import {Subject, Observable} from 'rxjs/Rx';
Matteo Scandolo63e43eb2016-12-14 14:18:53 -080022import {IWSEvent, IWSEventService} from '../websocket/global';
23
Matteo Scandolof2c3ed62016-12-15 14:32:50 -080024export interface IStoreService {
25 query(): Observable<any>;
26}
27
Matteo Scandolo63e43eb2016-12-14 14:18:53 -080028export class SynchronizerStore {
29 static $inject = ['WebSocket'];
30 private _notifications: Subject<IWSEvent> = new Subject();
31 constructor(
32 private webSocket: IWSEventService
33 ) {
34 this.webSocket.list()
35 .filter((e: IWSEvent) => {
Matteo Scandolo4e870232017-01-30 13:43:05 -080036 if (!e.msg || !e.msg.changed_fields) {
37 return false;
38 }
Matteo Scandoloe6f9c352017-09-01 12:19:56 -070039 return (e.msg.changed_fields.indexOf('backend_status') > -1 || e.msg.changed_fields.indexOf('backend_code') > -1) && !e.skip_notification;
Matteo Scandolo63e43eb2016-12-14 14:18:53 -080040 })
41 .subscribe(
42 (event: IWSEvent) => {
43 this._notifications.next(event);
44 }
45 );
46 }
47
48 query() {
49 return this._notifications.asObservable();
50 }
51}