Implement DMaaP message handling from policy

Handling of dmaap response from policy implemented
Blueprint updated for config policy fetch
Fix sonar issues

Change-Id: I7a8a54b5d62e5db94ea2bc2d28805d8f5680d579
Issue-ID: DCAEGEN2-1427
Signed-off-by: krishnaa96 <krishna.moorthy6@wipro.com>

4 files changed, 315 insertions, 185 deletions

diff --git a/dpo/data-formats/dmaap_son.json b/dpo/data-formats/dmaap_son.json
index 7e4a950..af5fc83 100644
--- a/dpo/data-formats/dmaap_son.json
+++ b/dpo/data-formats/dmaap_son.json
@@ -42,5 +42,16 @@
 			"location": "onap",
 			"topic_url": "https://HOSTNAME:3905/events/DCAE_CL_OUTPUT"
 		}
-	}
+	},
+        "CL_RSP_topic": {
+                "type": "message_router",
+                "aaf_username": "",
+                "aaf_password": "",
+                "dmaap_info": {
+                        "client_role": "son-subscriber",
+                        "client_id": "policy-son-1",
+                        "location": "onap",
+                        "topic_url": "https://HOSTNAME:3905/events/DCAE_CL_RSP"
+                }
+        }
 }
diff --git a/dpo/data-formats/oofToSonAsyncResp-dataformat.json b/dpo/data-formats/oofToSonAsyncResp-dataformat.json
index bf99528..4eb8f5a 100644
--- a/dpo/data-formats/oofToSonAsyncResp-dataformat.json
+++ b/dpo/data-formats/oofToSonAsyncResp-dataformat.json
@@ -1,91 +1,105 @@
 {
-	"dataformatversion": "1.0.0",
-	"jsonschema": {
-		"$schema": "http://json-schema.org/draft-04/schema#",
-		"additionalproperties": true,
-		"description": "",
-		"properties": {
-			"requestId": {
-				"description": "",
-				"type": "string"
-			},
-			"requestStatus": {
-				"description": "",
-				"type": "string"
-			},
-			"solutions": {
-				"description": "",
-				"items": {
-					"additionalproperties": true,
-					"description": "",
-					"properties": {
-						"finishTime": {
-							"description": "",
-							"type": "string"
-						},
-						"networkId": {
-							"description": "",
-							"type": "string"
-						},
-						"pciSolutions": {
-							"description": "",
-							"items": {
-								"additionalproperties": true,
-								"description": "",
-								"properties": {
-									"cellId": {
-										"description": "",
-										"type": "string"
-									},
-									"pci": {
-										"description": "",
-										"type": "string"
-									}
-								},
-								"required": [
-									"cellId",
-									"pci"
-								],
-								"type": "object"
-							},
-							"type": "array"
-						},
-						"startTime": {
-							"description": "",
-							"type": "string"
-						}
-					},
-					"required": [
-						"finishTime",
-						"networkId",
-						"pciSolutions",
-						"startTime"
-					],
-					"type": "object"
-				},
-				"type": "array"
-			},
-			"statusMessage": {
-				"description": "",
-				"type": "string"
-			},
-			"transactionId": {
-				"description": "",
-				"type": "string"
-			}
-		},
-		"required": [
-			"requestId",
-			"requestStatus",
-			"solutions",
-			"statusMessage",
-			"transactionId"
-		],
-		"type": "object"
-	},
-	"self": {
-		"description": "",
-		"name": "SON_OOF_ASYNC_RESP",
-		"version": "1.0.0"
-	}
+    "dataformatversion": "1.0.0", 
+    "jsonschema": {
+        "$schema": "http://json-schema.org/draft-04/schema#", 
+        "additionalproperties": true, 
+        "description": "", 
+        "properties": {
+            "requestId": {
+                "description": "", 
+                "type": "string"
+            }, 
+            "requestStatus": {
+                "description": "", 
+                "type": "string"
+            }, 
+            "solutions": {
+                "additionalproperties": true, 
+                "description": "", 
+                "properties": {
+                    "anrSolutions": {
+                        "description": "", 
+                        "items": {
+                            "additionalproperties": true, 
+                            "description": "", 
+                            "properties": {
+                                "cellId": {
+                                    "description": "", 
+                                    "type": "string"
+                                }, 
+                                "removeableNeighbors": {
+                                    "description": "", 
+                                    "items": {
+                                        "description": "", 
+                                        "type": "string"
+                                    }, 
+                                    "type": "array"
+                                }
+                            }, 
+                            "required": [
+                                "cellId", 
+                                "removeableNeighbors"
+                            ], 
+                            "type": "object"
+                        }, 
+                        "type": "array"
+                    }, 
+                    "networkId": {
+                        "description": "", 
+                        "type": "string"
+                    }, 
+                    "pciSolutions": {
+                        "description": "", 
+                        "items": {
+                            "additionalproperties": true, 
+                            "description": "", 
+                            "properties": {
+                                "cellId": {
+                                    "description": "", 
+                                    "type": "string"
+                                }, 
+                                "pci": {
+                                    "description": "", 
+                                    "type": "string"
+                                }
+                            }, 
+                            "required": [
+                                "cellId", 
+                                "pci"
+                            ], 
+                            "type": "object"
+                        }, 
+                        "type": "array"
+                    }
+                }, 
+                "required": [
+                    "anrSolutions", 
+                    "networkId", 
+                    "pciSolutions"
+                ], 
+                "type": "object"
+            }, 
+            "statusMessage": {
+                "description": "", 
+                "type": "string"
+            }, 
+            "transactionId": {
+                "description": "", 
+                "type": "string"
+            }
+        }, 
+        "required": [
+            "requestId", 
+            "requestStatus", 
+            "solutions", 
+            "statusMessage", 
+            "transactionId"
+        ], 
+        "type": "object"
+    }, 
+    "self": {
+        "description": "", 
+        "name": "SON_OOF_ASYNC_RESP", 
+        "version": "1.0.0"
+    }
 }
