ET9_WebGL_Dev/Server/Hotfix/Module/Message/InnerMessageDispatcherHelper.cs



 namespace ET
{
    public static class InnerMessageDispatcherHelper
    {
        public static async ETVoid HandleIActorResponse(Session session, IActorResponse iActorResponse)
		{
			ActorMessageSenderComponent.Instance.RunMessage(iActorResponse);
			await ETTask.CompletedTask;
		}

		public static async ETVoid HandleIActorRequest(Session session, IActorRequest iActorRequest)
		{
			InstanceIdStruct instanceIdStruct = new InstanceIdStruct(iActorRequest.ActorId);
			int replyId = instanceIdStruct.Process;
			instanceIdStruct.Process = IdGenerater.Process;
			iActorRequest.ActorId = instanceIdStruct.ToLong();

			string address = StartProcessConfigCategory.Instance.Get(replyId).InnerAddress;
			Session ss = NetInnerComponent.Instance.Get(address);
			Entity entity = Game.EventSystem.Get(iActorRequest.ActorId);
			if (entity == null)
			{
				Log.Warning($"not found actor: {MongoHelper.ToJson(iActorRequest)}");
				ActorResponse response = new ActorResponse
				{
					Error = ErrorCode.ERR_NotFoundActor,
					RpcId = iActorRequest.RpcId,
				};
				ss.Reply(response);
				return;
			}
	
			MailBoxComponent mailBoxComponent = entity.GetComponent<MailBoxComponent>();
			if (mailBoxComponent == null)
			{
				ActorResponse response = new ActorResponse
				{
					Error = ErrorCode.ERR_ActorNoMailBoxComponent,
					RpcId = iActorRequest.RpcId,
				};
				ss.Reply(response);
				Log.Error($"actor not add MailBoxComponent: {entity.GetType().Name} {iActorRequest}");
				return;
			}
			
			await mailBoxComponent.Handle(ss, iActorRequest);
		}

		public static async ETVoid HandleIActorMessage(Session session, IActorMessage iActorMessage)
		{
			InstanceIdStruct instanceIdStruct = new InstanceIdStruct(iActorMessage.ActorId);
			int replyId = instanceIdStruct.Process;
			instanceIdStruct.Process = IdGenerater.Process;
			iActorMessage.ActorId = instanceIdStruct.ToLong();
			
			Entity entity = Game.EventSystem.Get(iActorMessage.ActorId);
			if (entity == null)
			{
				Log.Error($"not found actor: {MongoHelper.ToJson(iActorMessage)}");
				return;
			}
	
			MailBoxComponent mailBoxComponent = entity.GetComponent<MailBoxComponent>();
			if (mailBoxComponent == null)
			{
				Log.Error($"actor not add MailBoxComponent: {entity.GetType().Name} {iActorMessage}");
				return;
			}
			
			Session ss = NetInnerComponent.Instance.Get(replyId);
			await mailBoxComponent.Handle(ss, iActorMessage);
		}
    }
}