Web PubSub service SDK Remove hub name parameter (Azure#45860)

`hub` name should be a client parameter

Author: Y-Sindo

sdk/webpubsub/azure-messaging-webpubsub/src/main/java/com/azure/messaging/webpubsub/WebPubSubServiceAsyncClient.java

@@ -28,7 +28,7 @@
 import com.azure.messaging.webpubsub.models.GetClientAccessTokenOptions;
 import com.azure.messaging.webpubsub.models.WebPubSubClientAccessToken;
 import com.azure.messaging.webpubsub.models.WebPubSubContentType;
-import com.azure.messaging.webpubsub.models.WebPubSubGroupMember;
+import com.azure.messaging.webpubsub.models.WebPubSubGroupConnection;
 import com.azure.messaging.webpubsub.models.WebPubSubPermission;
 
 import reactor.core.publisher.Flux;
@@ -441,7 +441,6 @@ public Mono<Void> addConnectionsToGroups(List<String> groups, String filter) {
      * }
      * </pre>
      *
-     * @param hub Target hub name, which should start with alphabetic characters and only contain alpha-numeric characters or underscore.
      * @param group Target group name, whose length should be greater than 0 and less than 1025.
      * @param requestOptions The options to configure the HTTP request before HTTP client sends it.
      * @throws HttpResponseException thrown if the request is rejected by server.
@@ -451,8 +450,7 @@ public Mono<Void> addConnectionsToGroups(List<String> groups, String filter) {
      * @return represents a page of elements as a LIST REST API result as paginated response with {@link PagedFlux}.
      */
     @ServiceMethod(returns = ReturnType.COLLECTION)
-    public PagedFlux<WebPubSubGroupMember> listConnectionsInGroup(String hub, String group,
-        RequestOptions requestOptions) {
+    public PagedFlux<WebPubSubGroupConnection> listConnectionsInGroup(String group, RequestOptions requestOptions) {
         PagedFlux<BinaryData> binaryDataPagedFlux
             = this.serviceClient.listConnectionsInGroupAsync(hub, group, requestOptions);
 
@@ -464,7 +462,7 @@ public PagedFlux<WebPubSubGroupMember> listConnectionsInGroup(String hub, String
                 pagedResponse.getStatusCode(), pagedResponse.getHeaders(),
                 pagedResponse.getValue()
                     .stream()
-                    .map(bd -> bd.toObject(WebPubSubGroupMember.class))
+                    .map(bd -> bd.toObject(WebPubSubGroupConnection.class))
                     .collect(java.util.stream.Collectors.toList()),
                 pagedResponse.getContinuationToken(), null));
         });

sdk/webpubsub/azure-messaging-webpubsub/src/main/java/com/azure/messaging/webpubsub/WebPubSubServiceClient.java

@@ -24,7 +24,7 @@
 import com.azure.messaging.webpubsub.models.GetClientAccessTokenOptions;
 import com.azure.messaging.webpubsub.models.WebPubSubClientAccessToken;
 import com.azure.messaging.webpubsub.models.WebPubSubContentType;
-import com.azure.messaging.webpubsub.models.WebPubSubGroupMember;
+import com.azure.messaging.webpubsub.models.WebPubSubGroupConnection;
 import com.azure.messaging.webpubsub.models.WebPubSubPermission;
 
 import java.util.List;
@@ -690,8 +690,8 @@ public Response<Void> closeUserConnectionsWithResponse(String userId, RequestOpt
      * @return represents a page of elements as a LIST REST API result as paginated response with {@link PagedIterable}.
      */
     @ServiceMethod(returns = ReturnType.COLLECTION)
-    public PagedIterable<WebPubSubGroupMember> listConnectionsInGroup(String group, RequestOptions requestOptions) {
+    public PagedIterable<WebPubSubGroupConnection> listConnectionsInGroup(String group, RequestOptions requestOptions) {
         return this.serviceClient.listConnectionsInGroup(hub, group, requestOptions)
-            .mapPage(binaryData -> binaryData.toObject(WebPubSubGroupMember.class));
+            .mapPage(binaryData -> binaryData.toObject(WebPubSubGroupConnection.class));
     }
 }

…bpubsub/models/WebPubSubGroupMember.java …sub/models/WebPubSubGroupConnection.javasdk/webpubsub/azure-messaging-webpubsub/src/main/java/com/azure/messaging/webpubsub/models/WebPubSubGroupMember.java renamed to sdk/webpubsub/azure-messaging-webpubsub/src/main/java/com/azure/messaging/webpubsub/models/WebPubSubGroupConnection.java sdk/webpubsub/azure-messaging-webpubsub/src/main/java/com/azure/messaging/webpubsub/models/WebPubSubGroupMember.java renamed to sdk/webpubsub/azure-messaging-webpubsub/src/main/java/com/azure/messaging/webpubsub/models/WebPubSubGroupConnection.java

@@ -15,7 +15,7 @@
  * Represents a connection in a group.
  */
 @Immutable
-public final class WebPubSubGroupMember implements JsonSerializable<WebPubSubGroupMember> {
+public final class WebPubSubGroupConnection implements JsonSerializable<WebPubSubGroupConnection> {
 
     /**
      * The ID of a connection.
@@ -33,7 +33,7 @@ public final class WebPubSubGroupMember implements JsonSerializable<WebPubSubGro
      * @param connectionId the connectionId value to set.
      * @param userId the userId value to set.
      */
-    private WebPubSubGroupMember(String connectionId, String userId) {
+    private WebPubSubGroupConnection(String connectionId, String userId) {
         this.connectionId = connectionId;
         this.userId = userId;
     }
@@ -78,7 +78,7 @@ public JsonWriter toJson(JsonWriter jsonWriter) throws IOException {
      * @throws IllegalStateException If the deserialized JSON object was missing any required properties.
      * @throws IOException If an error occurs while reading the WebPubSubGroupMember.
      */
-    public static WebPubSubGroupMember fromJson(JsonReader jsonReader) throws IOException {
+    public static WebPubSubGroupConnection fromJson(JsonReader jsonReader) throws IOException {
         return jsonReader.readObject(reader -> {
             String connectionId = null;
             String userId = null;
@@ -96,7 +96,7 @@ public static WebPubSubGroupMember fromJson(JsonReader jsonReader) throws IOExce
             if (connectionId == null) {
                 throw new IllegalStateException("Missing required property: connectionId");
             }
-            return new WebPubSubGroupMember(connectionId, userId);
+            return new WebPubSubGroupConnection(connectionId, userId);
         });
     }
 }

sdk/webpubsub/azure-messaging-webpubsub/src/test/java/com/azure/messaging/webpubsub/WebPubSubServiceAsyncClientTests.java

@@ -495,8 +495,7 @@ public void testListConnectionsInGroupAsync(int totalConnectionCount, int top, i
             options.addQueryParam("top", String.valueOf(top));
         }
 
-        PagedFlux<WebPubSubGroupMember> pagedFlux
-            = client.listConnectionsInGroup(TestUtils.HUB_NAME, groupName, options);
+        PagedFlux<WebPubSubGroupConnection> pagedFlux = client.listConnectionsInGroup(groupName, options);
         StepVerifier.create(pagedFlux.byPage()).thenConsumeWhile(page -> {
             actualPageCount[0]++;
             actualConnectionCount[0] += page.getValue().size();

sdk/webpubsub/azure-messaging-webpubsub/src/test/java/com/azure/messaging/webpubsub/WebPubSubServiceClientTests.java

@@ -43,7 +43,7 @@
 
 import com.azure.core.http.rest.PagedIterable;
 import com.azure.core.http.rest.PagedResponse;
-import com.azure.messaging.webpubsub.models.WebPubSubGroupMember;
+import com.azure.messaging.webpubsub.models.WebPubSubGroupConnection;
 
 public class WebPubSubServiceClientTests extends TestProxyTestBase {
 
@@ -458,8 +458,8 @@ public void testListConnectionsInGroup(int totalConnectionCount, int top, int ma
             options.addQueryParam("top", String.valueOf(top));
         }
 
-        PagedIterable<WebPubSubGroupMember> pages = client.listConnectionsInGroup(groupName, options);
-        for (PagedResponse<WebPubSubGroupMember> page : pages.iterableByPage()) {
+        PagedIterable<WebPubSubGroupConnection> pages = client.listConnectionsInGroup(groupName, options);
+        for (PagedResponse<WebPubSubGroupConnection> page : pages.iterableByPage()) {
             actualPageCount++;
             actualConnectionCount += page.getValue().size();
         }