958 lines
36 KiB
Python
958 lines
36 KiB
Python
from panda3d.core import NodePath
|
|
from panda3d.otp import NametagGlobals
|
|
|
|
from direct.directnotify.DirectNotifyGlobal import directNotify
|
|
from direct.fsm.StateData import StateData
|
|
from direct.showbase.MessengerGlobal import messenger
|
|
from direct.showbase.PythonUtil import Functor, PriorityCallbacks, SubframeCall, uniqueName
|
|
from direct.task.TaskManagerGlobal import taskMgr
|
|
|
|
from otp.avatar.Avatar import teleportNotify
|
|
from otp.avatar.Emote import globalEmote
|
|
from otp.otpbase import OTPLocalizer
|
|
|
|
from toontown.distributed import ToontownDistrictStats
|
|
from toontown.estate import HouseGlobals
|
|
from toontown.friends.FriendsListManager import FriendsListManager
|
|
from toontown.hood import ZoneUtil
|
|
from toontown.hood.QuietZoneState import QuietZoneState
|
|
from toontown.hood.TrialerForceAcknowledge import TrialerForceAcknowledge
|
|
from toontown.launcher.DownloadForceAcknowledge import DownloadForceAcknowledge
|
|
from toontown.safezone.PublicWalk import PublicWalk
|
|
from toontown.toon.Toon import teleportDebug
|
|
from toontown.toonbase import ToontownGlobals
|
|
from toontown.toonbase import TTLocalizer
|
|
from toontown.toonbase.ToonBaseGlobal import base
|
|
|
|
|
|
class Place(StateData, FriendsListManager):
|
|
notify = directNotify.newCategory('Place')
|
|
|
|
def __init__(self, loader, doneEvent):
|
|
StateData.__init__(self, doneEvent)
|
|
FriendsListManager.__init__(self)
|
|
self.loader = loader
|
|
self.dfaDoneEvent = 'dfaDoneEvent'
|
|
self.trialerFADoneEvent = 'trialerFADoneEvent'
|
|
self.zoneId = None
|
|
self.trialerFA = None
|
|
self._tiToken = None
|
|
self._leftQuietZoneLocalCallbacks = PriorityCallbacks()
|
|
self._leftQuietZoneSubframeCall = None
|
|
self._setZoneCompleteLocalCallbacks = PriorityCallbacks()
|
|
self._setZoneCompleteSubframeCall = None
|
|
|
|
def load(self):
|
|
StateData.load(self)
|
|
FriendsListManager.load(self)
|
|
self.walkDoneEvent = 'walkDone'
|
|
self.walkStateData = PublicWalk(self.fsm, self.walkDoneEvent)
|
|
self.walkStateData.load()
|
|
self._tempFSM = self.fsm
|
|
|
|
def unload(self):
|
|
StateData.unload(self)
|
|
FriendsListManager.unload(self)
|
|
self.notify.info('Unloading Place (%s). Fsm in %s' % (self.zoneId, self._tempFSM.getCurrentState().getName()))
|
|
if self._leftQuietZoneSubframeCall:
|
|
self._leftQuietZoneSubframeCall.cleanup()
|
|
self._leftQuietZoneSubframeCall = None
|
|
|
|
if self._setZoneCompleteSubframeCall:
|
|
self._setZoneCompleteSubframeCall.cleanup()
|
|
self._setZoneCompleteSubframeCall = None
|
|
|
|
self._leftQuietZoneLocalCallbacks = None
|
|
self._setZoneCompleteLocalCallbacks = None
|
|
del self._tempFSM
|
|
taskMgr.remove('goHomeFailed')
|
|
del self.walkDoneEvent
|
|
self.walkStateData.unload()
|
|
del self.walkStateData
|
|
del self.loader
|
|
if self.trialerFA:
|
|
self.trialerFA.exit()
|
|
del self.trialerFA
|
|
|
|
def _getQZState(self):
|
|
if hasattr(base, 'cr') and hasattr(base.cr, 'playGame'):
|
|
if hasattr(base.cr.playGame, 'quietZoneStateData') and base.cr.playGame.quietZoneStateData:
|
|
return base.cr.playGame.quietZoneStateData
|
|
|
|
return None
|
|
|
|
def addLeftQuietZoneCallback(self, callback, priority = None):
|
|
qzsd = self._getQZState()
|
|
if qzsd:
|
|
return qzsd.addLeftQuietZoneCallback(callback, priority)
|
|
else:
|
|
token = self._leftQuietZoneLocalCallbacks.add(callback, priority=priority)
|
|
if not self._leftQuietZoneSubframeCall:
|
|
self._leftQuietZoneSubframeCall = SubframeCall(self._doLeftQuietZoneCallbacks, taskMgr.getCurrentTask().getPriority() - 1)
|
|
|
|
return token
|
|
|
|
def removeLeftQuietZoneCallback(self, token):
|
|
if token is not None:
|
|
if token in self._leftQuietZoneLocalCallbacks:
|
|
self._leftQuietZoneLocalCallbacks.remove(token)
|
|
|
|
qzsd = self._getQZState()
|
|
if qzsd:
|
|
qzsd.removeLeftQuietZoneCallback(token)
|
|
|
|
def _doLeftQuietZoneCallbacks(self):
|
|
self._leftQuietZoneLocalCallbacks()
|
|
self._leftQuietZoneLocalCallbacks.clear()
|
|
self._leftQuietZoneSubframeCall = None
|
|
|
|
def addSetZoneCompleteCallback(self, callback, priority = None):
|
|
qzsd = self._getQZState()
|
|
if qzsd:
|
|
return qzsd.addSetZoneCompleteCallback(callback, priority)
|
|
else:
|
|
token = self._setZoneCompleteLocalCallbacks.add(callback, priority=priority)
|
|
if not self._setZoneCompleteSubframeCall:
|
|
self._setZoneCompleteSubframeCall = SubframeCall(self._doSetZoneCompleteLocalCallbacks, taskMgr.getCurrentTask().getPriority() - 1)
|
|
|
|
return token
|
|
|
|
def removeSetZoneCompleteCallback(self, token):
|
|
if token is not None:
|
|
if any(token == x[1] for x in self._setZoneCompleteLocalCallbacks._callbacks):
|
|
self._setZoneCompleteLocalCallbacks.remove(token)
|
|
|
|
qzsd = self._getQZState()
|
|
if qzsd:
|
|
qzsd.removeSetZoneCompleteCallback(token)
|
|
|
|
def _doSetZoneCompleteLocalCallbacks(self):
|
|
self._setZoneCompleteSubframeCall = None
|
|
localCallbacks = self._setZoneCompleteLocalCallbacks
|
|
self._setZoneCompleteLocalCallbacks()
|
|
localCallbacks.clear()
|
|
|
|
def setState(self, state):
|
|
if hasattr(self, 'fsm'):
|
|
curState = self.fsm.getName()
|
|
if state == 'pet' or curState == 'pet':
|
|
self.preserveFriendsList()
|
|
|
|
self.fsm.request(state)
|
|
|
|
def getState(self):
|
|
if hasattr(self, 'fsm'):
|
|
curState = self.fsm.getCurrentState().getName()
|
|
return curState
|
|
|
|
def getZoneId(self):
|
|
return self.zoneId
|
|
|
|
def getTaskZoneId(self):
|
|
return self.getZoneId()
|
|
|
|
def isPeriodTimerEffective(self):
|
|
return 1
|
|
|
|
def handleTeleportQuery(self, fromAvatar, toAvatar):
|
|
if base.config.GetBool('want-tptrack', False):
|
|
if toAvatar == base.localAvatar:
|
|
toAvatar.doTeleportResponse(fromAvatar, toAvatar, toAvatar.doId, 1, toAvatar.defaultShard, base.cr.playGame.getPlaceId(), self.getZoneId(), fromAvatar.doId)
|
|
else:
|
|
self.notify.warning('handleTeleportQuery toAvatar.doId != localAvatar.doId' % (toAvatar.doId, base.localAvatar.doId))
|
|
else:
|
|
fromAvatar.d_teleportResponse(toAvatar.doId, 1, toAvatar.defaultShard, base.cr.playGame.getPlaceId(), self.getZoneId())
|
|
|
|
def enablePeriodTimer(self):
|
|
if self.isPeriodTimerEffective():
|
|
if base.cr.periodTimerExpired:
|
|
taskMgr.doMethodLater(5, self.redoPeriodTimer, 'redoPeriodTimer')
|
|
|
|
self.accept('periodTimerExpired', self.periodTimerExpired)
|
|
|
|
def disablePeriodTimer(self):
|
|
taskMgr.remove('redoPeriodTimer')
|
|
self.ignore('periodTimerExpired')
|
|
|
|
def redoPeriodTimer(self, task):
|
|
messenger.send('periodTimerExpired')
|
|
return task.done
|
|
|
|
def periodTimerExpired(self):
|
|
self.fsm.request('final')
|
|
if base.localAvatar.book.isEntered:
|
|
base.localAvatar.book.exit()
|
|
base.localAvatar.b_setAnimState('CloseBook', 1, callback=self.__handlePeriodTimerBookClose)
|
|
else:
|
|
base.localAvatar.b_setAnimState('TeleportOut', 1, self.__handlePeriodTimerExitTeleport)
|
|
|
|
def exitPeriodTimerExpired(self):
|
|
pass
|
|
|
|
def __handlePeriodTimerBookClose(self):
|
|
base.localAvatar.b_setAnimState('TeleportOut', 1, self.__handlePeriodTimerExitTeleport)
|
|
|
|
def __handlePeriodTimerExitTeleport(self):
|
|
base.cr.loginFSM.request('periodTimeout')
|
|
|
|
def detectedPhoneCollision(self):
|
|
self.fsm.request('phone')
|
|
|
|
def detectedFishingCollision(self):
|
|
self.fsm.request('fishing')
|
|
|
|
def enterStart(self):
|
|
pass
|
|
|
|
def exitStart(self):
|
|
pass
|
|
|
|
def enterFinal(self):
|
|
pass
|
|
|
|
def exitFinal(self):
|
|
pass
|
|
|
|
def enterWalk(self, teleportIn = 0):
|
|
self.enterFLM()
|
|
self.walkStateData.enter()
|
|
if teleportIn == 0:
|
|
self.walkStateData.fsm.request('walking')
|
|
|
|
self.acceptOnce(self.walkDoneEvent, self.handleWalkDone)
|
|
if base.cr.productName in ['DisneyOnline-US', 'ES'] and not base.cr.isPaid() and base.localAvatar.tutorialAck:
|
|
base.localAvatar.chatMgr.obscure(0, 0)
|
|
base.localAvatar.chatMgr.normalButton.show()
|
|
|
|
self.accept('teleportQuery', self.handleTeleportQuery)
|
|
base.localAvatar.setTeleportAvailable(1)
|
|
base.localAvatar.questPage.acceptOnscreenHooks()
|
|
base.localAvatar.invPage.acceptOnscreenHooks()
|
|
base.localAvatar.questMap.acceptOnscreenHooks()
|
|
self.walkStateData.fsm.request('walking')
|
|
self.enablePeriodTimer()
|
|
|
|
def exitWalk(self):
|
|
self.exitFLM()
|
|
if base.cr.productName in ['DisneyOnline-US', 'ES'] and not base.cr.isPaid() and base.localAvatar.tutorialAck and not base.cr.whiteListChatEnabled:
|
|
base.localAvatar.chatMgr.obscure(1, 0)
|
|
|
|
self.disablePeriodTimer()
|
|
messenger.send('wakeup')
|
|
self.walkStateData.exit()
|
|
self.ignore(self.walkDoneEvent)
|
|
base.localAvatar.setTeleportAvailable(0)
|
|
self.ignore('teleportQuery')
|
|
if base.cr.playGame.hood != None:
|
|
base.cr.playGame.hood.hideTitleText()
|
|
|
|
base.localAvatar.questPage.hideQuestsOnscreen()
|
|
base.localAvatar.questPage.ignoreOnscreenHooks()
|
|
base.localAvatar.invPage.ignoreOnscreenHooks()
|
|
base.localAvatar.invPage.hideInventoryOnscreen()
|
|
base.localAvatar.questMap.hide()
|
|
base.localAvatar.questMap.ignoreOnscreenHooks()
|
|
|
|
def handleWalkDone(self, doneStatus):
|
|
mode = doneStatus['mode']
|
|
if mode == 'StickerBook':
|
|
self.last = self.fsm.getCurrentState().getName()
|
|
self.fsm.request('stickerBook')
|
|
elif mode == 'Options':
|
|
self.last = self.fsm.getCurrentState().getName()
|
|
self.fsm.request('stickerBook', [base.localAvatar.optionsPage])
|
|
elif mode == 'Sit':
|
|
self.last = self.fsm.getCurrentState().getName()
|
|
self.fsm.request('sit')
|
|
else:
|
|
Place.notify.error('Invalid mode: %s' % mode)
|
|
|
|
def enterSit(self):
|
|
self.enterFLM()
|
|
base.localAvatar.laffMeter.start()
|
|
self.accept('teleportQuery', self.handleTeleportQuery)
|
|
base.localAvatar.setTeleportAvailable(1)
|
|
base.localAvatar.b_setAnimState('SitStart', 1)
|
|
self.accept('arrow_up', self.fsm.request, extraArgs=['walk'])
|
|
|
|
def exitSit(self):
|
|
self.exitFLM()
|
|
base.localAvatar.laffMeter.stop()
|
|
base.localAvatar.setTeleportAvailable(0)
|
|
self.ignore('teleportQuery')
|
|
self.ignore('arrow_up')
|
|
|
|
def enterDrive(self):
|
|
self.enterFLM()
|
|
base.localAvatar.laffMeter.start()
|
|
self.accept('teleportQuery', self.handleTeleportQuery)
|
|
base.localAvatar.setTeleportAvailable(1)
|
|
base.localAvatar.b_setAnimState('SitStart', 1)
|
|
|
|
def exitDrive(self):
|
|
self.exitFLM()
|
|
base.localAvatar.laffMeter.stop()
|
|
base.localAvatar.setTeleportAvailable(0)
|
|
self.ignore('teleportQuery')
|
|
|
|
def enterPush(self):
|
|
self.enterFLM()
|
|
base.localAvatar.laffMeter.start()
|
|
self.accept('teleportQuery', self.handleTeleportQuery)
|
|
base.localAvatar.setTeleportAvailable(1)
|
|
base.localAvatar.attachCamera()
|
|
base.localAvatar.startUpdateSmartCamera()
|
|
base.localAvatar.startPosHprBroadcast()
|
|
base.localAvatar.b_setAnimState('Push', 1)
|
|
|
|
def exitPush(self):
|
|
self.exitFLM()
|
|
base.localAvatar.laffMeter.stop()
|
|
base.localAvatar.setTeleportAvailable(0)
|
|
base.localAvatar.stopUpdateSmartCamera()
|
|
base.localAvatar.detachCamera()
|
|
base.localAvatar.stopPosHprBroadcast()
|
|
self.ignore('teleportQuery')
|
|
|
|
def enterStickerBook(self, page = None):
|
|
self.enterFLM()
|
|
base.localAvatar.laffMeter.start()
|
|
target = base.cr.doFind('DistributedTarget')
|
|
if target:
|
|
target.hideGui()
|
|
|
|
self.accept('teleportQuery', self.handleTeleportQuery)
|
|
base.localAvatar.setTeleportAvailable(1)
|
|
if page:
|
|
base.localAvatar.book.setPage(page)
|
|
|
|
base.localAvatar.b_setAnimState('OpenBook', 1, self.enterStickerBookGUI)
|
|
base.localAvatar.obscureMoveFurnitureButton(1)
|
|
|
|
def enterStickerBookGUI(self):
|
|
base.localAvatar.collisionsOn()
|
|
base.localAvatar.book.showButton()
|
|
base.localAvatar.book.enter()
|
|
base.localAvatar.setGuiConflict(1)
|
|
base.localAvatar.startSleepWatch(self.__handleFallingAsleep)
|
|
self.accept('bookDone', self.__handleBook)
|
|
base.localAvatar.b_setAnimState('ReadBook', 1)
|
|
self.enablePeriodTimer()
|
|
|
|
def __handleFallingAsleep(self, task):
|
|
base.localAvatar.book.exit()
|
|
base.localAvatar.b_setAnimState('CloseBook', 1, callback=self.__handleFallingAsleepBookClose)
|
|
return task.done
|
|
|
|
def __handleFallingAsleepBookClose(self):
|
|
if hasattr(self, 'fsm'):
|
|
self.fsm.request('walk')
|
|
|
|
base.localAvatar.forceGotoSleep()
|
|
|
|
def exitStickerBook(self):
|
|
base.localAvatar.stopSleepWatch()
|
|
self.disablePeriodTimer()
|
|
self.exitFLM()
|
|
base.localAvatar.laffMeter.stop()
|
|
base.localAvatar.setGuiConflict(0)
|
|
base.localAvatar.book.exit()
|
|
base.localAvatar.book.hideButton()
|
|
base.localAvatar.collisionsOff()
|
|
self.ignore('bookDone')
|
|
base.localAvatar.setTeleportAvailable(0)
|
|
self.ignore('teleportQuery')
|
|
base.localAvatar.obscureMoveFurnitureButton(-1)
|
|
target = base.cr.doFind('DistributedTarget')
|
|
if target:
|
|
target.showGui()
|
|
|
|
def __handleBook(self):
|
|
base.localAvatar.stopSleepWatch()
|
|
base.localAvatar.book.exit()
|
|
bookStatus = base.localAvatar.book.getDoneStatus()
|
|
if bookStatus['mode'] == 'close':
|
|
base.localAvatar.b_setAnimState('CloseBook', 1, callback=self.handleBookClose)
|
|
elif bookStatus['mode'] == 'teleport':
|
|
zoneId = bookStatus['hood']
|
|
base.localAvatar.collisionsOff()
|
|
base.localAvatar.b_setAnimState('CloseBook', 1, callback=self.handleBookCloseTeleport, extraArgs=[zoneId, zoneId])
|
|
elif bookStatus['mode'] == 'exit':
|
|
self.exitTo = bookStatus.get('exitTo')
|
|
base.localAvatar.collisionsOff()
|
|
base.localAvatar.b_setAnimState('CloseBook', 1, callback=self.__handleBookCloseExit)
|
|
elif bookStatus['mode'] == 'gohome':
|
|
zoneId = bookStatus['hood']
|
|
base.localAvatar.collisionsOff()
|
|
base.localAvatar.b_setAnimState('CloseBook', 1, callback=self.goHomeNow, extraArgs=[zoneId])
|
|
elif bookStatus['mode'] == 'startparty':
|
|
firstStart = bookStatus['firstStart']
|
|
hostId = bookStatus['hostId']
|
|
base.localAvatar.collisionsOff()
|
|
base.localAvatar.b_setAnimState('CloseBook', 1, callback=self.startPartyNow, extraArgs=[firstStart, hostId])
|
|
|
|
def handleBookCloseTeleport(self, hoodId, zoneId):
|
|
if base.localAvatar.hasActiveBoardingGroup():
|
|
rejectText = TTLocalizer.BoardingCannotLeaveZone
|
|
base.localAvatar.elevatorNotifier.showMe(rejectText)
|
|
return
|
|
|
|
self.requestLeave({'loader': ZoneUtil.getBranchLoaderName(zoneId),
|
|
'where': ZoneUtil.getToonWhereName(zoneId),
|
|
'how': 'teleportIn',
|
|
'hoodId': hoodId,
|
|
'zoneId': zoneId,
|
|
'shardId': None,
|
|
'avId': -1})
|
|
|
|
def __handleBookCloseExit(self):
|
|
base.localAvatar.b_setAnimState('TeleportOut', 1, self.__handleBookExitTeleport, [0])
|
|
|
|
def __handleBookExitTeleport(self, requestStatus):
|
|
if base.cr.timeManager:
|
|
base.cr.timeManager.setDisconnectReason(ToontownGlobals.DisconnectBookExit)
|
|
|
|
base.transitions.fadeScreen(1.0)
|
|
base.cr.gameFSM.request(self.exitTo)
|
|
|
|
def goHomeNow(self, curZoneId):
|
|
if base.localAvatar.hasActiveBoardingGroup():
|
|
rejectText = TTLocalizer.BoardingCannotLeaveZone
|
|
base.localAvatar.elevatorNotifier.showMe(rejectText)
|
|
return
|
|
|
|
hoodId = ToontownGlobals.MyEstate
|
|
self.requestLeave({'loader': 'safeZoneLoader',
|
|
'where': 'estate',
|
|
'how': 'teleportIn',
|
|
'hoodId': hoodId,
|
|
'zoneId': -1,
|
|
'shardId': None,
|
|
'avId': -1})
|
|
|
|
def startPartyNow(self, firstStart, hostId):
|
|
if base.localAvatar.hasActiveBoardingGroup():
|
|
rejectText = TTLocalizer.BoardingCannotLeaveZone
|
|
base.localAvatar.elevatorNotifier.showMe(rejectText)
|
|
return
|
|
|
|
base.localAvatar.creatingNewPartyWithMagicWord = False
|
|
base.localAvatar.aboutToPlanParty = False
|
|
hoodId = ToontownGlobals.PartyHood
|
|
if firstStart:
|
|
zoneId = 0
|
|
ToontownDistrictStats.refresh('shardInfoUpdated')
|
|
curShardTuples = base.cr.listActiveShards()
|
|
lowestPop = 100000000000000000
|
|
shardId = None
|
|
for shardInfo in curShardTuples:
|
|
pop = shardInfo[2]
|
|
if pop < lowestPop:
|
|
lowestPop = pop
|
|
shardId = shardInfo[0]
|
|
|
|
if shardId == base.localAvatar.defaultShard:
|
|
shardId = None
|
|
|
|
base.cr.playGame.getPlace().requestLeave({'loader': 'safeZoneLoader',
|
|
'where': 'party',
|
|
'how': 'teleportIn',
|
|
'hoodId': hoodId,
|
|
'zoneId': zoneId,
|
|
'shardId': shardId,
|
|
'avId': -1})
|
|
else:
|
|
if hostId is None:
|
|
hostId = base.localAvatar.doId
|
|
|
|
base.cr.partyManager.sendAvatarToParty(hostId)
|
|
|
|
def handleBookClose(self):
|
|
if hasattr(self, 'fsm'):
|
|
self.fsm.request('walk')
|
|
|
|
if hasattr(self, 'toonSubmerged') and self.toonSubmerged == 1:
|
|
if hasattr(self, 'walkStateData'):
|
|
self.walkStateData.fsm.request('swimming', [self.loader.swimSound])
|
|
|
|
def requestLeave(self, requestStatus):
|
|
teleportDebug(requestStatus, 'requestLeave(%s)' % (requestStatus,))
|
|
if hasattr(self, 'fsm'):
|
|
self.doRequestLeave(requestStatus)
|
|
|
|
def doRequestLeave(self, requestStatus):
|
|
teleportDebug(requestStatus, 'requestLeave(%s)' % (requestStatus,))
|
|
self.fsm.request('DFA', [requestStatus])
|
|
|
|
def enterDFA(self, requestStatus):
|
|
teleportDebug(requestStatus, 'enterDFA(%s)' % (requestStatus,))
|
|
self.acceptOnce(self.dfaDoneEvent, self.enterDFACallback, [requestStatus])
|
|
self.dfa = DownloadForceAcknowledge(self.dfaDoneEvent)
|
|
self.dfa.enter(base.cr.hoodMgr.getPhaseFromHood(requestStatus['hoodId']))
|
|
|
|
def exitDFA(self):
|
|
self.ignore(self.dfaDoneEvent)
|
|
|
|
def handleEnterTunnel(self, requestStatus, collEntry):
|
|
if base.localAvatar.hasActiveBoardingGroup():
|
|
rejectText = TTLocalizer.BoardingCannotLeaveZone
|
|
base.localAvatar.elevatorNotifier.showMe(rejectText)
|
|
dummyNP = NodePath('dummyNP')
|
|
dummyNP.reparentTo(base.render)
|
|
tunnelOrigin = requestStatus['tunnelOrigin']
|
|
dummyNP.setPos(base.localAvatar.getPos())
|
|
dummyNP.setH(tunnelOrigin.getH())
|
|
dummyNP.setPos(dummyNP, 0, 4, 0)
|
|
base.localAvatar.setPos(dummyNP.getPos())
|
|
dummyNP.removeNode()
|
|
del dummyNP
|
|
return
|
|
|
|
self.requestLeave(requestStatus)
|
|
|
|
def enterDFACallback(self, requestStatus, doneStatus):
|
|
teleportDebug(requestStatus, 'enterDFACallback%s' % ((requestStatus, doneStatus),))
|
|
self.dfa.exit()
|
|
del self.dfa
|
|
if doneStatus['mode'] == 'complete':
|
|
if requestStatus.get('tutorial', 0):
|
|
out = {'teleportIn': 'tunnelOut'}
|
|
requestStatus['zoneId'] = 22000
|
|
requestStatus['hoodId'] = 22000
|
|
else:
|
|
out = {'teleportIn': 'teleportOut',
|
|
'tunnelIn': 'tunnelOut',
|
|
'doorIn': 'doorOut'}
|
|
|
|
teleportDebug(requestStatus, 'requesting %s, requestStatus=%s' % (out[requestStatus['how']], requestStatus))
|
|
self.fsm.request(out[requestStatus['how']], [requestStatus])
|
|
elif doneStatus['mode'] == 'incomplete':
|
|
self.fsm.request('DFAReject')
|
|
else:
|
|
Place.notify.error('Unknown done status for DownloadForceAcknowledge: ' + repr(doneStatus))
|
|
|
|
def enterDFAReject(self):
|
|
self.fsm.request('walk')
|
|
|
|
def exitDFAReject(self):
|
|
pass
|
|
|
|
def enterTrialerFA(self, requestStatus):
|
|
teleportDebug(requestStatus, 'enterTrialerFA(%s)' % requestStatus)
|
|
self.acceptOnce(self.trialerFADoneEvent, self.trialerFACallback, [requestStatus])
|
|
self.trialerFA = TrialerForceAcknowledge(self.trialerFADoneEvent)
|
|
self.trialerFA.enter(requestStatus['hoodId'])
|
|
|
|
def exitTrialerFA(self):
|
|
pass
|
|
|
|
def trialerFACallback(self, requestStatus, doneStatus):
|
|
if doneStatus['mode'] == 'pass':
|
|
self.fsm.request('DFA', [requestStatus])
|
|
elif doneStatus['mode'] == 'fail':
|
|
self.fsm.request('trialerFAReject')
|
|
else:
|
|
Place.notify.error('Unknown done status for TrialerForceAcknowledge: %s' % doneStatus)
|
|
|
|
def enterTrialerFAReject(self):
|
|
self.fsm.request('walk')
|
|
|
|
def exitTrialerFAReject(self):
|
|
pass
|
|
|
|
def enterDoorIn(self, requestStatus):
|
|
NametagGlobals.setMasterArrowsOn(0)
|
|
door = base.cr.doId2do.get(requestStatus['doorDoId'])
|
|
door.readyToExit()
|
|
base.localAvatar.obscureMoveFurnitureButton(1)
|
|
base.localAvatar.startQuestMap()
|
|
|
|
def exitDoorIn(self):
|
|
NametagGlobals.setMasterArrowsOn(1)
|
|
base.localAvatar.obscureMoveFurnitureButton(-1)
|
|
|
|
def enterDoorOut(self):
|
|
base.localAvatar.obscureMoveFurnitureButton(1)
|
|
|
|
def exitDoorOut(self):
|
|
base.localAvatar.obscureMoveFurnitureButton(-1)
|
|
base.localAvatar.stopQuestMap()
|
|
|
|
def handleDoorDoneEvent(self, requestStatus):
|
|
self.doneStatus = requestStatus
|
|
messenger.send(self.doneEvent)
|
|
|
|
def handleDoorTrigger(self):
|
|
self.fsm.request('doorOut')
|
|
|
|
def enterTunnelIn(self, requestStatus):
|
|
self.notify.debug('enterTunnelIn(requestStatus=' + str(requestStatus) + ')')
|
|
tunnelOrigin = base.render.find(requestStatus['tunnelName'])
|
|
self.accept('tunnelInMovieDone', self.__tunnelInMovieDone)
|
|
base.localAvatar.reconsiderCheesyEffect()
|
|
base.localAvatar.tunnelIn(tunnelOrigin)
|
|
base.localAvatar.startQuestMap()
|
|
|
|
def __tunnelInMovieDone(self):
|
|
self.ignore('tunnelInMovieDone')
|
|
self.fsm.request('walk')
|
|
|
|
def exitTunnelIn(self):
|
|
pass
|
|
|
|
def enterTunnelOut(self, requestStatus):
|
|
hoodId = requestStatus['hoodId']
|
|
zoneId = requestStatus['zoneId']
|
|
how = requestStatus['how']
|
|
tunnelOrigin = requestStatus['tunnelOrigin']
|
|
fromZoneId = ZoneUtil.getCanonicalZoneId(self.getZoneId())
|
|
tunnelName = requestStatus.get('tunnelName')
|
|
if tunnelName == None:
|
|
tunnelName = base.cr.hoodMgr.makeLinkTunnelName(self.loader.hood.id, fromZoneId)
|
|
|
|
self.doneStatus = {'loader': ZoneUtil.getLoaderName(zoneId),
|
|
'where': ZoneUtil.getToonWhereName(zoneId),
|
|
'how': how,
|
|
'hoodId': hoodId,
|
|
'zoneId': zoneId,
|
|
'shardId': None,
|
|
'tunnelName': tunnelName}
|
|
self.accept('tunnelOutMovieDone', self.__tunnelOutMovieDone)
|
|
base.localAvatar.tunnelOut(tunnelOrigin)
|
|
base.localAvatar.stopQuestMap()
|
|
|
|
def __tunnelOutMovieDone(self):
|
|
self.ignore('tunnelOutMovieDone')
|
|
messenger.send(self.doneEvent)
|
|
|
|
def exitTunnelOut(self):
|
|
pass
|
|
|
|
def enterTeleportOut(self, requestStatus, callback):
|
|
base.localAvatar.laffMeter.start()
|
|
base.localAvatar.b_setAnimState('TeleportOut', 1, callback, [requestStatus])
|
|
base.localAvatar.obscureMoveFurnitureButton(1)
|
|
|
|
def exitTeleportOut(self):
|
|
base.localAvatar.laffMeter.stop()
|
|
base.localAvatar.stopQuestMap()
|
|
base.localAvatar.obscureMoveFurnitureButton(-1)
|
|
|
|
def enterDied(self, requestStatus, callback = None):
|
|
if callback == None:
|
|
callback = self.__diedDone
|
|
|
|
base.localAvatar.laffMeter.start()
|
|
base.camera.wrtReparentTo(base.render)
|
|
base.localAvatar.b_setAnimState('Died', 1, callback, [requestStatus])
|
|
base.localAvatar.obscureMoveFurnitureButton(1)
|
|
|
|
def __diedDone(self, requestStatus):
|
|
self.doneStatus = requestStatus
|
|
messenger.send(self.doneEvent)
|
|
|
|
def exitDied(self):
|
|
base.localAvatar.laffMeter.stop()
|
|
base.localAvatar.obscureMoveFurnitureButton(-1)
|
|
|
|
def getEstateZoneAndGoHome(self, requestStatus):
|
|
self.doneStatus = requestStatus
|
|
avId = requestStatus['avId']
|
|
self.acceptOnce('setLocalEstateZone', self.goHome)
|
|
if avId > 0:
|
|
base.cr.estateMgr.getLocalEstateZone(avId)
|
|
else:
|
|
base.cr.estateMgr.getLocalEstateZone(base.localAvatar.getDoId())
|
|
|
|
if HouseGlobals.WANT_TELEPORT_TIMEOUT:
|
|
taskMgr.doMethodLater(HouseGlobals.TELEPORT_TIMEOUT, self.goHomeFailed, 'goHomeFailed')
|
|
|
|
def goHome(self, ownerId, zoneId):
|
|
self.notify.debug('goHome ownerId = %s' % ownerId)
|
|
taskMgr.remove('goHomeFailed')
|
|
if ownerId > 0 and ownerId != base.localAvatar.doId and not base.cr.isFriend(ownerId):
|
|
self.doneStatus['failed'] = 1
|
|
self.goHomeFailed(None)
|
|
return
|
|
|
|
if ownerId == 0 and zoneId == 0:
|
|
if self.doneStatus['shardId'] is None or self.doneStatus['shardId'] is base.localAvatar.defaultShard:
|
|
self.doneStatus['failed'] = 1
|
|
self.goHomeFailed(None)
|
|
return
|
|
else:
|
|
self.doneStatus['hood'] = ToontownGlobals.MyEstate
|
|
self.doneStatus['zone'] = base.localAvatar.lastHood
|
|
self.doneStatus['loaderId'] = 'safeZoneLoader'
|
|
self.doneStatus['whereId'] = 'estate'
|
|
self.doneStatus['how'] = 'teleportIn'
|
|
messenger.send(self.doneEvent)
|
|
return
|
|
|
|
if self.doneStatus['zoneId'] == -1:
|
|
self.doneStatus['zoneId'] = zoneId
|
|
elif self.doneStatus['zoneId'] != zoneId:
|
|
self.doneStatus['where'] = 'house'
|
|
|
|
self.doneStatus['ownerId'] = ownerId
|
|
messenger.send(self.doneEvent)
|
|
messenger.send('localToonLeft')
|
|
|
|
def goHomeFailed(self, task):
|
|
self.notify.debug('goHomeFailed')
|
|
self.notifyUserGoHomeFailed()
|
|
self.ignore('setLocalEstateZone')
|
|
self.doneStatus['hood'] = base.localAvatar.lastHood
|
|
self.doneStatus['zone'] = base.localAvatar.lastHood
|
|
self.fsm.request('teleportIn', [self.doneStatus])
|
|
return task.done
|
|
|
|
def notifyUserGoHomeFailed(self):
|
|
self.notify.debug('notifyUserGoHomeFailed')
|
|
failedToVisitAvId = self.doneStatus.get('avId', -1)
|
|
avName = None
|
|
if failedToVisitAvId != -1:
|
|
avatar = base.cr.identifyAvatar(failedToVisitAvId)
|
|
if avatar:
|
|
avName = avatar.getName()
|
|
|
|
if avName:
|
|
message = TTLocalizer.EstateTeleportFailedNotFriends % avName
|
|
else:
|
|
message = TTLocalizer.EstateTeleportFailed
|
|
|
|
base.localAvatar.setSystemMessage(0, message)
|
|
|
|
def enterTeleportIn(self, requestStatus):
|
|
self._tiToken = self.addSetZoneCompleteCallback(Functor(self._placeTeleportInPostZoneComplete, requestStatus), 100)
|
|
|
|
def _placeTeleportInPostZoneComplete(self, requestStatus):
|
|
teleportDebug(requestStatus, '_placeTeleportInPostZoneComplete(%s)' % (requestStatus,))
|
|
NametagGlobals.setMasterArrowsOn(0)
|
|
base.localAvatar.laffMeter.start()
|
|
base.localAvatar.startQuestMap()
|
|
base.localAvatar.reconsiderCheesyEffect()
|
|
base.localAvatar.obscureMoveFurnitureButton(1)
|
|
avId = requestStatus.get('avId', -1)
|
|
if avId != -1:
|
|
if avId in base.cr.doId2do:
|
|
teleportDebug(requestStatus, 'teleport to avatar')
|
|
avatar = base.cr.doId2do[avId]
|
|
avatar.forceToTruePosition()
|
|
base.localAvatar.gotoNode(avatar)
|
|
base.localAvatar.b_teleportGreeting(avId)
|
|
else:
|
|
friend = base.cr.identifyAvatar(avId)
|
|
if friend != None:
|
|
teleportDebug(requestStatus, 'friend not here, giving up')
|
|
base.localAvatar.setSystemMessage(avId, OTPLocalizer.WhisperTargetLeftVisit % (friend.getName(),))
|
|
friend.d_teleportGiveup(base.localAvatar.doId)
|
|
|
|
base.transitions.irisIn()
|
|
self.nextState = requestStatus.get('nextState', 'walk')
|
|
base.localAvatar.attachCamera()
|
|
base.localAvatar.startUpdateSmartCamera()
|
|
base.localAvatar.startPosHprBroadcast()
|
|
base.clock.tick()
|
|
base.localAvatar.b_setAnimState('TeleportIn', 1, callback=self.teleportInDone)
|
|
base.localAvatar.d_broadcastPositionNow()
|
|
base.localAvatar.b_setParent(ToontownGlobals.SPRender)
|
|
|
|
def teleportInDone(self):
|
|
if hasattr(self, 'fsm'):
|
|
teleportNotify.debug('teleportInDone: %s' % self.nextState)
|
|
self.fsm.request(self.nextState, [1])
|
|
|
|
def exitTeleportIn(self):
|
|
self.removeSetZoneCompleteCallback(self._tiToken)
|
|
self._tiToken = None
|
|
NametagGlobals.setMasterArrowsOn(1)
|
|
base.localAvatar.laffMeter.stop()
|
|
base.localAvatar.obscureMoveFurnitureButton(-1)
|
|
base.localAvatar.stopUpdateSmartCamera()
|
|
base.localAvatar.detachCamera()
|
|
base.localAvatar.stopPosHprBroadcast()
|
|
|
|
def requestTeleport(self, hoodId, zoneId, shardId, avId):
|
|
if avId > 0:
|
|
teleportNotify.debug('requestTeleport%s' % ((hoodId,
|
|
zoneId,
|
|
shardId,
|
|
avId),))
|
|
|
|
if base.localAvatar.hasActiveBoardingGroup():
|
|
if avId > 0:
|
|
teleportNotify.debug('requestTeleport: has active boarding group')
|
|
|
|
rejectText = TTLocalizer.BoardingCannotLeaveZone
|
|
base.localAvatar.elevatorNotifier.showMe(rejectText)
|
|
return
|
|
|
|
loaderId = ZoneUtil.getBranchLoaderName(zoneId)
|
|
whereId = ZoneUtil.getToonWhereName(zoneId)
|
|
if hoodId == ToontownGlobals.MyEstate:
|
|
loaderId = 'safeZoneLoader'
|
|
whereId = 'estate'
|
|
|
|
if hoodId == ToontownGlobals.PartyHood:
|
|
loaderId = 'safeZoneLoader'
|
|
whereId = 'party'
|
|
|
|
self.requestLeave({'loader': loaderId,
|
|
'where': whereId,
|
|
'how': 'teleportIn',
|
|
'hoodId': hoodId,
|
|
'zoneId': zoneId,
|
|
'shardId': shardId,
|
|
'avId': avId})
|
|
|
|
def enterQuest(self, npcToon):
|
|
base.localAvatar.b_setAnimState('neutral', 1)
|
|
self.accept('teleportQuery', self.handleTeleportQuery)
|
|
base.localAvatar.setTeleportAvailable(1)
|
|
base.localAvatar.laffMeter.start()
|
|
base.localAvatar.obscureMoveFurnitureButton(1)
|
|
|
|
def exitQuest(self):
|
|
base.localAvatar.setTeleportAvailable(0)
|
|
self.ignore('teleportQuery')
|
|
base.localAvatar.laffMeter.stop()
|
|
base.localAvatar.obscureMoveFurnitureButton(-1)
|
|
|
|
def enterPurchase(self):
|
|
base.localAvatar.b_setAnimState('neutral', 1)
|
|
self.accept('teleportQuery', self.handleTeleportQuery)
|
|
base.localAvatar.setTeleportAvailable(1)
|
|
base.localAvatar.laffMeter.start()
|
|
base.localAvatar.obscureMoveFurnitureButton(1)
|
|
|
|
def exitPurchase(self):
|
|
base.localAvatar.setTeleportAvailable(0)
|
|
self.ignore('teleportQuery')
|
|
base.localAvatar.laffMeter.stop()
|
|
base.localAvatar.obscureMoveFurnitureButton(-1)
|
|
|
|
def enterFishing(self):
|
|
base.localAvatar.b_setAnimState('neutral', 1)
|
|
self.accept('teleportQuery', self.handleTeleportQuery)
|
|
base.localAvatar.setTeleportAvailable(1)
|
|
base.localAvatar.laffMeter.start()
|
|
|
|
def exitFishing(self):
|
|
base.localAvatar.setTeleportAvailable(0)
|
|
self.ignore('teleportQuery')
|
|
base.localAvatar.laffMeter.stop()
|
|
|
|
def enterBanking(self):
|
|
base.localAvatar.b_setAnimState('neutral', 1)
|
|
self.accept('teleportQuery', self.handleTeleportQuery)
|
|
base.localAvatar.setTeleportAvailable(1)
|
|
base.localAvatar.laffMeter.start()
|
|
base.localAvatar.obscureMoveFurnitureButton(1)
|
|
base.localAvatar.startSleepWatch(self.__handleFallingAsleepBanking)
|
|
self.enablePeriodTimer()
|
|
|
|
def __handleFallingAsleepBanking(self, arg):
|
|
if hasattr(self, 'fsm'):
|
|
messenger.send('bankAsleep')
|
|
self.fsm.request('walk')
|
|
|
|
base.localAvatar.forceGotoSleep()
|
|
|
|
def exitBanking(self):
|
|
base.localAvatar.setTeleportAvailable(0)
|
|
self.ignore('teleportQuery')
|
|
base.localAvatar.laffMeter.stop()
|
|
base.localAvatar.obscureMoveFurnitureButton(-1)
|
|
base.localAvatar.stopSleepWatch()
|
|
self.disablePeriodTimer()
|
|
|
|
def enterPhone(self):
|
|
base.localAvatar.b_setAnimState('neutral', 1)
|
|
self.accept('teleportQuery', self.handleTeleportQuery)
|
|
base.localAvatar.setTeleportAvailable(1)
|
|
base.localAvatar.laffMeter.start()
|
|
base.localAvatar.obscureMoveFurnitureButton(1)
|
|
base.localAvatar.startSleepWatch(self.__handleFallingAsleepPhone)
|
|
self.enablePeriodTimer()
|
|
|
|
def __handleFallingAsleepPhone(self, arg):
|
|
if hasattr(self, 'fsm'):
|
|
self.fsm.request('walk')
|
|
|
|
messenger.send('phoneAsleep')
|
|
base.localAvatar.forceGotoSleep()
|
|
|
|
def exitPhone(self):
|
|
base.localAvatar.setTeleportAvailable(0)
|
|
self.ignore('teleportQuery')
|
|
base.localAvatar.laffMeter.stop()
|
|
base.localAvatar.obscureMoveFurnitureButton(-1)
|
|
base.localAvatar.stopSleepWatch()
|
|
self.disablePeriodTimer()
|
|
|
|
def enterStopped(self):
|
|
base.localAvatar.b_setAnimState('neutral', 1)
|
|
globalEmote.disableBody(base.localAvatar, 'enterStopped')
|
|
self.accept('teleportQuery', self.handleTeleportQuery)
|
|
if base.localAvatar.isDisguised:
|
|
base.localAvatar.setTeleportAvailable(0)
|
|
else:
|
|
base.localAvatar.setTeleportAvailable(1)
|
|
|
|
base.localAvatar.laffMeter.start()
|
|
base.localAvatar.obscureMoveFurnitureButton(1)
|
|
base.localAvatar.startSleepWatch(self.__handleFallingAsleepStopped)
|
|
self.enablePeriodTimer()
|
|
|
|
def __handleFallingAsleepStopped(self, arg):
|
|
if hasattr(self, 'fsm'):
|
|
self.fsm.request('walk')
|
|
|
|
base.localAvatar.forceGotoSleep()
|
|
messenger.send('stoppedAsleep')
|
|
|
|
def exitStopped(self):
|
|
globalEmote.releaseBody(base.localAvatar, 'exitStopped')
|
|
base.localAvatar.setTeleportAvailable(0)
|
|
self.ignore('teleportQuery')
|
|
base.localAvatar.laffMeter.stop()
|
|
base.localAvatar.obscureMoveFurnitureButton(-1)
|
|
base.localAvatar.stopSleepWatch()
|
|
self.disablePeriodTimer()
|
|
messenger.send('exitingStoppedState')
|
|
|
|
def enterPet(self):
|
|
base.localAvatar.b_setAnimState('neutral', 1)
|
|
globalEmote.disableBody(base.localAvatar, 'enterPet')
|
|
self.accept('teleportQuery', self.handleTeleportQuery)
|
|
base.localAvatar.setTeleportAvailable(1)
|
|
base.localAvatar.setTeleportAllowed(0)
|
|
base.localAvatar.laffMeter.start()
|
|
self.enterFLM()
|
|
|
|
def exitPet(self):
|
|
base.localAvatar.setTeleportAvailable(0)
|
|
base.localAvatar.setTeleportAllowed(1)
|
|
globalEmote.releaseBody(base.localAvatar, 'exitPet')
|
|
self.ignore('teleportQuery')
|
|
base.localAvatar.laffMeter.stop()
|
|
self.exitFLM()
|
|
|
|
def enterQuietZone(self, requestStatus):
|
|
self.quietZoneDoneEvent = uniqueName('quietZoneDone')
|
|
self.acceptOnce(self.quietZoneDoneEvent, self.handleQuietZoneDone)
|
|
self.quietZoneStateData = QuietZoneState(self.quietZoneDoneEvent)
|
|
self.quietZoneStateData.load()
|
|
self.quietZoneStateData.enter(requestStatus)
|
|
|
|
def exitQuietZone(self):
|
|
self.ignore(self.quietZoneDoneEvent)
|
|
del self.quietZoneDoneEvent
|
|
self.quietZoneStateData.exit()
|
|
self.quietZoneStateData.unload()
|
|
self.quietZoneStateData = None
|
|
|
|
def handleQuietZoneDone(self):
|
|
how = base.cr.handlerArgs['how']
|
|
self.fsm.request(how, [base.cr.handlerArgs])
|