测试移动

src/cache/cache.service.ts

@@ -75,4 +75,12 @@ export class CacheService implements OnModuleInit {
 
     await this.client.flushall();
   }
+
+  // publish(channel: string, message: string, callback?: Callback<number>): Pipeline;
+  public async publish(channel: string, message: string): Promise<any> {
+    if (!this.client) {
+      await this.getClient();
+    }
+    return await this.client.publish(channel, message);
+  }
 }

src/scene/actionType.ts

@@ -1,4 +1,7 @@
 export enum ActionType {
+  walk = 1,
+  breathPoint = 1004,
+  joystick = 15,
   rotate = 1014,
   userStatus = 1024,
   status = 1009,

src/scene/scene.service.ts

@@ -153,10 +153,17 @@ export class SceneService implements OnModuleInit, OnModuleDestroy {
   async rotate(request: RotateRequest) {
     try {
       // const reply = this.sceneGrpcService.rotate(request);
+      const res = await this.cacheService.publish(
+        'test',
+        JSON.stringify(request),
+      );
+
+      console.log('res', res);
+
       if (!this.onSteaming) {
         this.frameCnt += 1;
         this.RotateframeCnt = this.frameCnt;
-
+        // this.cacheService
         this.testFrame += 1;
         if (this.testFrame > 358) this.testFrame = 0;
         const stream: StreamFrameType = {
@@ -244,15 +251,21 @@ export class SceneService implements OnModuleInit, OnModuleDestroy {
   handleMessage(message: string | Buffer) {
     try {
       if (typeof message === 'string') {
-        // console.log('toto', message);
         const msg: RTCMessageRequest = JSON.parse(message);
         switch (msg.action_type) {
+          case ActionType.walk:
+            const walk = msg;
+            this.walking(walk);
+            break;
+          case ActionType.breathPoint:
+            this.handleBreath(msg);
+            break;
           case ActionType.rotate:
             const rotateRequest: RotateRequest = msg;
             this.rotate(rotateRequest);
             break;
           case ActionType.userStatus:
-            this.updateUserStatus();
+            this.updateUserStatus(msg);
             break;
           case ActionType.status:
             this.updateStatus();
@@ -265,6 +278,222 @@ export class SceneService implements OnModuleInit, OnModuleDestroy {
       this.logger.error('handleMessage:rtc', error);
     }
   }
+
+  walking(request) {
+    console.log('walking', request);
+    const walk1 = {
+      traceIds: [request.trace_id],
+      vehicle: null,
+      newUserStates: [
+        {
+          userId: '31251ce814121',
+          playerState: {
+            roomTypeId: '',
+            person: 0,
+            avatarId: '',
+            skinId: '',
+            roomId: '',
+            isHost: false,
+            isFollowHost: false,
+            skinDataVersion: '',
+            avatarComponents: '',
+            nickName: '',
+            movingMode: 0,
+            attitude: '',
+            areaName: '',
+            pathName: '',
+            pathId: '',
+            avatarSize: 1,
+            extra: '',
+            prioritySync: false,
+            avatarURL: '',
+            micStatus: 0,
+            player: {
+              position: { x: -755, y: -1450, z: -34 },
+              angle: { pitch: 0, yaw: 348, roll: 4.5912e-41 },
+            },
+            camera: {
+              position: { x: -1075, y: -1450, z: 86 },
+              angle: { pitch: 0, yaw: 0, roll: 0 },
+            },
+            cameraCenter: { x: -755, y: -1450, z: -34 },
+          },
+          renderInfo: {
+            renderType: 0,
+            videoFrame: null,
+            cameraStateType: 3,
+            isMoving: 1,
+            needIfr: 0,
+            isVideo: 0,
+            stillFrame: 0,
+            isRotating: 0,
+            isFollowing: 0,
+            clientPanoTitlesBitmap: [],
+            clientPanoTreceId: '',
+            prefetchVideoId: '',
+            noMedia: false,
+          },
+          event: null,
+          relation: 1,
+        },
+      ],
+      actionResponses: [
+        {
+          actionType: 1,
+          pointType: 0,
+          extra: '',
+          traceId: request.trace_id,
+          packetId: '',
+          nps: [],
+          peopleNum: 0,
+          zoneId: '',
+          echoMsg: '',
+          reserveDetail: null,
+          userWithAvatarList: [],
+          newUserStates: [],
+          code: 0,
+          msg: '',
+        },
+      ],
+      getStateType: 0,
+      code: 0,
+      msg: 'OK',
+    };
+    const stream: StreamFrameType = {
+      frame: this.frameCnt,
+      clipPath: path.join(__dirname, `../ws/video/2.h264`),
+      metaData: JSON.stringify(walk1),
+      serverTime: Date.now(),
+      DIR: 1,
+    };
+    console.log('walking', this.frameCnt, stream.clipPath);
+    this.streamService.pushFrameToSteam(stream);
+  }
+
+  handleBreath(request) {
+    console.log('request', request);
+    const nps = {
+      actionType: 1004,
+      pointType: 100,
+      extra: '',
+      traceId: 'bd152140-d352-4ad7-8f4c-d0246659372c',
+      packetId: '',
+      nps: [
+        { x: 235, y: -1791.875, z: -0.25 },
+        { x: 235, y: -1750, z: 0.5045047 },
+        { x: 235, y: -1722.5, z: 1 },
+        { x: 235, y: -1700, z: 1.4054055 },
+        { x: 235, y: -1653.125, z: 2.25 },
+        { x: 235, y: -1600, z: 3.2072072 },
+        { x: 235, y: -1583.75, z: 3.5 },
+        { x: 235, y: -1550, z: 4.108108 },
+        { x: 235, y: -1514.375, z: 4.75 },
+        { x: 235, y: -1499.9999, z: 5.0090113 },
+        { x: 235, y: -1445, z: 6 },
+        { x: 200, y: -1900, z: -1.8723404 },
+        { x: 200, y: -1850, z: -0.80851054 },
+        { x: 200, y: -1800, z: 0.23423433 },
+        { x: 200, y: -1750, z: 1.1351352 },
+        { x: 200, y: -1700, z: 2.036036 },
+        { x: 200, y: -1650, z: 2.9369369 },
+        { x: 200, y: -1600, z: 3.837838 },
+        { x: 200, y: -1550, z: 4.738739 },
+        { x: 200, y: -1500, z: 5.63964 },
+        { x: 200, y: -1444.2554, z: 6 },
+        { x: 176.25, y: -1443.75, z: 6 },
+        { x: 150, y: -2000, z: -4 },
+        { x: 150, y: -1950, z: -2.93617 },
+        { x: 150, y: -1932.8572, z: -2.5714293 },
+        { x: 150, y: -1900, z: -1.8723404 },
+        { x: 150, y: -1865.7142, z: -1.1428561 },
+        { x: 150, y: -1850.0001, z: -0.8085134 },
+        { x: 150, y: -1798.5714, z: 0.28571463 },
+        { x: 150, y: -1750, z: 1.319149 },
+        { x: 150, y: -1731.4286, z: 1.7142854 },
+        { x: 150, y: -1700, z: 2.382979 },
+        { x: 150, y: -1664.2856, z: 3.142859 },
+        { x: 150, y: -1650.0001, z: 3.446806 },
+        { x: 150, y: -1597.1428, z: 4.5714293 },
+        { x: 150, y: -1550, z: 5.5744677 },
+        { x: 150, y: -1443.1917, z: 6 },
+        { x: 150, y: -1500, z: 6 },
+        { x: 150, y: -1530, z: 6 },
+        { x: 117.5, y: -1442.5, z: 6 },
+        { x: 115, y: -1495, z: 6 },
+        { x: 100, y: -1442.1277, z: 6 },
+        { x: 100, y: -1495, z: 6 },
+        { x: 58.75, y: -1441.25, z: 6 },
+        { x: 57.5, y: -1495, z: 6 },
+        { x: 0, y: -1440, z: 6 },
+        { x: 0, y: -1495, z: 6 },
+        { x: -50, y: -1494.9999, z: 6 },
+        { x: -50, y: -1439.3378, z: 7.324497 },
+        { x: -64.16667, y: -1495, z: 6 },
+        { x: -68.63635, y: -1439.091, z: 7.8181725 },
+        { x: -100, y: -1494.9999, z: 6 },
+        { x: -100, y: -1438.6755, z: 8.648995 },
+        { x: -128.33334, y: -1495, z: 6 },
+        { x: -137.2727, y: -1438.1818, z: 9.636378 },
+        { x: -150, y: -1494.9999, z: 6 },
+        { x: -150, y: -1438.0132, z: 9.973526 },
+        { x: -192.50002, y: -1495, z: 6 },
+        { x: -200, y: -1450, z: 7.936013 },
+        { x: -205.90906, y: -1437.2727, z: 11.45455 },
+        { x: -250, y: -1450, z: 9.084496 },
+        { x: -250, y: -1436.6887, z: 12.622522 },
+        { x: -256.6667, y: -1495, z: 6 },
+        { x: -274.5454, y: -1436.3636, z: 13.272723 },
+        { x: -300, y: -1494.9999, z: 6 },
+        { x: -300, y: -1450, z: 10.232978 },
+        { x: -300, y: -1436.0264, z: 13.947053 },
+        { x: -320.83337, y: -1495, z: 6 },
+        { x: -343.1818, y: -1435.4546, z: 15.090897 },
+        { x: -350, y: -1494.9999, z: 6 },
+        { x: -350, y: -1450, z: 11.38146 },
+        { x: -385, y: -1495, z: 6 },
+        { x: -400, y: -1450, z: 10.610336 },
+        { x: -405, y: -1475, z: 6 },
+        { x: -411.81818, y: -1434.5454, z: 11.454548 },
+        { x: -450, y: -1474.9999, z: 0.8571429 },
+        { x: -450, y: -1450, z: 3.8835106 },
+        { x: -450, y: -1434.0398, z: 6.3973427 },
+        { x: -475, y: -1475, z: -2 },
+        { x: -480.45453, y: -1433.6364, z: 2.3636398 },
+        { x: -500, y: -1474.9999, z: -4.8571415 },
+        { x: -500, y: -1450, z: -2.8433151 },
+        { x: -500, y: -1433.3776, z: -0.22517776 },
+        { x: -545, y: -1475, z: -10 },
+        { x: -549.0909, y: -1432.7273, z: -6.727272 },
+        { x: -550, y: -1450, z: -9.570139 },
+        { x: -600, y: -1450, z: -16.285715 },
+        { x: -600, y: -1474.9999, z: -16.285715 },
+        { x: -600, y: -1432.053, z: -13.4702 },
+        { x: -615, y: -1475, z: -18 },
+        { x: -617.7273, y: -1431.8182, z: -15.818193 },
+        { x: -650, y: -1450, z: -22 },
+        { x: -650, y: -1474.9999, z: -22 },
+        { x: -650, y: -1431.3907, z: -20.09272 },
+        { x: -685, y: -1475, z: -26 },
+        { x: -686.36365, y: -1430.909, z: -24.909088 },
+        { x: -700, y: -1450, z: -27.714287 },
+        { x: -700, y: -1474.9999, z: -27.714283 },
+        { x: -700, y: -1430.7284, z: -26.71522 },
+        { x: -755, y: -1430, z: -34 },
+        { x: -755, y: -1450, z: -34 },
+        { x: -755, y: -1475, z: -34 },
+      ],
+      peopleNum: 0,
+      zoneId: '',
+      echoMsg: '',
+      reserveDetail: null,
+      userWithAvatarList: [],
+      newUserStates: [],
+      code: 0,
+      msg: '',
+    };
+    this.streamService.pushNormalDataToStream(nps);
+  }
+
   updateStatus() {
     const reply = {
       data: { action_type: 1009, echo_msg: { echoMsg: Date.now() } },
@@ -273,12 +502,13 @@ export class SceneService implements OnModuleInit, OnModuleDestroy {
     this.streamService.pushNormalDataToStream(reply);
   }
 
-  async updateUserStatus() {
+  async updateUserStatus(request) {
+    console.log('1024', request);
     const reply = {
       actionType: 1024,
       pointType: 100,
       extra: '',
-      traceId: '65db8e1b-2261-42eb-8bc5-8dc97bfe0b0e',
+      traceId: request.trace_id,
       packetId: '',
       nps: [],
       peopleNum: 0,
@@ -392,15 +622,13 @@ export class SceneService implements OnModuleInit, OnModuleDestroy {
         //   }, 1000 / 30);
         // };
 
-
         if (this.frameCnt > 1 && !this.onSteaming) {
           const streamMeta: StreamMetaType = {
             frame: this.frameCnt,
             metaData: JSON.stringify(frameMetaReply),
           };
           this.streamService.pushMetaDataToSteam(streamMeta);
-        };
-
+        }
 
         // }
       } catch (error) {

src/scene/stream/stream.service.ts

@@ -12,7 +12,7 @@ export class StreamService {
   private readonly block = 36;
   private logger: Logger = new Logger('StreamService');
   public onSteaming = new BehaviorSubject<boolean>(false);
-  constructor(private cacheService: CacheService) { }
+  constructor(private cacheService: CacheService) {}
 
   setChannel(channel: DataChannel) {
     this.channel = channel;
@@ -22,9 +22,7 @@ export class StreamService {
   }
 
   getQueueDataFromPool(poolKey: string) {
-
     // const redisData = this.cacheService.()
-
   }
   /**
    * stream core push normal stream
@@ -168,7 +166,6 @@ export class StreamService {
         // if(this.onSteaming){
         //   setTimeout()
         // }
-        
       });
     } catch (error) {
       this.logger.error(error);