add regex for onelake + test

src/main/scala/com/exasol/cloudetl/bucket/AzureAbfsBucket.scala

@@ -65,12 +65,17 @@ final case class AzureAbfsBucket(path: String, params: StorageProperties) extend
 
   // Intentionally copy-paste, duplicate count: 2. Please, refactor when
   // it reaches 3+.
+  // Fabric / OneLake: .dfs.fabric.microsoft.com
   private[this] final val AZURE_ABFS_PATH_REGEX: Regex =
     """abfss?://(.*)@([^.]+).dfs.core.windows.net/(.*)$""".r
+  private[this] final val AZURE_ABFS_ONELAKE_PATH_REGEX: Regex =
+    """abfss?://(.*)@([^.]+)\.dfs\.fabric\.microsoft\.com/(.*)$""".r
 
   private[this] def regexParsePath(path: String): AccountAndContainer = path match {
     case AZURE_ABFS_PATH_REGEX(containerName, accountName, _) =>
       AccountAndContainer(accountName, containerName)
+    case AZURE_ABFS_ONELAKE_PATH_REGEX(containerName, accountName, _) =>
+      AccountAndContainer(accountName, containerName)
     case _ =>
       throw new BucketValidationException(
         ExaError

src/test/scala/com/exasol/cloudetl/bucket/AzureAbfsBucketTest.scala

@@ -36,6 +36,21 @@ class AzureAbfsBucketTest extends AbstractBucketTest {
     assert(thrown.getMessage().startsWith("E-CSE-20"))
     assert(thrown.getMessage().contains(s"path '$path' scheme is not valid."))
   }
+  // https://github.com/MicrosoftDocs/fabric-docs/blob/main/docs/onelake/onelake-access-api.md
+  // "abfss://[email protected]/data/"
+  // The account name is always onelake
+  // The container name is your workspace name.
+  //
+  // From the docs
+  // -> abfs[s]://<workspace>@onelake.dfs.fabric.microsoft.com/<item>.<itemtype>/<path>/<fileName>
+  test("apply throws if Azure OneLake path does not return valid Bucket") {
+    val path = "abfss://[email protected]/item.itemtype/path/filename"
+    val exaMetadata = mockConnectionInfo("", "AZURE_SECRET_KEY=secret")
+    properties = defaultProperties ++ Map(PATH -> path, "CONNECTION_NAME" -> "connection_info")
+
+    val bucket = getBucket(properties, exaMetadata)
+    assert(bucket.isInstanceOf[AzureAbfsBucket])
+  }
 
   test("apply throws if no connection name is provided") {
     properties = defaultProperties