diff --git a/dpo/data-formats/policyToSonDmaap-dataformat.json b/dpo/data-formats/policyToSonDmaap-dataformat.json
new file mode 100644
index 0000000..28588a1
--- /dev/null
+++ b/dpo/data-formats/policyToSonDmaap-dataformat.json
@@ -0,0 +1,58 @@
+{
+    "dataformatversion": "1.0.0", 
+    "jsonschema": {
+        "$schema": "http://json-schema.org/draft-04/schema#", 
+        "additionalproperties": true, 
+        "description": "", 
+        "properties": {
+            "closedLoopControlName": {
+                "description": "", 
+                "type": "string"
+            }, 
+            "from": {
+                "description": "", 
+                "type": "string"
+            }, 
+            "payload": {
+                "description": "", 
+                "type": "string"
+            }, 
+            "policyName": {
+                "description": "", 
+                "type": "string"
+            }, 
+            "policyVersion": {
+                "description": "", 
+                "type": "string"
+            }, 
+            "requestID": {
+                "description": "", 
+                "type": "string"
+            }, 
+            "target": {
+                "description": "", 
+                "type": "string"
+            }, 
+            "version": {
+                "description": "", 
+                "type": "string"
+            }
+        }, 
+        "required": [
+            "closedLoopControlName", 
+            "from", 
+            "payload", 
+            "policyName", 
+            "policyVersion", 
+            "requestID", 
+            "target", 
+            "version"
+        ], 
+        "type": "object"
+    }, 
+    "self": {
+        "description": "", 
+        "name": "POLICY_TO_SON_DMAAP", 
+        "version": "1.0.0"
+    }
+}
diff --git a/dpo/data-formats/sonToOofReq-dataformat.json b/dpo/data-formats/sonToOofReq-dataformat.json
index e686dd1..d91edae 100644
--- a/dpo/data-formats/sonToOofReq-dataformat.json
+++ b/dpo/data-formats/sonToOofReq-dataformat.json
@@ -1,97 +1,144 @@
 {
-	"dataformatversion": "1.0.0",
-	"jsonschema": {
-		"$schema": "http://json-schema.org/draft-04/schema#",
-		"additionalproperties": true,
-		"description": "",
-		"properties": {
-			"cellInfo": {
-				"additionalproperties": true,
-				"description": "",
-				"properties": {
-					"cellIdList": {
-						"description": "",
-						"items": {
-							"description": "",
-							"type": "string"
-						},
-						"type": "array"
-					},
-					"networkId": {
-						"description": "",
-						"type": "string"
-					}
-				},
-				"required": [
-					"cellIdList",
-					"networkId"
-				],
-				"type": "object"
-			},
-			"requestInfo": {
-				"additionalproperties": true,
-				"description": "",
-				"properties": {
-					"callbackUrl": {
-						"description": "",
-						"type": "string"
-					},
-					"numSolutions": {
-						"description": "",
-						"type": "integer"
-					},
-					"optimizers": {
-						"description": "",
-						"items": {
-							"description": "",
-							"type": "string"
-						},
-						"type": "array"
-					},
-					"requestId": {
-						"description": "",
-						"type": "string"
-					},
-					"requestType": {
-						"description": "",
-						"type": "string"
-					},
-					"sourceId": {
-						"description": "",
-						"type": "string"
-					},
-					"timeout": {
-						"description": "",
-						"type": "integer"
-					},
-					"transactionId": {
-						"description": "",
-						"type": "string"
-					}
-				},
-				"required": [
-					"callbackUrl",
-					"numSolutions",
-					"optimizers",
-					"requestId",
-					"requestType",
-					"sourceId",
-					"timeout",
-					"transactionId"
-				],
-				"type": "object"
-			}
-		},
-		"required": [
-			"cellInfo",
-			"requestInfo"
-		],
-		"type": "object"
-	},
-	"self": {
-		"description": "",
-		"name": "SON_TO_OOF_REST_REQ",
-		"version": "1.0.0"
-	}
+    "dataformatversion": "1.0.0", 
+    "jsonschema": {
+        "$schema": "http://json-schema.org/draft-04/schema#", 
+        "additionalproperties": true, 
+        "description": "", 
+        "properties": {
+            "cellInfo": {
+                "additionalproperties": true, 
+                "description": "", 
+                "properties": {
+                    "anrInputList": {
+                        "description": "", 
+                        "items": {
+                            "additionalproperties": true, 
+                            "description": "", 
+                            "properties": {
+                                "cellId": {
+                                    "description": "", 
+                                    "type": "string"
+                                }, 
+                                "removeableNeighbors": {
+                                    "description": "", 
+                                    "items": {
+                                        "description": "", 
+                                        "type": "string"
+                                    }, 
+                                    "type": "array"
+                                }
+                            }, 
+                            "required": [
+                                "cellId", 
+                                "removeableNeighbors"
+                            ], 
+                            "type": "object"
+                        }, 
+                        "type": "array"
+                    }, 
+                    "cellIdList": {
+                        "description": "", 
+                        "items": {
+                            "description": "", 
+                            "type": "string"
+                        }, 
+                        "type": "array"
+                    }, 
+                    "networkId": {
+                        "description": "", 
+                        "type": "integer"
+                    }, 
+                    "trigger": {
+                        "description": "", 
+                        "type": "string"
+                    }
+                }, 
+                "required": [
+                    "anrInputList", 
+                    "cellIdList", 
+                    "networkId", 
+                    "trigger"
+                ], 
+                "type": "object"
+            }, 
+            "requestInfo": {
+                "additionalproperties": true, 
+                "description": "", 
+                "properties": {
+                    "callbackHeader": {
+                        "additionalproperties": true, 
+                        "description": "", 
+                        "properties": {
+                            "blob": {
+                                "description": "", 
+                                "type": "string"
+                            }
+                        }, 
+                        "required": [
+                            "blob"
+                        ], 
+                        "type": "object"
+                    }, 
+                    "callbackUrl": {
+                        "description": "", 
+                        "type": "string"
+                    }, 
+                    "numSolutions": {
+                        "description": "", 
+                        "type": "integer"
+                    }, 
+                    "optimizers": {
+                        "description": "", 
+                        "items": {
+                            "description": "", 
+                            "type": "string"
+                        }, 
+                        "type": "array"
+                    }, 
+                    "requestId": {
+                        "description": "", 
+                        "type": "string"
+                    }, 
+                    "requestType": {
+                        "description": "", 
+                        "type": "string"
+                    }, 
+                    "sourceId": {
+                        "description": "", 
+                        "type": "string"
+                    }, 
+                    "timeout": {
+                        "description": "", 
+                        "type": "integer"
+                    }, 
+                    "transactionId": {
+                        "description": "", 
+                        "type": "string"
+                    }
+                }, 
+                "required": [
+                    "callbackHeader", 
+                    "callbackUrl", 
+                    "numSolutions", 
+                    "optimizers", 
+                    "requestId", 
+                    "requestType", 
+                    "sourceId", 
+                    "timeout", 
+                    "transactionId"
+                ], 
+                "type": "object"
+            }
+        }, 
+        "required": [
+            "cellInfo", 
+            "requestInfo"
+        ], 
+        "type": "object"
+    }, 
+    "self": {
+        "description": "", 
+        "name": "SON_TO_OOF_REST_REQ", 
+        "version": "1.0.0"
+    }
 }
-