blob: 10c4d2ed352027b64f90a8af4cf0469053c951ff [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 Scandolof2c3ed62016-12-15 14:32:50 -080019/// <reference path="../../../../typings/index.d.ts"/>
Matteo Scandolo86bc26a2017-01-18 11:06:47 -080020import * as _ from 'lodash';
Matteo Scandolof2c3ed62016-12-15 14:32:50 -080021import {BehaviorSubject, Observable} from 'rxjs/Rx';
22import {IWSEvent, IWSEventService} from '../websocket/global';
23import {IXosResourceService} from '../rest/model.rest';
24import {IStoreHelpersService} from '../helpers/store.helpers';
Matteo Scandoloba0d92e2017-03-02 16:47:46 -080025import {IXosDebouncer} from '../../core/services/helpers/debounce.helper';
Matteo Scandolo0e171f32017-09-26 17:21:41 -070026import {IXosModeldefsCache} from '../helpers/modeldefs.service';
Matteo Scandolof2c3ed62016-12-15 14:32:50 -080027
Matteo Scandolo47860fe2017-02-02 12:05:55 -080028export interface IXosModelStoreService {
Matteo Scandolo1aee1982017-02-17 08:33:23 -080029 query(model: string, apiUrl?: string): Observable<any>;
Matteo Scandolo5d962a32017-08-01 18:16:14 -070030 get(model: string, id: string | number): Observable<any>;
Matteo Scandolo86bc26a2017-01-18 11:06:47 -080031 search(modelName: string): any[];
Matteo Scandolof2c3ed62016-12-15 14:32:50 -080032}
33
Matteo Scandolo1aee1982017-02-17 08:33:23 -080034export class XosModelStore implements IXosModelStoreService {
Matteo Scandolo0e171f32017-09-26 17:21:41 -070035 static $inject = [
36 '$log',
37 'WebSocket',
38 'StoreHelpers',
39 'ModelRest',
40 'XosDebouncer',
41 'XosModeldefsCache'
42 ];
Matteo Scandolof9dd4d02016-12-22 15:17:01 -080043 private _collections: any; // NOTE contains a map of {model: BehaviourSubject}
Matteo Scandoloba0d92e2017-03-02 16:47:46 -080044 private efficientNext: any; // NOTE debounce next
Matteo Scandolof2c3ed62016-12-15 14:32:50 -080045 constructor(
Matteo Scandolo17bf8242017-01-23 17:30:39 -080046 private $log: ng.ILogService,
Matteo Scandolof2c3ed62016-12-15 14:32:50 -080047 private webSocket: IWSEventService,
48 private storeHelpers: IStoreHelpersService,
Matteo Scandolobac22452017-01-03 16:35:32 -080049 private ModelRest: IXosResourceService,
Matteo Scandolo0e171f32017-09-26 17:21:41 -070050 private XosDebouncer: IXosDebouncer,
51 private XosModeldefsCache: IXosModeldefsCache
Matteo Scandolof2c3ed62016-12-15 14:32:50 -080052 ) {
Matteo Scandolof9dd4d02016-12-22 15:17:01 -080053 this._collections = {};
Matteo Scandolo968e7f22017-03-03 11:49:18 -080054 this.efficientNext = this.XosDebouncer.debounce(this.next, 500, this, false);
Matteo Scandolof2c3ed62016-12-15 14:32:50 -080055 }
56
Matteo Scandolo5d962a32017-08-01 18:16:14 -070057 public query(modelName: string, apiUrl?: string): Observable<any> {
Matteo Scandolo04a34a12017-09-12 10:37:48 -070058 this.$log.debug(`[XosModelStore] QUERY: ${modelName}`);
Matteo Scandolof9dd4d02016-12-22 15:17:01 -080059 // if there isn't already an observable for that item
Matteo Scandolo042ea632017-03-01 19:02:34 -080060 // create a new one and .next() is called by this.loadInitialData once data are received
Matteo Scandolo1aee1982017-02-17 08:33:23 -080061 if (!this._collections[modelName]) {
62 this._collections[modelName] = new BehaviorSubject([]); // NOTE maybe this can be created when we get response from the resource
63 this.loadInitialData(modelName, apiUrl);
Matteo Scandolof9dd4d02016-12-22 15:17:01 -080064 }
Matteo Scandolo0f3692e2017-07-10 14:06:41 -070065 // else manually trigger the next with the last know value to trigger the subscribe method of who's requesting this data
Matteo Scandolo042ea632017-03-01 19:02:34 -080066 else {
Matteo Scandolo04a34a12017-09-12 10:37:48 -070067 this.$log.debug(`[XosModelStore] QUERY: Calling "next" on: ${modelName}`);
Matteo Scandoloba0d92e2017-03-02 16:47:46 -080068 this.efficientNext(this._collections[modelName]);
Matteo Scandolo042ea632017-03-01 19:02:34 -080069 }
Matteo Scandolof9dd4d02016-12-22 15:17:01 -080070
Matteo Scandolo0e171f32017-09-26 17:21:41 -070071 // NOTE do we need to subscriber every time we query?
Matteo Scandolof2c3ed62016-12-15 14:32:50 -080072 this.webSocket.list()
Matteo Scandolo1aee1982017-02-17 08:33:23 -080073 .filter((e: IWSEvent) => e.model === modelName)
Matteo Scandolof2c3ed62016-12-15 14:32:50 -080074 .subscribe(
75 (event: IWSEvent) => {
Matteo Scandolo1aee1982017-02-17 08:33:23 -080076 this.storeHelpers.updateCollection(event, this._collections[modelName]);
Matteo Scandoloa4a47112016-12-16 10:06:13 -080077 },
Matteo Scandolo38e94a82017-03-02 12:17:27 -080078 err => this.$log.error
Matteo Scandolof2c3ed62016-12-15 14:32:50 -080079 );
Matteo Scandolof9dd4d02016-12-22 15:17:01 -080080
Matteo Scandolo1aee1982017-02-17 08:33:23 -080081 return this._collections[modelName].asObservable();
Matteo Scandolof2c3ed62016-12-15 14:32:50 -080082 }
83
Matteo Scandolo86bc26a2017-01-18 11:06:47 -080084 public search(modelName: string): any[] {
Matteo Scandolo1aee1982017-02-17 08:33:23 -080085 try {
86 const res = _.reduce(Object.keys(this._collections), (results, k) => {
87 let partialRes;
88 // NOTE wrapped in a try catch as some subject may be errored, due to not available REST endpoint
89 try {
90 partialRes = _.filter(this._collections[k].value, i => {
91 if (i && i.humanReadableName) {
92 return i.humanReadableName.toLowerCase().indexOf(modelName) > -1;
93 }
94 else if (i && i.name) {
95 return i.name.toLowerCase().indexOf(modelName) > -1;
96 }
97 return false;
98 });
99 } catch (e) {
100 partialRes = [];
Matteo Scandolo86bc26a2017-01-18 11:06:47 -0800101 }
Matteo Scandolo1aee1982017-02-17 08:33:23 -0800102 partialRes.map(m => {
Matteo Scandolo86bc26a2017-01-18 11:06:47 -0800103 m.modelName = k;
104 return m;
105 });
Matteo Scandolo1aee1982017-02-17 08:33:23 -0800106 return results.concat(partialRes);
107 }, []);
108 return res;
109 } catch (e) {
110 return [];
111 }
Matteo Scandolo86bc26a2017-01-18 11:06:47 -0800112 }
113
Matteo Scandolo5d962a32017-08-01 18:16:14 -0700114 public get(modelName: string, modelId: string | number): Observable<any> {
Matteo Scandolo04a34a12017-09-12 10:37:48 -0700115 this.$log.debug(`[XosModelStore] GET: ${modelName} [${modelId}]`);
116 const subject = new BehaviorSubject({});
Matteo Scandolo5d962a32017-08-01 18:16:14 -0700117
Matteo Scandolo04a34a12017-09-12 10:37:48 -0700118 if (angular.isString(modelId)) {
119 modelId = parseInt(modelId, 10);
120 }
Matteo Scandolo5d962a32017-08-01 18:16:14 -0700121
Matteo Scandolo04a34a12017-09-12 10:37:48 -0700122 this.query(modelName)
123 .subscribe((res) => {
124 const model = _.find(res, {id: modelId});
125 if (model) {
126 this.$log.debug(`[XosModelStore] GET: Calling "next" on: ${modelName} [${modelId}]`);
127 subject.next(model);
128 }
129 });
Matteo Scandolo5d962a32017-08-01 18:16:14 -0700130
131 return subject.asObservable();
Matteo Scandolo04964232017-01-07 12:53:46 -0800132 }
133
Matteo Scandoloba0d92e2017-03-02 16:47:46 -0800134 private next(subject: BehaviorSubject<any>): void {
135 subject.next(subject.value);
136 }
137
Matteo Scandolo1aee1982017-02-17 08:33:23 -0800138 private loadInitialData(model: string, apiUrl?: string) {
Matteo Scandolo5d962a32017-08-01 18:16:14 -0700139 // TODO provide always the apiUrl together with the query() params
Matteo Scandolo1aee1982017-02-17 08:33:23 -0800140 if (!angular.isDefined(apiUrl)) {
Matteo Scandolo0e171f32017-09-26 17:21:41 -0700141 apiUrl = this.XosModeldefsCache.getApiUrlFromModel(this.XosModeldefsCache.get(model));
Matteo Scandolo1aee1982017-02-17 08:33:23 -0800142 }
143 this.ModelRest.getResource(apiUrl).query().$promise
Matteo Scandolof2c3ed62016-12-15 14:32:50 -0800144 .then(
145 res => {
Matteo Scandolof9dd4d02016-12-22 15:17:01 -0800146 this._collections[model].next(res);
Matteo Scandolo17bf8242017-01-23 17:30:39 -0800147 })
148 .catch(
Matteo Scandolo1aee1982017-02-17 08:33:23 -0800149 err => {
150 this._collections[model].error(err);
Matteo Scandolo1aee1982017-02-17 08:33:23 -0800151 }
Matteo Scandolof2c3ed62016-12-15 14:32:50 -0800152 );
153 }
154}