support api/settings from Kudu (#1315)

Author: weidongxu-microsoft

azure-mgmt-appservice/src/main/java/com/microsoft/azure/management/appservice/WebAppBase.java

@@ -599,6 +599,20 @@ public interface WebAppBase extends
     @Beta(SinceVersion.V1_14_0)
     Completable zipDeployAsync(InputStream zipFile);
 
+    /**
+     * Gets the App Settings on site from Kudu client. It might lag after App Setting update to the site.
+     * @return the App Settings on site from Kudu client
+     */
+    @Beta(SinceVersion.V1_37_0)
+    Map<String, String> getSiteAppSettings();
+
+    /**
+     * Gets the App Settings on site from Kudu client. It might lag after App Setting update to the site.
+     * @return the App Settings on site from Kudu client
+     */
+    @Beta(SinceVersion.V1_37_0)
+    Observable<Map<String, String>> getSiteAppSettingsAsync();
+
     /**************************************************************
      * Fluent interfaces to provision a Web App or deployment slot.
      **************************************************************/

azure-mgmt-appservice/src/main/java/com/microsoft/azure/management/appservice/implementation/KuduClient.java

@@ -8,10 +8,15 @@
 
 import com.google.common.base.Joiner;
 import com.google.common.io.ByteStreams;
+import com.google.common.reflect.TypeToken;
+import com.microsoft.azure.AzureResponseBuilder;
 import com.microsoft.azure.management.appservice.DeployType;
 import com.microsoft.azure.management.appservice.WebAppBase;
+import com.microsoft.rest.RestClient;
 import com.microsoft.rest.RestException;
 import com.microsoft.rest.ServiceResponse;
+import com.microsoft.rest.ServiceResponseBuilder;
+import com.microsoft.rest.protocol.ResponseBuilder;
 import okhttp3.MediaType;
 import okhttp3.RequestBody;
 import okhttp3.ResponseBody;
@@ -35,13 +40,15 @@
 import java.io.IOException;
 import java.io.InputStream;
 import java.net.SocketTimeoutException;
+import java.util.Map;
 import java.util.Objects;
 import java.util.concurrent.TimeUnit;
 
 /**
  * A client which interacts with Kudu service.
  */
 class KuduClient {
+    private final RestClient restClient;
     private final KuduService service;
 
     KuduClient(WebAppBase webAppBase) {
@@ -53,11 +60,12 @@ class KuduClient {
                 .replace("https://", "");
         String[] parts = host.split("\\.", 2);
         host = Joiner.on('.').join(parts[0], "scm", parts[1]);
-        service = webAppBase.manager().restClient().newBuilder()
+        restClient = webAppBase.manager().restClient().newBuilder()
                 .withBaseUrl("https://" + host)
                 .withConnectionTimeout(3, TimeUnit.MINUTES)
                 .withReadTimeout(3, TimeUnit.MINUTES)
-                .build()
+                .build();
+        service = restClient
                 .retrofit().create(KuduService.class);
     }
 
@@ -98,6 +106,10 @@ private interface KuduService {
         @Headers({ "Content-Type: application/octet-stream", "x-ms-logging-context: com.microsoft.azure.management.appservice.WebApps publish", "x-ms-body-logging: false" })
         @POST("api/publish")
         Observable<Response<ResponseBody>> deploy(@Body RequestBody file, @Query("type") DeployType type, @Query("path") String path, @Query("restart") Boolean restart, @Query("clean") Boolean clean);
+
+        @Headers({ "x-ms-logging-context: com.microsoft.azure.management.appservice.WebApps settings" })
+        @GET("api/settings")
+        Observable<Response<ResponseBody>> settings();
     }
 
     Observable<String> streamApplicationLogsAsync() {
@@ -204,6 +216,37 @@ Completable deployAsync(DeployType type, InputStream file, String path, Boolean
         }
     }
 
+    Observable<Map<String, String>> settings() {
+        return retryOnError(service.settings().flatMap(new Func1<Response<ResponseBody>, Observable<ServiceResponse<Map<String, String>>>>() {
+            @Override
+            public Observable<ServiceResponse<Map<String, String>>> call(Response<ResponseBody> response) {
+                try {
+                    ResponseBuilder<Map<String, String>, RestException> responseBuilder = restClient
+                            .responseBuilderFactory().newInstance(restClient.serializerAdapter());
+                    // set throwOnGet404 to true
+                    if (responseBuilder instanceof AzureResponseBuilder) {
+                        ((AzureResponseBuilder<Map<String, String>, RestException>) responseBuilder).withThrowOnGet404(true);
+                    } else if (responseBuilder instanceof ServiceResponseBuilder) {
+                        ((ServiceResponseBuilder<Map<String, String>, RestException>) responseBuilder).withThrowOnGet404(true);
+                    }
+
+                    ServiceResponse<Map<String, String>> clientResponse = responseBuilder
+                            .register(200, new TypeToken<Map<String, String>>() { }.getType())
+                            .registerError(RestException.class)
+                            .build(response);
+                    return Observable.just(clientResponse);
+                } catch (Throwable t) {
+                    return Observable.error(t);
+                }
+            }
+        }).map(new Func1<ServiceResponse<Map<String, String>>, Map<String, String>>() {
+            @Override
+            public Map<String, String> call(ServiceResponse<Map<String, String>> response) {
+                return response.body();
+            }
+        }));
+    }
+
     private Observable<ServiceResponse<Void>> handleResponse(Observable<Response<ResponseBody>> observable) {
         return observable.flatMap(new Func1<Response<ResponseBody>, Observable<ServiceResponse<Void>>>() {
             @Override

azure-mgmt-appservice/src/main/java/com/microsoft/azure/management/appservice/implementation/WebAppBaseImpl.java

@@ -1785,6 +1785,14 @@ public WebAppDiagnosticLogsImpl<FluentT, FluentImplT> updateDiagnosticLogsConfig
         return defineDiagnosticLogsConfiguration();
     }
 
+    public Map<String, String> getSiteAppSettings() {
+        return getSiteAppSettingsAsync().toBlocking().single();
+    }
+
+    public Observable<Map<String, String>> getSiteAppSettingsAsync() {
+        return kuduClient.settings();
+    }
+
     private static class PipedInputStreamWithCallback extends PipedInputStream {
         private Action0 callback;