Bellsworne/splunk
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

made ai add a bunch of logging to diagnose the connection

Browse Source
This commit is contained in:
Chris Bell
2025-08-07 11:45:57 -05:00
parent c560c9cbb7
commit 4f5ba495a9
1 changed files with 113 additions and 80 deletions
Download Patch File Download Diff File Expand all files Collapse all files

189
splunk/networking/steam-manager.gd
View File

@@ -19,6 +19,10 @@ func _ready() -> void:
OS.set_environment("SteamGameId", str(steam_app_id))
steam_initialized = init_steam()
if not steam_initialized:
print("!!! Steam did not initialize. Multiplayer will be disabled.")
return
# Connect Steam lobby signals
Steam.lobby_created.connect(_on_lobby_created)
Steam.lobby_joined.connect(_on_lobby_joined)
@@ -40,15 +44,23 @@ func _ready() -> void:
func _on_p2p_session_request(steam_id_remote: int) -> void:
print("P2P session requested from: %s" % steam_id_remote)
Steam.acceptP2PSessionWithUser(steam_id_remote)
## ADDED: More detailed logging to confirm P2P acceptance.
print("[P2P] ==> Session request from: %s. Accepting." % steam_id_remote)
var accepted = Steam.acceptP2PSessionWithUser(steam_id_remote)
if not accepted:
print("[P2P] !!! Failed to accept P2P session with %s." % steam_id_remote)
func _process(delta):
## ADDED: Guard clause in case Steam fails to initialize.
if not steam_initialized:
return
Steam.run_callbacks()
if Input.is_action_just_pressed("interact"):
print(lobby_members)
## ADDED: Replaced simple print with a detailed diagnostic function.
log_multiplayer_info()
func check_command_line() -> void:
@@ -65,43 +77,54 @@ func init_steam() -> bool:
print("Steam init response: %s " % response)
if response['status'] > 0:
print("Failed to init steam! Code: %s " % response)
print("!!! Failed to init steam! Code: %s " % response)
return false
is_owned = Steam.isSubscribed()
steam_id = Steam.getSteamID()
steam_username = Steam.getPersonaName()
print("Steam ID: %s " % steam_id)
print("Steam initialized successfully for %s (ID: %s)." % [steam_username, steam_id])
if !is_owned:
print("Yo, you don't own this on steam, whats up with that?")
return false
print("!!! WARNING: Steam reports you do not own App ID %s." % steam_app_id)
# You might want to return false here in a real game
# return false
return true
func setup_multiplayer_peer(is_host: bool = false) -> void:
## ADDED: Check if a peer is already active before creating a new one.
if multiplayer.multiplayer_peer and multiplayer.get_connection_status() != MultiplayerPeer.CONNECTION_DISCONNECTED:
print("[Multiplayer] Peer already exists. Disconnecting old one.")
multiplayer.multiplayer_peer.close()
peer = SteamMultiplayerPeer.new()
if is_host:
var err = peer.create_host(0)
print("[Multiplayer] Creating Host...")
var err = peer.create_host() ## REMOVED: Channel is handled by the peer automatically now.
if err != OK:
print("Failed to create host: %s" % err)
print("[Multiplayer] !!! Failed to create host. Error: %s" % err)
return
print("Created host")
multiplayer.multiplayer_peer = peer
print("[Multiplayer] Host created successfully. My Peer ID: %s" % multiplayer.get_unique_id())
else:
if lobby_id == 0:
print("[Multiplayer] !!! Cannot create client, not in a lobby.")
return
var host_id = Steam.getLobbyOwner(lobby_id)
var err = peer.create_client(host_id, 0)
print("[Multiplayer] Creating Client, attempting to connect to host: %s" % host_id)
var err = peer.create_client(host_id) ## REMOVED: Channel is handled by the peer automatically.
if err != OK:
print("Failed to create client, error: %s" % err)
print("[Multiplayer] !!! Failed to create client. Error: %s" % err)
return
print("Client created, connecting to host: %s" % host_id)
multiplayer.multiplayer_peer = peer
multiplayer.multiplayer_peer = peer
print("[Multiplayer] Client peer created. Waiting for connection...")
func create_lobby():
@@ -113,16 +136,16 @@ func create_lobby():
func _on_lobby_created(connect: int, this_lobby_id: int):
if connect == 1:
lobby_id = this_lobby_id
print("Created lobby with id `%s`" % lobby_id)
print("Lobby created with id `%s`" % lobby_id)
Steam.setLobbyJoinable(lobby_id, true)
Steam.setLobbyData(lobby_id, "name", steam_username + "'s Lobby")
Steam.setLobbyData(lobby_id, "mode", "Splunk")
Steam.allowP2PPacketRelay(true)
setup_multiplayer_peer(true)
setup_multiplayer_peer(true) # Setup as host
else :
print("Failed to create lobby...")
print("!!! Failed to create lobby.")
func join_lobby(this_lobby_id: int):
@@ -137,15 +160,20 @@ func _on_lobby_joined(this_lobby_id: int, permissions: int, locked: bool, respon
print("Successfully joined lobby: %s" % lobby_id)
get_lobby_members()
# is_server() is the most reliable check for host status
if not multiplayer.is_server():
setup_multiplayer_peer()
setup_multiplayer_peer() # Setup as client
else:
## ADDED: Log the specific reason for the join failure.
print("!!! Failed to join lobby. Reason: %s" % get_join_fail_reason(response))
func get_lobby_members() -> void:
lobby_members.clear()
var num_members = Steam.getNumLobbyMembers(lobby_id)
if lobby_id == 0: return
var num_members = Steam.getNumLobbyMembers(lobby_id)
print("--- Refreshing Lobby Members (%s) ---" % num_members)
for i in range(num_members):
var member_id = Steam.getLobbyMemberByIndex(lobby_id, i)
var member_name = Steam.getFriendPersonaName(member_id)
@@ -153,23 +181,24 @@ func get_lobby_members() -> void:
"steam_id": member_id,
"steam_name": member_name
})
print("Lobby member: %s (%s)" % [member_name, member_id])
print(" - %s (%s)" % [member_name, member_id])
print("---------------------------------")
func _on_lobby_data_update(lobby: int, user: int, success: int) -> void:
if success:
# Check if the lobby data itself was updated (not a specific member)
if lobby == user:
print("Lobby data for lobby %s has been updated." % lobby)
var lobby_name = Steam.getLobbyData(lobby, "name")
print("New lobby name: %s" % lobby_name)
print(" > New lobby name: %s" % lobby_name)
else:
# A specific lobby member's data was updated
print("Data for member %s in lobby %s has been updated." % [user, lobby])
func _on_persona_change(steam_id_changed: int, flag: int) -> void:
pass
# This can be spammy, but useful for debugging name changes.
# print("Persona state changed for %s. Refreshing lobby members." % steam_id_changed)
get_lobby_members()
func leave_lobby() -> void:
@@ -177,76 +206,80 @@ func leave_lobby() -> void:
func _on_lobby_chat_update(lobby_id_update: int, user_changed_id: int, user_making_change_id: int, chat_state: int):
print("Lobby chat update. Member: %s, State: %s" % [user_changed_id, chat_state])
# A member's state has changed, check what happened
var state_string = "UNKNOWN"
match chat_state:
Steam.CHAT_MEMBER_STATE_CHANGE_ENTERED:
print("User %s entered the lobby." % user_changed_id)
get_lobby_members()
Steam.CHAT_MEMBER_STATE_CHANGE_ENTERED: state_string = "ENTERED"
Steam.CHAT_MEMBER_STATE_CHANGE_LEFT: state_string = "LEFT"
Steam.CHAT_MEMBER_STATE_CHANGE_DISCONNECTED: state_string = "DISCONNECTED"
Steam.CHAT_MEMBER_STATE_CHANGE_KICKED: state_string = "KICKED"
Steam.CHAT_MEMBER_STATE_CHANGE_BANNED: state_string = "BANNED"
Steam.CHAT_MEMBER_STATE_CHANGE_LEFT:
print("User %s left the lobby." % user_changed_id)
get_lobby_members()
print("[Lobby] Chat Update: User %s has %s." % [user_changed_id, state_string])
Steam.CHAT_MEMBER_STATE_CHANGE_DISCONNECTED:
print("User %s disconnected from the lobby." % user_changed_id)
get_lobby_members()
Steam.CHAT_MEMBER_STATE_CHANGE_KICKED:
print("User %s was kicked from the lobby." % user_changed_id)
get_lobby_members()
Steam.CHAT_MEMBER_STATE_CHANGE_BANNED:
print("User %s was banned from the lobby." % user_changed_id)
get_lobby_members()
# Any change in lobby membership should trigger a refresh.
get_lobby_members()
func _on_peer_connected(id: int) -> void:
print("Peer connected: %s" % id)
print("[Multiplayer] ✅ Peer connected: %s" % id)
# It's good practice to re-check lobby members when a peer connects successfully.
get_lobby_members()
func _on_peer_disconnected(id: int) -> void:
print("Peer disconnected: %s" % id)
print("[Multiplayer] ❌ Peer disconnected: %s" % id)
func _on_connected_to_server() -> void:
print("Connected to multiplayer host")
print("[Multiplayer] ✅ Successfully connected to the host.")
print("[Multiplayer] - My Peer ID is now: %s" % multiplayer.get_unique_id())
func _on_connection_failed() -> void:
print("Failed to connect to multiplayer host")
print("[Multiplayer] ❌ Connection to the host failed.")
func _on_server_disconnected() -> void:
print("Disconnected from multiplayer host")
func start_game():
pass
print("[Multiplayer] ❌ Disconnected from the host.")
@rpc("any_peer", "call_local", "reliable")
func start_game_rpc() -> void:
pass
## ADDED: New function to log all relevant multiplayer and lobby information.
func log_multiplayer_info():
print("\n--- DIAGNOSTIC INFO ---")
print("## Multiplayer Status:")
if multiplayer.multiplayer_peer:
print(" - Peer State: Active")
print(" - Connection Status: %s" % get_connection_status_string(multiplayer.get_connection_status()))
print(" - Is Server?: %s" % multiplayer.is_server())
print(" - My Peer ID: %s" % multiplayer.get_unique_id())
print(" - Connected Peer IDs: %s" % multiplayer.get_peer_ids())
else:
print(" - Peer State: Inactive (null)")
print("\n## Steam Lobby Info:")
print(" - In Lobby?: %s" % (lobby_id != 0))
print(" - Lobby ID: %s" % lobby_id)
print(" - Lobby Members Array (%s):" % lobby_members.size())
for member in lobby_members:
print(" - %s (%s)" % [member.steam_name, member.steam_id])
print("-------------------------\n")
## ADDED: Helper function to get a human-readable string for connection status.
func get_connection_status_string(status: int) -> String:
match status:
MultiplayerPeer.CONNECTION_DISCONNECTED: return "Disconnected"
MultiplayerPeer.CONNECTION_CONNECTING: return "Connecting"
MultiplayerPeer.CONNECTION_CONNECTED: return "Connected"
_: return "Unknown Status"
func get_join_fail_reason(response: int) -> String:
match response:
Steam.CHAT_ROOM_ENTER_RESPONSE_DOESNT_EXIST:
return "Lobby no longer exists"
Steam.CHAT_ROOM_ENTER_RESPONSE_NOT_ALLOWED:
return "Not allowed to join"
Steam.CHAT_ROOM_ENTER_RESPONSE_FULL:
return "Lobby is full"
Steam.CHAT_ROOM_ENTER_RESPONSE_ERROR:
return "Unknown error"
Steam.CHAT_ROOM_ENTER_RESPONSE_BANNED:
return "You are banned"
Steam.CHAT_ROOM_ENTER_RESPONSE_LIMITED:
return "Limited account"
Steam.CHAT_ROOM_ENTER_RESPONSE_CLAN_DISABLED:
return "Lobby is locked"
Steam.CHAT_ROOM_ENTER_RESPONSE_COMMUNITY_BAN:
return "Community locked"
Steam.CHAT_ROOM_ENTER_RESPONSE_MEMBER_BLOCKED_YOU:
return "A member blocked you"
Steam.CHAT_ROOM_ENTER_RESPONSE_YOU_BLOCKED_MEMBER:
return "You blocked a member"
_:
return "Unknown reason"
Steam.CHAT_ROOM_ENTER_RESPONSE_DOESNT_EXIST: return "Lobby no longer exists"
Steam.CHAT_ROOM_ENTER_RESPONSE_NOT_ALLOWED: return "Not allowed to join"
Steam.CHAT_ROOM_ENTER_RESPONSE_FULL: return "Lobby is full"
Steam.CHAT_ROOM_ENTER_RESPONSE_ERROR: return "Unknown error"
Steam.CHAT_ROOM_ENTER_RESPONSE_BANNED: return "You are banned"
Steam.CHAT_ROOM_ENTER_RESPONSE_LIMITED: return "Limited account"
Steam.CHAT_ROOM_ENTER_RESPONSE_CLAN_DISABLED: return "Lobby is locked"
Steam.CHAT_ROOM_ENTER_RESPONSE_COMMUNITY_BAN: return "Community locked"
Steam.CHAT_ROOM_ENTER_RESPONSE_MEMBER_BLOCKED_YOU: return "A member blocked you"
Steam.CHAT_ROOM_ENTER_RESPONSE_YOU_BLOCKED_MEMBER: return "You blocked a member"
_: return "Unknown reason"