44 lines
2 KiB
Python
44 lines
2 KiB
Python
from direct.distributed.PyDatagram import *
|
|
import urlparse
|
|
from otp.distributed.OtpDoGlobals import *
|
|
from otp.distributed.DistributedDirectoryAI import DistributedDirectoryAI
|
|
from toontown.distributed.ToontownInternalRepository import ToontownInternalRepository
|
|
import toontown.minigame.MinigameCreatorAI
|
|
from toontown.uberdog.TopToonsManagerUD import TopToonsManagerUD
|
|
|
|
if config.GetBool('want-rpc-server', False):
|
|
from toontown.rpc.ToontownRPCServer import ToontownRPCServer
|
|
from toontown.rpc.ToontownRPCHandler import ToontownRPCHandler
|
|
|
|
class ToontownUberRepository(ToontownInternalRepository):
|
|
def __init__(self, baseChannel, serverId):
|
|
ToontownInternalRepository.__init__(self, baseChannel, serverId, dcSuffix='UD')
|
|
|
|
self.notify.setInfo(True)
|
|
self.wantTopToons = self.config.GetBool('want-top-toons', True)
|
|
|
|
def handleConnected(self):
|
|
ToontownInternalRepository.handleConnected(self)
|
|
rootObj = DistributedDirectoryAI(self)
|
|
rootObj.generateWithRequiredAndId(self.getGameDoId(), 0, 0)
|
|
|
|
if config.GetBool('want-rpc-server', False):
|
|
endpoint = config.GetString('rpc-server-endpoint', 'http://localhost:8080/')
|
|
self.rpcServer = ToontownRPCServer(endpoint, ToontownRPCHandler(self))
|
|
self.rpcServer.start(useTaskChain=True)
|
|
|
|
self.createGlobals()
|
|
self.notify.info('Done.')
|
|
|
|
def createGlobals(self):
|
|
"""
|
|
Create "global" objects.
|
|
"""
|
|
|
|
self.csm = simbase.air.generateGlobalObject(OTP_DO_ID_CLIENT_SERVICES_MANAGER, 'ClientServicesManager')
|
|
self.chatAgent = simbase.air.generateGlobalObject(OTP_DO_ID_CHAT_MANAGER, 'ChatAgent')
|
|
self.friendsManager = simbase.air.generateGlobalObject(OTP_DO_ID_TTS_FRIENDS_MANAGER, 'TTSFriendsManager')
|
|
self.globalPartyMgr = simbase.air.generateGlobalObject(OTP_DO_ID_GLOBAL_PARTY_MANAGER, 'GlobalPartyManager')
|
|
if self.wantTopToons:
|
|
self.topToonsMgr = TopToonsManagerUD(self)
|
|
|