Init shading suppport

Author: amamounelsayed

README.md

@@ -30,7 +30,7 @@ build_script:
        Write-Host “Found git tag."
       } 
       else {
-       $buildNumber = "1.6.2-$env:APPVEYOR_BUILD_NUMBER"
+       $buildNumber = "1.7.1-$env:APPVEYOR_BUILD_NUMBER"
        Write-Host “git tag not found. Setting package suffix to '$buildNumber'"
       }     
       .\package.ps1 -buildNumber $buildNumber

appveyor.yml

@@ -19,10 +19,10 @@ steps:
        Write-Host “Found git tag."
       } 
       else {
-       $buildNumber = "1.6.2-$(Build.BuildId)"
+       $buildNumber = "1.7.1-$(Build.BuildId)"
        Write-Host “git tag not found. Setting package suffix to '$buildNumber'"
       }     
-      .\package.ps1 -buildNumber $buildNumber
+      .\package-pipeline.ps1 -buildNumber $buildNumber
   displayName: 'Executing build script'
 - task: CopyFiles@2
   inputs:

azure-pipelines.yml

@@ -19,7 +19,7 @@ steps:
        Write-Host “Found git tag."
       } 
       else {
-       $buildNumber = "1.6.2-$(Build.BuildId)"
+       $buildNumber = "1.7.1-$(Build.BuildId)"
        Write-Host “git tag not found. Setting package suffix to '$buildNumber'"
       }     
       .\package.ps1 -buildNumber $buildNumber

e2e-nightly-cli-azure-pipelines.yml

@@ -0,0 +1,29 @@
+param (
+  [string]$buildNumber = $env:APPVEYOR_BUILD_NUMBER
+)
+
+# A function that checks exit codes and fails script if an error is found 
+function StopOnFailedExecution {
+  if ($LastExitCode) 
+  { 
+    exit $LastExitCode 
+  }
+}
+Write-Host "Building azure-functions-java-worker" 
+cmd.exe /c '.\mvnBuild.bat'
+StopOnFailedExecution
+
+Write-Host "Creating nuget package Microsoft.Azure.Functions.JavaWorker" 
+Write-Host "buildNumber: " $buildNumber
+Get-Command nuget
+StopOnFailedExecution
+remove-item pkg -Recurse -ErrorAction Ignore
+mkdir pkg
+Get-ChildItem -Path .\target\* -Include 'azure*' -Exclude '*shaded.jar','*tests.jar' | %{ Copy-Item $_.FullName .\pkg\azure-functions-java-worker.jar }
+StopOnFailedExecution
+copy-item ./worker.config.json pkg
+copy-item ./tools/AzureFunctionsJavaWorker.nuspec pkg/
+Copy-Item ".\lib_worker_1.6.2" pkg\lib -Recurse
+set-location pkg
+nuget pack -Properties version=$buildNumber
+set-location ..

lib_worker_1.6.2/animal-sniffer-annotations-1.17.jar

