init public repo
This commit is contained in:
Lurkars
@@ -0,0 +1,44 @@
|
||||
extends Node
|
||||
|
||||
signal connection_failed()
|
||||
signal connection_succeeded()
|
||||
signal server_disconnected()
|
||||
|
||||
|
||||
func join_game(ip, port:int):
|
||||
get_tree().connect("connected_to_server", self, "_connected_ok")
|
||||
get_tree().connect("connection_failed", self, "_connected_fail")
|
||||
get_tree().connect("server_disconnected", self, "_server_disconnected")
|
||||
gamestate.connect("game_ended",self,"_game_ended")
|
||||
var host = NetworkedMultiplayerENet.new()
|
||||
host.create_client(ip, port)
|
||||
get_tree().set_network_peer(host)
|
||||
|
||||
|
||||
func _connected_ok():
|
||||
gamestate.rpc("set_player", get_tree().get_network_unique_id())
|
||||
emit_signal("connection_succeeded")
|
||||
|
||||
|
||||
func _connected_fail():
|
||||
get_tree().disconnect("connected_to_server", self, "_connected_ok")
|
||||
get_tree().disconnect("connection_failed", self, "_connected_fail")
|
||||
get_tree().disconnect("server_disconnected", self, "_server_disconnected")
|
||||
get_tree().set_network_peer(null)
|
||||
emit_signal("connection_failed")
|
||||
|
||||
|
||||
func _server_disconnected():
|
||||
gamestate.quit_game()
|
||||
emit_signal("server_disconnected")
|
||||
|
||||
|
||||
func _game_ended():
|
||||
get_tree().disconnect("connected_to_server", self, "_connected_ok")
|
||||
get_tree().disconnect("connection_failed", self, "_connected_fail")
|
||||
get_tree().disconnect("server_disconnected", self, "_server_disconnected")
|
||||
|
||||
gamestate.disconnect("game_ended",self,"_game_ended")
|
||||
|
||||
get_tree().set_refuse_new_network_connections(false)
|
||||
get_tree().set_network_peer(null)
|
||||
@@ -0,0 +1,14 @@
|
||||
extends Spatial
|
||||
|
||||
class_name GameServer
|
||||
|
||||
const SERVER_ADDR = "mur-server.lh8.de"
|
||||
const API_ADDR = "https://" + SERVER_ADDR + "/"
|
||||
const HEADERS = ["Content-Type: application/json"]
|
||||
const SSL = false
|
||||
|
||||
|
||||
func http():
|
||||
var game_server_requests = GameServerRequests.new()
|
||||
add_child(game_server_requests)
|
||||
return game_server_requests
|
||||
@@ -0,0 +1,35 @@
|
||||
extends Spatial
|
||||
|
||||
class_name GameServerRequests
|
||||
|
||||
var http:HTTPRequest
|
||||
|
||||
|
||||
func _ready():
|
||||
http = HTTPRequest.new()
|
||||
add_child(http)
|
||||
http.connect("request_completed",self, "_self_destroy")
|
||||
|
||||
|
||||
func connect_http(node,function):
|
||||
http.connect("request_completed",node,function)
|
||||
|
||||
|
||||
func get_request(path:String):
|
||||
http.request(game_server.API_ADDR + path, game_server.HEADERS, game_server.SSL, HTTPClient.METHOD_GET)
|
||||
|
||||
|
||||
func post_request(path:String, data:String = ""):
|
||||
http.request(game_server.API_ADDR + path, game_server.HEADERS, game_server.SSL, HTTPClient.METHOD_POST, data)
|
||||
|
||||
|
||||
func put_request(path:String, data:String = ""):
|
||||
http.request(game_server.API_ADDR + path, game_server.HEADERS, game_server.SSL, HTTPClient.METHOD_PUT, data)
|
||||
|
||||
|
||||
func delete_request(path:String, data:String = ""):
|
||||
http.request(game_server.API_ADDR + path, game_server.HEADERS, game_server.SSL, HTTPClient.METHOD_DELETE, data)
|
||||
|
||||
|
||||
func _self_destroy(result, response_code, headers, body):
|
||||
queue_free()
|
||||
@@ -0,0 +1,157 @@
|
||||
extends Node
|
||||
|
||||
const MAX_PEERS = 4
|
||||
const LOBBY_READY_WAIT_TIME = 3
|
||||
const EMPTY_WAIT_TIME = 30
|
||||
|
||||
var port:int = -1
|
||||
var dedicated_server:bool = false
|
||||
var server_secret:String = ""
|
||||
var server_id:String = "[GAME:-1] "
|
||||
|
||||
var timer:Timer
|
||||
|
||||
signal server_error(type, data)
|
||||
|
||||
|
||||
func _ready():
|
||||
for argument in OS.get_cmdline_args():
|
||||
if argument.split("=")[0] == "--port":
|
||||
dedicated_server = true
|
||||
port = int(argument.split("=")[1])
|
||||
if argument.split("=")[0] == "--server-id":
|
||||
server_id = "[GAME:" + str(argument.split("=")[1]) + "] "
|
||||
if argument.split("=")[0] == "--secret":
|
||||
server_secret=argument.split("=")[1]
|
||||
if argument.split("=")[0] == "--bots":
|
||||
gamestate.set_bots(bool(int(argument.split("=")[1])))
|
||||
|
||||
if dedicated_server:
|
||||
var err = host_game(port)
|
||||
if err == OK:
|
||||
print(server_id + "New game hosted: port=" + str(port) + " secret=" + str(server_secret) + " bots=" + str(gamestate.bots))
|
||||
else:
|
||||
print(server_id + "Could not create Server! (port=" + str(port) + " secret=" + str(server_secret) + ")")
|
||||
quit_server()
|
||||
|
||||
|
||||
func host_game(port:int, set_bots:bool = false):
|
||||
var host = NetworkedMultiplayerENet.new()
|
||||
var err = host.create_server(port, MAX_PEERS)
|
||||
get_tree().set_network_peer(host)
|
||||
|
||||
get_tree().connect("network_peer_connected", self, "_client_connected")
|
||||
get_tree().connect("network_peer_disconnected", self,"_client_disconnected")
|
||||
|
||||
gamestate.connect("players_changed",self,"_players_changed")
|
||||
gamestate.connect("game_ready",self,"_game_ready")
|
||||
gamestate.connect("game_ended",self,"_game_ended")
|
||||
|
||||
if set_bots:
|
||||
gamestate.bots = true
|
||||
|
||||
if timer == null:
|
||||
timer = Timer.new()
|
||||
timer.set_name("timer")
|
||||
timer.set_timer_process_mode(Timer.TIMER_PROCESS_PHYSICS)
|
||||
timer.set_one_shot(true)
|
||||
timer.set_autostart(false)
|
||||
add_child(timer)
|
||||
|
||||
if err != OK:
|
||||
emit_signal("server_error", "HOST", err)
|
||||
|
||||
return err
|
||||
|
||||
|
||||
func local_game(name:String, color:Color, bots:bool):
|
||||
var localhost = NetworkedMultiplayerENet.new()
|
||||
localhost.create_server(0, 0)
|
||||
get_tree().set_network_peer(localhost)
|
||||
gamestate.bots = bots
|
||||
gamestate.set_player(get_tree().get_network_unique_id(), name, color)
|
||||
gamestate.prepare_game()
|
||||
gamestate.post_start_game()
|
||||
|
||||
|
||||
func update_server_data():
|
||||
var req = game_server.http()
|
||||
req.put_request("game",to_json({'secret' : server_secret, 'player_count' : gamestate.players.size(), 'running' : gamestate.game_running}))
|
||||
|
||||
func _client_connected(id):
|
||||
if get_tree().is_network_server():
|
||||
if dedicated_server:
|
||||
print(server_id + "peer connected: " + str(id))
|
||||
gamestate.rpc_id(id, "set_bots" ,gamestate.bots)
|
||||
if not timer.is_stopped():
|
||||
timer.disconnect("timeout",self,"quit_server")
|
||||
timer.stop()
|
||||
|
||||
|
||||
func _client_disconnected(id):
|
||||
if get_tree().is_network_server():
|
||||
if dedicated_server:
|
||||
print(server_id + "peer disconnected: " + str(id))
|
||||
if gamestate.game_running:
|
||||
emit_signal("server_error", "DISCONNECTED", [id])
|
||||
gamestate.rpc("remove_player" ,id)
|
||||
else:
|
||||
gamestate.rpc("remove_player" ,id)
|
||||
|
||||
|
||||
func _players_changed(players):
|
||||
if get_tree().is_network_server():
|
||||
if dedicated_server:
|
||||
update_server_data()
|
||||
if players.empty():
|
||||
if gamestate.game_running:
|
||||
print(server_id + "All players disconnected, close server.")
|
||||
quit_server()
|
||||
else:
|
||||
print(server_id + "All players disconnected, wait for closing...")
|
||||
timer.set_wait_time(EMPTY_WAIT_TIME)
|
||||
timer.connect("timeout",self,"quit_server",[true])
|
||||
timer.start()
|
||||
|
||||
|
||||
func quit_server(triggered:bool = false):
|
||||
if dedicated_server && triggered:
|
||||
print(server_id + "Closing time over...quit")
|
||||
var req = game_server.http()
|
||||
req.connect_http(self,"_on_delete_server")
|
||||
req.delete_request("game",to_json({'secret' : server_secret}))
|
||||
|
||||
|
||||
func _on_delete_server(result, response_code, headers, body):
|
||||
if result != OK || response_code != HTTPClient.RESPONSE_OK:
|
||||
print(server_id + "ERROR: _on_delete_server, server might be in undefined state!")
|
||||
get_tree().quit()
|
||||
|
||||
|
||||
func _start_game():
|
||||
if get_tree().is_network_server():
|
||||
get_tree().set_refuse_new_network_connections(true)
|
||||
gamestate.rpc("prepare_game")
|
||||
|
||||
|
||||
func _game_ready(all_ready):
|
||||
if get_tree().is_network_server():
|
||||
if all_ready:
|
||||
timer.set_wait_time(LOBBY_READY_WAIT_TIME)
|
||||
timer.connect("timeout",self,"_start_game")
|
||||
timer.start()
|
||||
else:
|
||||
timer.disconnect("timeout",self,"_start_game")
|
||||
timer.stop()
|
||||
|
||||
|
||||
func _game_ended():
|
||||
get_tree().disconnect("network_peer_connected", self, "_client_connected")
|
||||
get_tree().disconnect("network_peer_disconnected", self,"_client_disconnected")
|
||||
|
||||
gamestate.disconnect("players_changed",self,"_players_changed")
|
||||
gamestate.disconnect("game_ready",self,"_game_ready")
|
||||
gamestate.disconnect("game_ended",self,"_game_ended")
|
||||
|
||||
get_tree().set_refuse_new_network_connections(false)
|
||||
get_tree().set_network_peer(null)
|
||||
Reference in New Issue
Block a user