Matteo Scandolo | 968e7f2 | 2017-03-03 11:49:18 -0800 | [diff] [blame] | 1 | import * as _ from 'lodash'; |
Matteo Scandolo | a160eef | 2017-03-06 17:21:26 -0800 | [diff] [blame] | 2 | import {Observable, BehaviorSubject, Subscription} from 'rxjs'; |
Matteo Scandolo | a62adbc | 2017-03-02 15:37:34 -0800 | [diff] [blame] | 3 | import {IXosModelStoreService} from '../../datasources/stores/model.store'; |
Matteo Scandolo | 968e7f2 | 2017-03-03 11:49:18 -0800 | [diff] [blame] | 4 | import { |
| 5 | IXosServiceGraph, IXosServiceModel, IXosTenantModel, IXosCoarseGraphData, |
Matteo Scandolo | 7517178 | 2017-03-08 14:17:01 -0800 | [diff] [blame] | 6 | IXosServiceGraphNode, IXosServiceGraphLink, IXosFineGrainedGraphData |
Matteo Scandolo | 968e7f2 | 2017-03-03 11:49:18 -0800 | [diff] [blame] | 7 | } from '../interfaces'; |
Matteo Scandolo | a62adbc | 2017-03-02 15:37:34 -0800 | [diff] [blame] | 8 | import {IXosDebouncer} from '../../core/services/helpers/debounce.helper'; |
Matteo Scandolo | 7629cc4 | 2017-03-13 14:12:15 -0700 | [diff] [blame] | 9 | import {IXosServiceGraphExtender, IXosServiceGraphReducer} from './graph.extender'; |
Matteo Scandolo | a62adbc | 2017-03-02 15:37:34 -0800 | [diff] [blame] | 10 | export interface IXosServiceGraphStore { |
| 11 | get(): Observable<IXosServiceGraph>; |
Matteo Scandolo | 968e7f2 | 2017-03-03 11:49:18 -0800 | [diff] [blame] | 12 | getCoarse(): Observable<IXosServiceGraph>; |
Matteo Scandolo | a62adbc | 2017-03-02 15:37:34 -0800 | [diff] [blame] | 13 | } |
| 14 | |
| 15 | export class XosServiceGraphStore implements IXosServiceGraphStore { |
| 16 | static $inject = [ |
| 17 | '$log', |
| 18 | 'XosModelStore', |
Matteo Scandolo | 7629cc4 | 2017-03-13 14:12:15 -0700 | [diff] [blame] | 19 | 'XosDebouncer', |
| 20 | 'XosServiceGraphExtender' |
Matteo Scandolo | a62adbc | 2017-03-02 15:37:34 -0800 | [diff] [blame] | 21 | ]; |
Matteo Scandolo | 968e7f2 | 2017-03-03 11:49:18 -0800 | [diff] [blame] | 22 | |
| 23 | // graph data store |
Matteo Scandolo | 7517178 | 2017-03-08 14:17:01 -0800 | [diff] [blame] | 24 | private graphData: BehaviorSubject<IXosFineGrainedGraphData> = new BehaviorSubject({ |
Matteo Scandolo | 968e7f2 | 2017-03-03 11:49:18 -0800 | [diff] [blame] | 25 | services: [], |
Matteo Scandolo | 7517178 | 2017-03-08 14:17:01 -0800 | [diff] [blame] | 26 | tenants: [], |
| 27 | networks: [], |
Matteo Scandolo | d487853 | 2017-03-20 17:39:55 -0700 | [diff] [blame] | 28 | subscribers: [], |
| 29 | servicedependencys: [] |
Matteo Scandolo | 968e7f2 | 2017-03-03 11:49:18 -0800 | [diff] [blame] | 30 | }); |
| 31 | |
Matteo Scandolo | 265c204 | 2017-03-20 10:15:40 -0700 | [diff] [blame] | 32 | private emptyGraph: IXosServiceGraph = { |
| 33 | nodes: [], |
| 34 | links: [] |
| 35 | }; |
| 36 | |
Matteo Scandolo | 7517178 | 2017-03-08 14:17:01 -0800 | [diff] [blame] | 37 | // representation of the graph as D3 requires |
Matteo Scandolo | 265c204 | 2017-03-20 10:15:40 -0700 | [diff] [blame] | 38 | private d3CoarseGraph = new BehaviorSubject(this.emptyGraph); |
| 39 | private d3FineGrainedGraph = new BehaviorSubject(this.emptyGraph); |
Matteo Scandolo | a62adbc | 2017-03-02 15:37:34 -0800 | [diff] [blame] | 40 | |
| 41 | // storing locally reference to the data model |
| 42 | private services; |
| 43 | private tenants; |
Matteo Scandolo | 7517178 | 2017-03-08 14:17:01 -0800 | [diff] [blame] | 44 | private subscribers; |
| 45 | private networks; |
Matteo Scandolo | d487853 | 2017-03-20 17:39:55 -0700 | [diff] [blame] | 46 | private servicedependencys; |
Matteo Scandolo | a62adbc | 2017-03-02 15:37:34 -0800 | [diff] [blame] | 47 | |
| 48 | // debounced functions |
| 49 | private handleData; |
| 50 | |
| 51 | // datastore |
Matteo Scandolo | a160eef | 2017-03-06 17:21:26 -0800 | [diff] [blame] | 52 | private ServiceSubscription: Subscription; |
| 53 | private TenantSubscription: Subscription; |
Matteo Scandolo | 7517178 | 2017-03-08 14:17:01 -0800 | [diff] [blame] | 54 | private SubscriberSubscription: Subscription; |
| 55 | private NetworkSubscription: Subscription; |
Matteo Scandolo | d487853 | 2017-03-20 17:39:55 -0700 | [diff] [blame] | 56 | private ServiceDependencySubscription: Subscription; |
Matteo Scandolo | a62adbc | 2017-03-02 15:37:34 -0800 | [diff] [blame] | 57 | |
| 58 | constructor ( |
| 59 | private $log: ng.ILogService, |
| 60 | private XosModelStore: IXosModelStoreService, |
Matteo Scandolo | 7629cc4 | 2017-03-13 14:12:15 -0700 | [diff] [blame] | 61 | private XosDebouncer: IXosDebouncer, |
| 62 | private XosServiceGraphExtender: IXosServiceGraphExtender |
Matteo Scandolo | a62adbc | 2017-03-02 15:37:34 -0800 | [diff] [blame] | 63 | ) { |
| 64 | |
Matteo Scandolo | 968e7f2 | 2017-03-03 11:49:18 -0800 | [diff] [blame] | 65 | this.$log.info(`[XosServiceGraphStore] Setup`); |
| 66 | |
Matteo Scandolo | a62adbc | 2017-03-02 15:37:34 -0800 | [diff] [blame] | 67 | // we want to have a quiet period of 500ms from the last event before doing anything |
Matteo Scandolo | 968e7f2 | 2017-03-03 11:49:18 -0800 | [diff] [blame] | 68 | this.handleData = this.XosDebouncer.debounce(this._handleData, 500, this, false); |
Matteo Scandolo | a62adbc | 2017-03-02 15:37:34 -0800 | [diff] [blame] | 69 | |
Matteo Scandolo | 968e7f2 | 2017-03-03 11:49:18 -0800 | [diff] [blame] | 70 | // observe models and populate graphData |
Matteo Scandolo | a160eef | 2017-03-06 17:21:26 -0800 | [diff] [blame] | 71 | this.ServiceSubscription = this.XosModelStore.query('Service', '/core/services') |
Matteo Scandolo | a62adbc | 2017-03-02 15:37:34 -0800 | [diff] [blame] | 72 | .subscribe( |
| 73 | (res) => { |
| 74 | this.combineData(res, 'services'); |
| 75 | }, |
| 76 | (err) => { |
Matteo Scandolo | 7517178 | 2017-03-08 14:17:01 -0800 | [diff] [blame] | 77 | this.$log.error(`[XosServiceGraphStore] Service Observable: `, err); |
Matteo Scandolo | a62adbc | 2017-03-02 15:37:34 -0800 | [diff] [blame] | 78 | } |
| 79 | ); |
| 80 | |
Matteo Scandolo | d487853 | 2017-03-20 17:39:55 -0700 | [diff] [blame] | 81 | this.ServiceDependencySubscription = this.XosModelStore.query('ServiceDependency', '/core/servicedependencys') |
| 82 | .subscribe( |
| 83 | (res) => { |
| 84 | this.combineData(res, 'servicedependencys'); |
| 85 | }, |
| 86 | (err) => { |
| 87 | this.$log.error(`[XosServiceGraphStore] Service Observable: `, err); |
| 88 | } |
| 89 | ); |
| 90 | |
Matteo Scandolo | a160eef | 2017-03-06 17:21:26 -0800 | [diff] [blame] | 91 | this.TenantSubscription = this.XosModelStore.query('Tenant', '/core/tenants') |
Matteo Scandolo | a62adbc | 2017-03-02 15:37:34 -0800 | [diff] [blame] | 92 | .subscribe( |
| 93 | (res) => { |
| 94 | this.combineData(res, 'tenants'); |
| 95 | }, |
| 96 | (err) => { |
Matteo Scandolo | 7517178 | 2017-03-08 14:17:01 -0800 | [diff] [blame] | 97 | this.$log.error(`[XosServiceGraphStore] Tenant Observable: `, err); |
Matteo Scandolo | a62adbc | 2017-03-02 15:37:34 -0800 | [diff] [blame] | 98 | } |
| 99 | ); |
Matteo Scandolo | 968e7f2 | 2017-03-03 11:49:18 -0800 | [diff] [blame] | 100 | |
Matteo Scandolo | 7517178 | 2017-03-08 14:17:01 -0800 | [diff] [blame] | 101 | this.SubscriberSubscription = this.XosModelStore.query('Subscriber', '/core/subscribers') |
Matteo Scandolo | 968e7f2 | 2017-03-03 11:49:18 -0800 | [diff] [blame] | 102 | .subscribe( |
Matteo Scandolo | 7517178 | 2017-03-08 14:17:01 -0800 | [diff] [blame] | 103 | (res) => { |
| 104 | this.combineData(res, 'subscribers'); |
| 105 | }, |
| 106 | (err) => { |
| 107 | this.$log.error(`[XosServiceGraphStore] Subscriber Observable: `, err); |
| 108 | } |
| 109 | ); |
| 110 | |
| 111 | this.NetworkSubscription = this.XosModelStore.query('Network', '/core/networks') |
| 112 | .subscribe( |
| 113 | (res) => { |
| 114 | this.combineData(res, 'networks'); |
Matteo Scandolo | 968e7f2 | 2017-03-03 11:49:18 -0800 | [diff] [blame] | 115 | }, |
| 116 | (err) => { |
| 117 | this.$log.error(`[XosServiceGraphStore] graphData Observable: `, err); |
| 118 | } |
| 119 | ); |
Matteo Scandolo | a62adbc | 2017-03-02 15:37:34 -0800 | [diff] [blame] | 120 | |
Matteo Scandolo | 7517178 | 2017-03-08 14:17:01 -0800 | [diff] [blame] | 121 | // observe graphData and build Coarse and FineGrained graphs |
| 122 | this.graphData |
| 123 | .subscribe( |
| 124 | (res: IXosFineGrainedGraphData) => { |
Matteo Scandolo | 98b5f5d | 2017-03-17 17:09:05 -0700 | [diff] [blame] | 125 | this.$log.debug(`[XosServiceGraphStore] New graph data received`, res); |
Matteo Scandolo | 7517178 | 2017-03-08 14:17:01 -0800 | [diff] [blame] | 126 | this.graphDataToCoarseGraph(res); |
| 127 | this.graphDataToFineGrainedGraph(res); |
| 128 | }, |
| 129 | (err) => { |
| 130 | this.$log.error(`[XosServiceGraphStore] graphData Observable: `, err); |
| 131 | } |
| 132 | ); |
Matteo Scandolo | a160eef | 2017-03-06 17:21:26 -0800 | [diff] [blame] | 133 | } |
| 134 | |
Matteo Scandolo | a62adbc | 2017-03-02 15:37:34 -0800 | [diff] [blame] | 135 | public get() { |
Matteo Scandolo | 968e7f2 | 2017-03-03 11:49:18 -0800 | [diff] [blame] | 136 | return this.d3FineGrainedGraph.asObservable(); |
| 137 | } |
| 138 | |
| 139 | public getCoarse() { |
| 140 | return this.d3CoarseGraph.asObservable(); |
Matteo Scandolo | a62adbc | 2017-03-02 15:37:34 -0800 | [diff] [blame] | 141 | } |
| 142 | |
Matteo Scandolo | d487853 | 2017-03-20 17:39:55 -0700 | [diff] [blame] | 143 | private combineData(data: any, type: 'services'|'tenants'|'subscribers'|'networks'|'servicedependencys') { |
Matteo Scandolo | a62adbc | 2017-03-02 15:37:34 -0800 | [diff] [blame] | 144 | switch (type) { |
| 145 | case 'services': |
| 146 | this.services = data; |
| 147 | break; |
| 148 | case 'tenants': |
| 149 | this.tenants = data; |
| 150 | break; |
Matteo Scandolo | 7517178 | 2017-03-08 14:17:01 -0800 | [diff] [blame] | 151 | case 'subscribers': |
| 152 | this.subscribers = data; |
| 153 | break; |
| 154 | case 'networks': |
| 155 | this.networks = data; |
| 156 | break; |
Matteo Scandolo | d487853 | 2017-03-20 17:39:55 -0700 | [diff] [blame] | 157 | case 'servicedependencys': |
| 158 | this.servicedependencys = data; |
| 159 | break; |
Matteo Scandolo | a62adbc | 2017-03-02 15:37:34 -0800 | [diff] [blame] | 160 | } |
| 161 | this.handleData(this.services, this.tenants); |
| 162 | } |
| 163 | |
| 164 | private _handleData(services: IXosServiceModel[], tenants: IXosTenantModel[]) { |
Matteo Scandolo | 968e7f2 | 2017-03-03 11:49:18 -0800 | [diff] [blame] | 165 | this.graphData.next({ |
| 166 | services: this.services, |
Matteo Scandolo | 7517178 | 2017-03-08 14:17:01 -0800 | [diff] [blame] | 167 | tenants: this.tenants, |
| 168 | subscribers: this.subscribers, |
Matteo Scandolo | d487853 | 2017-03-20 17:39:55 -0700 | [diff] [blame] | 169 | networks: this.networks, |
| 170 | servicedependencys: this.servicedependencys |
Matteo Scandolo | 968e7f2 | 2017-03-03 11:49:18 -0800 | [diff] [blame] | 171 | }); |
| 172 | } |
| 173 | |
Matteo Scandolo | 7517178 | 2017-03-08 14:17:01 -0800 | [diff] [blame] | 174 | private getNodeIndexById(id: number | string, nodes: IXosServiceModel[]) { |
Matteo Scandolo | 0c61c9b | 2017-03-03 11:49:18 -0800 | [diff] [blame] | 175 | return _.findIndex(nodes, {id: id}); |
| 176 | } |
| 177 | |
Matteo Scandolo | 7517178 | 2017-03-08 14:17:01 -0800 | [diff] [blame] | 178 | private d3Id(type: string, id: number) { |
| 179 | return `${type.toLowerCase()}~${id}`; |
| 180 | } |
| 181 | |
| 182 | private getTargetId(tenant: IXosTenantModel) { |
| 183 | |
| 184 | let targetId; |
| 185 | if (tenant.subscriber_service_id) { |
| 186 | targetId = this.d3Id('service', tenant.subscriber_service_id); |
| 187 | } |
| 188 | else if (tenant.subscriber_tenant_id) { |
| 189 | targetId = this.d3Id('tenant', tenant.subscriber_tenant_id); |
| 190 | } |
| 191 | else if (tenant.subscriber_network_id) { |
| 192 | targetId = this.d3Id('network', tenant.subscriber_network_id); |
| 193 | } |
| 194 | else if (tenant.subscriber_root_id) { |
| 195 | targetId = this.d3Id('subscriber', tenant.subscriber_root_id); |
| 196 | } |
| 197 | return targetId; |
| 198 | } |
| 199 | |
| 200 | private getSourceId(tenant: IXosTenantModel) { |
| 201 | return this.d3Id('service', tenant.provider_service_id); |
| 202 | } |
| 203 | |
| 204 | private getNodeType(n: any) { |
| 205 | return n.class_names.split(',')[0].toLowerCase(); |
| 206 | } |
| 207 | |
| 208 | private getNodeLabel(n: any) { |
| 209 | if (this.getNodeType(n) === 'tenant') { |
| 210 | return n.id; |
| 211 | } |
| 212 | return n.humanReadableName ? n.humanReadableName : n.name; |
| 213 | } |
| 214 | |
| 215 | private removeUnwantedFineGrainedData(data: IXosFineGrainedGraphData): IXosFineGrainedGraphData { |
| 216 | data.tenants = _.filter(data.tenants, t => t.kind !== 'coarse'); |
| 217 | data.networks = _.filter(data.networks, n => { |
| 218 | const subscriber = _.findIndex(data.tenants, {subscriber_network_id: n.id}); |
| 219 | return subscriber > -1; |
| 220 | }); |
| 221 | return data; |
| 222 | } |
| 223 | |
Matteo Scandolo | 968e7f2 | 2017-03-03 11:49:18 -0800 | [diff] [blame] | 224 | private graphDataToCoarseGraph(data: IXosCoarseGraphData) { |
Matteo Scandolo | 7517178 | 2017-03-08 14:17:01 -0800 | [diff] [blame] | 225 | |
Matteo Scandolo | 7629cc4 | 2017-03-13 14:12:15 -0700 | [diff] [blame] | 226 | try { |
Matteo Scandolo | d487853 | 2017-03-20 17:39:55 -0700 | [diff] [blame] | 227 | const links: IXosServiceGraphLink[] = _.chain(data.servicedependencys) |
Matteo Scandolo | 7629cc4 | 2017-03-13 14:12:15 -0700 | [diff] [blame] | 228 | .map((t: IXosTenantModel) => { |
| 229 | return { |
| 230 | id: t.id, |
| 231 | source: this.getNodeIndexById(t.provider_service_id, data.services), |
| 232 | target: this.getNodeIndexById(t.subscriber_service_id, data.services), |
| 233 | model: t |
| 234 | }; |
| 235 | }) |
| 236 | .value(); |
| 237 | |
| 238 | const nodes: IXosServiceGraphNode[] = _.map(data.services, (s: IXosServiceModel) => { |
Matteo Scandolo | 968e7f2 | 2017-03-03 11:49:18 -0800 | [diff] [blame] | 239 | return { |
Matteo Scandolo | 7629cc4 | 2017-03-13 14:12:15 -0700 | [diff] [blame] | 240 | id: s.id, |
| 241 | label: s.name, |
| 242 | model: s |
Matteo Scandolo | 968e7f2 | 2017-03-03 11:49:18 -0800 | [diff] [blame] | 243 | }; |
Matteo Scandolo | 7629cc4 | 2017-03-13 14:12:15 -0700 | [diff] [blame] | 244 | }); |
Matteo Scandolo | 968e7f2 | 2017-03-03 11:49:18 -0800 | [diff] [blame] | 245 | |
Matteo Scandolo | 7629cc4 | 2017-03-13 14:12:15 -0700 | [diff] [blame] | 246 | let graph: IXosServiceGraph = { |
| 247 | nodes, |
| 248 | links |
Matteo Scandolo | 968e7f2 | 2017-03-03 11:49:18 -0800 | [diff] [blame] | 249 | }; |
Matteo Scandolo | 968e7f2 | 2017-03-03 11:49:18 -0800 | [diff] [blame] | 250 | |
Matteo Scandolo | 7629cc4 | 2017-03-13 14:12:15 -0700 | [diff] [blame] | 251 | _.forEach(this.XosServiceGraphExtender.getCoarse(), (r: IXosServiceGraphReducer) => { |
| 252 | graph = r.reducer(graph); |
| 253 | }); |
| 254 | |
| 255 | this.d3CoarseGraph.next(graph); |
| 256 | } catch (e) { |
| 257 | this.d3CoarseGraph.error(e); |
| 258 | } |
Matteo Scandolo | a62adbc | 2017-03-02 15:37:34 -0800 | [diff] [blame] | 259 | } |
| 260 | |
Matteo Scandolo | 7517178 | 2017-03-08 14:17:01 -0800 | [diff] [blame] | 261 | private graphDataToFineGrainedGraph(data: IXosFineGrainedGraphData) { |
Matteo Scandolo | 7629cc4 | 2017-03-13 14:12:15 -0700 | [diff] [blame] | 262 | try { |
| 263 | data = this.removeUnwantedFineGrainedData(data); |
Matteo Scandolo | 7517178 | 2017-03-08 14:17:01 -0800 | [diff] [blame] | 264 | |
Matteo Scandolo | 7629cc4 | 2017-03-13 14:12:15 -0700 | [diff] [blame] | 265 | let nodes = _.reduce(Object.keys(data), (list: any[], k: string) => { |
| 266 | return list.concat(data[k]); |
| 267 | }, []); |
Matteo Scandolo | 7517178 | 2017-03-08 14:17:01 -0800 | [diff] [blame] | 268 | |
Matteo Scandolo | 7629cc4 | 2017-03-13 14:12:15 -0700 | [diff] [blame] | 269 | nodes = _.chain(nodes) |
| 270 | .map(n => { |
| 271 | n.d3Id = this.d3Id(this.getNodeType(n), n.id); |
| 272 | return n; |
| 273 | }) |
| 274 | .map(n => { |
| 275 | let node: IXosServiceGraphNode = { |
| 276 | id: n.d3Id, |
| 277 | label: this.getNodeLabel(n), |
| 278 | model: n, |
| 279 | type: this.getNodeType(n) |
| 280 | }; |
| 281 | return node; |
| 282 | }) |
| 283 | .value(); |
| 284 | |
| 285 | const links = _.reduce(data.tenants, (links: IXosServiceGraphLink[], tenant: IXosTenantModel) => { |
| 286 | const sourceId = this.getSourceId(tenant); |
| 287 | const targetId = this.getTargetId(tenant); |
| 288 | |
| 289 | if (!angular.isDefined(targetId)) { |
| 290 | // if the tenant is not pointing to anything, don't draw links |
| 291 | return links; |
| 292 | } |
| 293 | |
| 294 | const tenantToProvider = { |
| 295 | id: `${sourceId}_${tenant.d3Id}`, |
| 296 | source: this.getNodeIndexById(sourceId, nodes), |
| 297 | target: this.getNodeIndexById(tenant.d3Id, nodes), |
| 298 | model: tenant |
Matteo Scandolo | 7517178 | 2017-03-08 14:17:01 -0800 | [diff] [blame] | 299 | }; |
Matteo Scandolo | 7517178 | 2017-03-08 14:17:01 -0800 | [diff] [blame] | 300 | |
Matteo Scandolo | 7629cc4 | 2017-03-13 14:12:15 -0700 | [diff] [blame] | 301 | const tenantToSubscriber = { |
| 302 | id: `${tenant.d3Id}_${targetId}`, |
| 303 | source: this.getNodeIndexById(tenant.d3Id, nodes), |
| 304 | target: this.getNodeIndexById(targetId, nodes), |
| 305 | model: tenant |
| 306 | }; |
Matteo Scandolo | 7517178 | 2017-03-08 14:17:01 -0800 | [diff] [blame] | 307 | |
Matteo Scandolo | 7629cc4 | 2017-03-13 14:12:15 -0700 | [diff] [blame] | 308 | links.push(tenantToProvider); |
| 309 | links.push(tenantToSubscriber); |
Matteo Scandolo | 6d3e80e | 2017-03-10 11:34:43 -0800 | [diff] [blame] | 310 | return links; |
Matteo Scandolo | 7629cc4 | 2017-03-13 14:12:15 -0700 | [diff] [blame] | 311 | }, []); |
| 312 | |
Matteo Scandolo | 265c204 | 2017-03-20 10:15:40 -0700 | [diff] [blame] | 313 | if (nodes.length === 0 && links.length === 0) { |
Matteo Scandolo | 7629cc4 | 2017-03-13 14:12:15 -0700 | [diff] [blame] | 314 | return; |
Matteo Scandolo | 6d3e80e | 2017-03-10 11:34:43 -0800 | [diff] [blame] | 315 | } |
| 316 | |
Matteo Scandolo | 7629cc4 | 2017-03-13 14:12:15 -0700 | [diff] [blame] | 317 | let graph: IXosServiceGraph = { |
| 318 | nodes, |
| 319 | links |
Matteo Scandolo | 7517178 | 2017-03-08 14:17:01 -0800 | [diff] [blame] | 320 | }; |
| 321 | |
Matteo Scandolo | 7629cc4 | 2017-03-13 14:12:15 -0700 | [diff] [blame] | 322 | _.forEach(this.XosServiceGraphExtender.getFinegrained(), (r: IXosServiceGraphReducer) => { |
| 323 | graph = r.reducer(graph); |
| 324 | }); |
Matteo Scandolo | 7629cc4 | 2017-03-13 14:12:15 -0700 | [diff] [blame] | 325 | this.d3FineGrainedGraph.next(graph); |
| 326 | } catch (e) { |
| 327 | this.d3FineGrainedGraph.error(e); |
Matteo Scandolo | 7517178 | 2017-03-08 14:17:01 -0800 | [diff] [blame] | 328 | } |
Matteo Scandolo | 7517178 | 2017-03-08 14:17:01 -0800 | [diff] [blame] | 329 | } |
Matteo Scandolo | a62adbc | 2017-03-02 15:37:34 -0800 | [diff] [blame] | 330 | } |