Commit f1a1a6a7 authored by Yann Garcia's avatar Yann Garcia
Browse files

Validation against German CISE node - First round

parent decd8400
Loading
Loading
Loading
Loading
+128 −190
Original line number Diff line number Diff line
@@ -129,7 +129,7 @@ module AtsCise_TestCases {
          [v_recv_sync_ack == true]
            httpPort.receive(
                             mw_http_response(
                                              mw_http_response_201_created(
                                              mw_http_response_202_accepted(
                                                                            mw_http_message_body_xml(
                                                                                                     mw_xml_body_acknowledgement(
                                                                                                                                 mw_acknowledgement(
@@ -382,7 +382,7 @@ module AtsCise_TestCases {
        alt {
          [] httpPort.receive(
                              mw_http_response(
                                               mw_http_response_201_created(
                                               mw_http_response_ok(
                                                                   mw_http_message_body_xml(
                                                                                            mw_xml_body_acknowledgement(
                                                                                                                        mw_acknowledgement(
@@ -544,7 +544,7 @@ module AtsCise_TestCases {
          // }
          [] httpPort.receive(
                              mw_http_response(
                                               mw_http_response_201_created(
                                               mw_http_response_202_accepted(
                                                                             mw_http_message_body_xml(
                                                                                                      mw_xml_body_acknowledgement(
                                                                                                                                  mw_acknowledgement(
@@ -1011,11 +1011,11 @@ module AtsCise_TestCases {
        }
        // Test component configuration
        f_cf_02_up();
        f_cf_01_up();
        // Test adapter configuration
        f_process_pull_request_await_pull_response(
        f_process_pull_request_await_ack(
                                         -,
                                         m_sender_consumer_vessel,
                                         m_recipient_provider_vessel,
@@ -1023,7 +1023,7 @@ module AtsCise_TestCases {
                                         );
        // Postamble
        f_cf_02_down();
        f_cf_01_down();
      } // End of testcase TC_CDM_NODE_EI_NA_PULL_REQUEST_BV_01_01
@@ -1331,7 +1331,7 @@ module AtsCise_TestCases {
        f_cf_02_up();
        // Test adapter configuration
        f_process_pull_request_await_pull_response(
        f_process_pull_request_await_ack(
                                         -,
                                         m_sender_consumer_action,
                                         m_recipient_provider_action,
@@ -16636,8 +16636,6 @@ module AtsCise_TestCases {
       */
      testcase TC_CDM_NODE_EI_NA_SEC_BV_01() runs on CiseComponent system CiseTestAdapter {
        // Local variables
        var boolean v_recv_sync_ack := true;
        var boolean v_recv_response := false;
        var HttpMessage v_request;
        var Headers v_headers;
        var charstring v_date_time := f_get_current_date_time();
@@ -16686,23 +16684,14 @@ module AtsCise_TestCases {
                                                 PX_CISE_REQUEST_ACK, // RequiresAck
                                                 m_service( // Recipient
                                                          { string := PX_CISE_RECIPIENT_SERVICE_ID },
                                                          acknowledgement,
                                                          pull,
                                                          -,
                                                          PX_CISE_SEA_BASSIN,
                                                          provider,
                                                          online,
                                                          vesselService
                                                          ),
                                                 m_core_entity_payload_derivations_payload(
                                                                                           m_entity_payload( // Payload
                                                                                                            nonClassified,
                                                                                                            green,
                                                                                                            nonSpecified,
                                                                                                            {},
                                                                                                            false,
                                                                                                            -,
                                                                                                            false
                                                                                          )),
                                                 m_core_entity_payload_derivations_payload(m_entity_payload_vessel),
                                                 -,
                                                 1000 // ResponseTimeOut
                                                 ));
@@ -16732,10 +16721,10 @@ module AtsCise_TestCases {
        // Test Body
        tc_ac.start;
        alt {
          [v_recv_sync_ack == true]
          []
            httpPort.receive(
                             mw_http_response(
                                              mw_http_response_201_created(
                                              mw_http_response_202_accepted(
                                                                            mw_http_message_body_xml(
                                                                                                     mw_xml_body_acknowledgement(
                                                                                                                                 mw_acknowledgement(
@@ -16748,60 +16737,9 @@ module AtsCise_TestCases {
                             )))))) {
            tc_ac.stop;
            // var bitstring v_enc := oct2bit(v_pull_request_signed);
            // fx_dec_PullRequest_1(v_enc, v_pull_request);
            // f_verify_sign_pull_request(valueof(m_xml_body_pull_request(v_pull_request, v_pull_request_signed_str)), v_pull_request_signed_str);
            log("*** " & testcasename() & ": INFO: IUT successfully received synchronous Acknowledgment ***");
            v_recv_sync_ack := false; // Repeat and ...
            v_recv_response := true; // ... wait for the PullResponse
            tc_ac.start;
            repeat;
          }
          [v_recv_response == true]
            httpPort_notif.receive(
                                   mw_http_request(
                                                   mw_http_request_post(
                                                                        PICS_ROOT_API & PICS_PULL_RESPONSE_URI,
                                                                        -,
                                                                        mw_http_message_body_xml(
                                                                                                 mw_xml_body_pull_response(
                                                                                                                           mw_pull_response(
                                                                                                                                            ?,
                                                                                                                                            ?, // pattern "v_message_id*",
                                                                                                                                            high,
                                                                                                                                            -, -,
                                                                                                                                            success,
                                                                                                                                            -, -, -,
                                                                                                                                            v_correlation_id
                                   )))))) -> value v_request {
            tc_ac.stop;
            if (not(f_verify_sign_pull_response(v_request.request.body.xml_body, ""/*v_pull_response_canonicalized*/))) {
              log("*** " & testcasename() & ": FAIL: Signature not verified ***");
              f_selfOrClientSyncAndVerdict(c_tbDone, e_error);
            } else {
              log("*** " & testcasename() & ": PASS: IUT successfully received PullResponse ***");
            log("*** " & testcasename() & ": PASS: IUT successfully received sync Ack ***");
            f_selfOrClientSyncAndVerdict(c_tbDone, e_success);
          }
            // Send the response to finalyze the transaction
            f_init_default_headers_list(-, -, v_headers);
            httpPort_notif.send(
                                m_http_response(
                                                m_http_response_ok(
                                                                 m_http_message_body_xml(
                                                                                         m_xml_body_acknowledgement(
                                                                                                                   m_acknowledgement(
                                                                                                                                     v_request.request.body.xml_body.msg.pull_response.creationDateTime,
                                                                                                                                     v_request.request.body.xml_body.msg.pull_response.messageID,
                                                                                                                                     v_request.request.body.xml_body.msg.pull_response.priority,
                                                                                                                                     {},
                                                                                                                                     success
                                                                                          ))),
                                                                                          v_headers
                                )));
          }
          [] tc_ac.timeout {
            log("*** " & testcasename() & ": INCONC: Expected message not received ***");
            f_selfOrClientSyncAndVerdict(c_tbDone, e_timeout);
@@ -16866,7 +16804,7 @@ module AtsCise_TestCases {
                                                 PX_CISE_REQUEST_ACK, // RequiresAck
                                                 m_service( // Recipient
                                                          { string := PX_CISE_RECIPIENT_SERVICE_ID },
                                                          acknowledgement,
                                                          pull,
                                                          -,
                                                          PX_CISE_SEA_BASSIN,
                                                          provider,
@@ -16914,7 +16852,7 @@ module AtsCise_TestCases {
        alt {
          [] httpPort.receive(
                              mw_http_response(
                                               mw_http_response_201_created(
                                               mw_http_response_ok(
                                                                   mw_http_message_body_xml(
                                                                                            mw_xml_body_acknowledgement(
                                                                                                                        mw_acknowledgement(
@@ -16994,7 +16932,7 @@ module AtsCise_TestCases {
                                                 PX_CISE_REQUEST_ACK, // RequiresAck
                                                 m_service( // Recipient
                                                          { string := PX_CISE_RECIPIENT_SERVICE_ID },
                                                          acknowledgement,
                                                          pull,
                                                          -,
                                                          PX_CISE_SEA_BASSIN,
                                                          provider,
@@ -17042,7 +16980,7 @@ module AtsCise_TestCases {
        alt {
          [] httpPort.receive(
                              mw_http_response(
                                               mw_http_response_201_created(
                                               mw_http_response_ok(
                                                                   mw_http_message_body_xml(
                                                                                            mw_xml_body_acknowledgement(
                                                                                                                        mw_acknowledgement(
@@ -17122,7 +17060,7 @@ module AtsCise_TestCases {
                                                 PX_CISE_REQUEST_ACK, // RequiresAck
                                                 m_service( // Recipient
                                                          { string := PX_CISE_RECIPIENT_SERVICE_ID },
                                                          acknowledgement,
                                                          pull,
                                                          -,
                                                          PX_CISE_SEA_BASSIN,
                                                          provider,
@@ -17170,7 +17108,7 @@ module AtsCise_TestCases {
        alt {
          [] httpPort.receive(
                              mw_http_response(
                                               mw_http_response_201_created(
                                               mw_http_response_ok(
                                                                   mw_http_message_body_xml(
                                                                                            mw_xml_body_acknowledgement(
                                                                                                                        mw_acknowledgement(
@@ -17252,7 +17190,7 @@ module AtsCise_TestCases {
                                                 PX_CISE_REQUEST_ACK, // RequiresAck
                                                 m_service( // Recipient
                                                          { string := PX_CISE_RECIPIENT_SERVICE_ID },
                                                          acknowledgement,
                                                          pull,
                                                          -,
                                                          PX_CISE_SEA_BASSIN,
                                                          provider,
@@ -17301,7 +17239,7 @@ module AtsCise_TestCases {
          [v_recv_sync_ack == true]
            httpPort.receive(
                             mw_http_response(
                                              mw_http_response_201_created(
                                              mw_http_response_ok(
                                                                  mw_http_message_body_xml(
                                                                                           mw_xml_body_acknowledgement(
                                                                                                                       mw_acknowledgement(
@@ -17383,7 +17321,7 @@ module AtsCise_TestCases {
                                                 PX_CISE_REQUEST_ACK, // RequiresAck
                                                 m_service( // Recipient
                                                          { string := PX_CISE_RECIPIENT_SERVICE_ID },
                                                          acknowledgement,
                                                          pull,
                                                          -,
                                                          PX_CISE_SEA_BASSIN,
                                                          provider,
@@ -17432,7 +17370,7 @@ module AtsCise_TestCases {
          [v_recv_sync_ack == true]
            httpPort.receive(
                             mw_http_response(
                                              mw_http_response_201_created(
                                              mw_http_response_ok(
                                                                  mw_http_message_body_xml(
                                                                                           mw_xml_body_acknowledgement(
                                                                                                                       mw_acknowledgement(
@@ -17514,7 +17452,7 @@ module AtsCise_TestCases {
                                                 PX_CISE_REQUEST_ACK, // RequiresAck
                                                 m_service( // Recipient
                                                          { string := PX_CISE_RECIPIENT_SERVICE_ID },
                                                          acknowledgement,
                                                          pull,
                                                          -,
                                                          PX_CISE_SEA_BASSIN,
                                                          provider,
@@ -17645,7 +17583,7 @@ module AtsCise_TestCases {
                                                 PX_CISE_REQUEST_ACK, // RequiresAck
                                                 m_service( // Recipient
                                                          { string := PX_CISE_RECIPIENT_SERVICE_ID },
                                                          acknowledgement,
                                                          pull,
                                                          -,
                                                          PX_CISE_SEA_BASSIN,
                                                          provider,
@@ -17776,7 +17714,7 @@ module AtsCise_TestCases {
                                                 PX_CISE_REQUEST_ACK, // RequiresAck
                                                 m_service( // Recipient
                                                          { string := PX_CISE_RECIPIENT_SERVICE_ID },
                                                          acknowledgement,
                                                          pull,
                                                          -,
                                                          PX_CISE_SEA_BASSIN,
                                                          provider,
@@ -17814,7 +17752,7 @@ module AtsCise_TestCases {
          [v_recv_sync_ack == true]
            httpPort.receive(
                             mw_http_response(
                                              mw_http_response_201_created(
                                              mw_http_response_ok(
                                                                  mw_http_message_body_xml(
                                                                                           mw_xml_body_acknowledgement(
                                                                                                                       mw_acknowledgement(