Fatping

README.md

@@ -2,6 +2,9 @@
 
 In this repository you will find the ping-pong process for connection testing, which can be deployed on the [DSF](https://github.com/datasharingframework/dsf).
 
+## Version 2.x release
+Version 2.x of the ping-pong process (dubbed "Fat-Ping") includes the ability to test whether downloading FHIR resources from other DSF instances is possible. This also includes approximately measuring the network speed of resource downloads with larger download sizes (~100MB) returning more accurate results. It retains the ability to make connection tests without downloading resource like ping-pong 1.x. Documentation on configuration is available in the [wiki](https://github.com/datasharingframework/dsf-process-ping-pong/wiki).
+
 ## Development
 Branching follows the git-flow model, for the latest development version see branch [develop](https://github.com/datasharingframework/dsf-process-ping-pong/tree/develop).
 

pom.xml

@@ -5,15 +5,15 @@
 
 	<groupId>dev.dsf</groupId>
 	<artifactId>dsf-process-ping-pong</artifactId>
-	<version>1.0.1.0-SNAPSHOT</version>
+	<version>2.0.0.0-RC2</version>
 	<packaging>jar</packaging>
 
 	<properties>
 		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
 		<compileSource>17</compileSource>
 		<compileTarget>17</compileTarget>
 
-		<dsf.version>1.2.0-RC1</dsf.version>
+		<dsf.version>1.2.0</dsf.version>
 		<dsf.location>../dsf</dsf.location>
 	</properties>
 

src/main/java/dev/dsf/bpe/ConstantsPing.java

@@ -1,59 +1,188 @@
 package dev.dsf.bpe;
 
+import java.util.List;
 
-public interface ConstantsPing
+import jakarta.ws.rs.core.MediaType;
+
+public final class ConstantsPing
 {
-	String PROCESS_NAME_PING_AUTOSTART = "pingAutostart";
-	String PROCESS_NAME_PING = "ping";
-	String PROCESS_NAME_PONG = "pong";
-
-	String PROCESS_NAME_FULL_PING_AUTOSTART = "dsfdev_" + PROCESS_NAME_PING_AUTOSTART;
-	String PROCESS_NAME_FULL_PING = "dsfdev_" + PROCESS_NAME_PING;
-	String PROCESS_NAME_FULL_PONG = "dsfdev_" + PROCESS_NAME_PONG;
-
-	String PROCESS_DSF_URI_BASE = "http://dsf.dev/bpe/Process/";
-
-	String PROFILE_DSF_TASK_START_PING_AUTOSTART = "http://dsf.dev/fhir/StructureDefinition/task-start-ping-autostart";
-	String PROFILE_DSF_TASK_START_PING_AUTOSTART_PROCESS_URI = PROCESS_DSF_URI_BASE + PROCESS_NAME_PING_AUTOSTART;
-	String PROFILE_DSF_TASK_START_PING_AUTOSTART_MESSAGE_NAME = "startPingAutostart";
-
-	String PROFILE_DSF_TASK_STOP_PING_AUTOSTART = "http://dsf.dev/fhir/StructureDefinition/task-stop-ping-autostart";
-	String PROFILE_DSF_TASK_STOP_PING_AUTOSTART_PROCESS_URI = PROCESS_DSF_URI_BASE + PROCESS_NAME_PING_AUTOSTART;
-	String PROFILE_DSF_TASK_STOP_PING_AUTOSTART_MESSAGE_NAME = "stopPingAutostart";
-
-	String PROFILE_DSF_TASK_START_PING = "http://dsf.dev/fhir/StructureDefinition/task-start-ping";
-	String PROFILE_DSF_TASK_START_PING_MESSAGE_NAME = "startPing";
-
-	String PROFILE_DSF_TASK_PING = "http://dsf.dev/fhir/StructureDefinition/task-ping";
-	String PROFILE_DSF_TASK_PING_PROCESS_URI = PROCESS_DSF_URI_BASE + PROCESS_NAME_PING;
-	String PROFILE_DSF_TASK_PING_MESSAGE_NAME = "ping";
-
-	String PROFILE_DSF_TASK_PONG_TASK = "http://dsf.dev/fhir/StructureDefinition/task-pong";
-	String PROFILE_DSF_TASK_PONG_PROCESS_URI = PROCESS_DSF_URI_BASE + PROCESS_NAME_PONG;
-	String PROFILE_DSF_TASK_PONG_MESSAGE_NAME = "pong";
-
-	String CODESYSTEM_DSF_PING = "http://dsf.dev/fhir/CodeSystem/ping";
-	String CODESYSTEM_DSF_PING_VALUE_PING_STATUS = "ping-status";
-	String CODESYSTEM_DSF_PING_VALUE_PONG_STATUS = "pong-status";
-	String CODESYSTEM_DSF_PING_VALUE_ENDPOINT_IDENTIFIER = "endpoint-identifier";
-	String CODESYSTEM_DSF_PING_VALUE_TARGET_ENDPOINTS = "target-endpoints";
-	String CODESYSTEM_DSF_PING_VALUE_TIMER_INTERVAL = "timer-interval";
-
-	String CODESYSTEM_DSF_PING_STATUS = "http://dsf.dev/fhir/CodeSystem/ping-status";
-	String CODESYSTEM_DSF_PING_STATUS_VALUE_NOT_ALLOWED = "not-allowed";
-	String CODESYSTEM_DSF_PING_STATUS_VALUE_NOT_REACHABLE = "not-reachable";
-	String CODESYSTEM_DSF_PING_STATUS_VALUE_PONG_MISSING = "pong-missing";
-	String CODESYSTEM_DSF_PING_STATUS_VALUE_PONG_RECEIVED = "pong-received";
-	String CODESYSTEM_DSF_PING_STATUS_VALUE_PONG_SEND = "pong-send";
-
-	String EXTENSION_URL_PING_STATUS = "http://dsf.dev/fhir/StructureDefinition/extension-ping-status";
-	String EXTENSION_URL_CORRELATION_KEY = "correlation-key";
-	String EXTENSION_URL_ORGANIZATION_IDENTIFIER = "organization-identifier";
-	String EXTENSION_URL_ENDPOINT_IDENTIFIER = "endpoint-identifier";
-	String EXTENSION_URL_ERROR_MESSAGE = "error-message";
-
-	String BPMN_EXECUTION_VARIABLE_TIMER_INTERVAL = "timerInterval";
-	String BPMN_EXECUTION_VARIABLE_STOP_TIMER = "stopTimer";
-
-	String TIMER_INTERVAL_DEFAULT_VALUE = "PT24H";
+	private ConstantsPing()
+	{
+	}
+
+	public static final String PROCESS_NAME_PING_AUTOSTART = "pingAutostart";
+	public static final String PROCESS_NAME_PING = "ping";
+	public static final String PROCESS_NAME_PONG = "pong";
+
+	public static final String PROCESS_NAME_FULL_PING_AUTOSTART = "dsfdev_" + PROCESS_NAME_PING_AUTOSTART;
+	public static final String PROCESS_NAME_FULL_PING = "dsfdev_" + PROCESS_NAME_PING;
+	public static final String PROCESS_NAME_FULL_PONG = "dsfdev_" + PROCESS_NAME_PONG;
+
+	public static final String PROCESS_DSF_URI_BASE = "http://dsf.dev/bpe/Process/";
+
+	public static final String PROFILE_DSF_TASK_START_PING_AUTOSTART = "http://dsf.dev/fhir/StructureDefinition/task-start-ping-autostart";
+	public static final String PROFILE_DSF_TASK_START_PING_AUTOSTART_PROCESS_URI = PROCESS_DSF_URI_BASE
+			+ PROCESS_NAME_PING_AUTOSTART;
+	public static final String PROFILE_DSF_TASK_START_PING_AUTOSTART_MESSAGE_NAME = "startPingAutostart";
+
+	public static final String PROFILE_DSF_TASK_STOP_PING_AUTOSTART = "http://dsf.dev/fhir/StructureDefinition/task-stop-ping-autostart";
+	public static final String PROFILE_DSF_TASK_STOP_PING_AUTOSTART_PROCESS_URI = PROCESS_DSF_URI_BASE
+			+ PROCESS_NAME_PING_AUTOSTART;
+	public static final String PROFILE_DSF_TASK_STOP_PING_AUTOSTART_MESSAGE_NAME = "stopPingAutostart";
+
+	public static final String PROFILE_DSF_TASK_START_PING = "http://dsf.dev/fhir/StructureDefinition/task-start-ping";
+	public static final String PROFILE_DSF_TASK_START_PING_MESSAGE_NAME = "startPing";
+
+	public static final String PROFILE_DSF_TASK_PING = "http://dsf.dev/fhir/StructureDefinition/task-ping";
+	public static final String PROFILE_DSF_TASK_PING_PROCESS_URI = PROCESS_DSF_URI_BASE + PROCESS_NAME_PING;
+	public static final String PROFILE_DSF_TASK_PING_MESSAGE_NAME = "ping";
+
+	public static final String PROFILE_DSF_TASK_PONG_TASK = "http://dsf.dev/fhir/StructureDefinition/task-pong";
+	public static final String PROFILE_DSF_TASK_PONG_PROCESS_URI = PROCESS_DSF_URI_BASE + PROCESS_NAME_PONG;
+	public static final String PROFILE_DSF_TASK_PONG_MESSAGE_NAME = "pong";
+
+	public static final String PROFILE_DSF_TASK_CLEANUP_PONG = "http://dsf.dev/fhir/StructureDefinition/task-cleanup-pong";
+	public static final String PROFILE_DSF_TASK_CLEANUP_PONG_PROCESS_URI = PROCESS_DSF_URI_BASE + PROCESS_NAME_PONG;
+	public static final String PROFILE_DSF_TASK_CLEANUP_PONG_MESSAGE_NAME = "cleanupPong";
+
+	public static final String CODESYSTEM_DSF_PING = "http://dsf.dev/fhir/CodeSystem/ping-v2";
+	public static final String CODESYSTEM_DSF_PING_VALUE_PING_STATUS = "ping-status";
+	public static final String CODESYSTEM_DSF_PING_VALUE_PONG_STATUS = "pong-status";
+	public static final String CODESYSTEM_DSF_PING_VALUE_ENDPOINT_IDENTIFIER = "endpoint-identifier";
+	public static final String CODESYSTEM_DSF_PING_VALUE_TARGET_ENDPOINTS = "target-endpoints";
+	public static final String CODESYSTEM_DSF_PING_VALUE_TIMER_INTERVAL = "timer-interval";
+	public static final String CODESYSTEM_DSF_PING_VALUE_DOWNLOAD_RESOURCE_SIZE_BYTES = "download-resource-size-bytes";
+	public static final String CODESYSTEM_DSF_PING_VALUE_DOWNLOADED_DURATION_MILLIS = "downloaded-duration-millis";
+	public static final String CODESYSTEM_DSF_PING_VALUE_DOWNLOADED_BYTES = "downloaded-bytes";
+	public static final String CODESYSTEM_DSF_PING_VALUE_DOWNLOAD_RESOURCE_REFERENCE = "download-resource-reference";
+
+	public static final String CODESYSTEM_DSF_PING_STATUS = "http://dsf.dev/fhir/CodeSystem/ping-status-v2";
+	public static final String CODESYSTEM_DSF_PING_STATUS_VALUE_NOT_ALLOWED = "not-allowed";
+	public static final String CODESYSTEM_DSF_PING_STATUS_VALUE_NOT_REACHABLE = "not-reachable";
+	public static final String CODESYSTEM_DSF_PING_STATUS_VALUE_PONG_MISSING = "pong-missing";
+	public static final String CODESYSTEM_DSF_PING_STATUS_VALUE_PONG_RECEIVED = "pong-received";
+	public static final String CODESYSTEM_DSF_PING_STATUS_VALUE_PONG_SENT = "pong-sent";
+	public static final String CODESYSTEM_DSF_PING_STATUS_VALUE_ERROR_MESSAGE = "error-message";
+	public static final String CODESYSTEM_DSF_PING_STATUS_VALUE_RESOURCE_DOWNLOADED = "resource-downloaded";
+
+	public static final String CODESYSTEM_DSF_PING_UNITS = "http://dsf.dev/fhir/CodeSystem/ping-units-v2";
+	public static final String CODESYSTEM_DSF_PING_UNITS_VALUE_BITS_PER_SECOND = "bits-per-second";
+	public static final String CODESYSTEM_DSF_PING_UNITS_VALUE_BYTES_PER_SECOND = "bytes-per-second";
+	public static final String CODESYSTEM_DSF_PING_UNITS_VALUE_MEGABITS_PER_SECOND = "megabits-per-second";
+	public static final String CODESYSTEM_DSF_PING_UNITS_VALUE_MEGABYTES_PER_SECOND = "megabytes-per-second";
+
+	public static final List<String> CODESYSTEM_DSF_PING_UNITS_VALUES = List.of(
+			CODESYSTEM_DSF_PING_UNITS_VALUE_BITS_PER_SECOND, CODESYSTEM_DSF_PING_UNITS_VALUE_BYTES_PER_SECOND,
+			CODESYSTEM_DSF_PING_UNITS_VALUE_MEGABITS_PER_SECOND, CODESYSTEM_DSF_PING_UNITS_VALUE_MEGABYTES_PER_SECOND);
+
+	public static final String CODESYSTEM_READ_ACCESS_TAG = "http://dsf.dev/fhir/CodeSystem/read-access-tag";
+	public static final String CODESYSTEM_READ_ACCESS_TAG_VALUE_ALL = "ALL";
+
+	public static final String EXTENSION_URL_PING_STATUS = "http://dsf.dev/fhir/StructureDefinition/extension-ping-status-v2";
+	public static final String EXTENSION_URL_NETWORK_SPEED = "http://dsf.dev/fhir/StructureDefinition/extension-network-speed";
+	public static final String EXTENSION_URL_CORRELATION_KEY = "correlation-key";
+	public static final String EXTENSION_URL_ORGANIZATION_IDENTIFIER = "organization-identifier";
+	public static final String EXTENSION_URL_ENDPOINT_IDENTIFIER = "endpoint-identifier";
+	public static final String EXTENSION_URL_ERROR_MESSAGE = "error-message";
+	public static final String EXTENSION_URL_DOWNLOAD_SPEED = "download-speed";
+	public static final String EXTENSION_URL_UPLOAD_SPEED = "upload-speed";
+	public static final String EXTENSION_URL_NETWORK_SPEED_UNIT = "unit";
+	public static final String EXTENSION_URL_NETWORK_SPEED_VALUE = "network-speed";
+
+	public static final String BPMN_EXECUTION_VARIABLE_TIMER_INTERVAL = "timerInterval";
+	public static final String BPMN_EXECUTION_VARIABLE_STOP_TIMER = "stopTimer";
+	public static final String BPMN_EXECUTION_VARIABLE_DOWNLOAD_RESOURCE_SIZE_BYTES = "downloadResourceSizeBytes";
+	public static final String BPMN_EXECUTION_VARIABLE_DOWNLOAD_RESOURCE = "downloadResource";
+	public static final String BPMN_EXECUTION_VARIABLE_DOWNLOAD_RESOURCE_REFERENCE = "downloadResourceReference";
+	private static final String BPMN_EXECUTION_VARIABLE_STATUS_CODE = "statusCode";
+	private static final String BPMN_EXECUTION_VARIABLE_ERROR_MESSAGE = "errorMessage";
+	private static final String BPMN_EXECUTION_VARIABLE_ERROR_MESSAGE_LIST = "errorMessages";
+	private static final String BPMN_EXECUTION_VARIABLE_DOWNLOADED_BYTES = "downloadedBytes";
+	private static final String BPMN_EXECUTION_VARIABLE_DOWNLOADED_DURATION_MILLIS = "downloadedDurationMillis";
+	public static final String BPMN_EXECUTION_VARIABLE_PONG_TARGET_ENDPOINT_IDENTIFIER = "targetEndpointIdentifier";
+	private static final String BPMN_EXECUTION_VARIABLE_UPLOADED_BYTES = "uploadedBytes";
+	private static final String BPMN_EXECUTION_VARIABLE_UPLOADED_DURATION_MILLIS = "uploadedDurationMillis";
+	public static final String BPMN_EXECUTION_VARIABLE_RESOURCE_DOWNLOAD_ERROR_MESSAGE = "resourceDownloadErrorMessage";
+	public static final String BPMN_EXECUTION_VARIABLE_RESOURCE_UPLOAD_ERROR_MESSAGE = "resourceUploadErrorMessage";
+
+	public static final String BPMN_ERROR_CODE_RESOURCE_DOWNLOAD_ERROR = "resourceDownloadError";
+	public static final String BPMN_ERROR_CODE_RESOURCE_UPLOAD_ERROR = "resourceUploadError";
+
+	public static final String PONG_ERROR_MESSAGE_CLEANUP_TIMEOUT = "Timeout while waiting for cleanup message";
+
+	public static final int DOWNLOAD_RESOURCE_SIZE_BYTES_DEFAULT = 10000000;
+
+	public static final MediaType DOWNLOAD_RESOURCE_MIME_TYPE = MediaType.APPLICATION_OCTET_STREAM_TYPE;
+
+	public static final String TIMER_INTERVAL_DEFAULT_VALUE = "PT24H";
+
+	public static String getBpmnExecutionVariableStatusCode()
+	{
+		return BPMN_EXECUTION_VARIABLE_STATUS_CODE;
+	}
+
+	public static String getBpmnExecutionVariableStatusCode(String correlationKey)
+	{
+		return BPMN_EXECUTION_VARIABLE_STATUS_CODE + "_" + correlationKey;
+	}
+
+	public static String getBpmnExecutionVariableErrorMessage()
+	{
+		return BPMN_EXECUTION_VARIABLE_ERROR_MESSAGE;
+	}
+
+	public static String getBpmnExecutionVariableErrorMessage(String correlationKey)
+	{
+		return BPMN_EXECUTION_VARIABLE_ERROR_MESSAGE + "_" + correlationKey;
+	}
+
+	public static String getBpmnExecutionVariableDownloadedBytes()
+	{
+		return BPMN_EXECUTION_VARIABLE_DOWNLOADED_BYTES;
+	}
+
+	public static String getBpmnExecutionVariableDownloadedBytes(String correlationKey)
+	{
+		return BPMN_EXECUTION_VARIABLE_DOWNLOADED_BYTES + "_" + correlationKey;
+	}
+
+	public static String getBpmnExecutionVariableDownloadedDurationMillis()
+	{
+		return BPMN_EXECUTION_VARIABLE_DOWNLOADED_DURATION_MILLIS;
+	}
+
+	public static String getBpmnExecutionVariableDownloadedDurationMillis(String correlationKey)
+	{
+		return BPMN_EXECUTION_VARIABLE_DOWNLOADED_DURATION_MILLIS + "_" + correlationKey;
+	}
+
+	public static String getBpmnExecutionVariableUploadedBytes()
+	{
+		return BPMN_EXECUTION_VARIABLE_UPLOADED_BYTES;
+	}
+
+	public static String getBpmnExecutionVariableUploadedBytes(String correlationKey)
+	{
+		return BPMN_EXECUTION_VARIABLE_UPLOADED_BYTES + "_" + correlationKey;
+	}
+
+	public static String getBpmnExecutionVariableUploadedDurationMillis()
+	{
+		return BPMN_EXECUTION_VARIABLE_UPLOADED_DURATION_MILLIS;
+	}
+
+	public static String getBpmnExecutionVariableUploadedDurationMillis(String correlationKey)
+	{
+		return BPMN_EXECUTION_VARIABLE_UPLOADED_DURATION_MILLIS + "_" + correlationKey;
+	}
+
+	public static String getBpmnExecutionVariableErrorMessageList()
+	{
+		return BPMN_EXECUTION_VARIABLE_ERROR_MESSAGE_LIST;
+	}
+
+	public static String getBpmnExecutionVariableErrorMessageList(String correlationKey)
+	{
+		return getBpmnExecutionVariableErrorMessageList() + "_" + correlationKey;
+	}
 }

src/main/java/dev/dsf/bpe/PingProcessPluginDefinition.java

@@ -10,8 +10,8 @@
 
 public class PingProcessPluginDefinition implements ProcessPluginDefinition
 {
-	public static final String VERSION = "1.0.1.0";
-	public static final LocalDate RELEASE_DATE = LocalDate.of(2023, 9, 5);
+	public static final String VERSION = "2.0.0.0";
+	public static final LocalDate RELEASE_DATE = LocalDate.of(2023, 9, 12);
 
 	@Override
 	public String getName()
@@ -52,29 +52,33 @@ public Map<String, List<String>> getFhirResourcesByProcessId()
 
 		var cPing = "fhir/CodeSystem/dsf-ping.xml";
 		var cPingStatus = "fhir/CodeSystem/dsf-ping-status.xml";
+		var cPingUnits = "fhir/CodeSystem/dsf-ping-units.xml";
 
 		var sPingStatus = "fhir/StructureDefinition/dsf-extension-ping-status.xml";
 		var sPing = "fhir/StructureDefinition/dsf-task-ping.xml";
 		var sPong = "fhir/StructureDefinition/dsf-task-pong.xml";
 		var sStartPing = "fhir/StructureDefinition/dsf-task-start-ping.xml";
 		var sStartPingAutostart = "fhir/StructureDefinition/dsf-task-start-ping-autostart.xml";
 		var sStopPingAutostart = "fhir/StructureDefinition/dsf-task-stop-ping-autostart.xml";
+		var sCleanupPong = "fhir/StructureDefinition/dsf-task-cleanup-pong.xml";
+		var sNetworkSpeedExtension = "fhir/StructureDefinition/dsf-extension-network-speed.xml";
 
 		var tStartPing = "fhir/Task/dsf-task-start-ping.xml";
 		var tStartPingAutoStart = "fhir/Task/dsf-task-start-ping-autostart.xml";
 		var tStopPingAutoStart = "fhir/Task/dsf-task-stop-ping-autostart.xml";
 
 		var vPing = "fhir/ValueSet/dsf-ping.xml";
+		var vPingUnits = "fhir/ValueSet/dsf-ping-units.xml";
 		var vPingStatus = "fhir/ValueSet/dsf-ping-status.xml";
 		var vPongStatus = "fhir/ValueSet/dsf-pong-status.xml";
 
 		return Map.of(ConstantsPing.PROCESS_NAME_FULL_PING,
-				Arrays.asList(
-						aPing, cPing, cPingStatus, sPingStatus, sStartPing, sPong, tStartPing, vPing, vPingStatus),
+				Arrays.asList(aPing, cPing, cPingStatus, cPingUnits, sPingStatus, sStartPing, sPong, sCleanupPong,
+						sNetworkSpeedExtension, tStartPing, vPing, vPingStatus, vPingUnits),
 				ConstantsPing.PROCESS_NAME_FULL_PING_AUTOSTART,
 				Arrays.asList(aPingAutostart, cPing, sStartPingAutostart, sStopPingAutostart, tStartPingAutoStart,
 						tStopPingAutoStart, vPing),
-				ConstantsPing.PROCESS_NAME_FULL_PONG,
-				Arrays.asList(aPong, cPing, cPingStatus, sPingStatus, sPing, vPing, vPongStatus));
+				ConstantsPing.PROCESS_NAME_FULL_PONG, Arrays.asList(aPong, cPing, cPingStatus, cPingUnits, sPingStatus,
+						sPing, sNetworkSpeedExtension, vPing, vPongStatus, vPingUnits));
 	}
 }

src/main/java/dev/dsf/bpe/listener/PingPongDeploymentStateListener.java

@@ -0,0 +1,73 @@
+package dev.dsf.bpe.listener;
+
+import java.util.List;
+import java.util.Objects;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.InitializingBean;
+
+import dev.dsf.bpe.ConstantsPing;
+import dev.dsf.bpe.spring.config.PingConfig;
+import dev.dsf.bpe.v1.ProcessPluginDeploymentStateListener;
+
+public class PingPongDeploymentStateListener implements ProcessPluginDeploymentStateListener, InitializingBean
+{
+	private static final Logger logger = LoggerFactory.getLogger(PingPongDeploymentStateListener.class);
+
+	private final PingConfig pingConfig;
+	private final String networkSpeedUnit;
+
+	public PingPongDeploymentStateListener(PingConfig pingConfig)
+	{
+		this.pingConfig = pingConfig;
+		this.networkSpeedUnit = pingConfig.getNetworkSpeedUnit();
+	}
+
+	@Override
+	public void onProcessesDeployed(List<String> processes)
+	{
+		logger.debug("Validating plugin configuration...");
+		if (ConstantsPing.CODESYSTEM_DSF_PING_UNITS_VALUES.contains(networkSpeedUnit))
+		{
+			logger.debug("Network speed unit is valid: {}", networkSpeedUnit);
+		}
+		else
+		{
+			pingConfig.setNetworkSpeedUnit(ConstantsPing.CODESYSTEM_DSF_PING_UNITS_VALUE_MEGABYTES_PER_SECOND);
+			logger.debug("Network speed unit \"{}\" is not valid. Valid values are: {}. Defaulting to \"{}\"",
+					networkSpeedUnit, ConstantsPing.CODESYSTEM_DSF_PING_UNITS_VALUES,
+					ConstantsPing.CODESYSTEM_DSF_PING_UNITS_VALUE_MEGABYTES_PER_SECOND);
+		}
+
+		// TODO: fixme
+		int maxDownloadSizeBytes = pingConfig.getMaxDownloadSizeBytes();
+		int maxDownloadSizeBytesHeapFix = 100000000;
+		if (maxDownloadSizeBytes > maxDownloadSizeBytesHeapFix)
+		{
+			pingConfig.setMaxDownloadSizeBytes(maxDownloadSizeBytesHeapFix);
+			logger.debug(
+					"MaxDownloadSizeBytes is too large. Setting maxDownloadSizeBytes to {}. This avoids Java running out of memory and will be fixed in a future release",
+					maxDownloadSizeBytesHeapFix);
+		}
+
+		int maxUploadSizeBytes = pingConfig.getMaxUploadSizeBytes();
+		int maxUploadSizeBytesHeapFix = 100000000;
+		if (maxUploadSizeBytes > maxUploadSizeBytesHeapFix)
+		{
+			pingConfig.setMaxUploadSizeBytes(maxUploadSizeBytesHeapFix);
+			logger.debug(
+					"MaxUploadSizeBytes is too large. Setting maxUploadSizeBytes to {}. This avoids Java running out of memory and will be fixed in a future release",
+					maxUploadSizeBytesHeapFix);
+		}
+
+		logger.debug("Configuration validation complete.");
+	}
+
+	@Override
+	public void afterPropertiesSet() throws Exception
+	{
+		Objects.requireNonNull(networkSpeedUnit);
+		Objects.requireNonNull(pingConfig);
+	}
+}