|
@@ -29,20 +29,44 @@ func conn(id):
|
|
|
rpc_id(0,'ping')
|
|
|
rpc_id(0,'tokerequest')
|
|
|
|
|
|
+export var db_validation = true
|
|
|
+
|
|
|
remote func tokenreply(token, username):
|
|
|
var db = get_parent().get_node('PostgreSQL')
|
|
|
- var data = db.Read('validtokens_database','username',"'"+username+"'")
|
|
|
+ var data = db.Read('validtokens_database','username',"'"+str(username)+"'")
|
|
|
var message = 'token validated'
|
|
|
- if data == []:
|
|
|
- message = "no token found"
|
|
|
- if data[0][2] != token:
|
|
|
- message = "token is invalid"
|
|
|
- print('check tokens....')
|
|
|
+ if db_validation:
|
|
|
+ if data == [] or data == null:
|
|
|
+ message = "no token found"
|
|
|
+ return
|
|
|
+ if data[0][2] != token:
|
|
|
+ message = "token is invalid"
|
|
|
+ print('check tokens....')
|
|
|
+ print(token)
|
|
|
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)
|
|
|
+ print(message)
|
|
|
+ if message == 'token validated':
|
|
|
+ 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)
|
|
|
+ if username == null or username == "":
|
|
|
+ username = 'player' + str(custom_multiplayer.get_network_connected_peers().size())
|
|
|
+ usernames_dict[api.get_rpc_sender_id()] = str(username)
|
|
|
+ send_list_of_usernames(api.get_rpc_sender_id(), username)
|
|
|
+
|
|
|
+func send_list_of_usernames(user, username):
|
|
|
+ rpc_id(user,'_on_usernames', usernames_dict)
|
|
|
+ rpc_id(0,'_on_usernames', { user : username } )
|
|
|
+
|
|
|
+var messages_array = []
|
|
|
+var usernames_dict = {}
|
|
|
+
|
|
|
+remote func chat_messages(message):
|
|
|
+ if $players.has_node(str(api.get_rpc_sender_id())):
|
|
|
+ var buff = usernames_dict[api.get_rpc_sender_id()] + ': ' + str(message)
|
|
|
+ messages_array.append( buff )
|
|
|
+ rpc_id(0,'_On_chat_Message', buff)
|
|
|
|
|
|
remote func connected_peer():
|
|
|
print('syncing clients')
|