alai/godot/monitor/Monitor.gd
2022-08-27 18:10:36 -04:00

232 lines
5.9 KiB
GDScript

extends Node
signal monitor_loaded()
export var monitor_enabled: bool = false
export var development_url: String = "http://localhost:4050/api/v1"
var url_real: String = "https://alai.cromer.cl/api/v1"
export var use_development_url: bool = false
onready var url: String = development_url if use_development_url else url_real
var start_time: int = 0
var started: bool = false
var player: Dictionary = {}
var os_id: int = 0
var godot_version: Dictionary = Engine.get_version_info()
var processor_count: int = OS.get_processor_count()
var screen_count: int = OS.get_screen_count()
var screen_dpi: int = OS.get_screen_dpi()
var screen_size: Vector2 = OS.get_screen_size()
var machine_id: String = OS.get_unique_id()
var locale: String = OS.get_locale()
var game_version: String
var frames: Array = []
var coins: int = 0
var points: int = 0
var objects: Array = []
const empty_object: Dictionary = {
"name": "Object Name",
"state": "Object State",
"position_x": 0,
"position_y": 0,
"velocity_x": 0,
"velocity_y": 0
}
const empty_frame: Dictionary = {
"coins": 0,
"points": 0,
"fps": 0,
"elapsed_time": 0,
"objects": [],
}
# The game dictionary holds all data to be sent to the server
var game: Dictionary = {}
func _ready() -> void:
Event.connect("object_created", self, "_object_created")
Event.connect("object_updated", self, "_object_updated")
Event.connect("object_removed", self, "_object_removed")
game_version = get_parent().game_version
player["rut"] = ""
player["name"] = ""
player["email"] = ""
var os_name = OS.get_name()
if os_name == "Android":
os_id = 1
elif os_name == "iOS":
os_id = 2
elif os_name == "HTML5":
os_id = 3
elif os_name == "OSX":
os_id = 4
elif os_name == "Server":
os_id = 5
elif os_name == "Windows":
os_id = 6
elif os_name == "UWP":
os_id = 7
elif os_name == "X11":
os_id = 8
else:
os_id = 0
game["player"] = player
game["level_id"] = 0
game["os_id"] = os_id
game["godot_version"] = godot_version
game["processor_count"] = processor_count
game["machine_id"] = machine_id
game["locale"] = locale
game["screen_count"] = screen_count
game["screen_dpi"] = screen_dpi
game["screen_size"] = screen_size
game["game_version"] = game_version
game["won"] = false
game["timestamp"] = int(Time.get_unix_time_from_system())
game["frames"] = frames
var err = $HTTPRequest.connect("request_completed", self, "_on_request_completed")
if err != OK:
print(err)
err = $MonitorGUI.find_node("Button").connect("input_validated", self, "_on_input_validated")
if err != OK:
print(err)
func _physics_process(_delta: float) -> void:
if monitor_enabled:
if has_node("MonitorGUI") and not $MonitorGUI.visible:
$MonitorGUI.visible = true
emit_signal("monitor_loaded")
if started and not get_tree().paused:
var frame = empty_frame.duplicate(true)
frame["coins"] = coins
frame["points"] = points
frame["fps"] = Engine.get_frames_per_second()
frame["elapsed_time"] = Time.get_ticks_msec() - start_time
var frame_objects = objects.duplicate()
frame["objects"] = frame_objects
frames.append(frame)
if Input.is_action_just_pressed("Send"):
stop_monitor()
send_data()
else:
if Input.is_action_just_pressed("Send"):
start_monitor()
else:
get_tree().paused = false
emit_signal("monitor_loaded")
queue_free()
func _on_input_validated(validated_player: Dictionary) -> void:
$MonitorGUI.queue_free()
get_tree().paused = false
player = validated_player.duplicate(true)
game["player"] = player
func _object_created(name: String, state: String, position: Vector2, velocity: Vector2) -> void:
if monitor_enabled:
add_object(name, state, position, velocity)
func _object_updated(name: String, state: String, position: Vector2, velocity: Vector2) -> void:
if monitor_enabled:
remove_object(name)
add_object(name, state, position, velocity)
func _object_removed(name: String) -> void:
if monitor_enabled:
remove_object(name)
func start_monitor() -> void:
frames.clear()
game["level_id"] = 2 # PrototypeR
game["won"] = false
game["timestamp"] = int(Time.get_unix_time_from_system())
start_time = Time.get_ticks_msec()
started = true
func stop_monitor() -> void:
started = false
func add_object(name: String, state: String, position: Vector2, velocity: Vector2) -> void:
var object = empty_object.duplicate(true)
object["name"] = name
object["state"] = state
object["position_x"] = position.x
object["position_y"] = position.y
object["velocity_x"] = velocity.x
object["velocity_y"] = velocity.y
objects.append(object)
func remove_object(name: String) -> void:
for i in range(0, objects.size()):
if objects[i]["name"] == name:
objects.remove(i)
func _on_coin_update(amount: int) -> void:
coins = coins + amount
func _on_request_completed(result: int, response_code: int, headers: PoolStringArray, body: PoolByteArray) -> void:
if result != HTTPRequest.RESULT_SUCCESS:
print_debug("Error: Failed to connect with error code: " + str(result))
return
if response_code != HTTPClient.RESPONSE_OK:
print_debug("Error: Failed response with error code: " + str(response_code))
print_debug(headers)
if body.size() > 0:
var json = JSON.parse(body.get_string_from_utf8())
print_debug(JSON.print(json.result, "\t"))
func send_data() -> void:
var json = JSON.print(game)
var headers = ["Content-Type: application/json", "Content-Encoding: gzip", "Content-Transfer-Encoding: base64"]
var body = compress_payload(json)
print("JSON B: " + String(json.length()))
print("JSON MB: " + String(json.length() / pow(2, 20)))
print("Body B: " + String(body.length()))
print("Body MB: " + String(body.length() / pow(2, 20)))
$HTTPRequest.request(url + "/game", headers, false, HTTPClient.METHOD_POST, body)
func compress_payload(payload: String) -> String:
var bytes = payload.to_utf8()
var compressed = bytes.compress(File.COMPRESSION_GZIP)
var new_payload = Marshalls.raw_to_base64(compressed)
return new_payload