CodeGen from PR 17540 in Azure/azure-rest-api-specs

Merge 2d7eff3c2f531f8a38ed5c7c85a25dd07010016f into 75b53c0708590483bb2166b9e2751f1bdf5adefa
AzureSDKAutomation · Jan 28, 2022 · dc7ca47 · dc7ca47
1 parent 9a7505b
commit dc7ca47
Show file tree

Hide file tree

Showing 311 changed files with 11,060 additions and 3,228 deletions.
diff --git a/sdk/mediaservices/azure-resourcemanager-mediaservices/CHANGELOG.md b/sdk/mediaservices/azure-resourcemanager-mediaservices/CHANGELOG.md
@@ -1,7 +1,8 @@
 # Release History
 
-## 1.1.0-beta.3 (Unreleased)
+## 1.0.0-beta.1 (2022-01-28)
 
+- Azure Resource Manager MediaServices client library for Java. This package contains Microsoft Azure SDK for MediaServices Management SDK. This Swagger was generated by the API Framework. Package tag package-2021-11. For documentation on how to use this package, please see [Azure Management Libraries for Java](https://aka.ms/azsdk/java/mgmt).
 
 ## 1.1.0-beta.2 (2021-07-16)
 

diff --git a/sdk/mediaservices/azure-resourcemanager-mediaservices/README.md b/sdk/mediaservices/azure-resourcemanager-mediaservices/README.md
@@ -2,7 +2,7 @@
 
 Azure Resource Manager MediaServices client library for Java.
 
-This package contains Microsoft Azure SDK for MediaServices Management SDK. This Swagger was generated by the API Framework. Package tag package-2021-06. For documentation on how to use this package, please see [Azure Management Libraries for Java](https://aka.ms/azsdk/java/mgmt).
+This package contains Microsoft Azure SDK for MediaServices Management SDK. This Swagger was generated by the API Framework. Package tag package-2021-11. For documentation on how to use this package, please see [Azure Management Libraries for Java](https://aka.ms/azsdk/java/mgmt).
 
 ## We'd love to hear your feedback
 
@@ -32,7 +32,7 @@ Various documentation is available to help you get started
 <dependency>
     <groupId>com.azure.resourcemanager</groupId>
     <artifactId>azure-resourcemanager-mediaservices</artifactId>
-    <version>1.1.0-beta.2</version>
+    <version>1.1.0-beta.3</version>
 </dependency>
 ```
 [//]: # ({x-version-update-end})
@@ -74,6 +74,62 @@ See [API design][design] for general introduction on design and key concepts on
 
 ## Examples
 
+```java
+// storage account
+StorageAccount storageAccount = storageManager.storageAccounts().define(STORAGE_ACCOUNT)
+    .withRegion(REGION)
+    .withExistingResourceGroup(resourceGroup)
+    .create();
+
+// media service account
+MediaService account = manager.mediaservices().define(ACCOUNT)
+    .withRegion(Region.US_WEST3)
+    .withExistingResourceGroup(resourceGroup)
+    .withStorageAccounts(Collections.singletonList(
+        new com.azure.resourcemanager.mediaservices.models.StorageAccount()
+            .withId(storageAccount.id())
+            .withType(StorageAccountType.PRIMARY)))
+    .create();
+
+// transform
+Transform transform = manager.transforms()
+    .define("transform1")
+    .withExistingMediaService(resourceGroup, ACCOUNT)
+    .withOutputs(Collections.singletonList(new TransformOutput()
+        .withPreset(new BuiltInStandardEncoderPreset()
+            .withPresetName(EncoderNamedPreset.CONTENT_AWARE_ENCODING))))
+    .create();
+
+// output asset
+Asset asset = manager.assets()
+    .define("output1")
+    .withExistingMediaService(resourceGroup, ACCOUNT)
+    .create();
+
+// input uri
+String jobHttpBaseUri = "https://nimbuscdn-nimbuspm.streaming.mediaservices.windows.net/2b533311-b215-4409-80af-529c3e853622/";
+String jobFile = "Ignite-short.mp4";
+
+// job
+Job job = manager.jobs().define("job1")
+    .withExistingTransform(resourceGroup, ACCOUNT, "transform1")
+    .withInput(new JobInputHttp()
+        .withFiles(Collections.singletonList(jobFile))
+        .withBaseUri(jobHttpBaseUri)
+        .withLabel("input1"))
+    .withOutputs(Collections.singletonList(new JobOutputAsset().withAssetName("output1")))
+    .create();
+
+// wait for job completion
+JobState jobState = job.state();
+while (!(jobState == JobState.CANCELED || jobState == JobState.ERROR || jobState == JobState.FINISHED)) {
+    sleepIfRunningAgainstService(10 * 1000);    // wait 10 seconds
+    jobState = job.refresh().state();
+}
+
+// refresh output asset after job finished
+asset.refresh();
+```
 [Code snippets and samples](https://github.com/Azure/azure-sdk-for-java/blob/main/sdk/mediaservices/azure-resourcemanager-mediaservices/SAMPLE.md)
 
 

diff --git a/sdk/mediaservices/azure-resourcemanager-mediaservices/SAMPLE.md b/sdk/mediaservices/azure-resourcemanager-mediaservices/SAMPLE.md
diff --git a/sdk/mediaservices/azure-resourcemanager-mediaservices/pom.xml b/sdk/mediaservices/azure-resourcemanager-mediaservices/pom.xml
@@ -13,7 +13,7 @@
   <packaging>jar</packaging>
 
   <name>Microsoft Azure SDK for MediaServices Management</name>
-  <description>This package contains Microsoft Azure SDK for MediaServices Management SDK. For documentation on how to use this package, please see https://aka.ms/azsdk/java/mgmt. This Swagger was generated by the API Framework. Package tag package-2021-06.</description>
+  <description>This package contains Microsoft Azure SDK for MediaServices Management SDK. For documentation on how to use this package, please see https://aka.ms/azsdk/java/mgmt. This Swagger was generated by the API Framework. Package tag package-2021-11.</description>
   <url>https://github.com/Azure/azure-sdk-for-java</url>
 
   <licenses>
@@ -39,7 +39,6 @@
   <properties>
     <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
     <jacoco.skip>true</jacoco.skip>
-    <revapi.skip>true</revapi.skip>
   </properties>
   <dependencies>
     <dependency>

diff --git a/...aservices/src/main/java/com/azure/resourcemanager/mediaservices/MediaServicesManager.java b/...aservices/src/main/java/com/azure/resourcemanager/mediaservices/MediaServicesManager.java
@@ -8,6 +8,7 @@
 import com.azure.core.http.HttpClient;
 import com.azure.core.http.HttpPipeline;
 import com.azure.core.http.HttpPipelineBuilder;
+import com.azure.core.http.HttpPipelinePosition;
 import com.azure.core.http.policy.AddDatePolicy;
 import com.azure.core.http.policy.HttpLogOptions;
 import com.azure.core.http.policy.HttpLoggingPolicy;
@@ -30,6 +31,8 @@
 import com.azure.resourcemanager.mediaservices.implementation.LiveEventsImpl;
 import com.azure.resourcemanager.mediaservices.implementation.LiveOutputsImpl;
 import com.azure.resourcemanager.mediaservices.implementation.LocationsImpl;
+import com.azure.resourcemanager.mediaservices.implementation.MediaServiceOperationResultsImpl;
+import com.azure.resourcemanager.mediaservices.implementation.MediaServiceOperationStatusesImpl;
 import com.azure.resourcemanager.mediaservices.implementation.MediaservicesImpl;
 import com.azure.resourcemanager.mediaservices.implementation.OperationsImpl;
 import com.azure.resourcemanager.mediaservices.implementation.PrivateEndpointConnectionsImpl;
@@ -46,6 +49,8 @@
 import com.azure.resourcemanager.mediaservices.models.LiveEvents;
 import com.azure.resourcemanager.mediaservices.models.LiveOutputs;
 import com.azure.resourcemanager.mediaservices.models.Locations;
+import com.azure.resourcemanager.mediaservices.models.MediaServiceOperationResults;
+import com.azure.resourcemanager.mediaservices.models.MediaServiceOperationStatuses;
 import com.azure.resourcemanager.mediaservices.models.Mediaservices;
 import com.azure.resourcemanager.mediaservices.models.Operations;
 import com.azure.resourcemanager.mediaservices.models.PrivateEndpointConnections;
@@ -59,9 +64,12 @@
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Objects;
+import java.util.stream.Collectors;
 
 /** Entry point to MediaServicesManager. This Swagger was generated by the API Framework. */
 public final class MediaServicesManager {
+    private AccountFilters accountFilters;
+
     private Operations operations;
 
     private Mediaservices mediaservices;
@@ -72,7 +80,9 @@ public final class MediaServicesManager {
 
     private Locations locations;
 
-    private AccountFilters accountFilters;
+    private MediaServiceOperationStatuses mediaServiceOperationStatuses;
+
+    private MediaServiceOperationResults mediaServiceOperationResults;
 
     private Assets assets;
 
@@ -230,7 +240,7 @@ public MediaServicesManager authenticate(TokenCredential credential, AzureProfil
                 .append("-")
                 .append("com.azure.resourcemanager.mediaservices")
                 .append("/")
-                .append("1.1.0-beta.2");
+                .append("1.0.0-beta.1");
             if (!Configuration.getGlobalConfiguration().get("AZURE_TELEMETRY_DISABLED", false)) {
                 userAgentBuilder
                     .append(" (")
@@ -253,11 +263,24 @@ public MediaServicesManager authenticate(TokenCredential credential, AzureProfil
             List<HttpPipelinePolicy> policies = new ArrayList<>();
             policies.add(new UserAgentPolicy(userAgentBuilder.toString()));
             policies.add(new RequestIdPolicy());
+            policies
+                .addAll(
+                    this
+                        .policies
+                        .stream()
+                        .filter(p -> p.getPipelinePosition() == HttpPipelinePosition.PER_CALL)
+                        .collect(Collectors.toList()));
             HttpPolicyProviders.addBeforeRetryPolicies(policies);
             policies.add(retryPolicy);
             policies.add(new AddDatePolicy());
             policies.add(new ArmChallengeAuthenticationPolicy(credential, scopes.toArray(new String[0])));
-            policies.addAll(this.policies);
+            policies
+                .addAll(
+                    this
+                        .policies
+                        .stream()
+                        .filter(p -> p.getPipelinePosition() == HttpPipelinePosition.PER_RETRY)
+                        .collect(Collectors.toList()));
             HttpPolicyProviders.addAfterRetryPolicies(policies);
             policies.add(new HttpLoggingPolicy(httpLogOptions));
             HttpPipeline httpPipeline =
@@ -269,6 +292,14 @@ public MediaServicesManager authenticate(TokenCredential credential, AzureProfil
         }
     }
 
+    /** @return Resource collection API of AccountFilters. */
+    public AccountFilters accountFilters() {
+        if (this.accountFilters == null) {
+            this.accountFilters = new AccountFiltersImpl(clientObject.getAccountFilters(), this);
+        }
+        return accountFilters;
+    }
+
     /** @return Resource collection API of Operations. */
     public Operations operations() {
         if (this.operations == null) {
@@ -310,12 +341,22 @@ public Locations locations() {
         return locations;
     }
 
-    /** @return Resource collection API of AccountFilters. */
-    public AccountFilters accountFilters() {
-        if (this.accountFilters == null) {
-            this.accountFilters = new AccountFiltersImpl(clientObject.getAccountFilters(), this);
+    /** @return Resource collection API of MediaServiceOperationStatuses. */
+    public MediaServiceOperationStatuses mediaServiceOperationStatuses() {
+        if (this.mediaServiceOperationStatuses == null) {
+            this.mediaServiceOperationStatuses =
+                new MediaServiceOperationStatusesImpl(clientObject.getMediaServiceOperationStatuses(), this);
         }
-        return accountFilters;
+        return mediaServiceOperationStatuses;
+    }
+
+    /** @return Resource collection API of MediaServiceOperationResults. */
+    public MediaServiceOperationResults mediaServiceOperationResults() {
+        if (this.mediaServiceOperationResults == null) {
+            this.mediaServiceOperationResults =
+                new MediaServiceOperationResultsImpl(clientObject.getMediaServiceOperationResults(), this);
+        }
+        return mediaServiceOperationResults;
     }
 
     /** @return Resource collection API of Assets. */

diff --git a/...es/src/main/java/com/azure/resourcemanager/mediaservices/fluent/AccountFiltersClient.java b/...es/src/main/java/com/azure/resourcemanager/mediaservices/fluent/AccountFiltersClient.java
@@ -64,7 +64,7 @@ public interface AccountFiltersClient {
      * @throws IllegalArgumentException thrown if parameters fail the validation.
      * @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
      * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
-     * @return the details of an Account Filter in the Media Services account.
+     * @return the details of an Account Filter in the Media Services account along with {@link Response}.
      */
     @ServiceMethod(returns = ReturnType.SINGLE)
     Response<AccountFilterInner> getWithResponse(
@@ -97,7 +97,7 @@ AccountFilterInner createOrUpdate(
      * @throws IllegalArgumentException thrown if parameters fail the validation.
      * @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
      * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
-     * @return an Account Filter.
+     * @return an Account Filter along with {@link Response}.
      */
     @ServiceMethod(returns = ReturnType.SINGLE)
     Response<AccountFilterInner> createOrUpdateWithResponse(
@@ -130,7 +130,7 @@ Response<AccountFilterInner> createOrUpdateWithResponse(
      * @throws IllegalArgumentException thrown if parameters fail the validation.
      * @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
      * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
-     * @return the response.
+     * @return the {@link Response}.
      */
     @ServiceMethod(returns = ReturnType.SINGLE)
     Response<Void> deleteWithResponse(String resourceGroupName, String accountName, String filterName, Context context);
@@ -162,7 +162,7 @@ AccountFilterInner update(
      * @throws IllegalArgumentException thrown if parameters fail the validation.
      * @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
      * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
-     * @return an Account Filter.
+     * @return an Account Filter along with {@link Response}.
      */
     @ServiceMethod(returns = ReturnType.SINGLE)
     Response<AccountFilterInner> updateWithResponse(

diff --git a/...ices/src/main/java/com/azure/resourcemanager/mediaservices/fluent/AssetFiltersClient.java b/...ices/src/main/java/com/azure/resourcemanager/mediaservices/fluent/AssetFiltersClient.java
@@ -69,7 +69,7 @@ PagedIterable<AssetFilterInner> list(
      * @throws IllegalArgumentException thrown if parameters fail the validation.
      * @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
      * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
-     * @return the details of an Asset Filter associated with the specified Asset.
+     * @return the details of an Asset Filter associated with the specified Asset along with {@link Response}.
      */
     @ServiceMethod(returns = ReturnType.SINGLE)
     Response<AssetFilterInner> getWithResponse(
@@ -104,7 +104,7 @@ AssetFilterInner createOrUpdate(
      * @throws IllegalArgumentException thrown if parameters fail the validation.
      * @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
      * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
-     * @return an Asset Filter.
+     * @return an Asset Filter along with {@link Response}.
      */
     @ServiceMethod(returns = ReturnType.SINGLE)
     Response<AssetFilterInner> createOrUpdateWithResponse(
@@ -140,7 +140,7 @@ Response<AssetFilterInner> createOrUpdateWithResponse(
      * @throws IllegalArgumentException thrown if parameters fail the validation.
      * @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
      * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
-     * @return the response.
+     * @return the {@link Response}.
      */
     @ServiceMethod(returns = ReturnType.SINGLE)
     Response<Void> deleteWithResponse(
@@ -175,7 +175,7 @@ AssetFilterInner update(
      * @throws IllegalArgumentException thrown if parameters fail the validation.
      * @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
      * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
-     * @return an Asset Filter.
+     * @return an Asset Filter along with {@link Response}.
      */
     @ServiceMethod(returns = ReturnType.SINGLE)
     Response<AssetFilterInner> updateWithResponse(

diff --git a/...iaservices/src/main/java/com/azure/resourcemanager/mediaservices/fluent/AssetsClient.java b/...iaservices/src/main/java/com/azure/resourcemanager/mediaservices/fluent/AssetsClient.java
@@ -73,7 +73,7 @@ PagedIterable<AssetInner> list(
      * @throws IllegalArgumentException thrown if parameters fail the validation.
      * @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
      * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
-     * @return the details of an Asset in the Media Services account.
+     * @return the details of an Asset in the Media Services account along with {@link Response}.
      */
     @ServiceMethod(returns = ReturnType.SINGLE)
     Response<AssetInner> getWithResponse(
@@ -105,7 +105,7 @@ Response<AssetInner> getWithResponse(
      * @throws IllegalArgumentException thrown if parameters fail the validation.
      * @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
      * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
-     * @return an Asset.
+     * @return an Asset along with {@link Response}.
      */
     @ServiceMethod(returns = ReturnType.SINGLE)
     Response<AssetInner> createOrUpdateWithResponse(
@@ -134,7 +134,7 @@ Response<AssetInner> createOrUpdateWithResponse(
      * @throws IllegalArgumentException thrown if parameters fail the validation.
      * @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
      * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
-     * @return the response.
+     * @return the {@link Response}.
      */
     @ServiceMethod(returns = ReturnType.SINGLE)
     Response<Void> deleteWithResponse(String resourceGroupName, String accountName, String assetName, Context context);
@@ -165,7 +165,7 @@ Response<AssetInner> createOrUpdateWithResponse(
      * @throws IllegalArgumentException thrown if parameters fail the validation.
      * @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
      * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
-     * @return an Asset.
+     * @return an Asset along with {@link Response}.
      */
     @ServiceMethod(returns = ReturnType.SINGLE)
     Response<AssetInner> updateWithResponse(
@@ -200,7 +200,7 @@ AssetContainerSasInner listContainerSas(
      * @throws IllegalArgumentException thrown if parameters fail the validation.
      * @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
      * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
-     * @return the Asset Storage container SAS URLs.
+     * @return the Asset Storage container SAS URLs along with {@link Response}.
      */
     @ServiceMethod(returns = ReturnType.SINGLE)
     Response<AssetContainerSasInner> listContainerSasWithResponse(
@@ -235,7 +235,8 @@ StorageEncryptedAssetDecryptionDataInner getEncryptionKey(
      * @throws IllegalArgumentException thrown if parameters fail the validation.
      * @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
      * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
-     * @return the Asset storage encryption keys used to decrypt content created by version 2 of the Media Services API.
+     * @return the Asset storage encryption keys used to decrypt content created by version 2 of the Media Services API
+     *     along with {@link Response}.
      */
     @ServiceMethod(returns = ReturnType.SINGLE)
     Response<StorageEncryptedAssetDecryptionDataInner> getEncryptionKeyWithResponse(
@@ -266,7 +267,7 @@ ListStreamingLocatorsResponseInner listStreamingLocators(
      * @throws IllegalArgumentException thrown if parameters fail the validation.
      * @throws com.azure.core.management.exception.ManagementException thrown if the request is rejected by server.
      * @throws RuntimeException all other wrapped checked exceptions if the request fails to be sent.
-     * @return the Streaming Locators associated with this Asset.
+     * @return the Streaming Locators associated with this Asset along with {@link Response}.
      */
     @ServiceMethod(returns = ReturnType.SINGLE)
     Response<ListStreamingLocatorsResponseInner> listStreamingLocatorsWithResponse(