@@ -23,6 +23,7 @@ Get-ChildItem -Path .\target\* -Include 'azure*' -Exclude '*shaded.jar' | %{ Cop
 StopOnFailedExecution
 copy-item ./worker.config.json pkg
 copy-item ./tools/AzureFunctionsJavaWorker.nuspec pkg/
+Copy-Item ".\lib_worker_1.6.2" pkg\lib -Recurse
 set-location pkg
 nuget pack -Properties version=$buildNumber
 set-location ..

lib_worker_1.6.2/annotations-4.1.1.4.jar

@@ -4,7 +4,7 @@
 	<modelVersion>4.0.0</modelVersion>
 	<groupId>com.microsoft.azure.functions</groupId>
 	<artifactId>azure-functions-java-worker</artifactId>
-	<version>1.6.2</version>
+	<version>1.7.1</version>
 	<packaging>jar</packaging>
 	<parent>
 		<groupId>com.microsoft.maven</groupId>
@@ -174,7 +174,7 @@
 			</plugin>
 			<plugin>
 				<artifactId>maven-shade-plugin</artifactId>
-				<version>3.2.0</version>
+				<version>3.2.4</version>
 				<executions>
 					<execution>
 						<phase>package</phase>
@@ -184,14 +184,15 @@
 						<configuration>
 							<transformers>
 								<transformer
-									implementation="org.apache.maven.plugins.shade.resource.ManifestResourceTransformer">
+										implementation="org.apache.maven.plugins.shade.resource.ManifestResourceTransformer">
 									<mainClass>com.microsoft.azure.functions.worker.Application</mainClass>
 									<manifestEntries>
 										<Implementation-Title>${project.name}</Implementation-Title>
 										<Implementation-Version>${project.version}</Implementation-Version>
 										<Implementation-Vendor>${project.organization.name}</Implementation-Vendor>
 									</manifestEntries>
 								</transformer>
+								<transformer implementation="org.apache.maven.plugins.shade.resource.ServicesResourceTransformer"/>
 							</transformers>
 							<filters>
 								<filter>
@@ -203,6 +204,56 @@
 									</excludes>
 								</filter>
 							</filters>
+							<relocations>
+								<relocation combine.children="append">
+									<pattern>com.google</pattern>
+									<shadedPattern>com.microsoft.azure.functions.shaded.com.google</shadedPattern>
+								</relocation>
+								<relocation combine.children="append">
+									<pattern>com.sun</pattern>
+									<shadedPattern>com.microsoft.azure.functions.shaded.com.sun</shadedPattern>
+								</relocation>
+								<relocation combine.children="append">
+									<pattern>android</pattern>
+									<shadedPattern>com.microsoft.azure.functions.shaded.android</shadedPattern>
+								</relocation>
+								<relocation combine.children="append">
+									<pattern>google</pattern>
+									<shadedPattern>com.microsoft.azure.functions.shaded.google</shadedPattern>
+								</relocation>
+								<relocation combine.children="append">
+									<pattern>identity</pattern>
+									<shadedPattern>com.microsoft.azure.functions.shaded.identity</shadedPattern>
+								</relocation>
+								<relocation combine.children="append">
+									<pattern>shared</pattern>
+									<shadedPattern>com.microsoft.azure.functions.shaded.shared</shadedPattern>
+								</relocation>
+								<relocation combine.children="append">
+									<pattern>org</pattern>
+									<shadedPattern>com.microsoft.azure.functions.shaded.org</shadedPattern>
+								</relocation>
+								<relocation combine.children="append">
+									<pattern>io.netty</pattern>
+									<shadedPattern>com.microsoft.azure.functions.shaded.io.netty</shadedPattern>
+								</relocation>
+								<relocation combine.children="append">
+									<pattern>io.perfmark</pattern>
+									<shadedPattern>com.microsoft.azure.functions.shaded.io.perfmark</shadedPattern>
+								</relocation>
+								<relocation combine.children="append">
+									<pattern>io.grpc</pattern>
+									<shadedPattern>com.microsoft.azure.functions.shaded.io.grpc</shadedPattern>
+								</relocation>
+								<relocation combine.children="append">
+									<pattern>javax.annotation</pattern>
+									<shadedPattern>com.microsoft.azure.functions.shaded.javax.annotation</shadedPattern>
+								</relocation>
+								<relocation combine.children="append">
+									<pattern>io.opencensus</pattern>
+									<shadedPattern>com.microsoft.azure.functions.shaded.io.opencensus</shadedPattern>
+								</relocation>
+							</relocations>
 						</configuration>
 					</execution>
 				</executions>

lib_worker_1.6.2/checker-qual-2.5.2.jar

@@ -36,4 +36,4 @@ if(!$skipCliDownload)
 Write-Host "Copying azure-functions-java-worker to  Functions Host workers directory...."
 Get-ChildItem -Path .\target\* -Include 'azure*' -Exclude '*shaded.jar','*tests.jar' | %{ Copy-Item $_.FullName ".\Azure.Functions.Cli\workers\java\azure-functions-java-worker.jar" }
 Copy-Item ".\worker.config.json" ".\Azure.Functions.Cli\workers\java"
-
+Copy-Item ".\lib_worker_1.6.2" ".\Azure.Functions.Cli\workers\java\lib" -Recurse

lib_worker_1.6.2/commons-cli-1.4.jar

@@ -44,6 +44,7 @@ if(!$skipCliDownload)
 Write-Host "Copying azure-functions-java-worker to  Functions Host workers directory...."
 Get-ChildItem -Path .\target\* -Include 'azure*' -Exclude '*shaded.jar','*tests.jar' | %{ Copy-Item $_.FullName ".\Azure.Functions.Cli\workers\java\azure-functions-java-worker.jar" }
 Copy-Item ".\worker.config.json" ".\Azure.Functions.Cli\workers\java"
+Copy-Item ".\lib_worker_1.6.2" ".\Azure.Functions.Cli\workers\java\lib" -Recurse
 
 Write-Host "Building endtoendtests...."
 $Env:Path = $Env:Path+";$currDir\Azure.Functions.Cli"

lib_worker_1.6.2/commons-lang3-3.9.jar

@@ -6,4 +6,6 @@
 public final class Constants {
     private Constants(){}
     public final static String TRIGGER_METADATA_DOLLAR_REQUEST_KEY = "$request";
+    public final static String FUNCTIONS_WORKER_DIRECTORY = "FUNCTIONS_WORKER_DIRECTORY";
+    public final static String JAVA_REVERSE_JARS_LOADING = "JAVA_REVERSE_JARS_LOADING";
 }

lib_worker_1.6.2/error_prone_annotations-2.3.2.jar

@@ -1,17 +1,21 @@
 package com.microsoft.azure.functions.worker.broker;
 
 import java.io.File;
+import java.io.FileFilter;
 import java.io.IOException;
 import java.net.URL;
 import java.util.*;
 import java.util.concurrent.ConcurrentHashMap;
+import java.util.logging.Level;
 
 import com.microsoft.azure.functions.rpc.messages.*;
 import com.microsoft.azure.functions.worker.Constants;
+import com.microsoft.azure.functions.worker.WorkerLogManager;
 import com.microsoft.azure.functions.worker.binding.BindingDataStore;
 import com.microsoft.azure.functions.worker.description.FunctionMethodDescriptor;
 import com.microsoft.azure.functions.worker.reflect.ClassLoaderProvider;
 
+import org.apache.commons.lang3.SystemUtils;
 import org.apache.commons.lang3.exception.ExceptionUtils;
 import org.apache.commons.lang3.tuple.ImmutablePair;
 
@@ -89,7 +93,45 @@ private void addSearchPathsToClassLoader(FunctionMethodDescriptor function) thro
 
 	private void registerWithClassLoaderProvider(File libDirectory) {
 		try {
-			classLoaderProvider.addDirectory(libDirectory);
+			if(SystemUtils.IS_JAVA_1_8) {
+				String workerPath = System.getenv(Constants.FUNCTIONS_WORKER_DIRECTORY) + "/lib";
+				String reverseJarsLoading = System.getenv(Constants.JAVA_REVERSE_JARS_LOADING);
+				if(reverseJarsLoading != null && reverseJarsLoading.toLowerCase().equals("true")) {
+					if(!new File(workerPath).exists()) {
+						throw new Exception("Customer:  " + workerPath);
+					} else {
+						File[] jarFiles = new File(workerPath).listFiles(new FileFilter() {
+							@Override
+							public boolean accept(File file) {
+								return file.isFile() && file.getName().endsWith(".jar");
+							}
+						});
+						if(jarFiles.length == 0) {
+							throw new Exception("Customer length:  " + jarFiles.length);
+						}
+					}
+					classLoaderProvider.addDirectory(libDirectory);
+					classLoaderProvider.addDirectory(new File(workerPath));
+				} else {
+					if(!new File(workerPath).exists()) {
+						throw new Exception("Default:  " + workerPath);
+					} else {
+						File[] jarFiles = new File(workerPath).listFiles(new FileFilter() {
+							@Override
+							public boolean accept(File file) {
+								return file.isFile() && file.getName().endsWith(".jar");
+							}
+						});
+						if(jarFiles.length == 0) {
+							throw new Exception("Default length:  " + jarFiles.length);
+						}
+					}
+					classLoaderProvider.addDirectory(new File(workerPath));
+					classLoaderProvider.addDirectory(libDirectory);
+				}
+			} else {
+				classLoaderProvider.addDirectory(libDirectory);
+			}
 		} catch (Exception ex) {
 			ExceptionUtils.rethrow(ex);
 		}