And once again
This commit is contained in:
26
scenes_old_2/utils/camera_mount/camera_mount.gd
Normal file
26
scenes_old_2/utils/camera_mount/camera_mount.gd
Normal file
@ -0,0 +1,26 @@
|
||||
extends Node3D
|
||||
class_name CameraMount
|
||||
|
||||
# -- When camera mount is not active, client shouldn't connect to it
|
||||
@export var active: bool = false
|
||||
@export var default: bool = false
|
||||
@export var accept_input: bool = false
|
||||
|
||||
var camera: Camera3D
|
||||
|
||||
|
||||
# Called when the node enters the scene tree for the first time.
|
||||
func _ready() -> void:
|
||||
camera = Camera3D.new()
|
||||
add_child(camera)
|
||||
|
||||
|
||||
@rpc("any_peer", "call_local", "reliable")
|
||||
func connect_to_camera() -> void:
|
||||
if active:
|
||||
camera.make_current()
|
||||
|
||||
|
||||
# Called every frame. 'delta' is the elapsed time since the previous frame.
|
||||
func _process(delta: float) -> void:
|
||||
pass
|
6
scenes_old_2/utils/camera_mount/camera_mount.tscn
Normal file
6
scenes_old_2/utils/camera_mount/camera_mount.tscn
Normal file
@ -0,0 +1,6 @@
|
||||
[gd_scene load_steps=2 format=3 uid="uid://316q8oy76ev1"]
|
||||
|
||||
[ext_resource type="Script" path="res://scenes/utils/camera_mount/camera_mount.gd" id="1_5dtrj"]
|
||||
|
||||
[node name="CameraMount" type="Node3D"]
|
||||
script = ExtResource("1_5dtrj")
|
28
scenes_old_2/utils/client_node/client_node.gd
Normal file
28
scenes_old_2/utils/client_node/client_node.gd
Normal file
@ -0,0 +1,28 @@
|
||||
extends Node3D
|
||||
class_name ClientNode
|
||||
|
||||
@export var is_connected_to_camera: bool = false
|
||||
|
||||
var available_cameras: Array[CameraMount] = []
|
||||
|
||||
|
||||
# Called every frame. 'delta' is the elapsed time since the previous frame.
|
||||
func _physics_process(delta: float) -> void:
|
||||
if not is_connected_to_camera:
|
||||
var game_root := helpers.get_root_node()
|
||||
var available_cameras_raw: Array[Node] = game_root.find_children(
|
||||
"*", "CameraMount", true, false
|
||||
)
|
||||
for camera_raw in available_cameras_raw:
|
||||
var camera: CameraMount = camera_raw as CameraMount
|
||||
if camera.active:
|
||||
if camera.accept_input:
|
||||
camera.connect_to_camera()
|
||||
break
|
||||
camera.connect_to_camera()
|
||||
available_cameras.append(camera)
|
||||
|
||||
|
||||
@rpc("authority", "reliable", "call_local")
|
||||
func force_camera_attachment(camera_mount: CameraMount) -> void:
|
||||
camera_mount.connect_to_camera()
|
6
scenes_old_2/utils/client_node/client_node.tscn
Normal file
6
scenes_old_2/utils/client_node/client_node.tscn
Normal file
@ -0,0 +1,6 @@
|
||||
[gd_scene load_steps=2 format=3 uid="uid://b4y8gnogfoulk"]
|
||||
|
||||
[ext_resource type="Script" path="res://scenes/utils/client_node/client_node.gd" id="1_otqq8"]
|
||||
|
||||
[node name="ClientNode" type="Node3D"]
|
||||
script = ExtResource("1_otqq8")
|
160
scenes_old_2/utils/game_root/game_root.gd
Normal file
160
scenes_old_2/utils/game_root/game_root.gd
Normal file
@ -0,0 +1,160 @@
|
||||
class_name GameRoot extends Node
|
||||
|
||||
signal load_map(name: String)
|
||||
|
||||
const MAIN_MENU_SCENE := "res://scenes/interface/main_menu/main_menu.tscn"
|
||||
const SERVER_DATA_NODE := "res://scenes/utils/server_data/server_data.tscn"
|
||||
|
||||
# -- config from args
|
||||
var config_file: String = ""
|
||||
|
||||
|
||||
@onready var level_root: Node3D = $Level
|
||||
@onready var utils_root: Node = $Utils
|
||||
|
||||
func _parse_args() -> void:
|
||||
var args := Array(OS.get_cmdline_args())
|
||||
|
||||
var config_arg: String = "--config"
|
||||
if args.has(config_arg):
|
||||
var index := args.find(config_arg)
|
||||
config_file = args[index + 1]
|
||||
|
||||
|
||||
# Called when the node enters the scene tree for the first time.
|
||||
func _ready() -> void:
|
||||
_parse_args()
|
||||
var err: Error
|
||||
|
||||
if err != OK:
|
||||
logger.error("Couldn't load utils node")
|
||||
return
|
||||
if OS.has_feature("dedicated_server") or DisplayServer.get_name() == "headless":
|
||||
err = _start_dedicated_server()
|
||||
if err != OK:
|
||||
logger.error("couldn't start the server, err is " + str(err))
|
||||
else:
|
||||
err = _start_game()
|
||||
if err != OK:
|
||||
logger.error("couldn't start the game, err is " + str(err))
|
||||
multiplayer.peer_connected.connect(_on_player_connected)
|
||||
multiplayer.peer_disconnected.connect(_on_player_disconnected)
|
||||
multiplayer.connected_to_server.connect(_on_connected_to_server)
|
||||
|
||||
|
||||
func _on_player_disconnected(id) -> void:
|
||||
logger.info("player is disconnected with id: " + str(id))
|
||||
|
||||
|
||||
func _on_player_connected(id) -> void:
|
||||
# Send the client information about the server
|
||||
if multiplayer.is_server():
|
||||
logger.info("player is connected with id: " + str(id))
|
||||
_sync_map_from_server.rpc_id(id)
|
||||
|
||||
|
||||
@rpc("authority", "reliable", "call_remote")
|
||||
func _sync_map_from_server() -> void:
|
||||
var server_node := helpers.get_server_node()
|
||||
load_map.emit(server_node.current_map)
|
||||
|
||||
|
||||
func _on_connected_to_server() -> void:
|
||||
logger.info("connection is successful, sending info")
|
||||
register_player.rpc_id(1, multiplayer.get_unique_id(), "client")
|
||||
|
||||
|
||||
@rpc("any_peer", "reliable", "call_remote")
|
||||
func register_player(id: int, name: String):
|
||||
logger.info("registering player: " + str(id))
|
||||
if multiplayer.is_server():
|
||||
var player_data := PlayerData.new()
|
||||
player_data.id = id
|
||||
player_data.username = name
|
||||
player_data.active = true
|
||||
var server_node: ServerData = helpers.get_server_node()
|
||||
server_node.players[id] = helpers.player_data_into_dict(player_data)
|
||||
logger.info("player " + str(id) + " is registered")
|
||||
else:
|
||||
logger.debug("register player is supposed to be executed on the server")
|
||||
|
||||
|
||||
func _start_dedicated_server() -> Error:
|
||||
if config_file != "":
|
||||
logger.info("reading config from the file: " + config_file)
|
||||
logger.info("starting in the dedicated server mode")
|
||||
return OK
|
||||
|
||||
|
||||
func _start_game() -> Error:
|
||||
logger.info("starting in the game mode")
|
||||
|
||||
if not ResourceLoader.exists(MAIN_MENU_SCENE):
|
||||
return ERR_DOES_NOT_EXIST
|
||||
var scene: PackedScene = ResourceLoader.load(MAIN_MENU_SCENE)
|
||||
if not scene.can_instantiate():
|
||||
return ERR_CANT_OPEN
|
||||
|
||||
var node: MainMenu = scene.instantiate()
|
||||
add_child(node)
|
||||
return OK
|
||||
|
||||
|
||||
func _load_utils() -> Error:
|
||||
if not ResourceLoader.exists(SERVER_DATA_NODE):
|
||||
return ERR_DOES_NOT_EXIST
|
||||
var scene: PackedScene = ResourceLoader.load(SERVER_DATA_NODE)
|
||||
if not scene.can_instantiate():
|
||||
return ERR_CANT_OPEN
|
||||
|
||||
var node: ServerData = scene.instantiate()
|
||||
utils_root.add_child(node)
|
||||
return OK
|
||||
|
||||
|
||||
func _on_load_map(map_name: String) -> void:
|
||||
var path_tmpl := "res://scenes/maps/maps/%s"
|
||||
var path := path_tmpl % map_name
|
||||
logger.info("Loading map from " + path)
|
||||
|
||||
if not ResourceLoader.exists(path):
|
||||
logger.error("map " + map_name + " doesn't exist")
|
||||
var scene: PackedScene = ResourceLoader.load(path)
|
||||
if scene.can_instantiate():
|
||||
var node: Node3D = scene.instantiate()
|
||||
logger.info("loading map: " + map_name)
|
||||
for c in level_root.get_children():
|
||||
level_root.remove_child(c)
|
||||
c.queue_free()
|
||||
level_root.add_child(node)
|
||||
else:
|
||||
logger.error("Can't initialize")
|
||||
|
||||
|
||||
func create_server(
|
||||
port: int, player_limit: int, server_only: bool = false, map: String = "lowpoly_tdm_2.tscn"
|
||||
) -> Error:
|
||||
var peer := ENetMultiplayerPeer.new()
|
||||
logger.info("starting a server the port: " + str(port))
|
||||
var err := peer.create_server(port, player_limit)
|
||||
multiplayer.multiplayer_peer = peer
|
||||
if err:
|
||||
return err
|
||||
_load_utils()
|
||||
var server_data: ServerData = helpers.get_server_node()
|
||||
server_data.port = port
|
||||
server_data.player_limit = player_limit
|
||||
server_data.current_map = map
|
||||
if !server_only:
|
||||
register_player(1, "server")
|
||||
return OK
|
||||
|
||||
|
||||
func join_server(ip: String, port: int) -> Error:
|
||||
var peer = ENetMultiplayerPeer.new()
|
||||
logger.info("trying to connect to: " + ip + ":" + str(port))
|
||||
var err = peer.create_client(ip, port)
|
||||
if err != OK:
|
||||
return err
|
||||
multiplayer.multiplayer_peer = peer
|
||||
return OK
|
21
scenes_old_2/utils/game_root/game_root.tscn
Normal file
21
scenes_old_2/utils/game_root/game_root.tscn
Normal file
@ -0,0 +1,21 @@
|
||||
[gd_scene load_steps=3 format=3 uid="uid://f3lbhroreypw"]
|
||||
|
||||
[ext_resource type="Script" path="res://scenes/utils/game_root/game_root.gd" id="1_ogtsj"]
|
||||
[ext_resource type="Script" path="res://scenes/utils/client_node/client_node.gd" id="2_75551"]
|
||||
|
||||
[node name="GameRoot" type="Node"]
|
||||
script = ExtResource("1_ogtsj")
|
||||
|
||||
[node name="ServerDataSpawner" type="MultiplayerSpawner" parent="."]
|
||||
_spawnable_scenes = PackedStringArray("res://scenes/utils/server_data/server_data.tscn")
|
||||
spawn_path = NodePath("../Utils")
|
||||
spawn_limit = 1
|
||||
|
||||
[node name="Utils" type="Node" parent="."]
|
||||
|
||||
[node name="Level" type="Node3D" parent="."]
|
||||
|
||||
[node name="ClientNode" type="Node3D" parent="."]
|
||||
script = ExtResource("2_75551")
|
||||
|
||||
[connection signal="load_map" from="." to="." method="_on_load_map"]
|
21
scenes_old_2/utils/player_data/player_data.gd
Normal file
21
scenes_old_2/utils/player_data/player_data.gd
Normal file
@ -0,0 +1,21 @@
|
||||
class_name PlayerData extends Resource
|
||||
|
||||
@export var id: int = 0
|
||||
@export var username: String = ""
|
||||
|
||||
@export var score: int = 0
|
||||
@export var damage: int = 0
|
||||
@export var headshots: int = 0
|
||||
|
||||
enum Side {
|
||||
BLUE = 0,
|
||||
RED = 1,
|
||||
UNDEFINED = -1,
|
||||
}
|
||||
|
||||
const blue = "attack"
|
||||
const red = "defend"
|
||||
const underfined = "undefined"
|
||||
@export var side: PlayerData.Side = Side.UNDEFINED
|
||||
|
||||
@export var active: bool = false
|
18
scenes_old_2/utils/server_data/server_data.gd
Normal file
18
scenes_old_2/utils/server_data/server_data.gd
Normal file
@ -0,0 +1,18 @@
|
||||
class_name ServerData extends Node
|
||||
|
||||
@export var players: Dictionary = {}
|
||||
@export var port: int = 27015
|
||||
@export var player_limit: int = 30
|
||||
@export var current_map: String = "lowpoly_tdm_2"
|
||||
|
||||
@rpc("any_peer", "reliable", "call_local")
|
||||
func set_player_side(side: String):
|
||||
if multiplayer.is_server():
|
||||
var id: int = multiplayer.get_remote_sender_id()
|
||||
if players.has(id):
|
||||
players[id]["side"] = side
|
||||
|
||||
|
||||
# Called every frame. 'delta' is the elapsed time since the previous frame.
|
||||
func _process(delta: float) -> void:
|
||||
pass
|
17
scenes_old_2/utils/server_data/server_data.tscn
Normal file
17
scenes_old_2/utils/server_data/server_data.tscn
Normal file
@ -0,0 +1,17 @@
|
||||
[gd_scene load_steps=3 format=3 uid="uid://cu6t3m38skton"]
|
||||
|
||||
[ext_resource type="Script" path="res://scenes/utils/server_data/server_data.gd" id="1_o07e3"]
|
||||
|
||||
[sub_resource type="SceneReplicationConfig" id="SceneReplicationConfig_t8y34"]
|
||||
properties/0/path = NodePath(".:players")
|
||||
properties/0/spawn = true
|
||||
properties/0/replication_mode = 1
|
||||
properties/1/path = NodePath(".:current_map")
|
||||
properties/1/spawn = true
|
||||
properties/1/replication_mode = 1
|
||||
|
||||
[node name="ServerData" type="Node"]
|
||||
script = ExtResource("1_o07e3")
|
||||
|
||||
[node name="MultiplayerSynchronizer" type="MultiplayerSynchronizer" parent="."]
|
||||
replication_config = SubResource("SceneReplicationConfig_t8y34")
|
Reference in New Issue
Block a user