transpub/whatsappbackend.py

147 lines
5.3 KiB
Python
Raw Normal View History

__author__ = "Steffen Vogel"
__copyright__ = "Copyright 2015, Steffen Vogel"
__license__ = "GPLv3"
__maintainer__ = "Steffen Vogel"
__email__ = "post@steffenvogel.de"
2013-08-01 23:45:51 +00:00
"""
2013-08-01 23:45:51 +00:00
This file is part of transWhat
transWhat is free software: you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
the Free Software Foundation, either version 3 of the License, or
any later version.
transwhat is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
GNU General Public License for more details.
You should have received a copy of the GNU General Public License
along with transWhat. If not, see <http://www.gnu.org/licenses/>.
"""
2013-05-31 18:53:21 +00:00
from Spectrum2.backend import SpectrumBackend
from Spectrum2 import protocol_pb2
from session import Session
import logging
class WhatsAppBackend(SpectrumBackend):
2015-12-02 21:06:56 +00:00
def __init__(self, io, spectrum_jid):
2013-05-31 18:53:21 +00:00
SpectrumBackend.__init__(self)
2013-06-28 19:37:39 +00:00
self.logger = logging.getLogger(self.__class__.__name__)
2013-05-31 18:53:21 +00:00
self.io = io
self.sessions = { }
self.spectrum_jid = spectrum_jid
# Used to prevent duplicate messages
self.lastMsgId = {}
2013-05-31 18:53:21 +00:00
self.logger.debug("Backend started")
2013-05-31 18:53:21 +00:00
# RequestsHandlers
def handleLoginRequest(self, user, legacyName, password, extra):
self.logger.debug("handleLoginRequest(user=%s, legacyName=%s)", user, legacyName)
2013-06-28 19:37:39 +00:00
if user not in self.sessions:
2015-12-02 21:06:56 +00:00
self.sessions[user] = Session(self, user, legacyName, extra)
2013-06-28 19:37:39 +00:00
self.sessions[user].login(password)
2013-05-31 18:53:21 +00:00
def handleLogoutRequest(self, user, legacyName):
self.logger.debug("handleLogoutRequest(user=%s, legacyName=%s)", user, legacyName)
2013-06-28 19:37:39 +00:00
if user in self.sessions:
self.sessions[user].logout()
del self.sessions[user]
2013-05-31 18:53:21 +00:00
def handleMessageSendRequest(self, user, buddy, message, xhtml="", ID=""):
self.logger.debug("handleMessageSendRequest(user=%s, buddy=%s, message=%s, xhtml=%s, ID=%s)", user, buddy, message, xhtml, ID)
# For some reason spectrum occasionally sends to identical messages to
# a buddy, one to the bare jid and one to the /bot resource. This
# causes duplicate messages. Thus we should not send consecutive
# messages with the same id
if ID == '':
self.sessions[user].sendMessageToWA(buddy, message, ID, xhtml)
elif user not in self.lastMsgId or self.lastMsgId[user] != ID:
self.sessions[user].sendMessageToWA(buddy, message, ID, xhtml)
self.lastMsgId[user] = ID
2013-05-31 18:53:21 +00:00
def handleJoinRoomRequest(self, user, room, nickname, pasword):
self.logger.debug("handleJoinRoomRequest(user=%s, room=%s, nickname=%s)", user, room, nickname)
2013-06-28 19:37:39 +00:00
self.sessions[user].joinRoom(room, nickname)
2013-05-31 18:53:21 +00:00
def handleLeaveRoomRequest(self, user, room):
self.logger.debug("handleLeaveRoomRequest(user=%s, room=%s)", user, room)
self.sessions[user].leaveRoom(room)
2013-05-31 18:53:21 +00:00
def handleStatusChangeRequest(self, user, status, statusMessage):
self.logger.debug("handleStatusChangeRequest(user=%s, status=%d, statusMessage=%s)", user, status, statusMessage)
self.sessions[user].changeStatusMessage(statusMessage)
2013-05-31 18:53:21 +00:00
self.sessions[user].changeStatus(status)
2015-12-01 19:33:02 +00:00
def handleBuddies(self, buddies):
"""Called when user logs in. Used to initialize roster."""
self.logger.debug("handleBuddies(buddies=%s)", buddies)
2015-12-01 21:21:38 +00:00
buddies = [b for b in buddies.buddy]
if len(buddies) > 0:
user = buddies[0].userName
self.sessions[user].loadBuddies(buddies)
2015-12-01 19:33:02 +00:00
2013-05-31 18:53:21 +00:00
def handleBuddyUpdatedRequest(self, user, buddy, nick, groups):
self.logger.debug("handleBuddyUpdatedRequest(user=%s, buddy=%s, nick=%s, groups=%s)", user, buddy, nick, str(groups))
2013-05-31 18:53:21 +00:00
self.sessions[user].updateBuddy(buddy, nick, groups)
def handleBuddyRemovedRequest(self, user, buddy, groups):
self.logger.debug("handleBuddyRemovedRequest(user=%s, buddy=%s, groups=%s)", user, buddy, str(groups))
2013-05-31 18:53:21 +00:00
self.sessions[user].removeBuddy(buddy)
def handleTypingRequest(self, user, buddy):
self.logger.debug("handleTypingRequest(user=%s, buddy=%s)", user, buddy)
2013-05-31 18:53:21 +00:00
self.sessions[user].sendTypingStarted(buddy)
def handleTypedRequest(self, user, buddy):
self.logger.debug("handleTypedRequest(user=%s, buddy=%s)", user, buddy)
2013-05-31 18:53:21 +00:00
self.sessions[user].sendTypingStopped(buddy)
def handleStoppedTypingRequest(self, user, buddy):
self.logger.debug("handleStoppedTypingRequest(user=%s, buddy=%s)", user, buddy)
2013-05-31 18:53:21 +00:00
self.sessions[user].sendTypingStopped(buddy)
def handleVCardRequest(self, user, buddy, ID):
self.logger.debug("handleVCardRequest(user=%s, buddy=%s, ID=%s)", user, buddy, ID)
self.sessions[user].requestVCard(buddy, ID)
2013-06-28 19:37:39 +00:00
# TODO
def handleBuddyBlockToggled(self, user, buddy, blocked):
pass
def handleVCardUpdatedRequest(self, user, photo, nickname):
pass
2013-05-31 18:53:21 +00:00
def handleAttentionRequest(self, user, buddy, message):
pass
def handleFTStartRequest(self, user, buddy, fileName, size, ftID):
self.logger.debug('File send request %s, for user %s, from %s, size: %s',
fileName, user, buddy, size)
2013-05-31 18:53:21 +00:00
def handleFTFinishRequest(self, user, buddy, fileName, size, ftID):
pass
def handleFTPauseRequest(self, ftID):
pass
def handleFTContinueRequest(self, ftID):
pass
def handleRawXmlRequest(self, xml):
pass
def handleMessageAckRequest(self, user, legacyName, ID = 0):
self.logger.info("Meassage ACK request for %s !!",legacyName)
2013-05-31 18:53:21 +00:00
def sendData(self, data):
self.io.sendData(data)