mirror of
https://github.com/Sneed-Group/Poodletooth-iLand
synced 2024-11-01 01:07:54 +00:00
264 lines
9.4 KiB
Python
264 lines
9.4 KiB
Python
from direct.showbase import GarbageReport
|
|
from direct.distributed.PyDatagram import PyDatagram
|
|
from direct.distributed.MsgTypes import CLIENTAGENT_EJECT
|
|
|
|
from otp.ai.AIBaseGlobal import *
|
|
from otp.ai.MagicWordGlobal import *
|
|
from otp.avatar import DistributedAvatarAI
|
|
from otp.avatar import PlayerBase
|
|
from otp.distributed import OtpDoGlobals
|
|
from otp.distributed.ClsendTracker import ClsendTracker
|
|
from otp.otpbase import OTPLocalizer
|
|
|
|
|
|
class DistributedPlayerAI(DistributedAvatarAI.DistributedAvatarAI, PlayerBase.PlayerBase, ClsendTracker):
|
|
def __init__(self, air):
|
|
DistributedAvatarAI.DistributedAvatarAI.__init__(self, air)
|
|
PlayerBase.PlayerBase.__init__(self)
|
|
ClsendTracker.__init__(self)
|
|
self.friendsList = []
|
|
self.DISLname = ''
|
|
self.DISLid = 0
|
|
self.adminAccess = 0
|
|
|
|
if __dev__:
|
|
|
|
def generate(self):
|
|
self._sentExitServerEvent = False
|
|
DistributedAvatarAI.DistributedAvatarAI.generate(self)
|
|
|
|
def announceGenerate(self):
|
|
DistributedAvatarAI.DistributedAvatarAI.announceGenerate(self)
|
|
ClsendTracker.announceGenerate(self)
|
|
self._doPlayerEnter()
|
|
|
|
def _announceArrival(self):
|
|
self.sendUpdate('arrivedOnDistrict', [self.air.districtId])
|
|
|
|
def _announceExit(self):
|
|
self.sendUpdate('arrivedOnDistrict', [0])
|
|
|
|
def _sendExitServerEvent(self):
|
|
self.air.writeServerEvent('avatarExit', self.doId, '')
|
|
if __dev__:
|
|
self._sentExitServerEvent = True
|
|
|
|
def delete(self):
|
|
if __dev__:
|
|
del self._sentExitServerEvent
|
|
self._doPlayerExit()
|
|
ClsendTracker.destroy(self)
|
|
if __dev__:
|
|
GarbageReport.checkForGarbageLeaks()
|
|
DistributedAvatarAI.DistributedAvatarAI.delete(self)
|
|
|
|
def isPlayerControlled(self):
|
|
return True
|
|
|
|
def setLocation(self, parentId, zoneId):
|
|
DistributedAvatarAI.DistributedAvatarAI.setLocation(self, parentId, zoneId)
|
|
if self.isPlayerControlled():
|
|
if not self.air._isValidPlayerLocation(parentId, zoneId):
|
|
self.notify.info('booting player %s for doing setLocation to (%s, %s)' % (self.doId, parentId, zoneId))
|
|
self.air.writeServerEvent('suspicious', self.doId, 'invalid setLocation: (%s, %s)' % (parentId, zoneId))
|
|
self.requestDelete()
|
|
|
|
def _doPlayerEnter(self):
|
|
self.incrementPopulation()
|
|
self._announceArrival()
|
|
|
|
def _doPlayerExit(self):
|
|
self._announceExit()
|
|
self.decrementPopulation()
|
|
|
|
def incrementPopulation(self):
|
|
self.air.incrementPopulation()
|
|
|
|
def decrementPopulation(self):
|
|
simbase.air.decrementPopulation()
|
|
|
|
def b_setChat(self, chatString, chatFlags):
|
|
self.setChat(chatString, chatFlags)
|
|
self.d_setChat(chatString, chatFlags)
|
|
|
|
def d_setChat(self, chatString, chatFlags):
|
|
self.sendUpdate('setChat', [chatString, chatFlags])
|
|
|
|
def setChat(self, chatString, chatFlags):
|
|
pass
|
|
|
|
def d_setMaxHp(self, maxHp):
|
|
DistributedAvatarAI.DistributedAvatarAI.d_setMaxHp(self, maxHp)
|
|
self.air.writeServerEvent('setMaxHp', self.doId, '%s' % maxHp)
|
|
|
|
def d_setSystemMessage(self, aboutId, chatString):
|
|
self.sendUpdate('setSystemMessage', [aboutId, chatString])
|
|
|
|
def d_setCommonChatFlags(self, flags):
|
|
self.sendUpdate('setCommonChatFlags', [flags])
|
|
|
|
def setCommonChatFlags(self, flags):
|
|
pass
|
|
|
|
def d_friendsNotify(self, avId, status):
|
|
self.sendUpdate('friendsNotify', [avId, status])
|
|
|
|
def friendsNotify(self, avId, status):
|
|
pass
|
|
|
|
def setAccountName(self, accountName):
|
|
self.accountName = accountName
|
|
|
|
def getAccountName(self):
|
|
return self.accountName
|
|
|
|
def setDISLid(self, id):
|
|
self.DISLid = id
|
|
|
|
def getDISLid(self):
|
|
return self.DISLid
|
|
|
|
def d_setFriendsList(self, friendsList):
|
|
self.sendUpdate('setFriendsList', [friendsList])
|
|
|
|
def setFriendsList(self, friendsList):
|
|
self.friendsList = friendsList
|
|
self.notify.debug('setting friends list to %s' % self.friendsList)
|
|
|
|
def getFriendsList(self):
|
|
return self.friendsList
|
|
|
|
def setAdminAccess(self, access):
|
|
self.adminAccess = access
|
|
|
|
def d_setAdminAccess(self, access):
|
|
self.sendUpdate('setAdminAccess', [access])
|
|
|
|
def b_setAdminAccess(self, access):
|
|
self.setAdminAccess(access)
|
|
self.d_setAdminAccess(access)
|
|
|
|
def getAdminAccess(self):
|
|
return self.adminAccess
|
|
|
|
def extendFriendsList(self, friendId, friendCode):
|
|
for i in xrange(len(self.friendsList)):
|
|
friendPair = self.friendsList[i]
|
|
if friendPair[0] == friendId:
|
|
self.friendsList[i] = (friendId, friendCode)
|
|
return
|
|
|
|
self.friendsList.append((friendId, friendCode))
|
|
|
|
|
|
@magicWord(category=CATEGORY_SYSTEM_ADMINISTRATOR, types=[str])
|
|
def system(message):
|
|
"""
|
|
Broadcast a <message> to the game server.
|
|
"""
|
|
message = 'ADMIN: ' + message
|
|
dclass = simbase.air.dclassesByName['ClientServicesManager']
|
|
dg = dclass.aiFormatUpdate('systemMessage',
|
|
OtpDoGlobals.OTP_DO_ID_CLIENT_SERVICES_MANAGER,
|
|
10, 1000000, [message])
|
|
simbase.air.send(dg)
|
|
|
|
@magicWord(category=CATEGORY_SYSTEM_ADMINISTRATOR, types=[int])
|
|
def maintenance(minutes):
|
|
"""
|
|
Initiate the maintenance message sequence. It will last for the specified
|
|
amount of <minutes>.
|
|
"""
|
|
def disconnect(task):
|
|
dg = PyDatagram()
|
|
dg.addServerHeader(10, simbase.air.ourChannel, CLIENTAGENT_EJECT)
|
|
dg.addUint16(154)
|
|
dg.addString('Toontown United is now closed for maintenance.')
|
|
simbase.air.send(dg)
|
|
return Task.done
|
|
|
|
def countdown(minutes):
|
|
if minutes > 0:
|
|
system(OTPLocalizer.CRMaintenanceCountdownMessage % minutes)
|
|
else:
|
|
system(OTPLocalizer.CRMaintenanceMessage)
|
|
taskMgr.doMethodLater(10, disconnect, 'maintenance-disconnection')
|
|
if minutes <= 5:
|
|
next = 60
|
|
minutes -= 1
|
|
elif minutes % 5:
|
|
next = 60 * (minutes%5)
|
|
minutes -= minutes % 5
|
|
else:
|
|
next = 300
|
|
minutes -= 5
|
|
if minutes >= 0:
|
|
taskMgr.doMethodLater(next, countdown, 'maintenance-task',
|
|
extraArgs=[minutes])
|
|
|
|
|
|
countdown(minutes)
|
|
|
|
@magicWord(category=CATEGORY_ADMINISTRATOR, types=[str, str, int])
|
|
def accessLevel(accessLevel, storage='PERSISTENT', showGM=1):
|
|
"""
|
|
Modify the target's access level.
|
|
"""
|
|
accessName2Id = {
|
|
'user': CATEGORY_USER.defaultAccess,
|
|
'u': CATEGORY_USER.defaultAccess,
|
|
'communitymanager': CATEGORY_COMMUNITY_MANAGER.defaultAccess,
|
|
'community': CATEGORY_COMMUNITY_MANAGER.defaultAccess,
|
|
'c': CATEGORY_COMMUNITY_MANAGER.defaultAccess,
|
|
'moderator': CATEGORY_MODERATOR.defaultAccess,
|
|
'mod': CATEGORY_MODERATOR.defaultAccess,
|
|
'm': CATEGORY_MODERATOR.defaultAccess,
|
|
'creative': CATEGORY_CREATIVE.defaultAccess,
|
|
'creativity': CATEGORY_CREATIVE.defaultAccess,
|
|
'c': CATEGORY_CREATIVE.defaultAccess,
|
|
'programmer': CATEGORY_PROGRAMMER.defaultAccess,
|
|
'coder': CATEGORY_PROGRAMMER.defaultAccess,
|
|
'p': CATEGORY_PROGRAMMER.defaultAccess,
|
|
'administrator': CATEGORY_ADMINISTRATOR.defaultAccess,
|
|
'admin': CATEGORY_ADMINISTRATOR.defaultAccess,
|
|
'a': CATEGORY_ADMINISTRATOR.defaultAccess,
|
|
'systemadministrator': CATEGORY_SYSTEM_ADMINISTRATOR.defaultAccess,
|
|
'systemadmin': CATEGORY_SYSTEM_ADMINISTRATOR.defaultAccess,
|
|
'sysadministrator': CATEGORY_SYSTEM_ADMINISTRATOR.defaultAccess,
|
|
'sysadmin': CATEGORY_SYSTEM_ADMINISTRATOR.defaultAccess,
|
|
'system': CATEGORY_SYSTEM_ADMINISTRATOR.defaultAccess,
|
|
'sys': CATEGORY_SYSTEM_ADMINISTRATOR.defaultAccess,
|
|
's': CATEGORY_SYSTEM_ADMINISTRATOR.defaultAccess
|
|
}
|
|
try:
|
|
accessLevel = int(accessLevel)
|
|
except:
|
|
if accessLevel not in accessName2Id:
|
|
return 'Invalid access level!'
|
|
accessLevel = accessName2Id[accessLevel]
|
|
if accessLevel not in accessName2Id.values():
|
|
return 'Invalid access level!'
|
|
target = spellbook.getTarget()
|
|
invoker = spellbook.getInvoker()
|
|
if invoker == target:
|
|
return "You can't set your own access level!"
|
|
if not accessLevel < invoker.getAdminAccess():
|
|
return "The target's access level must be lower than yours!"
|
|
if target.getAdminAccess() == accessLevel:
|
|
return "%s's access level is already %d!" % (target.getName(), accessLevel)
|
|
target.b_setAdminAccess(accessLevel)
|
|
if showGM:
|
|
target.b_setGM(accessLevel)
|
|
temporary = storage.upper() in ('SESSION', 'TEMP', 'TEMPORARY')
|
|
if not temporary:
|
|
target.air.dbInterface.updateObject(
|
|
target.air.dbId,
|
|
target.getDISLid(),
|
|
target.air.dclassesByName['AccountAI'],
|
|
{'ADMIN_ACCESS': accessLevel})
|
|
if not temporary:
|
|
target.d_setSystemMessage(0, '%s set your access level to %d!' % (invoker.getName(), accessLevel))
|
|
return "%s's access level has been set to %d." % (target.getName(), accessLevel)
|
|
else:
|
|
target.d_setSystemMessage(0, '%s set your access level to %d temporarily!' % (invoker.getName(), accessLevel))
|
|
return "%s's access level has been set to %d temporarily." % (target.getName(), accessLevel)
|