List anonymous HTTP triggers after function deployment (#4508)

* List annoymous http triggers after function deployment

* Provide function access keys document after non-anonymous triggers deployed

* Adopt stable tools common library

Author: Flanker32

PluginsAndFeatures/azure-toolkit-for-intellij/build.gradle

@@ -111,7 +111,7 @@ dependencies {
         exclude group: "javax.xml.bind", module: "jaxb-api"
     }
     compile group: 'com.microsoft.azure', name: 'azure-auth-helper', version: '0.4.0'
-    compile 'com.microsoft.azure:azure-tools-common:0.4.0'
+    compile 'com.microsoft.azure:azure-tools-common:0.5.0'
     compile group: 'com.microsoft.azure.appplatform.v2019_05_01_preview', name: 'azure-mgmt-appplatform', version: '1.0.0-beta-2'
     compile group: 'org.dom4j', name: 'dom4j', version: '2.1.3'
     compile group: 'jaxen', name: 'jaxen', version: '1.2.0'

PluginsAndFeatures/azure-toolkit-for-intellij/src/com/microsoft/intellij/runner/functions/library/function/DeployFunctionHandler.java

@@ -34,27 +34,35 @@
 import com.microsoft.azure.common.function.handlers.artifact.MSDeployArtifactHandlerImpl;
 import com.microsoft.azure.common.function.handlers.artifact.RunFromBlobArtifactHandlerImpl;
 import com.microsoft.azure.common.function.handlers.artifact.RunFromZipArtifactHandlerImpl;
+import com.microsoft.azure.common.function.model.FunctionResource;
 import com.microsoft.azure.common.handlers.ArtifactHandler;
 import com.microsoft.azure.common.handlers.artifact.ArtifactHandlerBase;
 import com.microsoft.azure.common.handlers.artifact.FTPArtifactHandlerImpl;
 import com.microsoft.azure.common.handlers.artifact.ZIPArtifactHandlerImpl;
 import com.microsoft.azure.common.utils.AppServiceUtils;
+import com.microsoft.azure.functions.annotation.AuthorizationLevel;
 import com.microsoft.azure.management.appservice.FunctionApp;
 import com.microsoft.azure.management.appservice.FunctionApp.Update;
 import com.microsoft.intellij.runner.functions.library.IAppServiceContext;
 import com.microsoft.intellij.runner.functions.library.IPrompter;
+import org.apache.commons.collections4.CollectionUtils;
 import org.apache.commons.lang3.StringUtils;
 
+import java.io.IOException;
+import java.util.List;
 import java.util.Map;
 import java.util.function.Consumer;
+import java.util.stream.Collectors;
 
 import static com.microsoft.azure.common.appservice.DeploymentType.*;
 
 /**
- * Deploy artifacts to target Azure Functions in Azure. If target Azure
- * Functions doesn't exist, it will be created.
+ * Deploy artifacts to target Azure Functions in Azure.
+ * Todo: Move the handler to tools-common
  */
 public class DeployFunctionHandler {
+    private static final int LIST_TRIGGERS_MAX_RETRY = 3;
+    private static final int LIST_TRIGGERS_RETRY_PERIOD_IN_SECONDS = 10;
     private static final String FUNCTIONS_WORKER_RUNTIME_NAME = "FUNCTIONS_WORKER_RUNTIME";
     private static final String FUNCTIONS_WORKER_RUNTIME_VALUE = "java";
     private static final String SET_FUNCTIONS_WORKER_RUNTIME = "Set function worker runtime to java";
@@ -70,6 +78,19 @@ public class DeployFunctionHandler {
     private static final String FUNCTION_APP_UPDATE_DONE = "Successfully updated the function app %s.";
     private static final String UNKNOW_DEPLOYMENT_TYPE = "The value of <deploymentType> is unknown, supported values are: " +
             "ftp, zip, msdeploy, run_from_blob and run_from_zip.";
+    private static final String FAILED_TO_LIST_TRIGGERS = "Deployment succeeded, but failed to list http trigger urls.";
+    private static final String UNABLE_TO_LIST_NONE_ANONYMOUS_HTTP_TRIGGERS = "Some http trigger urls cannot be displayed " +
+            "because they are non-anonymous. To access the non-anonymous triggers, "
+            + "please refer https://aka.ms/azure-functions-key.";
+    private static final String HTTP_TRIGGER_URLS = "HTTP Trigger Urls:";
+    private static final String NO_ANONYMOUS_HTTP_TRIGGER = "No anonymous HTTP Triggers found in deployed function app, "
+            + "skip list triggers.";
+    private static final String AUTH_LEVEL = "authLevel";
+    private static final String HTTP_TRIGGER = "httpTrigger";
+    private static final String NO_TRIGGERS_FOUNDED = "No triggers found in deployed function app, " +
+            "please try recompile the project by `Build` -> `Build Project` and deploy again.";
+    private static final String SYNCING_TRIGGERS_AND_FETCH_FUNCTION_INFORMATION = "Syncing triggers and fetching "
+            + "function information (Attempt %d/%d)...";
 
     private static final OperatingSystemEnum DEFAULT_OS = OperatingSystemEnum.Windows;
     private IAppServiceContext ctx;
@@ -89,6 +110,7 @@ public FunctionApp execute() throws Exception {
         prompt(DEPLOY_START);
         getArtifactHandler().publish(deployTarget);
         prompt(String.format(DEPLOY_FINISH, ctx.getAppName()));
+        listHTTPTriggerUrls();
         return (FunctionApp) deployTarget.getApp();
     }
 
@@ -107,6 +129,68 @@ private void configureAppSettings(final Consumer<Map> withAppSettings, final Map
         }
     }
 
+    /**
+     * List anonymous HTTP Triggers url after deployment
+     */
+    private void listHTTPTriggerUrls() {
+        try {
+            final List<FunctionResource> triggers = listFunctions();
+            final List<FunctionResource> httpFunction =
+                    triggers.stream()
+                            .filter(function -> function.getTrigger() != null &&
+                                    StringUtils.equalsIgnoreCase(function.getTrigger().getType(), HTTP_TRIGGER))
+                            .collect(Collectors.toList());
+            final List<FunctionResource> anonymousTriggers =
+                    httpFunction.stream()
+                                .filter(bindingResource -> bindingResource.getTrigger() != null &&
+                                        StringUtils.equalsIgnoreCase(
+                                                (CharSequence) bindingResource.getTrigger().getProperty(AUTH_LEVEL),
+                                                AuthorizationLevel.ANONYMOUS.toString()))
+                                .collect(Collectors.toList());
+            if (CollectionUtils.isEmpty(httpFunction) || CollectionUtils.isEmpty(anonymousTriggers)) {
+                prompt(NO_ANONYMOUS_HTTP_TRIGGER);
+                return;
+            }
+            prompt(HTTP_TRIGGER_URLS);
+            anonymousTriggers.forEach(trigger -> prompt(String.format("\t %s : %s", trigger.getName(), trigger.getTriggerUrl())));
+            if (anonymousTriggers.size() < httpFunction.size()) {
+                prompt(UNABLE_TO_LIST_NONE_ANONYMOUS_HTTP_TRIGGERS);
+            }
+        } catch (InterruptedException | IOException e) {
+            prompt(FAILED_TO_LIST_TRIGGERS);
+        } catch (AzureExecutionException e) {
+            prompt(e.getMessage());
+        }
+    }
+
+    /**
+     * Sync triggers and return function list of deployed function app
+     * Will retry when get empty result, the max retry times is LIST_TRIGGERS_MAX_RETRY
+     * @return List of functions in deployed function app
+     * @throws AzureExecutionException Throw if get empty result after LIST_TRIGGERS_MAX_RETRY times retry
+     * @throws IOException Throw if meet IOException while getting Azure client
+     * @throws InterruptedException Throw when thread was interrupted while sleeping between retry
+     */
+    private List<FunctionResource> listFunctions() throws AzureExecutionException, InterruptedException, IOException {
+        final FunctionApp functionApp = getFunctionApp();
+        for (int i = 0; i < LIST_TRIGGERS_MAX_RETRY; i++) {
+            Thread.sleep(LIST_TRIGGERS_RETRY_PERIOD_IN_SECONDS * 1000);
+            prompt(String.format(SYNCING_TRIGGERS_AND_FETCH_FUNCTION_INFORMATION, i + 1, LIST_TRIGGERS_MAX_RETRY));
+            functionApp.syncTriggers();
+            final List<FunctionResource> triggers =
+                    ctx.getAzureClient().appServices().functionApps()
+                       .listFunctions(ctx.getResourceGroup(),
+                                      ctx.getAppName()).stream()
+                       .map(envelope -> FunctionResource.parseFunction(envelope))
+                       .filter(function -> function != null)
+                       .collect(Collectors.toList());
+            if (CollectionUtils.isNotEmpty(triggers)) {
+                return triggers;
+            }
+        }
+        throw new AzureExecutionException(NO_TRIGGERS_FOUNDED);
+    }
+
     private OperatingSystemEnum getOsEnum() throws AzureExecutionException {
         final RuntimeConfiguration runtime = ctx.getRuntime();
         if (runtime != null && StringUtils.isNotBlank(runtime.getOs())) {