lost frme

src/scene/scene.service.ts

@@ -25,7 +25,7 @@ export class SceneService implements OnModuleInit, OnModuleDestroy {
     private rotateService: RotateService,
     private moveService: MoveService,
     private getRouterService: GetRouterService, // @InjectQueue('rotate') private rotateQueue: Queue, // @InjectQueue('walking') private walkingQueue: Queue,
-  ) {}
+  ) { }
   @Client(grpcClientOptions) private readonly client: ClientGrpc;
 
   public _frameInteval: NodeJS.Timeout;
@@ -340,8 +340,8 @@ export class SceneService implements OnModuleInit, OnModuleDestroy {
           if (seqs?.length) {
             const lastSeq = rotateCamData?.length
               ? (Array.from(rotateCamData).concat(
-                  seqs,
-                ) as any as StreamReplyType[])
+                seqs,
+              ) as any as StreamReplyType[])
               : seqs;
             console.log('walking --总序列--seqs', seqs.length);
             this.handleSeqMoving(lastSeq);
@@ -389,8 +389,8 @@ export class SceneService implements OnModuleInit, OnModuleDestroy {
                 console.log('joystickRes-seqs', seqs.length);
                 const lastSeq = rotateCamData?.length
                   ? (Array.from(rotateCamData).concat(
-                      seqs,
-                    ) as any as StreamReplyType[])
+                    seqs,
+                  ) as any as StreamReplyType[])
                   : seqs;
                 this.handleSeqMoving(lastSeq);
               } else {
@@ -593,15 +593,14 @@ export class SceneService implements OnModuleInit, OnModuleDestroy {
   async handleIframeRequest() {
     //TODO Iframe 最终传什么？
 
-    this.requestIFrameQueue.next(this.streamService.lastStreamFrame);
+    this.requestIFrameQueue.next(this.streamService.lastStreamFrame.getValue());
 
     if (!this.requestIFrameQueueSub) {
       this.requestIFrameQueueSub = this.requestIFrameQueue.subscribe(
         (frameData: StreamFrameType) => {
           const nextFrame = this.frameCnt.getValue() + 1;
-          this.logger.warn('lostIframe', nextFrame, frameData);
+          this.logger.warn('lostIframe', nextFrame, JSON.stringify(frameData));
           frameData.frame = nextFrame;
-          console.log('frameData', frameData);
           this.streamService.pushFrameToSteam(frameData);
           this.frameCnt.next(nextFrame);
           this.resumeStream();
@@ -696,7 +695,7 @@ export class SceneService implements OnModuleInit, OnModuleDestroy {
                 delete redisData.mediaSrc;
                 this.logger.log(
                   `user:${this.user_id}:first render stream` +
-                    JSON.stringify({ path: clipPath, meta: redisData }),
+                  JSON.stringify({ path: clipPath, meta: redisData }),
                 );
                 const status = await this.pushFirstRender(
                   clipPath,