Finalyze TC_CDM_NODE_PULL_REQUEST_BV_01_01 (d8ac6624) · Commits · CDM - Common information sharing environment and Data Model / CISE Data Model

etc/AtsCise/AtsCise_Cnit.cf_

+5 −4

Original line number	Original line	Diff line number	Diff line
	@@ -20,7 +20,8 @@ LibHttp_Pics.PICS_USE_TOKEN_HEADER := true

	# LibCise test parameters		# LibCise test parameters
	LibCise_Pixits.PX_CISE_REQUEST_ACK := false		LibCise_Pixits.PX_CISE_REQUEST_ACK := false
	LibCise_Pixits.PX_CISE_ADAPTOR_URI := "/cise-adapter/api/v1/messages"
			LibCise_Pics.PICS_CISE_ADAPTOR_URI := "/cise-adapter/api/v1/messages"

	[LOGGING]		[LOGGING]
	# In this section you can specify the name of the log file and the classes of events		# In this section you can specify the name of the log file and the classes of events
	@@ -40,7 +41,7 @@ LogEventTypes:= Yes
	# In this section you can specify parameters that are passed to Test Ports.		# In this section you can specify parameters that are passed to Test Ports.
	# Unsecured		# Unsecured
	system.httpPort.params := "HTTP(codecs=xml:xml_codec;json:json_codec)/TCP(debug=1,server=172.25.1.54,port=8200)"		system.httpPort.params := "HTTP(codecs=xml:xml_codec;json:json_codec)/TCP(debug=1,server=172.25.1.54,port=8200)"
	system.httpPort_notif.params := "HTTP(codecs=xml:xml_codec;json:json_codec)/TCP(debug=1,server_mode=1,local_port=8200,use_ssl=0)"		system.httpPort_notif.params := "HTTP(codecs=xml:xml_codec;json:json_codec)/TCP(debug=1,server_mode=1,local_port=8300,use_ssl=0)"
	# TLS		# TLS
	#system.httpPort.params := "HTTP(codecs=xml:xml_codec;json:json_codec)/TCP(debug=1,server=172.25.1.54,port=443,use_ssl=1,trusted_ca_list=/home/y.garcia/var/ssl/archive/yanngarcia.ddns.net/fullchain1.pem,privkey=/home/y.garcia/var/ssl/archive/yanngarcia.ddns.net/privkey1.pem,certificate=/home/y.garcia/var/ssl/archive/yanngarcia.ddns.net/fullchain1.pem)"		#system.httpPort.params := "HTTP(codecs=xml:xml_codec;json:json_codec)/TCP(debug=1,server=172.25.1.54,port=443,use_ssl=1,trusted_ca_list=/home/y.garcia/var/ssl/archive/yanngarcia.ddns.net/fullchain1.pem,privkey=/home/y.garcia/var/ssl/archive/yanngarcia.ddns.net/privkey1.pem,certificate=/home/y.garcia/var/ssl/archive/yanngarcia.ddns.net/fullchain1.pem)"
	#system.httpPort_notif.params := "HTTP(codecs=xml:xml_codec;json:json_codec)/TCP(debug=1,server_mode=1,local_port=443,use_ssl=1,mutual_auth=1,mutual_tls=1,trusted_ca_list=/home/y.garcia/var/ssl/archive/yanngarcia.ddns.net/fullchain1.pem,privkey=/home/y.garcia/var/ssl/archive/yanngarcia.ddns.net/privkey1.pem,certificate=/home/y.garcia/var/ssl/archive/yanngarcia.ddns.net/fullchain1.pem)"		#system.httpPort_notif.params := "HTTP(codecs=xml:xml_codec;json:json_codec)/TCP(debug=1,server_mode=1,local_port=443,use_ssl=1,mutual_auth=1,mutual_tls=1,trusted_ca_list=/home/y.garcia/var/ssl/archive/yanngarcia.ddns.net/fullchain1.pem,privkey=/home/y.garcia/var/ssl/archive/yanngarcia.ddns.net/privkey1.pem,certificate=/home/y.garcia/var/ssl/archive/yanngarcia.ddns.net/fullchain1.pem)"
	@@ -74,10 +75,10 @@ system.utPort.params := "HTTP(codecs=xml:xml_codec;json:json_codec)/TCP(debug=1,
	#AtsCise_TestControl.control		#AtsCise_TestControl.control

	# Check that the IUT responds with an HTPP 200 OK Acknowledgment response when receiving a PullRequest for vessels with discovery based on sea basin - no Acknowledgment required		# Check that the IUT responds with an HTPP 200 OK Acknowledgment response when receiving a PullRequest for vessels with discovery based on sea basin - no Acknowledgment required
	#AtsCise_TestCases.TC_CDM_NODE_PULL_REQUEST_BV_01_01		AtsCise_TestCases.TC_CDM_NODE_PULL_REQUEST_BV_01_01

	# Check that the IUT sends a PullRequest for vessels with discovery based on sea basin - no Acknowledgment required		# Check that the IUT sends a PullRequest for vessels with discovery based on sea basin - no Acknowledgment required
	AtsCise_TestCases.TC_CDM_ADAPTOR_PULL_REQUEST_BV_01		#AtsCise_TestCases.TC_CDM_ADAPTOR_PULL_REQUEST_BV_01

	[GROUPS]		[GROUPS]
	# In this section you can specify groups of hosts. These groups can be used inside the		# In this section you can specify groups of hosts. These groups can be used inside the

