# Twisted imports
from twisted.internet import reactor, task
from twisted.internet.defer import Deferred
# Twisted imports
from twisted.internet import reactor, task
from twisted.internet.defer import Deferred
MSNEventBase.connectionMade(self)
self._setState('CONNECTED')
self.sendLine("VER %s %s" % (self._nextTransactionID(), MSN_PROTOCOL_VERSION))
MSNEventBase.connectionMade(self)
self._setState('CONNECTED')
self.sendLine("VER %s %s" % (self._nextTransactionID(), MSN_PROTOCOL_VERSION))
def connectionLost(self, reason):
self._setState('DISCONNECTED')
def connectionLost(self, reason):
self._setState('DISCONNECTED')
def handle_OUT(self, params):
checkParamLen(len(params), 1, 'OUT')
def handle_OUT(self, params):
checkParamLen(len(params), 1, 'OUT')
if params[0] == "OTH": self.multipleLogin()
elif params[0] == "SSD": self.serverGoingDown()
else: raise MSNProtocolError, "Invalid Parameters received for OUT" # debug
if params[0] == "OTH": self.multipleLogin()
elif params[0] == "SSD": self.serverGoingDown()
else: raise MSNProtocolError, "Invalid Parameters received for OUT" # debug
(the whole URL is required)
@ivar status: The status of the client -- this is generally kept
up to date by the default command handlers
(the whole URL is required)
@ivar status: The status of the client -- this is generally kept
up to date by the default command handlers
slpLink = SLPLink_AvatarReceive(remoteUser=msnContact.userHandle, switchboard=self, consumer=buffer, context=msnContact.msnobj.text)
self.slpLinks[slpLink.sessionID] = slpLink
return d
slpLink = SLPLink_AvatarReceive(remoteUser=msnContact.userHandle, switchboard=self, consumer=buffer, context=msnContact.msnobj.text)
self.slpLinks[slpLink.sessionID] = slpLink
return d
def handleSLPMessage(self, slpMessage):
if slpMessage.status == "200":
def handleSLPMessage(self, slpMessage):
if slpMessage.status == "200":