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="Loop is in state ${exchangeProperty[policyStatus]}, it can only be deployed when in state SUBMIT" />
232 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('Loop is in state ${exchangeProperty[policyStatus]}, it can only be deployed when in state SUBMIT','ERROR',${exchangeProperty[loopObject]})" />
237 message="DEPLOY request successfully executed for loop: ${header.loopName}" />
239 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('DEPLOY request successfully executed','INFO',${exchangeProperty[loopObject]})" />
241 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=endLog()" />
243 <exception>java.lang.Exception</exception>
245 <constant>false</constant>
248 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=errorLog()" />
251 message="DEPLOY request failed for loop: ${header.loopName}" />
253 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('DEPLOY request failed, Error reported: ${exception}','ERROR',${exchangeProperty[loopObject]})" />
259 uri="/v2/loop/undeployLoop/{loopName}"
260 outType="org.onap.clamp.loop.Loop"
261 produces="application/json">
265 excludePattern="loopName" />
269 message="DCAE UNDEPLOY request for loop: ${header.loopName}" />
271 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=startLog(*, 'DCAE UNDEPLOY request')" />
273 uri="bean:org.onap.clamp.authorization.AuthorizationController?method=authorize(*,'cl','','update')" />
274 <to uri="direct:load-loop" />
276 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('DCAE UNDEPLOY request','INFO',${exchangeProperty[loopObject]})" />
277 <to uri="direct:get-status-from-dcae" />
280 <simple> ${exchangeProperty[dcaeStatus]} == 'DEPLOYED' or ${exchangeProperty[dcaeStatus]} == 'IN_ERROR' or ${exchangeProperty[dcaeStatus]} == 'PROCESSING'
282 <to uri="direct:undeploy-loop" />
287 message="Loop is in state ${exchangeProperty[dcaeStatus]}, it can only be undeployed when in state DEPLOYED/IN_ERROR/PROCESSING" />
289 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]})" />
294 message="UNDEPLOY request successfully executed for loop: ${header.loopName}" />
296 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('UNDEPLOY request successfully executed','INFO',${exchangeProperty[loopObject]})" />
298 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=endLog()" />
300 <exception>java.lang.Exception</exception>
302 <constant>false</constant>
305 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=errorLog()" />
308 message="UNDEPLOY request failed for loop: ${header.loopName}" />
310 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('UNDEPLOY request failed, Error reported: ${exception}','ERROR',${exchangeProperty[loopObject]})" />
316 uri="/v2/loop/stop/{loopName}"
317 outType="org.onap.clamp.loop.Loop"
318 produces="application/json">
322 excludePattern="loopName" />
326 message="STOP request for loop: ${header.loopName}" />
328 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=startLog(*,'STOP request')" />
330 uri="bean:org.onap.clamp.authorization.AuthorizationController?method=authorize(*,'cl','','update')" />
331 <to uri="direct:load-loop" />
333 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('STOP request','INFO',${exchangeProperty[loopObject]})" />
335 <to uri="direct:remove-all-policy-from-active-pdp-group" />
338 message="STOP request successfully executed for loop: ${header.loopName}" />
340 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('STOP request successfully executed','INFO',${exchangeProperty[loopObject]})" />
342 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=endLog()" />
344 <exception>java.lang.Exception</exception>
346 <constant>false</constant>
349 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=errorLog()" />
352 message="STOP request failed for loop: $${header.loopName}" />
354 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('STOP request failed, Error reported: ${exception}','ERROR',${exchangeProperty[loopObject]})" />
360 uri="/v2/loop/restart/{loopName}"
361 outType="org.onap.clamp.loop.Loop"
362 produces="application/json">
366 excludePattern="loopName" />
370 message="RESTART request for loop: ${header.loopName}" />
372 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=startLog(*,'RESTART request')" />
374 uri="bean:org.onap.clamp.authorization.AuthorizationController?method=authorize(*,'cl','','update')" />
375 <to uri="direct:load-loop" />
378 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('RESTART request','INFO',${exchangeProperty[loopObject]})" />
380 <to uri="direct:add-all-to-active-pdp-group" />
383 message="RESTART request successfully executed for loop: ${header.loopName}" />
385 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('RESTART request successfully executed','INFO',${exchangeProperty[loopObject]})" />
387 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=endLog()" />
389 <exception>java.lang.Exception</exception>
391 <constant>false</constant>
394 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=errorLog()" />
397 message="RESTART request failed for loop: ${header.loopName}" />
399 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('RESTART request failed, Error reported: ${exception}','INFO',${exchangeProperty[loopObject]})" />
405 uri="/v2/loop/submit/{loopName}"
406 outType="org.onap.clamp.loop.Loop"
407 produces="application/json">
411 excludePattern="loopName" />
415 message="POLICY SUBMIT request for loop: ${header.loopName}" />
417 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=startLog(*, 'POLICY SUBMIT request')" />
419 uri="bean:org.onap.clamp.authorization.AuthorizationController?method=authorize(*,'cl','','update')" />
420 <to uri="direct:load-loop" />
422 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('POLICY SUBMIT request','INFO',${exchangeProperty[loopObject]})" />
423 <setProperty propertyName="raiseHttpExceptionFlag">
424 <simple resultType="java.lang.Boolean">false</simple>
426 <to uri="direct:remove-all-policy-from-active-pdp-group" />
429 message="Processing all MICRO-SERVICES policies defined in loop ${exchangeProperty[loopObject].getName()}" />
431 <simple>${exchangeProperty[loopObject].getMicroServicePolicies()}
433 <setProperty propertyName="microServicePolicy">
434 <simple>${body}</simple>
438 message="Processing Micro Service Policy: ${exchangeProperty[microServicePolicy].getName()}" />
439 <setProperty propertyName="raiseHttpExceptionFlag">
440 <simple resultType="java.lang.Boolean">false</simple>
442 <to uri="direct:delete-micro-service-policy" />
443 <to uri="direct:create-micro-service-policy" />
447 message="Processing all OPERATIONAL policies defined in loop ${exchangeProperty[loopObject].getName()}" />
449 <simple>${exchangeProperty[loopObject].getOperationalPolicies()}
451 <setProperty propertyName="operationalPolicy">
452 <simple>${body}</simple>
456 message="Processing Operational Policy: ${exchangeProperty[operationalPolicy].getName()}" />
457 <setProperty propertyName="raiseHttpExceptionFlag">
458 <simple resultType="java.lang.Boolean">false</simple>
461 <to uri="direct:delete-operational-policy" />
462 <to uri="direct:create-operational-policy" />
466 message="Processing all GUARD policies defined in loop ${exchangeProperty[loopObject].getName()}" />
468 <simple>${exchangeProperty[operationalPolicy].createGuardPolicyPayloads().entrySet()}
470 <setProperty propertyName="guardPolicy">
471 <simple>${body}</simple>
475 message="Processing Guard Policy: ${exchangeProperty[guardPolicy].getKey()}" />
477 <setProperty propertyName="raiseHttpExceptionFlag">
478 <simple resultType="java.lang.Boolean">false</simple>
480 <to uri="direct:delete-guard-policy" />
481 <to uri="direct:create-guard-policy" />
485 <to uri="direct:add-all-to-active-pdp-group" />
489 message="SUBMIT request successfully executed for loop: ${header.loopName}" />
491 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('SUBMIT request successfully executed','INFO',${exchangeProperty[loopObject]})" />
493 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=endLog()" />
495 <exception>java.lang.Exception</exception>
497 <constant>false</constant>
500 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=errorLog()" />
503 message="SUBMIT request failed for loop: ${header.loopName}" />
505 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('SUBMIT request failed, Error reported: ${exception}','ERROR',${exchangeProperty[loopObject]})" />
510 <put uri="/v2/loop/delete/{loopName}">
514 excludePattern="loopName" />
518 message="DELETE request for loop: ${header.loopName}" />
520 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=startLog(*,'DELETE request')" />
522 uri="bean:org.onap.clamp.authorization.AuthorizationController?method=authorize(*,'cl','','update')" />
523 <to uri="direct:load-loop" />
525 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('DELETE request','INFO',${exchangeProperty[loopObject]})" />
526 <to uri="direct:remove-all-policy-from-active-pdp-group" />
528 <simple>${exchangeProperty[loopObject].getMicroServicePolicies()}
530 <setProperty propertyName="microServicePolicy">
531 <simple>${body}</simple>
535 message="Processing Micro Service Policy: ${exchangeProperty[microServicePolicy].getName()}" />
536 <to uri="direct:delete-micro-service-policy" />
541 message="Processing all OPERATIONAL policies defined in loop ${exchangeProperty[loopObject].getName()}" />
543 <simple>${exchangeProperty[loopObject].getOperationalPolicies()}
545 <setProperty propertyName="operationalPolicy">
546 <simple>${body}</simple>
550 message="Processing Operational Policy: ${exchangeProperty[operationalPolicy].getName()}" />
551 <to uri="direct:delete-operational-policy" />
554 message="Processing all GUARD policies defined in loop ${exchangeProperty[loopObject].getName()}" />
556 <simple>${exchangeProperty[operationalPolicy].createGuardPolicyPayloads().entrySet()}
558 <setProperty propertyName="guardPolicy">
559 <simple>${body}</simple>
563 message="Processing Guard Policy: ${exchangeProperty[guardPolicy].getKey()}" />
564 <to uri="direct:delete-guard-policy" />
568 uri="bean:org.onap.clamp.loop.log.LoopService?method=deleteLoop(${header.loopName})" />
571 message="DELETE request successfully executed for loop: ${header.loopName}" />
573 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('DELETE request successfully executed','INFO',${exchangeProperty[loopObject]})" />
575 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=endLog()" />
577 <exception>java.lang.Exception</exception>
579 <constant>false</constant>
582 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=errorLog()" />
585 message="DELETE request failed for loop: ${header.loopName}" />
587 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('DELETE request failed, Error reported: ${exception}','ERROR',${exchangeProperty[loopObject]})" />
593 uri="/v2/loop/getstatus/{loopName}"
594 outType="org.onap.clamp.loop.Loop"
595 produces="application/json">
599 excludePattern="loopName" />
603 message="GET STATUS request for loop: ${header.loopName}" />
605 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=startLog(*, 'GET STATUS request')" />
607 uri="bean:org.onap.clamp.authorization.AuthorizationController?method=authorize(*,'cl','','read')" />
608 <to uri="direct:load-loop" />
610 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('GET STATUS request','INFO',${exchangeProperty[loopObject]})" />
611 <setProperty propertyName="raiseHttpExceptionFlag">
612 <simple resultType="java.lang.Boolean">false</simple>
614 <to uri="direct:get-status-from-policy" />
615 <to uri="direct:get-status-from-dcae" />
617 uri="bean:org.onap.clamp.loop.LoopOperation?method=updateLoopStatus(${exchangeProperty[loopObject]},${exchangeProperty[policyStatus]}, ${exchangeProperty[dcaeStatus]})" />
620 message="Get Status request successfully executed. The new state is: ${body}" />
622 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('Get Status request successfully executed','INFO',${exchangeProperty[loopObject]})" />
624 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=endLog()" />
626 <exception>java.lang.Exception</exception>
628 <constant>false</constant>
631 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=errorLog()" />
634 message="Get Status request failed for loop: ${header.loopName}" />
636 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('Get Status request failed, Error reported: ${exception}','ERROR',${exchangeProperty[loopObject]})" />
640 uri="bean:org.onap.clamp.loop.LoopController?method=getLoop(${header.loopName})" />