mirror/quantum-space-buddies
1
0
Fork 0
mirror of https://github.com/misternebula/quantum-space-buddies.git synced 2025-04-25 12:02:38 +00:00
Code Issues Projects Releases Wiki Activity

bruh

Browse Source
This commit is contained in:
Mister_Nebula 2022-08-26 20:31:49 +01:00
parent b46a45e346
commit 849b6d1e7e
3 changed files with 19 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
EpicOnlineTransport/Common.cs
View File

@ -120,6 +120,8 @@ public abstract class Common
protected void SendInternal(ProductUserId target, SocketId socketId, InternalMessages type) protected void SendInternal(ProductUserId target, SocketId socketId, InternalMessages type)
{ {
Debug.LogError($"SendInternal type:{type} to {target}");
EOSSDKComponent.GetP2PInterface().SendPacket(new SendPacketOptions() EOSSDKComponent.GetP2PInterface().SendPacket(new SendPacketOptions()
{ {
AllowDelayedDelivery = true, AllowDelayedDelivery = true,

12
EpicOnlineTransport/Server.cs
View File

@ -67,14 +67,19 @@ public class Server : Common
protected override void OnReceiveInternalData(InternalMessages type, ProductUserId clientUserId, SocketId socketId) protected override void OnReceiveInternalData(InternalMessages type, ProductUserId clientUserId, SocketId socketId)
{ {
Debug.LogError($"OnReceiveInteralData type:{type} from {clientUserId}");
if (ignoreAllMessages) if (ignoreAllMessages)
{ {
Debug.LogError($"- IgnoreAllMessages :/");
return; return;
} }
switch (type) switch (type)
{ {
case InternalMessages.CONNECT: case InternalMessages.CONNECT:
Debug.LogError($"- CONNECT connectedId:{nextConnectionID + 1}");
if (epicToMirrorIds.Count >= maxConnections) if (epicToMirrorIds.Count >= maxConnections)
{ {
Debug.LogError("Reached max connections"); Debug.LogError("Reached max connections");
@ -97,6 +102,7 @@ public class Server : Common
case InternalMessages.DISCONNECT: case InternalMessages.DISCONNECT:
if (epicToMirrorIds.TryGetValue(clientUserId, out var connId)) if (epicToMirrorIds.TryGetValue(clientUserId, out var connId))
{ {
Debug.LogError($"- DISCONNECT connectedId:{connId}");
OnDisconnected.Invoke(connId); OnDisconnected.Invoke(connId);
//CloseP2PSessionWithUser(clientUserId, socketId); //CloseP2PSessionWithUser(clientUserId, socketId);
epicToMirrorIds.Remove(clientUserId); epicToMirrorIds.Remove(clientUserId);
@ -142,6 +148,7 @@ public class Server : Common
public void Disconnect(int connectionId) public void Disconnect(int connectionId)
{ {
Debug.LogError($"DISCONNECT {connectionId}");
if (epicToMirrorIds.TryGetValue(connectionId, out var userId)) if (epicToMirrorIds.TryGetValue(connectionId, out var userId))
{ {
SocketId socketId; SocketId socketId;
@ -152,7 +159,7 @@ public class Server : Common
} }
else else
{ {
Debug.LogWarning("Trying to disconnect unknown connection id: " + connectionId); Debug.LogError("Trying to disconnect unknown connection id: " + connectionId);
} }
} }
@ -205,8 +212,11 @@ public class Server : Common
protected override void OnConnectionFailed(ProductUserId remoteId) protected override void OnConnectionFailed(ProductUserId remoteId)
{ {
Debug.LogError($"OnConnectionFailed");
if (ignoreAllMessages) if (ignoreAllMessages)
{ {
Debug.LogError($"- IgnoreAllMessages :/");
return; return;
} }

8
QSB/Player/Messages/PlayerKickMessage.cs
View File

@ -35,11 +35,15 @@ internal class PlayerKickMessage : QSBMessage<string>
return; return;
} }
Delay.RunFramesLater(20, KickPlayer); Delay.RunFramesLater(10, KickPlayer);
} }
private void KickPlayer() private void KickPlayer()
=> PlayerId.GetNetworkConnection().Disconnect(); {
var connectionToClient = PlayerId.GetNetworkConnection();
connectionToClient.Disconnect();
Transport.activeTransport.OnServerDisconnected(connectionToClient.connectionId);
}
public override void OnReceiveRemote() public override void OnReceiveRemote()
{ {