Ensure that all requireNotNull calls are annotated

Author: blootsvoets

src/main/java/org/radarbase/output/config/RestructureConfig.kt

@@ -82,7 +82,7 @@ data class RestructureConfig(
             copyOnChange<T, String?>(
                 null,
                 modification = { System.getenv(key).takeIf { it.isNotEmpty() } },
-                doCopy = { doCopy(requireNotNull(it)) }
+                doCopy = { doCopy(requireNotNull(it) { "Environment variable $key is empty" }) },
             )
 
         inline fun <T, V> T.copyOnChange(

src/main/java/org/radarbase/output/source/SourceStorageFactory.kt

@@ -11,18 +11,20 @@ class SourceStorageFactory(
     private val tempPath: Path,
 ) {
     private val s3SourceClient: MinioClient? = if (resourceConfig.sourceType == ResourceType.S3) {
-        requireNotNull(resourceConfig.s3).createS3Client()
+        requireNotNull(resourceConfig.s3) { "Missing S3 configuration" }
+            .createS3Client()
     } else null
 
     private val azureSourceClient: BlobServiceClient? =
         if (resourceConfig.sourceType == ResourceType.AZURE) {
-            requireNotNull(resourceConfig.azure).createAzureClient()
+            requireNotNull(resourceConfig.azure) { "Missing Azure configuration" }
+                .createAzureClient()
         } else null
 
     fun createSourceStorage() = when (resourceConfig.sourceType) {
         ResourceType.S3 -> {
-            val s3Config = requireNotNull(resourceConfig.s3)
-            val minioClient = requireNotNull(s3SourceClient)
+            val s3Config = requireNotNull(resourceConfig.s3) { "Missing S3 configuration for source storage" }
+            val minioClient = requireNotNull(s3SourceClient) { "Missing S3 client configuration for source storage" }
             S3SourceStorage(minioClient, s3Config, tempPath)
         }
         ResourceType.HDFS -> {
@@ -34,8 +36,8 @@ class SourceStorageFactory(
             createSourceStorage.invoke(factory) as SourceStorage
         }
         ResourceType.AZURE -> {
-            val azureClient = requireNotNull(azureSourceClient)
-            val azureConfig = requireNotNull(resourceConfig.azure)
+            val azureClient = requireNotNull(azureSourceClient) { "Missing Azure client configuration for source storage" }
+            val azureConfig = requireNotNull(resourceConfig.azure) { "Missing Azure configuration for source storage" }
             AzureSourceStorage(azureClient, azureConfig, tempPath)
         }
         else -> throw IllegalStateException("Cannot create kafka storage for type ${resourceConfig.sourceType}")