a3x/transpub
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

Update session.py

Browse source 
see issue #82
This commit is contained in:
Bee 2017-07-02 16:37:08 +02:00 committed by GitHub
parent fe0ffe7891
commit 6563c7282b
1 changed files with 22 additions and 27 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

35
transWhat/session.py
View file

@ -135,39 +135,34 @@ class Session(YowsupApp):
"\n".join(text) + "\nIf you do not join them you will lose messages" "\n".join(text) + "\nIf you do not join them you will lose messages"
#self.bot.send(message) #self.bot.send(message)
def _updateGroups(self, response, request): def _updateGroups(self, response, _):
self.logger.debug('Received groups list %s' % response) self.logger.debug('Received groups list %s' % response)
groups = response.getGroups() groups = response.getGroups()
for group in groups: for group in groups:
room = group.getId() room = group.getId()
# ensure self.groups[room] exists
if room not in self.groups:
owner = group.getOwner().split('@')[0] owner = group.getOwner().split('@')[0]
subjectOwner = group.getSubjectOwner().split('@')[0] subjectOwner = group.getSubjectOwner().split('@')[0]
subject = utils.softToUni(group.getSubject()) subject = utils.softToUni(group.getSubject())
self.groups[room] = Group(room, owner, subject, subjectOwner,
if room in self.groups: self.backend, self.user)
oroom = self.groups[room] # add/update room participants
oroom.owner = owner
oroom.subjectOwner = subjectOwner
oroom.subject = subject
else:
self.groups[room] = Group(room, owner, subject, subjectOwner, self.backend, self.user)
# self.joinRoom(self._shortenGroupId(room), self.user.split("@")[0])
self.groups[room].addParticipants(group.getParticipants().keys(), self.groups[room].addParticipants(group.getParticipants().keys(),
self.buddies, self.legacyName) self.buddies, self.legacyName)
self.gotGroupList = True
#self._addParticipantsToRoom(room, group.getParticipants()) # join rooms
while self.joinRoomQueue:
if room in self.groupOfflineQueue: self.joinRoom(*self.joinRoomQueue.pop(0))
# deliver queued offline messages
for room in self.groupOfflineQueue:
while self.groupOfflineQueue[room]: while self.groupOfflineQueue[room]:
msg = self.groupOfflineQueue[room].pop(0) msg = self.groupOfflineQueue[room].pop(0)
self.backend.handleMessage(self.user, room, msg[1], self.backend.handleMessage(self.user, room, msg[1], msg[0], "",
msg[0], "", msg[2]) msg[2])
self.logger.debug("Send queued group message to: %s %s %s" % self.logger.debug("Send queued group message to: %s %s %s" %
(msg[0], msg[1], msg[2])) (msg[0], msg[1], msg[2]))
self.gotGroupList = True # pass update to backend
for room, nick in self.joinRoomQueue:
self.joinRoom(room, nick)
self.joinRoomQueue = []
self.updateRoomList() self.updateRoomList()
def joinRoom(self, room, nick): def joinRoom(self, room, nick):