diff options
Diffstat (limited to 'csit/tests')
| -rw-r--r-- | csit/tests/cps-data-operations/cps-data-operations.robot | 77 |
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 0000000000..451fb0a424 --- /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} + |