1 <rests xmlns="http://camel.apache.org/schema/spring">
4 uri="/v2/loop/getAllNames"
5 outType="java.lang.String[]"
6 produces="application/json">
8 <removeHeaders pattern="*" />
11 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=startLog(*, 'GET ALL Loop')" />
13 uri="bean:org.onap.clamp.authorization.AuthorizationController?method=authorize(*,'cl','','read')" />
15 uri="bean:org.onap.clamp.loop.LoopController?method=getLoopNames()" />
17 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=endLog()" />
19 <exception>java.lang.Exception</exception>
21 <constant>false</constant>
24 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=errorLog()" />
30 uri="/v2/loop/{loopName}"
31 outType="org.onap.clamp.loop.Loop"
32 produces="application/json">
36 excludePattern="loopName" />
39 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=startLog(*, 'GET Loop')" />
41 uri="bean:org.onap.clamp.authorization.AuthorizationController?method=authorize(*,'cl','','read')" />
43 uri="bean:org.onap.clamp.loop.LoopController?method=getLoop(${header.loopName})" />
45 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=endLog()" />
47 <exception>java.lang.Exception</exception>
49 <constant>false</constant>
52 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=errorLog()" />
58 uri="/v2/loop/svgRepresentation/{loopName}"
59 outType="java.lang.String"
60 produces="application/xml">
64 excludePattern="loopName" />
67 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=startLog(*, 'Get SVG Representation')" />
69 uri="bean:org.onap.clamp.authorization.AuthorizationController?method=authorize(*,'cl','','read')" />
71 uri="bean:org.onap.clamp.loop.LoopController?method=getSVGRepresentation(${header.loopName})" />
73 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=endLog()" />
75 <exception>java.lang.Exception</exception>
77 <constant>false</constant>
80 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=errorLog()" />
87 uri="/v2/loop/updateGlobalProperties/{loopName}"
88 type="com.google.gson.JsonObject"
89 consumes="application/json"
90 outType="org.onap.clamp.loop.Loop"
91 produces="application/json">
95 excludePattern="loopName" />
98 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=startLog(*, 'Update the global properties')" />
100 uri="bean:org.onap.clamp.authorization.AuthorizationController?method=authorize(*,'cl','','update')" />
101 <setHeader headerName="GlobalPropertiesJson">
102 <simple>${body}</simple>
104 <to uri="direct:load-loop" />
106 uri="bean:org.onap.clamp.loop.LoopController?method=updateGlobalPropertiesJson(${header.loopName},${header.GlobalPropertiesJson})" />
108 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('Global Properties UPDATED','INFO',${exchangeProperty[loopObject]})" />
110 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=endLog()" />
112 <exception>java.lang.Exception</exception>
114 <constant>false</constant>
117 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=errorLog()" />
123 uri="/v2/loop/updateOperationalPolicies/{loopName}"
124 type="com.google.gson.JsonArray"
125 consumes="application/json"
126 outType="org.onap.clamp.loop.Loop"
127 produces="application/json">
131 excludePattern="loopName" />
134 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=startLog(*, 'Update operational policies')" />
136 uri="bean:org.onap.clamp.authorization.AuthorizationController?method=authorize(*,'cl','','update')" />
137 <setHeader headerName="OperationalPoliciesArray">
138 <simple>${body}</simple>
140 <to uri="direct:load-loop" />
142 uri="bean:org.onap.clamp.loop.LoopController?method=updateOperationalPolicies(${header.loopName},${header.OperationalPoliciesArray})" />
144 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('Operational and Guard policies UPDATED','INFO',${exchangeProperty[loopObject]})" />
146 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=endLog()" />
148 <exception>java.lang.Exception</exception>
150 <constant>false</constant>
153 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=errorLog()" />
159 uri="/v2/loop/updateMicroservicePolicy/{loopName}"
160 type="org.onap.clamp.policy.microservice.MicroServicePolicy"
161 consumes="application/json"
162 outType="org.onap.clamp.policy.microservice.MicroServicePolicy"
163 produces="application/json">
167 excludePattern="loopName" />
170 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=startLog(*, 'Update Microservice policies')" />
172 uri="bean:org.onap.clamp.authorization.AuthorizationController?method=authorize(*,'cl','','update')" />
173 <setProperty propertyName="MicroServicePolicyObject">
174 <simple>${body}</simple>
177 <to uri="direct:load-loop" />
179 uri="bean:org.onap.clamp.loop.LoopController?method=updateMicroservicePolicy(${header.loopName},${exchangeProperty[MicroServicePolicyObject]})" />
181 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('Micro Service policies UPDATED','INFO',${exchangeProperty[loopObject]})" />
183 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=endLog()" />
185 <exception>java.lang.Exception</exception>
187 <constant>false</constant>
190 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=errorLog()" />
196 uri="/v2/loop/deployLoop/{loopName}"
197 outType="org.onap.clamp.loop.Loop"
198 produces="application/json">
202 excludePattern="loopName" />
206 message="DCAE DEPLOY request for loop: ${header.loopName}" />
208 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=startLog(*, 'DCAE DEPLOY request')" />
210 uri="bean:org.onap.clamp.authorization.AuthorizationController?method=authorize(*,'cl','','update')" />
211 <to uri="direct:load-loop" />
213 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('DCAE DEPLOY request','INFO',${exchangeProperty[loopObject]})" />
215 <to uri="direct:get-status-from-policy" />
216 <to uri="direct:get-status-from-dcae" />
219 message="Policy deployment status: ${exchangeProperty[policyStatus]}"></log>
222 <simple> ${exchangeProperty[policyStatus]} == 'SUBMITTED' and
223 ${exchangeProperty[dcaeStatus]} == 'NOT_DEPLOYED'
225 <to uri="direct:deploy-loop" />
230 message="POLICY status ${exchangeProperty[policyStatus]}/DCAE status ${exchangeProperty[dcaeStatus]}, DCAE deployment will be started anyway" />
232 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('POLICY status ${exchangeProperty[policyStatus]}/DCAE status ${exchangeProperty[dcaeStatus]}, DCAE deployment will be started anyway','ERROR',${exchangeProperty[loopObject]})" />
233 <to uri="direct:deploy-loop" />
238 message="DEPLOY request successfully executed for loop: ${header.loopName}" />
240 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('DEPLOY request successfully executed','INFO',${exchangeProperty[loopObject]})" />
242 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=endLog()" />
244 <exception>java.lang.Exception</exception>
246 <constant>false</constant>
249 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=errorLog()" />
252 message="DEPLOY request failed for loop: ${header.loopName}" />
254 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('DEPLOY request failed, Error reported: ${exception}','ERROR',${exchangeProperty[loopObject]})" />
260 uri="/v2/loop/undeployLoop/{loopName}"
261 outType="org.onap.clamp.loop.Loop"
262 produces="application/json">
266 excludePattern="loopName" />
270 message="DCAE UNDEPLOY request for loop: ${header.loopName}" />
272 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=startLog(*, 'DCAE UNDEPLOY request')" />
274 uri="bean:org.onap.clamp.authorization.AuthorizationController?method=authorize(*,'cl','','update')" />
275 <to uri="direct:load-loop" />
277 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('DCAE UNDEPLOY request','INFO',${exchangeProperty[loopObject]})" />
278 <to uri="direct:get-status-from-dcae" />
281 <simple> ${exchangeProperty[dcaeStatus]} == 'DEPLOYED' or ${exchangeProperty[dcaeStatus]} == 'IN_ERROR' or ${exchangeProperty[dcaeStatus]} == 'PROCESSING'
283 <to uri="direct:undeploy-loop" />
288 message="Loop is in state ${exchangeProperty[dcaeStatus]}, it can only be undeployed when in state DEPLOYED/IN_ERROR/PROCESSING" />
290 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('Loop is in state ${exchangeProperty[dcaeStatus]}, it can only be deployed when in state DEPLOYED','ERROR',${exchangeProperty[loopObject]})" />
295 message="UNDEPLOY request successfully executed for loop: ${header.loopName}" />
297 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('UNDEPLOY request successfully executed','INFO',${exchangeProperty[loopObject]})" />
299 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=endLog()" />
301 <exception>java.lang.Exception</exception>
303 <constant>false</constant>
306 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=errorLog()" />
309 message="UNDEPLOY request failed for loop: ${header.loopName}" />
311 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('UNDEPLOY request failed, Error reported: ${exception}','ERROR',${exchangeProperty[loopObject]})" />
317 uri="/v2/loop/stop/{loopName}"
318 outType="org.onap.clamp.loop.Loop"
319 produces="application/json">
323 excludePattern="loopName" />
327 message="STOP request for loop: ${header.loopName}" />
329 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=startLog(*,'STOP request')" />
331 uri="bean:org.onap.clamp.authorization.AuthorizationController?method=authorize(*,'cl','','update')" />
332 <to uri="direct:load-loop" />
334 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('STOP request','INFO',${exchangeProperty[loopObject]})" />
336 <to uri="direct:remove-all-policy-from-active-pdp-group" />
339 message="STOP request successfully executed for loop: ${header.loopName}" />
341 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('STOP request successfully executed','INFO',${exchangeProperty[loopObject]})" />
343 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=endLog()" />
345 <exception>java.lang.Exception</exception>
347 <constant>false</constant>
350 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=errorLog()" />
353 message="STOP request failed for loop: $${header.loopName}" />
355 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('STOP request failed, Error reported: ${exception}','ERROR',${exchangeProperty[loopObject]})" />
361 uri="/v2/loop/restart/{loopName}"
362 outType="org.onap.clamp.loop.Loop"
363 produces="application/json">
367 excludePattern="loopName" />
371 message="RESTART request for loop: ${header.loopName}" />
373 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=startLog(*,'RESTART request')" />
375 uri="bean:org.onap.clamp.authorization.AuthorizationController?method=authorize(*,'cl','','update')" />
376 <to uri="direct:load-loop" />
379 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('RESTART request','INFO',${exchangeProperty[loopObject]})" />
381 <to uri="direct:add-all-to-active-pdp-group" />
384 message="RESTART request successfully executed for loop: ${header.loopName}" />
386 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('RESTART request successfully executed','INFO',${exchangeProperty[loopObject]})" />
388 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=endLog()" />
390 <exception>java.lang.Exception</exception>
392 <constant>false</constant>
395 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=errorLog()" />
398 message="RESTART request failed for loop: ${header.loopName}" />
400 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('RESTART request failed, Error reported: ${exception}','INFO',${exchangeProperty[loopObject]})" />
406 uri="/v2/loop/submit/{loopName}"
407 outType="org.onap.clamp.loop.Loop"
408 produces="application/json">
412 excludePattern="loopName" />
416 message="POLICY SUBMIT request for loop: ${header.loopName}" />
418 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=startLog(*, 'POLICY SUBMIT request')" />
420 uri="bean:org.onap.clamp.authorization.AuthorizationController?method=authorize(*,'cl','','update')" />
421 <to uri="direct:load-loop" />
423 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('POLICY SUBMIT request','INFO',${exchangeProperty[loopObject]})" />
424 <setProperty propertyName="raiseHttpExceptionFlag">
425 <simple resultType="java.lang.Boolean">false</simple>
427 <to uri="direct:remove-all-policy-from-active-pdp-group" />
430 message="Processing all MICRO-SERVICES policies defined in loop ${exchangeProperty[loopObject].getName()}" />
432 <simple>${exchangeProperty[loopObject].getMicroServicePolicies()}
434 <setProperty propertyName="microServicePolicy">
435 <simple>${body}</simple>
439 message="Processing Micro Service Policy: ${exchangeProperty[microServicePolicy].getName()}" />
440 <setProperty propertyName="raiseHttpExceptionFlag">
441 <simple resultType="java.lang.Boolean">false</simple>
443 <to uri="direct:delete-micro-service-policy" />
444 <to uri="direct:create-micro-service-policy" />
448 message="Processing all OPERATIONAL policies defined in loop ${exchangeProperty[loopObject].getName()}" />
450 <simple>${exchangeProperty[loopObject].getOperationalPolicies()}
452 <setProperty propertyName="operationalPolicy">
453 <simple>${body}</simple>
457 message="Processing Operational Policy: ${exchangeProperty[operationalPolicy].getName()}" />
458 <setProperty propertyName="raiseHttpExceptionFlag">
459 <simple resultType="java.lang.Boolean">false</simple>
462 <to uri="direct:delete-operational-policy" />
463 <to uri="direct:create-operational-policy" />
467 message="Processing all GUARD policies defined in loop ${exchangeProperty[loopObject].getName()}" />
469 <simple>${exchangeProperty[operationalPolicy].createGuardPolicyPayloads().entrySet()}
471 <setProperty propertyName="guardPolicy">
472 <simple>${body}</simple>
476 message="Processing Guard Policy: ${exchangeProperty[guardPolicy].getKey()}" />
478 <setProperty propertyName="raiseHttpExceptionFlag">
479 <simple resultType="java.lang.Boolean">false</simple>
481 <to uri="direct:delete-guard-policy" />
482 <to uri="direct:create-guard-policy" />
486 <to uri="direct:add-all-to-active-pdp-group" />
490 message="SUBMIT request successfully executed for loop: ${header.loopName}" />
492 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('SUBMIT request successfully executed','INFO',${exchangeProperty[loopObject]})" />
494 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=endLog()" />
496 <exception>java.lang.Exception</exception>
498 <constant>false</constant>
501 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=errorLog()" />
504 message="SUBMIT request failed for loop: ${header.loopName}" />
506 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('SUBMIT request failed, Error reported: ${exception}','ERROR',${exchangeProperty[loopObject]})" />
511 <put uri="/v2/loop/delete/{loopName}">
515 excludePattern="loopName" />
519 message="DELETE request for loop: ${header.loopName}" />
521 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=startLog(*,'DELETE request')" />
523 uri="bean:org.onap.clamp.authorization.AuthorizationController?method=authorize(*,'cl','','update')" />
524 <to uri="direct:load-loop" />
526 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('DELETE request','INFO',${exchangeProperty[loopObject]})" />
527 <to uri="direct:remove-all-policy-from-active-pdp-group" />
529 <simple>${exchangeProperty[loopObject].getMicroServicePolicies()}
531 <setProperty propertyName="microServicePolicy">
532 <simple>${body}</simple>
536 message="Processing Micro Service Policy: ${exchangeProperty[microServicePolicy].getName()}" />
537 <to uri="direct:delete-micro-service-policy" />
542 message="Processing all OPERATIONAL policies defined in loop ${exchangeProperty[loopObject].getName()}" />
544 <simple>${exchangeProperty[loopObject].getOperationalPolicies()}
546 <setProperty propertyName="operationalPolicy">
547 <simple>${body}</simple>
551 message="Processing Operational Policy: ${exchangeProperty[operationalPolicy].getName()}" />
552 <to uri="direct:delete-operational-policy" />
555 message="Processing all GUARD policies defined in loop ${exchangeProperty[loopObject].getName()}" />
557 <simple>${exchangeProperty[operationalPolicy].createGuardPolicyPayloads().entrySet()}
559 <setProperty propertyName="guardPolicy">
560 <simple>${body}</simple>
564 message="Processing Guard Policy: ${exchangeProperty[guardPolicy].getKey()}" />
565 <to uri="direct:delete-guard-policy" />
569 uri="bean:org.onap.clamp.loop.log.LoopService?method=deleteLoop(${header.loopName})" />
572 message="DELETE request successfully executed for loop: ${header.loopName}" />
574 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('DELETE request successfully executed','INFO',${exchangeProperty[loopObject]})" />
576 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=endLog()" />
578 <exception>java.lang.Exception</exception>
580 <constant>false</constant>
583 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=errorLog()" />
586 message="DELETE request failed for loop: ${header.loopName}" />
588 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('DELETE request failed, Error reported: ${exception}','ERROR',${exchangeProperty[loopObject]})" />
594 uri="/v2/loop/getstatus/{loopName}"
595 outType="org.onap.clamp.loop.Loop"
596 produces="application/json">
600 excludePattern="loopName" />
604 message="GET STATUS request for loop: ${header.loopName}" />
606 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=startLog(*, 'GET STATUS request')" />
608 uri="bean:org.onap.clamp.authorization.AuthorizationController?method=authorize(*,'cl','','read')" />
609 <to uri="direct:load-loop" />
611 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('GET STATUS request','INFO',${exchangeProperty[loopObject]})" />
612 <setProperty propertyName="raiseHttpExceptionFlag">
613 <simple resultType="java.lang.Boolean">false</simple>
615 <to uri="direct:get-status-from-policy" />
616 <to uri="direct:get-status-from-dcae" />
618 uri="bean:org.onap.clamp.loop.LoopOperation?method=updateLoopStatus(${exchangeProperty[loopObject]},${exchangeProperty[policyStatus]}, ${exchangeProperty[dcaeStatus]})" />
621 message="Get Status request successfully executed. The new state is: ${body}" />
623 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('Get Status request successfully executed','INFO',${exchangeProperty[loopObject]})" />
625 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=endLog()" />
627 <exception>java.lang.Exception</exception>
629 <constant>false</constant>
632 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=errorLog()" />
635 message="Get Status request failed for loop: ${header.loopName}" />
637 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('Get Status request failed, Error reported: ${exception}','ERROR',${exchangeProperty[loopObject]})" />
641 uri="bean:org.onap.clamp.loop.LoopController?method=getLoop(${header.loopName})" />