123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156 |
- extends Node
- var net = NetworkedMultiplayerENet.new()
- var api = MultiplayerAPI.new()
- var port = 8081
- var maxplayer = 4
- export(NodePath) var database
- func _ready():
- print('listening to port: ' + str(port))
- net.create_server(port, maxplayer)
-
- self.set_custom_multiplayer(api)
- custom_multiplayer.set_root_node(self)
- custom_multiplayer.set_network_peer(net)
-
- net.connect("peer_disconnected",self,"disc")
- net.connect("peer_connected",self,"conn")
- pass # Replace with function body.
- func _process(_delta):
- custom_multiplayer.poll()
- var playerphsyics = preload('res://playerphysics.tscn')
- func conn(id):
- print('client connected, id: ' + str(id))
- yield(get_tree(),"physics_frame")
- rpc_id(0,'ping')
- rpc_id(0,'tokerequest')
- remote func tokenreply(token, username):
- var db = get_parent().get_node('PostgreSQL')
- var data = db.Read('validtokens_database','username',"'"+username+"'")
- var message = 'token validated'
- if data == []:
- message = "no token found"
- if data[0][2] != token:
- message = "token is invalid"
- print('check tokens....')
- print(data)
- print('clients connected: ' + str(custom_multiplayer.get_network_connected_peers().size()))
- var instance = playerphsyics.instance()
- instance.name = str(api.get_rpc_sender_id())
- $players.add_child(instance)
- remote func connected_peer():
- print('syncing clients')
- rpc_id(0,'_On_Peer_Connected')
- func makedummmy():
- var node = api.get_rpc_sender_id()
- $players.get_node(str(node)).add_to_group('dummy')
- remote func send_clients():
- rpc_id(api.get_rpc_sender_id(), 'client_data', custom_multiplayer.get_network_connected_peers())
- # extra
- func disc(arg):
- print('client disconnected, id: ' + str(arg))
- rpc_id(0,'_On_Player_Disconnect',arg)
- remote func latency(arg):
- rpc_id(api.get_rpc_sender_id(), 'returnping', arg)
- remote func input_handler(arg):
- var id = api.get_rpc_sender_id()
- if $players.has_node(str(id)):
- $players.get_node(str(id)).input = arg
- var tick = 0
- export var tickrate = 3
- func _physics_process(delta):
- var position_datachunk = {}
- for i in $players.get_children():
- position_datachunk[i.name] = i.global_position
- rpc_unreliable_id(0, 'player_position', position_datachunk)
-
- var animation_datachunk = {}
- for i in $players.get_children():
- animation_datachunk[i.name] = i.animation
- rpc_unreliable_id(0, 'player_animation', animation_datachunk)
-
- # tick += 1
- # if fmod(tick,tickrate) == 0:
- # var enemies_datachunk = PoolByteArray()
- # for i in $enemies.dict.arraypos.size():
- # if $enemies.dict.arrayvida[i] > 0:
- # var pos = $enemies.dict.arraypos[i]
- # enemies_datachunk.append_array( return_int16(pos.x) )
- # enemies_datachunk.append_array( return_int16(pos.y) )
- # var bytetest : PoolByteArray
- # bytetest.append($enemies.dict.type[i] )
- # enemies_datachunk.append_array( bytetest )
- # rpc_unreliable_id(0, 'enemies_position_2', enemies_datachunk)
- func return_int16(number):
- var int16 = number + 32768
- var bytetest : PoolByteArray
- var byte1:int = int(int16/255)
- var byte2:int = int(fmod(int16,255))
- bytetest.append(byte1)
- bytetest.append(byte2)
- return bytetest
- func player_anim(attack,arg):
- rpc_id( 0,'attack_anim', attack, int(arg) )
- func hp_update(vida, id):
- rpc_id( 0,'atr_update', {id:{'hp':vida}})
- func kill_update(kill, xp, lv, nxt, id):
- rpc_id( 0,'atr_update', {id:{'k':kill, 'xp':xp, 'lv':lv, 'nxt':nxt}})
- func level_up(lv, maxhp, gain, dmgup, id):
- rpc_id( 0,'level_up', lv, id)
- $players.get_node(str(id)).regenhp(gain)
- $players.get_node(str(id)).dmg += dmgup
- rpc_id( 0,'atr_update', {id:{'maxhp':maxhp}})
-
- # gen_power_queue(str(id))
- #powerup code
- var queue_powermenu_request = {
- # 'id' : {'power':['a','b','c'],'client':0}
- }
- func gen_power_queue(client):
- var time = str(OS.get_system_time_msecs())+str(client)
- queue_powermenu_request[time] = {}
- queue_powermenu_request[time]['power'] = gen_power()
- queue_powermenu_request[time]['client'] = client
- rpc_id( int(client), 'powerpick', queue_powermenu_request[time]['power'] , time )
- _pauser_gen(false)
- remote func optionpick(id, choice):
- var client = api.get_rpc_sender_id()
- if queue_powermenu_request.has(id):
- var power = queue_powermenu_request[id]['power'][choice]
- print(power)
- if $players.has_node(str(client)):
- $players.get_node(str(client)).add_power(power)
- queue_powermenu_request.erase(id)
- print(queue_powermenu_request)
- _pauser_gen(true)
- func _pauser_gen(arg):
- set_physics_process(arg)
- $enemies.set_physics_process(arg)
- for i in $players.get_children():
- i.set_physics_process(arg)
- func gen_power():
- return ['a','b','c']
|