120 lines
3.5 KiB
GDScript
120 lines
3.5 KiB
GDScript
extends Node
|
|
|
|
var peer = ENetMultiplayerPeer.new()
|
|
var connected_peers = []
|
|
|
|
func create_server(port, maxPlayers):
|
|
peer.close()
|
|
var result = peer.create_server(port, maxPlayers) # Second paramater specifies the player limit. Can be anything between 1 and 4095
|
|
multiplayer.multiplayer_peer = peer
|
|
prints("Creating server result:", result)
|
|
if result == OK:
|
|
print("Server should be listening on port: ", port)
|
|
elif result == ERR_ALREADY_IN_USE:
|
|
printerr("Port is being used by something else!")
|
|
else:
|
|
printerr("Server can't start, and idk the problem")
|
|
|
|
|
|
peer.peer_connected.connect(
|
|
func(new_peer_id):
|
|
await get_tree().create_timer(0.5).timeout ## REQUIRED, THE RPC IS MADE BEFORE THE CLIENT IS FULLY CONNECTED
|
|
if connected_peers.has(new_peer_id):
|
|
print("CONFLICT ID FOUND")
|
|
return
|
|
else:
|
|
print("NEW CONNECTION FROM ", new_peer_id)
|
|
rpc_id(new_peer_id, "sync_mapPath", Global.currentMapPath)
|
|
rpc_id(new_peer_id, "sync_names", Global.connectedPlayers)
|
|
rpc_id(new_peer_id, "sync_respawn_speed", Global.respawnTimeModifier)
|
|
rpc_id(new_peer_id, "sync_gamemode", Global.gamemode)
|
|
rpc_id(new_peer_id, "sync_mapName", Global.mapName)
|
|
rpc_id(new_peer_id, "sync_roundTimer", Global.roundTimer)
|
|
rpc("add_newly_connected_player_character", new_peer_id)
|
|
rpc_id(new_peer_id, "add_previously_connected_player_characters", connected_peers)
|
|
add_player_node(new_peer_id)
|
|
)
|
|
|
|
### NOT WORKING YET
|
|
peer.peer_disconnected.connect(
|
|
func(peer_id):
|
|
rpc("disconnect_peer", peer_id)
|
|
)
|
|
|
|
|
|
func load_map(map):
|
|
Global.multiplayerCurrent = true
|
|
get_tree().change_scene_to_file(map)
|
|
|
|
@rpc
|
|
func add_newly_connected_player_character(new_peer_id):
|
|
print("Connected to server!")
|
|
if Global.teddyAuthorityID == null:
|
|
load_map(Global.currentMapPath)
|
|
Input.set_mouse_mode(Input.MOUSE_MODE_CAPTURED)
|
|
add_player_node(new_peer_id)
|
|
|
|
|
|
func add_player_node(peer_id):
|
|
connected_peers.append(peer_id)
|
|
Global.connectedPlayersByPeerID = connected_peers
|
|
var player_character = preload("res://scenes/Teddy.tscn").instantiate()
|
|
player_character.set_multiplayer_authority(peer_id)
|
|
await get_tree().create_timer(0.5).timeout
|
|
Global.currentMapNode.add_child(player_character)
|
|
player_character.position.y = 10
|
|
|
|
@rpc
|
|
func add_previously_connected_player_characters(peer_ids):
|
|
await get_tree().create_timer(0.5).timeout
|
|
for peer_id in peer_ids:
|
|
add_player_node(peer_id)
|
|
|
|
@rpc
|
|
func disconnect_peer(peer_id):
|
|
peer_id.queue_free()
|
|
print(peer_id, " has disconnected!")
|
|
|
|
@rpc("any_peer", "reliable")
|
|
func sync_names(connectedPlayers):
|
|
Global.connectedPlayers = connectedPlayers
|
|
rpc("sync_name_all_peers", Global.playerName)
|
|
sync_name_all_peers(Global.playerName)
|
|
|
|
@rpc("any_peer", "reliable")
|
|
func sync_name_all_peers(name):
|
|
Global.connectedPlayers += [name]
|
|
print(Global.connectedPlayers)
|
|
|
|
@rpc("any_peer", "reliable")
|
|
func sync_respawn_speed(speed):
|
|
Global.respawnTimeModifier = speed
|
|
|
|
@rpc("any_peer", "reliable")
|
|
func sync_gamemode(gamemode):
|
|
Global.gamemode = gamemode
|
|
|
|
@rpc("any_peer", "reliable")
|
|
func sync_mapName(map):
|
|
Global.mapName = map
|
|
|
|
@rpc("any_peer", "reliable")
|
|
func sync_mapPath(path):
|
|
Global.currentMapPath = path
|
|
|
|
@rpc("any_peer", "reliable")
|
|
func sync_roundTimer(time):
|
|
Global.roundTimer = time
|
|
|
|
@rpc("any_peer", "reliable")
|
|
func check_name(name): # Returns true if it finds a matching name
|
|
for i in range(Global.connectedPlayers.size()):
|
|
if Global.playerName == Global.connectedPlayers[i]:
|
|
return true
|
|
else:
|
|
return false
|
|
|
|
@rpc("any_peer", "reliable")
|
|
func check_round_status(status):
|
|
pass
|
|
return true
|