fix emulated tests

Author: ahmedmuhsin

emulatedtests/pom.xml

@@ -21,7 +21,7 @@
 	<properties>
 		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
 		<java.version>1.8</java.version>
-		<azure.functions.maven.plugin.version>1.18.0</azure.functions.maven.plugin.version>
+		<azure.functions.maven.plugin.version>1.37.1</azure.functions.maven.plugin.version>
 		<azure.functions.java.library.version>3.1.0</azure.functions.java.library.version>
 		<azure.functions.java.library.sql.version>2.1.0</azure.functions.java.library.sql.version>
 		<durabletask.azure.functions>1.0.0-beta.1</durabletask.azure.functions>

emulatedtests/src/main/java/com/microsoft/azure/functions/endtoend/BlobTriggerTests.java

@@ -1,10 +1,10 @@
 package com.microsoft.azure.functions.endtoend;
 
+import com.azure.storage.blob.BlobClientBuilder;
 import com.microsoft.azure.functions.annotation.*;
 
+import java.io.ByteArrayInputStream;
 import java.io.ByteArrayOutputStream;
-import java.util.List;
-import java.util.Optional;
 
 import com.microsoft.azure.functions.*;
 
@@ -69,7 +69,6 @@ public void BlobTriggerStringTest(
     public void BlobTriggerToBlobTest_BlobClient(
             @BlobTrigger(name = "triggerBlob", path = "test-triggerinput-blobclient/{name}", dataType = "binary") BlobClient triggerBlobClient,
             @BindingName("name") String fileName,
-            @BlobOutput(name = "outputBlob", path = "test-output-java-new/{name}", dataType = "binary") OutputBinding<byte[]> outputBlob,
             final ExecutionContext context
     ) {
         context.getLogger().info("BlobTriggerUsingBlobClient triggered for blob: " + fileName);
@@ -78,9 +77,21 @@ public void BlobTriggerToBlobTest_BlobClient(
         ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
         triggerBlobClient.downloadStream(outputStream);
 
-        // Set the downloaded content as output
-        outputBlob.setValue(outputStream.toByteArray());
-        context.getLogger().info("Blob content copied successfully from trigger blob to output blob.");
+        // Get connection string from environment variable
+        String connectionString = System.getenv("AzureWebJobsStorage");
+
+        // Define the BlobClient for the destination blob
+        BlobClient outputBlobClient = new BlobClientBuilder()
+                .connectionString(connectionString)
+                .containerName("test-output-java-new")
+                .blobName(fileName)
+                .buildClient();
+
+        // Upload the blob content to the destination container
+        byte[] data = outputStream.toByteArray();
+        outputBlobClient.upload(new ByteArrayInputStream(data), data.length, true);
+
+        context.getLogger().info("Uploaded blob " + fileName + " to container test-output-java-new");
     }
 
     /**
@@ -91,7 +102,6 @@ public void BlobTriggerToBlobTest_BlobClient(
     public void BlobTriggerToBlobTest_BlobContainerClient(
             @BlobTrigger(name = "triggerBlob", path = "test-triggerinput-blobcontclient/{name}", dataType = "binary") BlobContainerClient triggerBlobContainerClient,
             @BindingName("name") String fileName,
-            @BlobOutput(name = "outputBlob", path = "test-output-java-new/{name}", dataType = "binary") OutputBinding<byte[]> outputBlob,
             final ExecutionContext context
     ) {
         context.getLogger().info("BlobTriggerUsingBlobContainerClient triggered for blob: " + fileName);
@@ -101,9 +111,21 @@ public void BlobTriggerToBlobTest_BlobContainerClient(
         ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
         triggerBlobClient.downloadStream(outputStream);
 
-        // Set the downloaded content as output
-        outputBlob.setValue(outputStream.toByteArray());
-        context.getLogger().info("Blob content copied successfully from trigger blob to output blob.");
+        // Get connection string from environment variable
+        String connectionString = System.getenv("AzureWebJobsStorage");
+
+        // Define the BlobClient for the destination blob
+        BlobClient outputBlobClient = new BlobClientBuilder()
+                .connectionString(connectionString)
+                .containerName("test-output-java-new")
+                .blobName(fileName)
+                .buildClient();
+
+        // Upload the blob content to the destination container
+        byte[] data = outputStream.toByteArray();
+        outputBlobClient.upload(new ByteArrayInputStream(data), data.length, true);
+
+        context.getLogger().info("Uploaded blob " + fileName + " to container test-output-java-new");
     }
 
     public static class TestBlobData {

eng/ci/templates/jobs/build.yml

@@ -15,7 +15,7 @@ jobs:
         java -version
       displayName: 'Check default java version'
     - pwsh: |
-         .\installJavaAdditions.ps1
+        .\installLibsLocally.ps1
       displayName: 'Install java-additions locally'
     - pwsh: |
         mvn clean package

eng/ci/templates/jobs/run-emulated-tests-linux.yml

@@ -58,7 +58,7 @@ jobs:
           java -version
         displayName: 'Check default java version'
       - pwsh: |
-          .\installJavaAdditions.ps1
+          .\installLibsLocally.ps1
         displayName: 'Install java-additions locally'
       - pwsh: |
           if ("$(isTag)"){

eng/ci/templates/jobs/run-emulated-tests-windows.yml

@@ -48,7 +48,7 @@ jobs:
           java -version
         displayName: 'Check default java version'
       - pwsh: |
-          .\installJavaAdditions.ps1
+          .\installLibsLocally.ps1
         displayName: 'Install java-additions locally'
       - pwsh: |
           if ("$(isTag)"){

installJavaAdditions.ps1

@@ -0,0 +1,52 @@
+# Variables for first repository
+$repoUrl1 = 'https://github.com/ahmedmuhsin/azure-functions-java-additions.git'
+$branchName1 = 'sdk-types'
+$repoName1 = 'azure-functions-java-additions'
+
+# Clone the first repository
+git clone $repoUrl1
+
+# Change directory to the cloned repository
+Set-Location $repoName1
+
+# Checkout the desired branch
+git checkout $branchName1
+
+# Detect OS and execute build accordingly
+if ($IsWindows) {
+    # Run the batch script (mvnBuild.bat)
+    & ".\mvnBuild.bat"
+} else {
+    # Extract and explicitly invoke the mvn command from mvnBuild.bat
+    $mvnCommand = Get-Content "./mvnBuild.bat" | Where-Object { $_ -match '^mvn\s+' }
+    if ($null -ne $mvnCommand) {
+        # Execute the extracted mvn command explicitly as a single line
+        bash -c "$mvnCommand"
+    } else {
+        Write-Error "No mvn command found in mvnBuild.bat."
+    }
+}
+
+# Return to the parent directory before working on the second repository
+Set-Location ..
+
+# Variables for second repository
+$repoUrl2 = 'https://github.com/ahmedmuhsin/azure-maven-plugins.git'
+$branchName2 = 'sdk-types'
+$repoName2 = 'azure-maven-plugins'
+
+# Clone the second repository
+git clone $repoUrl2
+
+# Change directory to the cloned repository
+Set-Location $repoName2
+
+# Checkout the desired branch
+git checkout $branchName2
+
+# Run Maven command to build/install, skipping tests and javadoc
+if ($IsWindows) {
+    & "mvn" "clean" "install" "-DskipTests" "-Dmaven.javadoc.skip=true"
+} else {
+    bash -c "mvn clean install -DskipTests -Dmaven.javadoc.skip=true"
+}