charleslemaux/Mirror
1
0
Fork 0
mirror of https://github.com/MirrorNetworking/Mirror.git synced 2024-11-18 02:50:32 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix(EncryptionTransport): Implement OnServerConnectedWithAddress

Browse Source
This commit is contained in:
MrGadget 2024-07-11 11:32:50 -04:00
parent aad625decc
commit 938cdc6c2a
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
Assets/Mirror/Transports/Encryption/EncryptionTransport.cs
View File

@ -76,7 +76,9 @@ private void HandleInnerServerDataReceived(int connId, ArraySegment<byte> data,
} }
} }
private void HandleInnerServerConnected(int connId) private void HandleInnerServerConnected(int connId) => HandleInnerServerConnected(connId, inner.ServerGetClientAddress(connId));
private void HandleInnerServerConnected(int connId, string clientRemoteAddress)
{ {
Debug.Log($"[EncryptionTransport] New connection #{connId}"); Debug.Log($"[EncryptionTransport] New connection #{connId}");
EncryptedConnection ec = null; EncryptedConnection ec = null;
@ -89,7 +91,8 @@ private void HandleInnerServerConnected(int connId)
{ {
Debug.Log($"[EncryptionTransport] Connection #{connId} is ready"); Debug.Log($"[EncryptionTransport] Connection #{connId} is ready");
ServerRemoveFromPending(ec); ServerRemoveFromPending(ec);
OnServerConnected?.Invoke(connId); //OnServerConnected?.Invoke(connId);
OnServerConnectedWithAddress?.Invoke(connId, clientRemoteAddress);
}, },
(type, msg) => (type, msg) =>
{ {
@ -206,6 +209,7 @@ public override void ServerStart()
_credentials = EncryptionCredentials.Generate(); _credentials = EncryptionCredentials.Generate();
} }
inner.OnServerConnected = HandleInnerServerConnected; inner.OnServerConnected = HandleInnerServerConnected;
inner.OnServerConnectedWithAddress = HandleInnerServerConnected;
inner.OnServerDataReceived = HandleInnerServerDataReceived; inner.OnServerDataReceived = HandleInnerServerDataReceived;
inner.OnServerDataSent = (connId, bytes, channel) => OnServerDataSent?.Invoke(connId, bytes, channel); inner.OnServerDataSent = (connId, bytes, channel) => OnServerDataSent?.Invoke(connId, bytes, channel);
inner.OnServerError = HandleInnerServerError; inner.OnServerError = HandleInnerServerError;