chess - online multiplayer chess game (note server currently down)


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68

extends Node
class_name Network

var ws := WebSocketClient.new()

var connected := false

signal game_over(problem, isok)
signal connection_established

const url := "wss://gd-chess-server.herokuapp.com/"


func _ready():
	SaveLoad.save_string("user://network_log.log", "")  # overwrite last log


func open() -> void:
	ws.connect_to_url(url)
	ws.connect("connection_established", self, "_connection_established")
	ws.connect("connection_closed", self, "_connection_closed")
	ws.connect("connection_error", self, "_connection_error")
	ws.connect("data_received", self, "_data_recieved")
	Log.net("OPEN NETWORK: " + url)


func close() -> void:
	ws.disconnect_from_host(0, "Close")


func _connection_established(_protocol) -> void:
	Log.net("CONNECTED TO %s" % url)
	emit_signal("connection_established")  # bubble the signal up
	connected = true


func _connection_closed(_was_clean_closed) -> void:
	connected = false
	Log.net("DISCONNECTED FROM %s" % url)
	Log.err("Connection closed")
	emit_signal("game_over", "Connection closed", false)


func _connection_error() -> void:
	connected = false
	Log.err("Connection error")
	Log.net("DISCONNECTED FROM %s" % url)
	emit_signal("game_over", "Connection error", false)


func _data_recieved():
	pass


func _process(_delta: float) -> void:
	var wsstatus := ws.get_connection_status()
	if wsstatus == ws.CONNECTION_CONNECTING or wsstatus == ws.CONNECTION_CONNECTED:
		ws.poll()


func send_packet(variant, header: String) -> void:
	var pckt = {header = header, data = variant}
	if ws.get_peer(1).is_connected_to_host():
		ws.get_peer(1).put_var(pckt)
		Log.net("SENT: %s" % pckt)
	else:
		Log.err("not connected to server: packet %s not sent" % pckt)
		Log.net("FAILED SEND: %s" % pckt)