Add deserializeSetupPayload()

Author: linux-china

packages/rsocket-core/src/RSocketServer.js

@@ -21,7 +21,9 @@ import type {
   DuplexConnection,
   Frame,
   FrameWithData,
+  SetupFrame,
   Payload,
+  SetupPayload,
   ReactiveSocket,
   PartialResponder,
 } from 'rsocket-types';
@@ -180,7 +182,7 @@ export default class RSocketServer<D, M> {
               try {
                 const requestHandler = this._config.getRequestHandler(
                   serverMachine,
-                  deserializePayload(serializers, frame),
+                  deserializeSetupPayload(serializers, frame),
                 );
                 serverMachine.setRequestHandler(requestHandler);
                 this._connections.add(serverMachine);
@@ -277,3 +279,17 @@ function deserializePayload<D, M>(
     metadata: serializers.metadata.deserialize(frame.metadata),
   };
 }
+
+function deserializeSetupPayload<D, M>(
+  serializers: PayloadSerializers<D, M>,
+  frame: SetupFrame,
+): SetupPayload<D, M> {
+  return {
+    data: serializers.data.deserialize(frame.data),
+    metadata: serializers.metadata.deserialize(frame.metadata),
+    keepAlive: frame.keepAlive,
+    lifetime: frame.lifetime,
+    metadataMimeType: frame.metadataMimeType,
+    dataMimeType: frame.dataMimeType,
+  };
+}