Initial commit.

Services/Old/ConnectionService.gd

@@ -0,0 +1,74 @@
+extends Node
+
+var ConsoleService
+var NetworkService
+
+func _ready():
+	NetworkService = $"/root/NetworkService"
+	ConsoleService = $"/root/ConsoleService"
+	NetworkService.connect("on_client_connected", self, "on_client_connected")
+	NetworkService.connect("on_server_connected", self, "on_server_connected")
+	NetworkService.connect("on_server_disconnected", self, "on_server_disconnected")
+
+func on_client_connected(id: int):
+	if NetworkService.NETWORK_MODE == 'server':
+		var server_mods = get_local_mods()
+		rpc_id(id, "compute_needed_mods", server_mods)
+		
+func get_local_mods():
+	var md5_hashes = []
+	for mod_desc in ModService.mod_arr:
+		if not mod_desc.md5: continue
+		md5_hashes.push_back(mod_desc.md5)
+	return md5_hashes
+
+remote func send_mods_to_client(id: int, needed_mods: Array):
+	var ModService = $"/root/ModService"
+	for mod_desc in ModService.mod_arr:
+		if not needed_mods.has(mod_desc.md5):
+			continue
+		if mod_desc.type != 'zip':
+			continue
+		var mod_file = File.new()
+		mod_file.open(mod_desc.path, 1)
+		var file_length = mod_file.get_len()
+		var bytes = mod_file.get_buffer(file_length)
+		ConsoleService.log("Sending mod "+mod_desc.name+" with size: "+String(bytes.size()/1000000)+"MB")
+		rpc_id(id, "receive_mod", mod_desc.name, bytes)
+
+remote func compute_needed_mods(server_mods: Array):
+	var needed_mods_md5 = server_mods
+	var dir = Directory.new()
+	var err = dir.make_dir_recursive('user://servers/'+NetworkService.server_hash+'/mods')
+	var mod_dir_exists = dir.open('user://servers/'+NetworkService.server_hash+'/mods')
+	dir.list_dir_begin()
+
+	while true:
+		var file = dir.get_next()
+		var basename = file.get_basename()
+		if file == "":
+			break
+		if file.ends_with(".zip") and server_mods.has(basename):
+			needed_mods_md5.erase(basename)
+
+	dir.list_dir_end()
+	
+	rpc_id(1, 'send_mods_to_client', get_tree().get_network_unique_id(), needed_mods_md5)
+
+remote func receive_mod(name: String, bytes: PoolByteArray):
+	ConsoleService.log("Receiving mod "+name+" with size: "+String(bytes.size()/1000000)+"MB")
+	var file_path = 'user://servers/'+NetworkService.server_hash+'/mods/'+name+'.zip'
+	var dir_path = file_path.get_base_dir()
+	var mod_file = File.new()
+	var dir = Directory.new()
+	var err = dir.make_dir_recursive(dir_path)
+	mod_file.open(file_path, 2)
+	mod_file.store_buffer(bytes)
+	mod_file.close()
+	dir.rename(file_path, dir_path+'/'+mod_file.get_md5(file_path)+'.zip')
+
+func on_server_connected():
+	pass
+	
+func on_server_disconnected():
+	pass

Services/Old/ModService.gd

@@ -0,0 +1,122 @@
+extends Node
+
+var ConsoleService
+
+var data_path = "."
+var mod_dict = {}
+var mod_arr = []
+var mod_instances = {}
+
+func _ready():
+	ConsoleService = $"/root/ConsoleService"
+
+# Locate all mods that can be loaded for the given game.
+func find_local_mods():
+	var dir = Directory.new()
+
+	var mod_dir_exists = dir.open(data_path + "/mods")
+	if (mod_dir_exists != 0):
+		dir.change_dir(data_path)
+		dir.make_dir("mods")
+		dir.change_dir(data_path + "/mods")
+
+	dir.list_dir_begin()
+
+	while true:
+		var file = dir.get_next()
+		var basename = file.get_basename()
+		if file == "":
+			break
+		elif file.ends_with(".zip"):
+			var mod_desc = {
+				"name": basename,
+				"path": data_path + "/mods/" + file,
+				"md5": File.new().get_md5(data_path + "/mods/" + file),
+				"type": "zip"
+			}
+			mod_arr.append(mod_desc)
+			mod_dict[mod_desc.name] = mod_desc
+		elif dir.file_exists(basename+"/main.gd"):
+			var mod_desc = {
+				"name": basename,
+				"path": data_path + "/mods/" + file,
+				"md5": null,
+				"type": "folder"
+			}
+			mod_arr.append(mod_desc)
+			mod_dict[mod_desc.name] = mod_desc
+
+	dir.list_dir_end()
+
+# Prepare initial instances of mods for preprocessing. Used to determine mod dependencies and configuration
+# Prior to final loading and initialization.
+func preload_instances():
+	if mod_arr.size() == 0:
+		ConsoleService.error("[ModService] No mods found (Run find_local_mods and download_server_mods first)")
+		return
+
+	for mod_desc in mod_arr:
+		mod_instances[mod_desc.name] = _get_mod_instance(mod_desc)
+		if !mod_instances[mod_desc.name]:
+			ConsoleService.error("[ModService] Failed to load mod '"+mod_desc.name+"'")
+
+func compute_dependency_graph():
+	if mod_instances.size() == 0:
+		ConsoleService.error("[ModService] Mods have not been preloaded (Run preload_instances first)")
+		return
+
+	var resolved = []; # Properly ordered mod list.
+	for mod_desc in mod_arr:
+		_resolve_dependency(mod_desc, resolved, [])
+
+	return resolved
+
+func _resolve_dependency(mod_desc: Dictionary, resolved: Array, unresolved: Array):
+	if mod_desc in resolved:
+		return
+	# Seen is used to prevent
+	unresolved.append(mod_desc)
+	if not "dependencies" in mod_instances[mod_desc.name]:
+		resolved.append(mod_desc)
+		unresolved.erase(mod_desc)
+		return
+
+	var deps = mod_instances[mod_desc.name].dependencies
+	for dep in deps:
+		var dep_desc = mod_dict[dep]
+		if not dep_desc in resolved:
+			if dep_desc in unresolved:
+				ConsoleService.error("[ModService] Circular dependency between '"+mod_desc.name+"' <-> '"+dep+"'")
+				assert(false)
+			if not dep in mod_instances:
+				ConsoleService.error("[ModService] Mod '"+mod_desc.name+"' requires mod '"+dep+"' to be installed, but it is not")
+				assert(false)
+			_resolve_dependency(dep_desc, resolved, unresolved)
+	resolved.append(mod_desc)
+	unresolved.erase(mod_desc)
+	
+func load_mods():
+	if mod_arr.size() == 0:
+		print("[ModService] No mods found (Run find_mods first)")
+		return
+
+	for mod_desc in mod_arr:
+		var mod_instance = _get_mod_instance(mod_desc)
+		mod_instances[mod_desc.name] = mod_instance
+		if !mod_instance:
+			ConsoleService.log("[ModService] Failed to load mod '"+mod_desc.name+"'")
+			continue
+		
+		$"/root/Main/Mods".add_child(mod_instance)
+		if mod_instance.has_method('init'):
+			mod_instance.init()
+
+func _get_mod_instance(mod_desc: Dictionary):
+	if mod_desc.type == 'zip':
+		ProjectSettings.load_resource_pack(mod_desc.path, true)
+	
+	var mod_script = load("res://mods/"+mod_desc.name+"/main.gd");
+	if !mod_script:
+		return
+	var mod_instance = mod_script.new()
+	return mod_instance