Bladeren bron

add dymic steam

gemercheung 3 jaren geleden
bovenliggende
commit
67614a84ba
4 gewijzigde bestanden met toevoegingen van 129 en 36 verwijderingen
  1. 2 2
      package.json
  2. 17 3
      src/meta.gateway.ts
  3. 105 31
      src/scene/scene.service.ts
  4. 5 0
      yarn.lock

+ 2 - 2
package.json

@@ -31,7 +31,6 @@
     "@nestjs/platform-socket.io": "^8.4.4",
     "@nestjs/platform-ws": "^8.4.4",
     "@nestjs/websockets": "^8.4.4",
-    "bl": "^5.0.0",
     "buffer": "^6.0.3",
     "multistream": "^4.1.0",
     "nestjs-redis": "^1.3.3",
@@ -39,7 +38,8 @@
     "redis": "^4",
     "reflect-metadata": "^0.1.13",
     "rimraf": "^3.0.2",
-    "rxjs": "^7.2.0"
+    "rxjs": "^7.2.0",
+    "stream-buffers": "^3.0.2"
   },
   "devDependencies": {
     "@nestjs/cli": "^8.0.0",

+ 17 - 3
src/meta.gateway.ts

@@ -32,8 +32,9 @@ initLogger('Debug');
   path: '/ws',
 })
 export class MetaGateway
-  implements OnGatewayInit, OnGatewayConnection, OnGatewayDisconnect {
-  constructor(private readonly sceneService: SceneService) { }
+  implements OnGatewayInit, OnGatewayConnection, OnGatewayDisconnect
+{
+  constructor(private readonly sceneService: SceneService) {}
   private logger: Logger = new Logger('MetaGateway');
   private peer: PeerConnection = null;
   private timer: NodeJS.Timeout;
@@ -280,10 +281,23 @@ export class MetaGateway
       fe_version: '',
       is_browser: false,
     };
+
+    const startReply = {
+      id: 'start',
+      data: '{"IsHost":false,"SkinID":"10089","SkinDataVersion":"1008900008","RoomTypeID":""}',
+      room_id: 'e629ef3e-022d-4e64-8654-703bb96410eb',
+      channel_id: '3a1a62e9a3c74de6___channel',
+      user_id: 'ed58c8d4ce38c',
+      trace_id: '394df10a-d924-43a9-940d-1dbb41e43f24',
+      packet_id: '',
+      session_id: '67087ad820ea4c89af311e27281d73a6',
+      client_os: '',
+      fe_version: '',
+    };
     this.sceneService.onSteaming.subscribe((val) => {
       if (val) {
         console.log('onSteaming-start', val);
-        client.send(JSON.stringify(demoVal));
+        client.send(JSON.stringify(startReply));
       }
       // debugger
     });

File diff suppressed because it is too large
+ 105 - 31
src/scene/scene.service.ts


+ 5 - 0
yarn.lock

@@ -5008,6 +5008,11 @@ statuses@2.0.1:
   resolved "https://registry.npmmirror.com/statuses/-/statuses-1.5.0.tgz"
   integrity sha512-OpZ3zP+jT1PI7I8nemJX4AKmAX070ZkYPVWV/AaKTJl+tXCTGyVdC1a4SL8RUQYEwk/f34ZX8UTykN68FwrqAA==
 
+stream-buffers@^3.0.2:
+  version "3.0.2"
+  resolved "https://registry.npmmirror.com/stream-buffers/-/stream-buffers-3.0.2.tgz#5249005a8d5c2d00b3a32e6e0a6ea209dc4f3521"
+  integrity sha512-DQi1h8VEBA/lURbSwFtEHnSTb9s2/pwLEaFuNhXwy1Dx3Sa0lOuYT2yNUr4/j2fs8oCAMANtrZ5OrPZtyVs3MQ==
+
 streamsearch@0.1.2:
   version "0.1.2"
   resolved "https://registry.npmmirror.com/streamsearch/-/streamsearch-0.1.2.tgz"