[web-pubsub-client-protobuf] Add more tests (Azure#25183)

### Packages impacted by this PR
eb-pubsub-client-protobuf

### Issues associated with this PR


### Describe the problem that is addressed by this PR
Add more tests

### What are the possible designs available to address the problem? If there are more than one possible design, why was the one in this PR chosen?


### Are there test cases added in this PR? _(If not, why?)_


### Provide a list of related PRs _(if any)_


### Command used to generate this PR:**_(Applicable only to SDK release request PRs)_

### Checklists
- [ ] Added impacted package name to the issue description
- [ ] Does this PR needs any fixes in the SDK Generator?** _(If so, create an Issue in the [Autorest/typescript](https://github.com/Azure/autorest.typescript) repository and link it here)_
- [ ] Added a changelog (if necessary)

Author: zackliu

sdk/web-pubsub/web-pubsub-client-protobuf/src/generated/clientProto.d.ts

@@ -2570,11 +2570,11 @@ export const DownstreamMessage = $root.DownstreamMessage = (() => {
 
         /**
          * DataMessage sequenceId.
-         * @member {number|Long} sequenceId
+         * @member {number|Long|null|undefined} sequenceId
          * @memberof DownstreamMessage.DataMessage
          * @instance
          */
-        DataMessage.prototype.sequenceId = $util.Long ? $util.Long.fromBits(0,0,true) : 0;
+        DataMessage.prototype.sequenceId = null;
 
         // OneOf field names bound to virtual getters and setters
         let $oneOfFields;
@@ -2590,6 +2590,17 @@ export const DownstreamMessage = $root.DownstreamMessage = (() => {
             set: $util.oneOfSetter($oneOfFields)
         });
 
+        /**
+         * DataMessage _sequenceId.
+         * @member {"sequenceId"|undefined} _sequenceId
+         * @memberof DownstreamMessage.DataMessage
+         * @instance
+         */
+        Object.defineProperty(DataMessage.prototype, "_sequenceId", {
+            get: $util.oneOfGetter($oneOfFields = ["sequenceId"]),
+            set: $util.oneOfSetter($oneOfFields)
+        });
+
         /**
          * Creates a new DataMessage instance using the specified properties.
          * @function create
@@ -2721,9 +2732,11 @@ export const DownstreamMessage = $root.DownstreamMessage = (() => {
                 if (error)
                     return "data." + error;
             }
-            if (message.sequenceId != null && message.hasOwnProperty("sequenceId"))
+            if (message.sequenceId != null && message.hasOwnProperty("sequenceId")) {
+                properties._sequenceId = 1;
                 if (!$util.isInteger(message.sequenceId) && !(message.sequenceId && $util.isInteger(message.sequenceId.low) && $util.isInteger(message.sequenceId.high)))
                     return "sequenceId: integer|Long expected";
+            }
             return null;
         };
 
@@ -2776,11 +2789,6 @@ export const DownstreamMessage = $root.DownstreamMessage = (() => {
             if (options.defaults) {
                 object.from = "";
                 object.data = null;
-                if ($util.Long) {
-                    let long = new $util.Long(0, 0, true);
-                    object.sequenceId = options.longs === String ? long.toString() : options.longs === Number ? long.toNumber() : long;
-                } else
-                    object.sequenceId = options.longs === String ? "0" : 0;
             }
             if (message.from != null && message.hasOwnProperty("from"))
                 object.from = message.from;
@@ -2791,11 +2799,14 @@ export const DownstreamMessage = $root.DownstreamMessage = (() => {
             }
             if (message.data != null && message.hasOwnProperty("data"))
                 object.data = $root.MessageData.toObject(message.data, options);
-            if (message.sequenceId != null && message.hasOwnProperty("sequenceId"))
+            if (message.sequenceId != null && message.hasOwnProperty("sequenceId")) {
                 if (typeof message.sequenceId === "number")
                     object.sequenceId = options.longs === String ? String(message.sequenceId) : message.sequenceId;
                 else
                     object.sequenceId = options.longs === String ? $util.Long.prototype.toString.call(message.sequenceId) : options.longs === Number ? new $util.LongBits(message.sequenceId.low >>> 0, message.sequenceId.high >>> 0).toNumber(true) : message.sequenceId;
+                if (options.oneofs)
+                    object._sequenceId = "sequenceId";
+            }
             return object;
         };
 

sdk/web-pubsub/web-pubsub-client-protobuf/src/generated/clientProto.js

@@ -61,7 +61,7 @@ message DownstreamMessage {
         string from = 1;
         optional string group = 2;
         MessageData data = 3;
-        uint64 sequence_id = 4;
+        optional uint64 sequence_id = 4;
     }
 
     message SystemMessage {

sdk/web-pubsub/web-pubsub-client-protobuf/src/protos/client.proto

@@ -33,7 +33,6 @@ export class WebPubSubProtobufProtocolBase {
    */
   public static parseMessages(input: ArrayBuffer): WebPubSubMessage | null {
     const downstream = DownstreamMessage.decode(new Uint8Array(input));
-    // logger.verbose(`Receiving: ${JSON.stringify(downstream)}`);
     if (downstream.ackMessage) {
       const ack = {
         kind: "ack",
@@ -72,7 +71,7 @@ export class WebPubSubProtobufProtocolBase {
         data = messageData.textData;
       } else if (messageData.jsonData) {
         dataType = "json";
-        data = messageData.jsonData;
+        data = JSON.parse(messageData.jsonData);
       } else if (messageData.binaryData) {
         dataType = "binary";
         data = messageData.binaryData.buffer.slice(
@@ -81,7 +80,6 @@ export class WebPubSubProtobufProtocolBase {
         );
       } else if (messageData.protobufData) {
         dataType = "protobuf";
-        // data = google.protobuf.Any.encode(messageData.protobufData).finish();
         data = messageData.protobufData;
       } else {
         return null;
@@ -115,7 +113,6 @@ export class WebPubSubProtobufProtocolBase {
    * @param message - The message to be written
    */
   public static writeMessage(message: WebPubSubMessage): ArrayBuffer {
-    // logger.verbose(`Writing: ${JSON.stringify(message)}`);
     let upstream: UpstreamMessage;
     switch (message.kind) {
       case "joinGroup": {