Bombsquad-Ballistica-Modded-Server-Mirror/dist/ba_root/mods/tools/servercheck.py

# Released under the MIT License. See LICENSE for details.


# NOT COMPLETED YET

from serverData import serverdata
from playersData import pdata
import _ba
import urllib.request
import json
import datetime
import time
import ba
from ba._general import Call
import threading
import setting
# class ServerChecker:

# 	def __init__():
# 		run()

# 	def run(self):
# 		clients=roset.players
# 		# check if some one joined the party
# 		for client in clients:
# 			if cleint.account_id not in serverdata.currentclients:
# 				self.playerjoined(client)
# 		# check if some one left the party
# 		clients_id=[client.account_id for client in clients]
# 		for player in serverdata.currentclients:
# 			if player not in clients_id:
# 				self.playerleft(player)


# 	def playerjoined(self,client):
# 		if client.account_id in serverdata.cachedclients:
# 			serevrdata.currentclients[client_account_id]=serverdata.cachedclients[id]

# 		playerData=pdata.get_info(client.account_id)
# 		playerData["lastjoin"]=time.time()
# 		if playerData ==None:
# 			self.registernewplayer(cleint)
# 		else if playerData['isBan']:
# 			_ba.disconnect_client(client.client_id,9999)
# 		else:
# 			serverData.currentclients[client_account_id]=playerData


# 	def playerleft(self,player):
# 		serverdata.cachedclients[player]=serverdata.currentclients[player]

# 		serverdata.currentclients.remove(player)

# 		timeplayed=time.time()-serverdata.currentclients[player]['lastjoin']
# 		serverdata.cachedclients[player]["totaltimeplayed"]+=timeplayed

# 		pdata.update_profile(serverdata.cachedclients[player])

settings = setting.get_settings_data()

def on_player_join(pbid):
	
	player_data=pdata.get_info(pbid)
	
	if player_data!=None:
		device_strin=""
		if player_data["isBan"] or player_data["accountAge"] < settings["minAgeToJoinInHours"]:
			for ros in _ba.get_game_roster():
				if ros['account_id']==pbid:
					if not player_data["isBan"]:
						_ba.screenmessage("New Accounts not allowed here , come back later",transient=True,clients=[ros['client_id']])
					_ba.disconnect_client(ros['client_id'])
			return
		else:

			serverdata.clients[pbid]=player_data

			verify_account(pbid,player_data)
		
	else:
		
		d_string=""
		for ros in _ba.get_game_roster():
			if ros['account_id']==pbid:
				d_string=ros['display_string']

		thread = FetchThread(
		    target=my_acc_age,
		    callback=save_age,
		    pb_id=pbid,
		    display_string=d_string
		)

		thread.start()

		

		#pdata.add_profile(pbid,d_string,d_string)

def verify_account(pb_id,p_data):
	d_string=""
	for ros in _ba.get_game_roster():
		if ros['account_id']==pb_id:
			d_string=ros['display_string']

	if d_string not in p_data['display_string']:

		thread2 = FetchThread(
			    target=get_device_accounts,
			    callback=save_ids,
			    pb_id=pb_id,
			    display_string=d_string
			)
		thread2.start()


#============== IGNORE BLOW CODE , ELSE DIE =======================

def _make_request_safe(request, retries=2, raise_err=True):
    try:
        return request()
    except:
        if retries > 0:
            time.sleep(1)
            return _make_request_safe(request, retries=retries-1, raise_err=raise_err)
        if raise_err:
            raise

def get_account_age_in_hours(pb_id):
	# thanks rikko 
    account_creation_url = "http://bombsquadgame.com/accountquery?id=" + pb_id
    account_creation = _make_request_safe(lambda: urllib.request.urlopen(account_creation_url))
    if account_creation is not None:
        try:
            account_creation = json.loads(account_creation.read())
        except ValueError:
            pass
        else:
            creation_time = account_creation["created"]
            creation_time = map(str, creation_time)
            creation_time = datetime.datetime.strptime("/".join(creation_time), "%Y/%m/%d/%H/%M/%S")
            # Convert to IST
            creation_time += datetime.timedelta(hours=5, minutes=30)
            print(creation_time)
            now = datetime.datetime.now()
            delta = now - creation_time
            delta_hours = delta.total_seconds() / (60 * 60)
            return delta_hours

def get_device_accounts(pb_id):
	url="http://bombsquadgame.com/bsAccountInfo?buildNumber=20258&accountID="+pb_id
	data=_make_request_safe(lambda:urllib.request.urlopen(url))
	if data is not None:
		try:
			accounts=json.loads(data.read())["accountDisplayStrings"]
		except ValueError:
			return ['???']
		else:
			return accounts

# =======  yes fucking threading code , dont touch ==============


class FetchThread(threading.Thread):
    def __init__(self,target, callback=None,pb_id="ji",display_string="XXX"):
        
        super(FetchThread, self).__init__(target=self.target_with_callback, args=(pb_id,display_string,))
        self.callback = callback
        self.method = target
        
        
    def target_with_callback(self,pb_id,display_string):
        
        data=self.method(pb_id)
        if self.callback is not None:
            self.callback(data,pb_id,display_string)


def my_acc_age(pb_id):
    
    return get_account_age_in_hours(pb_id)


def save_age(age, pb_id,display_string):
    
    
    pdata.add_profile(pb_id,display_string,display_string,age)
    time.sleep(2)
    thread2 = FetchThread(
		    target=get_device_accounts,
		    callback=save_ids,
		    pb_id=pb_id,
		    display_string=display_string
		)
    thread2.start()
    if age < settings["minAgeToJoinInHours"]:
    	msg="New Accounts not allowed to play here , come back tmrw."
    	_ba.pushcall(Call(kick_by_pb_id,pb_id,msg),from_other_thread=True)

def save_ids(ids,pb_id,display_string):

	
	pdata.update_displayString(pb_id,ids)

	if display_string not in ids:
		msg="Spoofed Id detected , Goodbye"
		_ba.pushcall(Call(kick_by_pb_id,pb_id,msg),from_other_thread=True)
	


def kick_by_pb_id(pb_id,msg):
	for ros in _ba.get_game_roster():
		if ros['account_id']==pb_id:
			_ba.screenmessage(msg, transient=True, clients=[ros['client_id']])
			_ba.disconnect_client(ros['client_id'])
			_ba.chatmessage("id spoofer kicked")