1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
|
import { Action } from '../../../../framework/src/flux/action';
import { Dispatch } from '../../../../framework/src/flux/store';
import { CoreModelNetworkElement, LpResponse } from '../models/coreModel';
import configurationService, { getValueByName } from '../services/configurationService';
import { ViewSpecification } from 'models/uiModels';
import { IApplicationStoreState } from '../../../../framework/src/store/applicationStore';
import { AddSnackbarNotification } from '../../../../framework/src/actions/snackbarActions';
export class ConfigurationApplicationBaseAction extends Action { }
export class UpdateLoading extends ConfigurationApplicationBaseAction {
constructor (public loading: boolean) {
super();
}
}
export class UpdateCoreModel extends ConfigurationApplicationBaseAction {
constructor (public nodeId?: string, public coreModel?: CoreModelNetworkElement) {
super();
}
}
export class UpdateLp extends ConfigurationApplicationBaseAction {
constructor (public lpId?: string, public capability?: string, public conditionalPackage?: string, public viewSpecifications: ViewSpecification[] = []) {
super();
}
}
export class UpdateViewData extends ConfigurationApplicationBaseAction {
constructor (public viewId?: string, public indexValues: string = "", public viewData: {} = {}) {
super();
}
}
export const updateMountIdAsyncActionCreator = (nodeId: string | undefined) => async (dispatch: Dispatch) => {
if (!nodeId) {
dispatch(new UpdateCoreModel());
return;
}
dispatch(new UpdateLoading(true));
const coreModel = await configurationService.getCoreModelByNodeId(nodeId);
dispatch(new UpdateLoading(false));
return coreModel
? dispatch(new UpdateCoreModel(nodeId, coreModel))
: dispatch(new UpdateCoreModel());
}
export const updateLpIdAsyncActionCreator = (lpId: string | undefined) => async (dispatch: Dispatch, getState: () => IApplicationStoreState) => {
const { configuration: { coreModel: coreModel, nodeId: nodeId } } = getState();
if (! nodeId || !lpId || !coreModel) {
dispatch(new UpdateLp());
return;
}
// find the lp with its unique uuid
let lpData: LpResponse | null = null;
for (let ltp of coreModel.ltp) {
const lp = ltp.lp.find(pl => pl.uuid === lpId);
if (lp) {
lpData = lp;
break;
}
}
// urn:onf:params:xml:ns:yang:microwave-model?module=microwave-model => microwave-model
let capability: string | null = lpData && getValueByName("capability", lpData.extension, null);
if (capability) {
const paramIndex = capability.indexOf('?');
if (paramIndex > -1) {
capability = capability.slice(paramIndex+1);
}
const params = capability.split("&").map(p => (p || "=").split("="));
const capParam = params.find(p => p[0] === "module") || null;
capability = capParam && capParam[1] || null;
}
const revision: string | null = lpData && getValueByName("revision", lpData.extension, null);
const conditionalPackage: string | null = lpData && getValueByName("conditional-package", lpData.extension, null);
dispatch(new UpdateLoading(true));
const viewSpecifications = capability && await configurationService.getUIDescriptionByCapability(capability, revision) || [];
dispatch(new UpdateLoading(false));
return coreModel ?
dispatch(new UpdateLp(lpId, capability || undefined, conditionalPackage || undefined, viewSpecifications)) :
dispatch(new UpdateLp());
}
export const updateViewDataAsyncActionCreator = (viewId: string | undefined, indexValues: string[] = []) => async (dispatch: Dispatch, getState: () => IApplicationStoreState) => {
const { configuration: { nodeId, lpId, capability, conditionalPackage, viewSpecifications } } = getState();
if (!viewId || !capability || !nodeId || !lpId || !conditionalPackage) {
dispatch(new AddSnackbarNotification({ message: `Error invalid parameter !${JSON.stringify({viewId ,capability ,nodeId ,lpId ,conditionalPackage}, null,2)}`, options: { variant: 'error' } }));
dispatch(new UpdateViewData());
return;
}
const viewSpecification = viewSpecifications.find(desc => desc.id === viewId);
if (!viewSpecification) {
dispatch(new AddSnackbarNotification({ message: `Error viewId ${viewId} not found !`, options: { variant: 'error' } }));
dispatch(new UpdateViewData());
return;
}
const url = viewSpecification.url.replace(/\$\$NODEID\$\$/g, nodeId).replace(/\$\$LPUUID\$\$/g, lpId);
dispatch(new UpdateLoading(true));
const data = capability && await configurationService.getViewData(url) || { };
dispatch(new UpdateLoading(false));
let viewData: { [path: string]: {} } = data;
const pathElements = viewSpecification.dataPath &&
viewSpecification.dataPath.replace(
/\/\$\$INDEX:(\d+):?([a-z\-]+)?\$\$/ig,
(_, indexStr, keyStr) => {
const index = +indexStr;
return indexValues[index] && '/' + indexValues[index] || '';
}).split("/") || [];
for (let path of pathElements) {
if (path === "") {
break;
}
viewData = viewData[path];
}
return viewData ?
dispatch(new UpdateViewData(viewId, indexValues.length > 0 ? indexValues.join("/") : "", viewData)) :
dispatch(new UpdateViewData());
}
|
