[CSIT] Testing DataOperations Request with positive Scenario

# Sending CMHandle with ready state to the NCMP then it forwarded to DMI to complete the read operation once done with success it produces a message to the client topic'

Issue-ID: CPS-1560
Signed-off-by: raviteja.karumuri <raviteja.karumuri@est.tech>
Change-Id: I0af68fdf97bf0a5063361ae08475dee38dbe7b8e

1 files changed, 77 insertions, 0 deletions

diff --git a/csit/tests/cps-data-operations/cps-data-operations.robot b/csit/tests/cps-data-operations/cps-data-operations.robot
new file mode 100644
index 000000000..451fb0a42
--- /dev/null
+++ b/csit/tests/cps-data-operations/cps-data-operations.robot
@@ -0,0 +1,77 @@
+/*
+ *  ============LICENSE_START=======================================================
+ *  Copyright (C) 2023 Nordix Foundation
+ *  ================================================================================
+ *  Licensed under the Apache License, Version 2.0 (the "License");
+ *  you may not use this file except in compliance with the License.
+ *  You may obtain a copy of the License at
+ *
+ *        http://www.apache.org/licenses/LICENSE-2.0
+ *
+ *  Unless required by applicable law or agreed to in writing, software
+ *  distributed under the License is distributed on an "AS IS" BASIS,
+ *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *  See the License for the specific language governing permissions and
+ *  limitations under the License.
+ *
+ *  SPDX-License-Identifier: Apache-2.0
+ * ============LICENSE_END=========================================================
+ */
+
+*** Settings ***
+Documentation         NCMP
+
+Library               Collections
+Library               OperatingSystem
+Library               RequestsLibrary
+Library               BuiltIn
+Library               ConfluentKafkaLibrary
+
+Suite Setup           Create Session      CPS_URL    http://${CPS_CORE_HOST}:${CPS_CORE_PORT}
+
+*** Variables ***
+
+${auth}                                 Basic Y3BzdXNlcjpjcHNyMGNrcyE=
+${topic}                                data-operation-client-topic
+${ncmpBasePath}                         /ncmp
+${expectedRequestId}                    ${EMPTY}
+${dmipluginCsitStubUrl}                 http://${DMI_CSIT_STUB_HOST}:${DMI_CSIT_STUB_PORT}
+${newCmHandleRequestBody}               {"dmiPlugin":"${dmipluginCsitStubUrl}","createdCmHandles":[{"cmHandle":"850117873c9a4936856a5081be96e6a8"}]}
+
+*** Test Cases ***
+
+NCMP Data Operation, forwarded to DMI, response on Client Topic
+        ${uri}=                          Set Variable        ${ncmpBasePath}/v1/data
+        ${dataOperationReqBody}=         Get Binary File     ${DATADIR}${/}dataOperationRequest.json
+        ${params}=                       Create Dictionary   topic=${topic}
+        ${headers}=                      Create Dictionary   Content-Type=application/json         Authorization=${auth}
+                                         POST On Session     CPS_URL   ncmpInventory/v1/ch         headers=${headers}     data=${newCmHandleRequestBody}
+        Sleep                            5                   wait some time to get updated the cm handle state to READY
+        ${response}=                     POST On Session     CPS_URL   ${uri}   params=${params}   headers=${headers}     data=${dataOperationReqBody}
+        Set Global Variable              ${expectedRequestId}       ${response.json()}[requestId]
+        Should Be Equal As Strings       ${response.status_code}   200
+        Sleep                            5                         wait some time to get published a message to the client topic
+
+Consume cloud event from client topic
+    ${group_id}=         Create Consumer     port=19092               auto_offset_reset=earliest
+    Subscribe Topic      topics=${topic}     group_id=${group_id}
+    ${messages}=         Poll                group_id=${group_id}     only_value=false
+    ${event}                        Set Variable                      ${messages}[0]
+    ${headers}                      Set Variable                      ${event.headers()}
+    ${specVersionHeaderValue}       Set Variable                      ${headers[1][1]}
+    ${sourceHeaderValue}            Set Variable                      ${headers[3][1]}
+    ${typeHeaderValue}              Set Variable                      ${headers[4][1]}
+    ${correlationIdHeaderValue}     Set Variable                      ${headers[8][1]}
+    Should Be Equal As Strings      ${specVersionHeaderValue}         1.0
+    Should Be Equal As Strings      ${sourceHeaderValue}              DMI
+    Should Be Equal As Strings      ${correlationIdHeaderValue}       ${expectedRequestId}
+    Should Be Equal As Strings      ${typeHeaderValue}                org.onap.cps.ncmp.events.async1_0_0.DataOperationEvent
+    [Teardown]                      Basic Teardown                    ${group_id}
+
+*** Keywords ***
+
+Basic Teardown
+    [Arguments]     ${group_id}
+    Unsubscribe     ${group_id}
+    Close Consumer  ${group_id}
+