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 ClosedLoop')" />
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 Closed 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" />
205 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=startLog(*, 'Deploy the closed loop')" />
207 uri="bean:org.onap.clamp.authorization.AuthorizationController?method=authorize(*,'cl','','update')" />
209 uri="direct:load-loop" />
211 <simple>${exchangeProperty[loopObject].getOperationalPolicies()}
213 <setProperty propertyName="operationalPolicy">
214 <simple>${body}</simple>
217 uri="direct:get-status-from-policy" />
220 uri="direct:get-status-from-dcae" />
224 message="policy status0: ${exchangeProperty[policyStatus]}"></log>
227 message="dcae status0: ${exchangeProperty[dcaeStatus]}"></log>
229 <simple> ${exchangeProperty[policyStatus]} == 'SUBMITTED' and
230 ${exchangeProperty[dcaeStatus]} == 'NOT_DEPLOYED'
233 uri="direct:deploy-closedloop" />
238 message="Closed Loop is in state ${exchangeProperty[policyStatus]}, it can only be deployed when in state SUBMIT" />
240 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('Closed Loop is in state ${exchangeProperty[policyStatus]}, it can only be deployed when in state SUBMIT','ERROR',${exchangeProperty[loopObject]})" />
244 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=endLog()" />
246 <exception>java.lang.Exception</exception>
248 <constant>false</constant>
251 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=errorLog()" />
254 message="Deploy request failed for loop: ${header.loopName}" />
256 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('Deploy request failed','ERROR',${exchangeProperty[loopObject]})" />
262 uri="/v2/loop/undeployLoop/{loopName}"
263 outType="org.onap.clamp.loop.Loop"
264 produces="application/json">
268 excludePattern="loopName" />
271 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=startLog(*, 'Undeploy the closed loop')" />
273 uri="bean:org.onap.clamp.authorization.AuthorizationController?method=authorize(*,'cl','','update')" />
275 uri="direct:load-loop" />
277 uri="direct:get-status-from-dcae" />
280 <simple> ${exchangeProperty[dcaeStatus]} == 'DEPLOYED'
283 uri="direct:undeploy-closedloop" />
288 message="Closed Loop is in state ${exchangeProperty[dcaeStatus]}, it can only be undeployed when in state DEPLOYED" />
290 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('Closed Loop is in state ${exchangeProperty[dcaeStatus]}, it can only be deployed when in state DEPLOYED','ERROR',${exchangeProperty[loopObject]})" />
294 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=endLog()" />
296 <exception>java.lang.Exception</exception>
298 <constant>false</constant>
301 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=errorLog()" />
304 message="Undeploy request failed for loop: $${header.loopName}" />
306 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('Undeploy request failed','ERROR',${exchangeProperty[loopObject]})" />
312 uri="/v2/loop/stop/{loopName}"
313 outType="org.onap.clamp.loop.Loop"
314 produces="application/json">
318 excludePattern="loopName" />
322 message="Receive STOP request for loop: ${header.loopName}" />
324 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=startLog('Stop the closed loop')" />
326 uri="bean:org.onap.clamp.authorization.AuthorizationController?method=authorize(*,'cl','','update')" />
327 <to uri="direct:load-loop" />
328 <to uri="direct:remove-all-policy-from-active-pdp-group" />
331 message="STOP request successfully executed for loop: ${body}" />
333 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('STOP request successfully executed','INFO',${exchangeProperty[loopObject]})" />
335 uri="bean:org.onap.clamp.loop.LoopController?method=getLoop(${header.loopName})" />
337 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=endLog()" />
339 <exception>java.lang.Exception</exception>
341 <constant>false</constant>
344 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=errorLog()" />
347 message="STOP request failed for loop: $${header.loopName}" />
349 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('STOP request failed','ERROR',${exchangeProperty[loopObject]})" />
355 uri="/v2/loop/start/{loopName}"
356 outType="org.onap.clamp.loop.Loop"
357 produces="application/json">
361 excludePattern="loopName" />
365 message="Receive START request for loop: ${header.loopName}" />
367 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=startLog('Start the closed loop')" />
369 uri="bean:org.onap.clamp.authorization.AuthorizationController?method=authorize(*,'cl','','update')" />
370 <to uri="direct:load-loop" />
373 <to uri="direct:add-all-to-active-pdp-group" />
376 message="START request successfully executed for loop: ${header.loopName}" />
378 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('START request successfully executed','INFO',${exchangeProperty[loopObject]})" />
380 uri="bean:org.onap.clamp.loop.LoopController?method=getLoop(${header.loopName})" />
382 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=endLog()" />
384 <exception>java.lang.Exception</exception>
386 <constant>false</constant>
389 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=errorLog()" />
392 message="START request failed for loop: ${header.loopName}" />
394 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('START request failed','INFO',${exchangeProperty[loopObject]})" />
400 uri="/v2/loop/submit/{loopName}"
401 outType="org.onap.clamp.loop.Loop"
402 produces="application/json">
406 excludePattern="loopName" />
410 message="Receive SUBMIT request for loop: ${header.loopName}" />
412 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=startLog(*, 'Submit the closed loop')" />
414 uri="bean:org.onap.clamp.authorization.AuthorizationController?method=authorize(*,'cl','','update')" />
415 <to uri="direct:load-loop" />
417 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('Receive SUBMIT request','INFO',${exchangeProperty[loopObject]})" />
418 <setProperty propertyName="raiseHttpExceptionFlag">
419 <simple resultType="java.lang.Boolean">false</simple>
421 <to uri="direct:remove-all-policy-from-active-pdp-group" />
424 message="Processing all MICRO-SERVICES policies defined in loop ${exchangeProperty[loopObject].getName()}" />
426 <simple>${exchangeProperty[loopObject].getMicroServicePolicies()}
428 <setProperty propertyName="microServicePolicy">
429 <simple>${body}</simple>
433 message="Processing Micro Service Policy: ${exchangeProperty[microServicePolicy].getName()}" />
434 <setProperty propertyName="raiseHttpExceptionFlag">
435 <simple resultType="java.lang.Boolean">false</simple>
437 <to uri="direct:delete-micro-service-policy" />
438 <to uri="direct:create-micro-service-policy" />
442 message="Processing all OPERATIONAL policies defined in loop ${exchangeProperty[loopObject].getName()}" />
444 <simple>${exchangeProperty[loopObject].getOperationalPolicies()}
446 <setProperty propertyName="operationalPolicy">
447 <simple>${body}</simple>
451 message="Processing Operational Policy: ${exchangeProperty[operationalPolicy].getName()}" />
452 <setProperty propertyName="raiseHttpExceptionFlag">
453 <simple resultType="java.lang.Boolean">false</simple>
456 <to uri="direct:delete-operational-policy" />
457 <to uri="direct:create-operational-policy" />
461 message="Processing all GUARD policies defined in loop ${exchangeProperty[loopObject].getName()}" />
463 <simple>${exchangeProperty[operationalPolicy].createGuardPolicyPayloads().entrySet()}
465 <setProperty propertyName="guardPolicy">
466 <simple>${body}</simple>
470 message="Processing Guard Policy: ${exchangeProperty[guardPolicy].getKey()}" />
472 <setProperty propertyName="raiseHttpExceptionFlag">
473 <simple resultType="java.lang.Boolean">false</simple>
475 <to uri="direct:delete-guard-policy" />
476 <to uri="direct:create-guard-policy" />
480 <to uri="direct:add-all-to-active-pdp-group" />
484 message="SUBMIT request successfully executed for loop: ${header.loopName}" />
486 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('SUBMIT request successfully executed','INFO',${exchangeProperty[loopObject]})" />
488 uri="bean:org.onap.clamp.loop.LoopController?method=getLoop(${header.loopName})" />
490 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=endLog()" />
492 <exception>java.lang.Exception</exception>
494 <constant>false</constant>
497 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=errorLog()" />
500 message="SUBMIT request failed for loop: ${header.loopName}" />
502 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('SUBMIT request failed','ERROR',${exchangeProperty[loopObject]})" />
507 <put uri="/v2/loop/delete/{loopName}">
511 excludePattern="loopName" />
515 message="Receive DELETE request for loop: ${header.loopName}" />
517 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=startLog('Delete the closed loop')" />
519 uri="bean:org.onap.clamp.authorization.AuthorizationController?method=authorize(*,'cl','','update')" />
520 <to uri="direct:load-loop" />
522 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('Receive DELETE request','INFO',${exchangeProperty[loopObject]})" />
523 <to uri="direct:remove-all-policy-from-active-pdp-group" />
525 <simple>${exchangeProperty[loopObject].getMicroServicePolicies()}
527 <setProperty propertyName="microServicePolicy">
528 <simple>${body}</simple>
532 message="Processing Micro Service Policy: ${exchangeProperty[microServicePolicy].getName()}" />
533 <to uri="direct:delete-micro-service-policy" />
538 message="Processing all OPERATIONAL policies defined in loop ${exchangeProperty[loopObject].getName()}" />
540 <simple>${exchangeProperty[loopObject].getOperationalPolicies()}
542 <setProperty propertyName="operationalPolicy">
543 <simple>${body}</simple>
547 message="Processing Operational Policy: ${exchangeProperty[operationalPolicy].getName()}" />
548 <to uri="direct:delete-operational-policy" />
551 message="Processing all GUARD policies defined in loop ${exchangeProperty[loopObject].getName()}" />
553 <simple>${exchangeProperty[operationalPolicy].createGuardPolicyPayloads().entrySet()}
555 <setProperty propertyName="guardPolicy">
556 <simple>${body}</simple>
560 message="Processing Guard Policy: ${exchangeProperty[guardPolicy].getKey()}" />
561 <to uri="direct:delete-guard-policy" />
565 uri="bean:org.onap.clamp.loop.log.LoopService?method=deleteLoop(${header.loopName})" />
568 message="DELETE request successfully executed for loop: ${header.loopName}" />
570 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('DELETE request successfully executed','INFO',${exchangeProperty[loopObject]})" />
572 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=endLog()" />
574 <exception>java.lang.Exception</exception>
576 <constant>false</constant>
579 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=errorLog()" />
582 message="DELETE request failed for loop: ${header.loopName}" />
584 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('DELETE request failed','ERROR',${exchangeProperty[loopObject]})" />
590 uri="/v2/loop/getstatus/{loopName}"
591 outType="org.onap.clamp.loop.Loop"
592 produces="application/json">
594 <removeHeaders pattern="*" excludePattern="loopName"/>
598 message="Get current status for loop: ${header.loopName}" />
600 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=startLog(*, 'Get the closed loop status')" />
602 uri="bean:org.onap.clamp.authorization.AuthorizationController?method=authorize(*,'cl','','read')" />
603 <to uri="direct:load-loop" />
605 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('Receive GET STATUS request','INFO',${exchangeProperty[loopObject]})" />
606 <setProperty propertyName="raiseHttpExceptionFlag">
607 <simple resultType="java.lang.Boolean">false</simple>
609 <to uri="direct:get-status-from-policy" />
610 <to uri="direct:get-status-from-dcae" />
612 uri="bean:org.onap.clamp.loop.LoopOperation?method=updateLoopStatus(${exchangeProperty[policyStatus], ${exchangeProperty[dcaeStatus])" />
616 message="Get Status request successfully executed for loop: ${body}" />
618 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('Get Status request successfully executed','INFO',${exchangeProperty[loopObject]})" />
620 uri="bean:org.onap.clamp.loop.LoopController?method=getLoop(${header.loopName})" />
622 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=endLog()" />
624 <exception>java.lang.Exception</exception>
626 <constant>false</constant>
629 uri="bean:org.onap.clamp.flow.log.FlowLogOperation?method=errorLog()" />
632 message="Get Status request failed for loop: ${header.loopName}" />
634 uri="bean:org.onap.clamp.loop.log.LoopLogService?method=addLog('Get Status request failed','ERROR',${exchangeProperty[loopObject]})" />