airpg-front/assets/scripts/socket/processCtr.ts

import { _decorator, Component, Game, Node } from "cc"
import { GameCtr } from "../gameCtr"
const { ccclass, property } = _decorator

@ccclass("processCtr")
export class processCtr extends Component {

    //消息队列
    public messageQueue = []
    public isProcessing = false

    private gameCtr :GameCtr = null;
    
    start() {

    }

    update(deltaTime: number) {

    }

    public init(gameCtr:GameCtr)
    {
        this.gameCtr = gameCtr;
    }


    processNextMessage = function() {
        console.log("processDoing"+this.isProcessing+"   "+this.messageQueue.length)
        if (this.isProcessing || this.messageQueue.length === 0) {
            return;  // If a message is currently being processed or there's no message in the queue, exit
        }
    
        const data = this.messageQueue.shift();  // Dequeue the next message
        this.isProcessing = true;
    
        switch (data.type) {
                case "plot":
                    this.handlePlotMessage(data)
                    break
                case "options":
                    this.handleOptionsMessage(data)
                    break
                case "votes":
                    this.handleVotesMessage(data)
                    break
                case "voteResult":
                    this.handleVoteResultMessage(data)
                    break
                case "state":
                    this.handleStateMessage(data)
                    break
                default:
                    console.warn("Unknown message type:", data.type)
                this.doneProcessing();  // Ensure processing flag is reset even for unknown types
        }
    };

    doneProcessing = () => {
        this.isProcessing = false;
        this.processNextMessage();  // Check if there are more messages to process after current one is done
    };

    private handlePlotMessage(data: any) {
        console.log("Received plot message:", data)
        // 在这里处理 "展示剧情" 类型的消息

         this.gameCtr.handleStoryPannelMove(data);
        
    }

    private handleOptionsMessage(data: any) {
        console.log("Received options message:", data)
        // 在这里处理 "options" 类型的消息
        this.gameCtr.handleOptions(data);

    }

    private handleVoteResultMessage(data: any) {
        console.log("Received VoteResult message:", data)
        // 在这里处理 "VoteResult" 类型的消息
        this.gameCtr.handleVoteResul(data);

    }
    private handleVotesMessage(data: any) {
        console.log("Received votes message:", data)
        this.doneProcessing()
    }

    private handleStateMessage(data: any) {
        console.log("Received State message:", data)
        // 在这里处理 "State" 类型的消息.
        // this.gameCtr.handleStateResul(data);
        this.doneProcessing()
    }
}