ttcn/AtsCise/AtsCise_TestCases.ttcn

+67 −194

Original line number	Original line	Diff line number	Diff line
	@@ -18,14 +18,13 @@ module AtsCise_TestCases {
	import from LibCise_Functions all;		import from LibCise_Functions all;
	import from LibCise_TestSystem all;		import from LibCise_TestSystem all;

	// TODO Add here your custom RFCs import		// LibCDM
	import from http_www_cise_eu_servicemodel_v1_message all;		import from http_www_cise_eu_servicemodel_v1_message all;
	import from http_www_cise_eu_servicemodel_v1_service all;		import from http_www_cise_eu_servicemodel_v1_service all;
	import from http_www_cise_eu_servicemodel_v1_authority all;		import from http_www_cise_eu_servicemodel_v1_authority all;
	import from http_www_cise_eu_datamodel_v1_entity_vessel all;		import from http_www_cise_eu_datamodel_v1_entity_vessel all;
	import from http_www_cise_eu_datamodel_v1_entity_cargo all;		import from http_www_cise_eu_datamodel_v1_entity_cargo all;


	import from LibHelpers_Functions all;		import from LibHelpers_Functions all;

	group node {		group node {
	@@ -40,15 +39,14 @@ module AtsCise_TestCases {
	*/		*/
	testcase TC_CDM_NODE_PULL_REQUEST_BV_01_01() runs on CiseComponent system CiseTestAdapter {		testcase TC_CDM_NODE_PULL_REQUEST_BV_01_01() runs on CiseComponent system CiseTestAdapter {
	// Local variables		// Local variables
			var boolean v_recv_sync_ack := true;
			var boolean v_recv_response := false;
	var Headers v_headers;		var Headers v_headers;
	var HttpMessage v_response;		var HttpMessage v_request, v_response;
	var charstring v_date_time := f_get_current_date_time();		var charstring v_date_time := f_get_current_date_time();
	var charstring v_expected_date_time := substr(v_date_time, 0, lengthof(v_date_time) - 5);		var charstring v_expected_date_time := substr(v_date_time, 0, lengthof(v_date_time) - 5);
	var charstring v_message_id := f_generate_uuid();		var charstring v_message_id := f_generate_uuid();
	var charstring v_correlation_id := f_generate_uuid();		var charstring v_correlation_id := f_generate_uuid();
	// var charstring v_date_time := "2023-02-15T09:47:23+0100"; // For debug purpose with Mockoon
	// var charstring v_message_id := "c57dc1e1-9473-c1fa-40c4-88a4fc32"; // For debug purpose with Mockoon
	// var charstring v_correlation_id := "19789ef3-2e5f-393d-9011-407be7d5"; // For debug purpose with Mockoon
	var PullRequest_1 v_pull_request;		var PullRequest_1 v_pull_request;
	var octetstring v_pull_request_signed;		var octetstring v_pull_request_signed;
	var charstring v_pull_request_canonicalized;		var charstring v_pull_request_canonicalized;
	@@ -56,14 +54,14 @@ module AtsCise_TestCases {
	var integer v_result;		var integer v_result;

	// Test control		// Test control
	if (not(PICS_IUT_CDM_NODE)) {		if (not(PICS_IUT_CDM_NODE) or not(PICS_CDM_PULL_REQUEST) or not(PICS_CDM_VESSEL_SERVICE)) {
	log("* " & testcasename() & ": PICS_IUT_CDM_NODE required for executing the TC *");		log("* " & testcasename() & ": PICS_IUT_CDM_NODE and PICS_CDM_PULL_REQUEST and PICS_CDM_VESSEL_SERVICE required for executing the TC *");
	setverdict(inconc);		setverdict(inconc);
	stop;		stop;
	}		}

	// Test component configuration		// Test component configuration
	f_cf_01_up();		f_cf_02_up();

	// Test adapter configuration		// Test adapter configuration

	@@ -85,7 +83,8 @@ module AtsCise_TestCases {
	{},		{},
	request,		request,
	{},		{},
	-, -, -,		-, -,
			f_generate_uuid(), // ContextID
	v_correlation_id,		v_correlation_id,
	PX_CISE_REQUEST_ACK, // RequiresAck		PX_CISE_REQUEST_ACK, // RequiresAck
	m_service( // Recipient		m_service( // Recipient
	@@ -119,11 +118,13 @@ module AtsCise_TestCases {
	v_pull_request_signed_str := oct2char(v_pull_request_signed);		v_pull_request_signed_str := oct2char(v_pull_request_signed);
	log("v_pull_request_signed_str: ", v_pull_request_signed_str);		log("v_pull_request_signed_str: ", v_pull_request_signed_str);

			f_verify_sign_pull_request(valueof(m_xml_body_pull_request(v_pull_request, v_pull_request_signed_str)), ""/v_pull_response_canonicalized/);

	f_init_default_headers_list(-, -, v_headers);		f_init_default_headers_list(-, -, v_headers);
	httpPort.send(		httpPort.send(
	m_http_request(		m_http_request(
	m_http_request_post(		m_http_request_post(
	PICS_ROOT_API & PX_CISE_PULL_REQUEST_URI & "?messageId=" & v_message_id,		PICS_ROOT_API & PICS_CISE_PULL_REQUEST_URI & "?messageId=" & v_message_id,
	v_headers,		v_headers,
	m_http_message_body_xml(		m_http_message_body_xml(
	m_xml_body_pull_request( // As the message was signed, we need to send as raw XML to prevent codec call		m_xml_body_pull_request( // As the message was signed, we need to send as raw XML to prevent codec call
	@@ -135,7 +136,8 @@ module AtsCise_TestCases {
	// Test Body		// Test Body
	tc_ac.start;		tc_ac.start;
	alt {		alt {
	[] httpPort.receive(		[v_recv_sync_ack == true]
			httpPort.receive(
	mw_http_response(		mw_http_response(
	mw_http_response_201_created(		mw_http_response_201_created(
	mw_http_message_body_xml(		mw_http_message_body_xml(
	@@ -154,168 +156,23 @@ module AtsCise_TestCases {
	// fx_dec_PullRequest_1(v_enc, v_pull_request);		// 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);		// 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() & ": PASS: IUT successfully received Acknowledgment *");		if (v_response.response.body.xml_body.msg.acknowledgement.AckCode != success) {
	f_selfOrClientSyncAndVerdict(c_tbDone, e_success); // TODO Repeat and wait for the PullResponse ???		log("* " & testcasename() & ": FAIL: Acknowledgement issue *");
	}
	[] httpPort.receive(
	mw_http_response(
	mw_http_response_201_created(
	mw_http_message_body_xml(
	mw_xml_body_pull_response(
	mw_pull_response(
	?,
	?, // pattern "v_message_id*",
	high,
	-, -,
	success,
	-, -,
	v_correlation_id
	)))))) -> value v_response {
	tc_ac.stop;

	/*if (not(f_verify_sign_pull_response(v_response.response.body.xml_body, v_pull_request_canonicalized))) {
	log("* " & testcasename() & ": FAIL: Signature not verified *");
	f_selfOrClientSyncAndVerdict(c_tbDone, e_error);		f_selfOrClientSyncAndVerdict(c_tbDone, e_error);
	} else {*/		} else {
	log("* " & testcasename() & ": PASS: IUT successfully received mandatory Acknowledgement *");		log("* " & testcasename() & ": INFO: IUT successfully received synchronous Acknowledgment *");
	f_selfOrClientSyncAndVerdict(c_tbDone, e_success);		v_recv_sync_ack := false; // Repeat and ...
	//}		v_recv_response := true; // ... wait for the PullResponse
	}
	[] tc_ac.timeout {
	log("* " & testcasename() & ": INCONC: Expected message not received *");
	f_selfOrClientSyncAndVerdict(c_tbDone, e_timeout);
	}
	} // End of 'alt' statement

	// Postamble
	f_cf_01_down();

	} // End of testcase TC_CDM_NODE_PULL_REQUEST_BV_01_01

	/**
	* @desc Check that the IUT responds with an HTPP 200 OK Acknowledgment response when receiving a PullRequest from a known peer with a list of vessels in specified basin - no Acknowledgment required
	* @see ETSI GS CDM 004 [1] Clause 5.4.2 Pull
	* @see ETSI GS CDM 004 [1] Clause 8.1.3 Pull (Request/Response)
	* @see ETSI GS CDM 004 [1] Clause 8.1.4 Pull Request Querying Mechanism
	*/
	testcase TC_CDM_NODE_PULL_REQUEST_BV_01_0x() runs on CiseComponent system CiseTestAdapter {
	// Local variables
	var Headers v_headers;
	var HttpMessage v_response;
	var charstring v_date_time := f_get_current_date_time();
	var charstring v_expected_date_time := substr(v_date_time, 0, lengthof(v_date_time) - 5);
	var charstring v_message_id := f_generate_uuid();
	var charstring v_correlation_id := f_generate_uuid();
	// var charstring v_date_time := "2023-02-15T09:47:23+0100"; // For debug purpose with Mockoon
	// var charstring v_message_id := "c57dc1e1-9473-c1fa-40c4-88a4fc32"; // For debug purpose with Mockoon
	// var charstring v_correlation_id := "19789ef3-2e5f-393d-9011-407be7d5"; // For debug purpose with Mockoon
	var PullRequest_1 v_pull_request;
	var octetstring v_pull_request_signed;
	var charstring v_pull_request_canonicalized;
	var charstring v_pull_request_signed_str;
	var integer v_result;

	// Test control
	if (not(PICS_IUT_CDM_NODE)) {
	log("* " & testcasename() & ": PICS_IUT_CDM_NODE required for executing the TC *");
	setverdict(inconc);
	stop;
	}

	// Test component configuration
	f_cf_01_up();

	// Test adapter configuration

	// Preamble
	v_pull_request := valueof(
	m_pull_request(
	v_date_time,
	v_message_id,
	high,
	m_service( // Sender
	{ string := PX_CISE_SENDER_SERVICE_ID },
	pull,
	-,
	PX_CISE_SEA_BASSIN,
	consumer,
	online,
	vesselService
	),
	{},
	request,
	{},
	-, -, -,
	v_correlation_id,
	PX_CISE_REQUEST_ACK, // RequiresAck
	m_service( // Recipient
	{ string := PX_CISE_RECIPIENT_SERVICE_ID },
	acknowledgement,
	-,
	PX_CISE_SEA_BASSIN,
	provider,
	online,
	vesselService
	),
	m_core_entity_payload_derivations_payload(
	m_entity_payload( // Payload
	nonClassified,
	green,
	nonSpecified,
	{},
	false,
	-,
	false
	)
	),
	-,
	1000 // ResponseTimeOut
	));
	v_result := f_sign_pull_request(v_pull_request, PX_SECURITY_SIGN_HASH_ALG, PICS_CISE_TS_CERTIFICATE, PICS_CISE_TS_SIGNING_PRIVATE_KEY, PICS_CISE_TS_SIGNING_PRIVATE_PASSWD, v_pull_request_signed, v_pull_request_canonicalized);
	if (v_result != 0) {
	log("* " & testcasename() & ": INCONC: Signature processing failed *");
	f_selfOrClientSyncAndVerdict(c_prDone, e_timeout);
	}
	v_pull_request_signed_str := oct2char(v_pull_request_signed);
	log("v_pull_request_signed_str: ", v_pull_request_signed_str);
	f_init_default_headers_list(-, -, v_headers);
	httpPort.send(
	m_http_request(
	m_http_request_post(
	PICS_ROOT_API & PX_CISE_PULL_REQUEST_URI & "?messageId=" & v_message_id,
	v_headers,
	m_http_message_body_xml(
	m_xml_body_pull_request( // As the message was signed, we need to send as raw XML to prevent codec call
	v_pull_request,
	v_pull_request_signed_str // If raw isspecified, the codec does not encode the message
	)))));
	f_selfOrClientSyncAndVerdict(c_prDone, e_success);

	// Test Body
	tc_ac.start;
	alt {
	[PX_CISE_REQUEST_ACK] httpPort.receive(
	mw_http_response(
	mw_http_response_201_created(
	mw_http_message_body_xml(
	mw_xml_body_acknowledgement(
	mw_acknowledgement(
	?,
	?, //pattern "v_message_id*",
	-, -, -, -, -, -,
	v_correlation_id
	)))))) -> value v_response {
	tc_ac.stop;

	// TODO Check message & signature
	log("* " & testcasename() & ": INFO: IUT successfully received Acknowledgement *");

	tc_ac.start;		tc_ac.start;
	repeat;		repeat;
	}		}
	[] httpPort.receive(		}
	mw_http_response(		[v_recv_response == true]
	mw_http_response_201_created(		httpPort_notif.receive(
			mw_http_request(
			mw_http_request_post(
			PICS_ROOT_API & PICS_PULL_RESPONSE_URI,
			-,
	mw_http_message_body_xml(		mw_http_message_body_xml(
	mw_xml_body_pull_response(		mw_xml_body_pull_response(
	mw_pull_response(		mw_pull_response(
	@@ -324,19 +181,35 @@ module AtsCise_TestCases {
	high,		high,
	-, -,		-, -,
	success,		success,
	-, -,		-, -, -,
	v_correlation_id		v_correlation_id
	)))))) -> value v_response {		)))))) -> value v_request {
	tc_ac.stop;		tc_ac.stop;

	// Verify signature		if (not(f_verify_sign_pull_response(v_request.request.body.xml_body, ""/v_pull_response_canonicalized/))) {
	if (not(f_verify_sign_pull_response(v_response.response.body.xml_body, v_pull_request_canonicalized))) {
	log("* " & testcasename() & ": FAIL: Signature not verified *");		log("* " & testcasename() & ": FAIL: Signature not verified *");
	f_selfOrClientSyncAndVerdict(c_tbDone, e_error);		f_selfOrClientSyncAndVerdict(c_tbDone, e_error);
	} else {		} else {
	log("* " & testcasename() & ": PASS: IUT successfully received PullResponse *");		log("* " & testcasename() & ": PASS: IUT successfully received PullResponse *");
	f_selfOrClientSyncAndVerdict(c_tbDone, e_success);		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 {		[] tc_ac.timeout {
	log("* " & testcasename() & ": INCONC: Expected message not received *");		log("* " & testcasename() & ": INCONC: Expected message not received *");
	@@ -345,9 +218,9 @@ module AtsCise_TestCases {
	} // End of 'alt' statement		} // End of 'alt' statement

	// Postamble		// Postamble
	f_cf_01_down();		f_cf_02_down();

	} // End of testcase TC_CDM_NODE_PULL_REQUEST_BV_01_0x		} // End of testcase TC_CDM_NODE_PULL_REQUEST_BV_01_01

	} // End of group PullRequest		} // End of group PullRequest

ttcn/LibCise/LibCdm4/http_www_cise_eu_servicemodel_v1_message.ttcn

+4 −4

ttcn/LibCise/LibCdm5/module.mk

+0 −1

Original line number	Original line	Diff line number	Diff line
	@@ -19,7 +19,6 @@ sources := \
	http_www_cise_eu_datamodel_v1_entity_uniqueidentifier.ttcn \		http_www_cise_eu_datamodel_v1_entity_uniqueidentifier.ttcn \
	http_www_cise_eu_datamodel_v1_entity_vessel.ttcn \		http_www_cise_eu_datamodel_v1_entity_vessel.ttcn \
	http_www_cise_eu_datamodel_v1_relationship.ttcn \		http_www_cise_eu_datamodel_v1_relationship.ttcn \
	NoTargetNamespace.ttcn


	modules := ../LibCdm4		modules := ../LibCdm4

ttcn/LibCise/ttcn/LibCise_Functions.ttcn

+81 −30

File changed.

Preview size limit exceeded, changes collapsed.

Original line number	Original line	Diff line number	Diff line
	@@ -167,7 +167,7 @@ success. */
	XSD.String ackDetail length(5000) optional,		XSD.String ackDetail length(5000) optional,
	/* Used in operations like to Discovery or Get Subscribers to return the		/* Used in operations like to Discovery or Get Subscribers to return the
	results of the operation. */		results of the operation. */
	//record of Service_1 discoveredServices_list optional, /modified/		record of Service_1 discoveredServices_list optional, /modified/
	XSD.String elem optional		XSD.String elem optional
	}		}
	with {		with {
	@@ -195,7 +195,7 @@ with {
	variant (AckCode) "name as capitalized";		variant (AckCode) "name as capitalized";
	variant (ackDetail) "name as capitalized";		variant (ackDetail) "name as capitalized";
	//variant (discoveredServices_list) "untagged";		//variant (discoveredServices_list) "untagged";
	//variant (discoveredServices_list[-]) "name as 'DiscoveredServices'";		variant (discoveredServices_list[-]) "name as 'DiscoveredServices'";
	};		};


	@@ -532,7 +532,7 @@ with {
	variant (reliability) "name as capitalized";		variant (reliability) "name as capitalized";
	variant (ccRecipients_list) "untagged";		variant (ccRecipients_list) "untagged";
	variant (ccRecipients_list[-]) "name as 'CcRecipients'";		variant (ccRecipients_list[-]) "name as 'CcRecipients'";
	variant (elem) "anyElement from 'http://www.w3.org/2000/09/xmldsig#/'";// except unqualified, 'http://www.cise.eu/servicemodel/v1/message/'";		variant (elem) "anyElement except unqualified, 'http://www.cise.eu/servicemodel/v1/message/'";//"anyElement from 'http://www.w3.org/2000/09/xmldsig#/'";// except unqualified, 'http://www.cise.eu/servicemodel/v1/message/'";
	variant (errorDetail) "name as capitalized";		variant (errorDetail) "name as capitalized";
	variant (resultCode) "name as capitalized";		variant (resultCode) "name as capitalized";
	variant (fulfils) "name as capitalized";		variant (fulfils) "name as capitalized";
	@@ -614,7 +614,7 @@ with {
	variant (reliability) "name as capitalized";		variant (reliability) "name as capitalized";
	variant (ccRecipients_list) "untagged";		variant (ccRecipients_list) "untagged";
	variant (ccRecipients_list[-]) "name as 'CcRecipients'";		variant (ccRecipients_list[-]) "name as 'CcRecipients'";
	variant (elem) "anyElement except unqualified, 'http://www.cise.eu/servicemodel/v1/message/'"		variant (elem) "anyElement except unqualified, 'http://www.cise.eu/servicemodel/v1/message/'";
	variant (pullType) "name as capitalized";		variant (pullType) "name as capitalized";
	variant (responseTimeOut) "name as capitalized";		variant (responseTimeOut) "name as capitalized";
	variant (requests) "name as capitalized";		variant (requests) "name as capitalized";

Admin message