sync mgmt sync-stack (#3044)

* sync-stack

* fluent settings

* sync core

* use beta core

* fix script

* sync core

* fix fluent compilation

* enable sync-stack for autorest

* sync versions

* re-generate test code

* fix line break

* Revert "sync versions"

This reverts commit d1a00aa.

* sync-versions

* sync core

* core

* re-generate test code

* sync core

* sync test

* disable sync-stack by default

* async fix

* script fix

* sync spotbugs fix

* re-generate test code

* sync core

* add pageable test

* sync core

* sync test

* use java8 for fluent-test

* log file removal

* add log

* more logs

* use release instead of source and target

* set generation timeout to a higher value

* add compilation test

---------

Co-authored-by: actions-user <[email protected]>

Author: XiaofeiCao

azure-dataplane-tests/src/main/java/com/azure/ai/formrecognizer/documentanalysis/implementation/DocumentModelsImpl.java

@@ -2433,8 +2433,7 @@ public PagedResponse<DocumentModelSummary> listModelsSinglePage(Context context)
      */
     @ServiceMethod(returns = ReturnType.COLLECTION)
     public PagedIterable<DocumentModelSummary> listModels() {
-        return new PagedIterable<>(() -> listModelsSinglePage(Context.NONE),
-            nextLink -> listModelsNextSinglePage(nextLink));
+        return new PagedIterable<>(() -> listModelsSinglePage(), nextLink -> listModelsNextSinglePage(nextLink));
     }
 
     /**

azure-dataplane-tests/src/main/java/com/azure/ai/formrecognizer/documentanalysis/implementation/MiscellaneousImpl.java

@@ -221,7 +221,7 @@ public PagedResponse<OperationSummary> listOperationsSinglePage(Context context)
      */
     @ServiceMethod(returns = ReturnType.COLLECTION)
     public PagedIterable<OperationSummary> listOperations() {
-        return new PagedIterable<>(() -> listOperationsSinglePage(Context.NONE),
+        return new PagedIterable<>(() -> listOperationsSinglePage(),
             nextLink -> listOperationsNextSinglePage(nextLink));
     }
 

azure-dataplane-tests/src/main/java/com/azure/data/schemaregistry/implementation/SchemaGroupsOperationsImpl.java

@@ -204,7 +204,7 @@ public PagedResponse<String> listSinglePage(Context context) {
      */
     @ServiceMethod(returns = ReturnType.COLLECTION)
     public PagedIterable<String> list() {
-        return new PagedIterable<>(() -> listSinglePage(Context.NONE), nextLink -> listNextSinglePage(nextLink));
+        return new PagedIterable<>(() -> listSinglePage(), nextLink -> listNextSinglePage(nextLink));
     }
 
     /**

azure-dataplane-tests/src/main/java/com/azure/data/schemaregistry/implementation/SchemasImpl.java

@@ -586,7 +586,7 @@ public PagedResponse<Integer> getVersionsSinglePage(String groupName, String sch
      */
     @ServiceMethod(returns = ReturnType.COLLECTION)
     public PagedIterable<Integer> getVersions(String groupName, String schemaName) {
-        return new PagedIterable<>(() -> getVersionsSinglePage(groupName, schemaName, Context.NONE),
+        return new PagedIterable<>(() -> getVersionsSinglePage(groupName, schemaName),
             nextLink -> getVersionsNextSinglePage(nextLink));
     }
 

core

@@ -156,16 +156,25 @@ $job = @(
     # empty byte array in client implementation
     "--version=$AUTOREST_CORE_VERSION $FLUENTLITE_ARGUMENTS --regenerate-pom=false --input-file=https://github.com/Azure/azure-rest-api-specs/blob/f840c84013f12b701aac7065ceeb13a59b26051b/specification/deviceprovisioningservices/resource-manager/Microsoft.Devices/stable/2022-02-05/iotdps.json --java.namespace=com.azure.mgmtlitetest.emptybytearrayinclients"
 
+    # sync-stack
+    # lite
+    "--version=$AUTOREST_CORE_VERSION $FLUENTLITE_ARGUMENTS --regenerate-pom=false https://raw.githubusercontent.com/Azure/azure-rest-api-specs/main/specification/mediaservices/resource-manager/readme.md --tag=package-account-2023-01 --java.namespace=com.azure.mgmtlitetest.mediaservicessync --enable-sync-stack=true"
+    # premium
+    "--version=$AUTOREST_CORE_VERSION $FLUENT_ARGUMENTS --input-file=https://raw.githubusercontent.com/Azure/azure-rest-api-specs/8fa9b5051129dd4808c9be1f5b753af226b044db/specification/iothub/resource-manager/Microsoft.Devices/stable/2023-06-30/iothub.json --namespace=com.azure.mgmttest.iothubsync --enable-sync-stack=true"
+    # special cases
+    "--version=$AUTOREST_CORE_VERSION $FLUENTLITE_ARGUMENTS --regenerate-pom=false --input-file=./swagger/sync-stack.json --namespace=com.azure.mgmtlitetest.syncstack --enable-sync-stack=true"
+
     # "--version=$AUTOREST_CORE_VERSION $FLUENTLITE_ARGUMENTS --regenerate-pom=false https://raw.githubusercontent.com/Azure/azure-rest-api-specs/main/specification/network/resource-manager/readme.md --tag=package-2020-06 --java.namespace=com.azure.mgmtlitetest.network"
     # "--version=$AUTOREST_CORE_VERSION $FLUENTLITE_ARGUMENTS --regenerate-pom=false https://raw.githubusercontent.com/Azure/azure-rest-api-specs/main/specification/compute/resource-manager/readme.md --tag=package-2020-06-30 --java.namespace=com.azure.mgmtlitetest.compute"
 ) | ForEach-Object -Parallel $generateScript -ThrottleLimit $Parallelization -AsJob
 
-$job | Wait-Job -Timeout 360
+$job | Wait-Job -Timeout 3600
 $job | Receive-Job
 
 # delete module-info as fluent-test is on java8
 if (Test-Path ./src/main/java/module-info.java) {
-    Remove-Item -Path ./src/main/java/module-info.java -Force | Out-Null
+    Remove-Item -Path ./src/main/java/module-info.java -Force -verbose
+    $ExitCode = $ExitCode -bor $LASTEXITCODE
 }
 
 exit $ExitCode

fluent-tests/Initialize-Tests.ps1

@@ -68,6 +68,7 @@ def codegen(autorest_java: str, specs_dir: str, sdk: str, output_sdk_dir: str) -
         '--java.license-header=MICROSOFT_MIT_SMALL',
         '--java.output-folder=' + output_sdk_dir,
         '--java.namespace=' + namespace,
+        '--enable-sync-stack=true',
         readme_dir]
 
     logging.info(' '.join(command))

fluent-tests/gen_all.py

@@ -78,6 +78,21 @@
     </profile>
   </profiles>
 
+  <!--  make source and target version Java8 to avoid weird access issues -->
+  <build>
+    <pluginManagement>
+      <plugins>
+        <plugin>
+          <groupId>org.apache.maven.plugins</groupId>
+          <artifactId>maven-compiler-plugin</artifactId>
+          <configuration>
+            <release>8</release>
+          </configuration>
+        </plugin>
+      </plugins>
+    </pluginManagement>
+  </build>
+
   <dependencies>
     <dependency>
       <groupId>com.azure.tools</groupId>

fluent-tests/pom.xml

@@ -11,11 +11,14 @@
 import com.azure.core.management.exception.ManagementException;
 import com.azure.core.management.polling.PollerFactory;
 import com.azure.core.management.polling.PollResult;
+import com.azure.core.management.polling.SyncPollerFactory;
+import com.azure.core.util.BinaryData;
 import com.azure.core.util.Context;
 import com.azure.core.util.CoreUtils;
 import com.azure.core.util.polling.AsyncPollResponse;
 import com.azure.core.util.polling.LongRunningOperationStatus;
 import com.azure.core.util.polling.PollerFlux;
+import com.azure.core.util.polling.SyncPoller;
 import com.azure.core.util.serializer.SerializerAdapter;
 import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
@@ -144,6 +147,23 @@ public <T, U> PollerFlux<PollResult<T>, U> getLroResult(Mono<Response<Flux<ByteB
                 context);
     }
 
+    /**
+     * Gets long running operation result.
+     *
+     * @param activationResponse the response of activation operation.
+     * @param pollResultType type of poll result.
+     * @param finalResultType type of final result.
+     * @param context the context shared by all requests.
+     * @param <T> type of poll result.
+     * @param <U> type of final result.
+     * @return SyncPoller for poll result and final result.
+     */
+    public <T, U> SyncPoller<PollResult<T>, U> getLroResult(Response<BinaryData> activationResponse,
+                                                            Type pollResultType, Type finalResultType, Context context) {
+        return SyncPollerFactory.create(serializerAdapter, httpPipeline, pollResultType, finalResultType,
+            Duration.ofSeconds(3), () -> activationResponse, context);
+    }
+
     /**
      * Gets the final result, or an error, based on last async poll response.
      *

fluent-tests/src/main/java/com/azure/resourcemanager/resources/fluentcore/AzureServiceClient.java

@@ -45,6 +45,7 @@
 import com.azure.mgmtlitetest.storage.models.StorageAccounts;
 import com.azure.mgmtlitetest.streamanalytics.models.AggregateFunctionProperties;
 import com.azure.mgmtlitetest.streamstyleserialization.implementation.CommunityGalleriesClientImpl;
+import com.azure.mgmtlitetest.syncstack.SyncStackManager;
 import com.azure.mgmttest.azurestack.fluent.models.ExtendedProductInner;
 import com.azure.mgmttest.education.fluent.models.LabDetailsInner;
 import reactor.core.publisher.Mono;
@@ -220,4 +221,10 @@ public void testChildWithParentFlattenedProperties() {
     public void testEmptyByteArrayInClients() {
         Class<DpsCertificatesClientImpl> clazz = DpsCertificatesClientImpl.class;
     }
+
+    public void testSyncStack() {
+        SyncStackManager syncStackManager = mock(SyncStackManager.class);
+        syncStackManager.normalPageables().list("name");
+        syncStackManager.normalPageables().list("name", "filter", Context.NONE);
+    }
 }