X-Git-Url: http://git.maemo.org/git/?p=theonering;a=blobdiff_plain;f=src%2Fgvoice%2Fconversations.py;h=fed382b7d2ef8fe9ad4086ddbe0391a7a78b3044;hp=fad4b407e4b2f07d20f1038660f5cb79c7278d3c;hb=074b7adedaeba92d5993f8015be26c684f8bbfd8;hpb=fc96b200d858e66bbf02037b5002a07cd71c2654;ds=sidebyside diff --git a/src/gvoice/conversations.py b/src/gvoice/conversations.py index fad4b40..fed382b 100644 --- a/src/gvoice/conversations.py +++ b/src/gvoice/conversations.py @@ -1,24 +1,64 @@ #!/usr/bin/python +from __future__ import with_statement +import datetime import logging -import util.coroutines as coroutines +try: + import cPickle + pickle = cPickle +except ImportError: + import pickle -import backend +import constants +import util.coroutines as coroutines +import util.misc as misc_utils -_moduleLogger = logging.getLogger("gvoice.conversations") +_moduleLogger = logging.getLogger(__name__) class Conversations(object): - def __init__(self, backend): - self._backend = backend + def __init__(self, getter): + self._get_raw_conversations = getter self._conversations = {} self.updateSignalHandler = coroutines.CoTee() - self.update() + + @property + def _name(self): + return repr(self._get_raw_conversations.__name__) + + def load(self, path): + assert not self._conversations + try: + with open(path, "rb") as f: + fileVersion, fileBuild, convs = pickle.load(f) + except (pickle.PickleError, IOError, EOFError, ValueError): + _moduleLogger.exception("While loading for %s" % self._name) + return + + if misc_utils.compare_versions( + misc_utils.parse_version("0.8.0"), + misc_utils.parse_version(fileVersion), + ) <= 0: + self._conversations = convs + else: + _moduleLogger.debug( + "%s Skipping cache due to version mismatch (%s-%s)" % ( + self._name, fileVersion, fileBuild + ) + ) + + def save(self, path): + try: + dataToDump = (constants.__version__, constants.__build__, self._conversations) + with open(path, "wb") as f: + pickle.dump(dataToDump, f, pickle.HIGHEST_PROTOCOL) + except (pickle.PickleError, IOError): + _moduleLogger.exception("While saving for %s" % self._name) def update(self, force=False): if not force and self._conversations: @@ -27,23 +67,23 @@ class Conversations(object): oldConversationIds = set(self._conversations.iterkeys()) updateConversationIds = set() - messages = self._backend.get_messages() - sortedMessages = backend.sort_messages(messages) - for messageData in sortedMessages: - key = messageData["contactId"], messageData["number"] + conversations = list(self._get_raw_conversations()) + conversations.sort() + for conversation in conversations: + key = misc_utils.normalize_number(conversation.number) try: - conversation = self._conversations[key] - isNewConversation = False + mergedConversations = self._conversations[key] except KeyError: - conversation = Conversation(self._backend, messageData) - self._conversations[key] = conversation - isNewConversation = True + mergedConversations = MergedConversations() + self._conversations[key] = mergedConversations - if isNewConversation: - # @todo see if this has issues with a user marking a item as unread/unarchive? + try: + mergedConversations.append_conversation(conversation) isConversationUpdated = True - else: - isConversationUpdated = conversation.merge_conversation(messageData) + except RuntimeError, e: + if False: + _moduleLogger.debug("%s Skipping conversation for %r because '%s'" % (self._name, key, e)) + isConversationUpdated = False if isConversationUpdated: updateConversationIds.add(key) @@ -58,53 +98,130 @@ class Conversations(object): def get_conversation(self, key): return self._conversations[key] + def clear_conversation(self, key): + try: + del self._conversations[key] + except KeyError: + _moduleLogger.info("%s Conversation never existed for %r" % (self._name, key, )) + + def clear_all(self): + self._conversations.clear() + + +class MergedConversations(object): + + def __init__(self): + self._conversations = [] + + def append_conversation(self, newConversation): + self._validate(newConversation) + similarExist = False + for similarConversation in self._find_related_conversation(newConversation.id): + self._update_previous_related_conversation(similarConversation, newConversation) + self._remove_repeats(similarConversation, newConversation) + similarExist = True + if similarExist: + # Hack to reduce a race window with GV marking messages as read + # because it thinks we replied when really we replied to the + # previous message. Clients of this code are expected to handle + # this gracefully. Other race conditions may exist but clients are + # responsible for them + if newConversation.messages: + newConversation.isRead = False + else: + newConversation.isRead = True + self._conversations.append(newConversation) -class Conversation(object): + def to_dict(self): + selfDict = {} + selfDict["conversations"] = [conv.to_dict() for conv in self._conversations] + return selfDict - def __init__(self, backend, data): - self._backend = backend - self._data = dict((key, value) for (key, value) in data.iteritems()) + @property + def conversations(self): + return self._conversations - # confirm we have a list - self._data["messageParts"] = list( - self._append_time(message, self._data["time"]) - for message in self._data["messageParts"] - ) + def _validate(self, newConversation): + if not self._conversations: + return - def __getitem__(self, key): - return self._data[key] + for constantField in ("number", ): + assert getattr(self._conversations[0], constantField) == getattr(newConversation, constantField), "Constant field changed, soemthing is seriously messed up: %r v %r" % ( + getattr(self._conversations[0], constantField), + getattr(newConversation, constantField), + ) - def merge_conversation(self, moreData): - """ - @returns True if there was content to merge (new messages arrived - rather than being a duplicate) + if newConversation.time <= self._conversations[-1].time: + raise RuntimeError("Conversations got out of order") - @warning This assumes merges are done in chronological order - """ - for constantField in ("contactId", "number"): - assert self._data[constantField] == moreData[constantField], "Constant field changed, soemthing is seriously messed up: %r v %r" % (self._data, moreData) + def _find_related_conversation(self, convId): + similarConversations = ( + conversation + for conversation in self._conversations + if conversation.id == convId + ) + return similarConversations + + def _update_previous_related_conversation(self, relatedConversation, newConversation): + for commonField in ("isSpam", "isTrash", "isArchived"): + newValue = getattr(newConversation, commonField) + setattr(relatedConversation, commonField, newValue) + + def _remove_repeats(self, relatedConversation, newConversation): + newConversationMessages = newConversation.messages + newConversation.messages = [ + newMessage + for newMessage in newConversationMessages + if newMessage not in relatedConversation.messages + ] + _moduleLogger.debug("Found %d new messages in conversation %s (%d/%d)" % ( + len(newConversationMessages) - len(newConversation.messages), + newConversation.id, + len(newConversation.messages), + len(newConversationMessages), + )) + assert 0 < len(newConversation.messages), "Everything shouldn't have been removed" + + +def filter_out_read(conversations): + return ( + conversation + for conversation in conversations + if not conversation.isRead and not conversation.isArchived + ) + + +def is_message_from_self(message): + return message.whoFrom == "Me:" + + +def filter_out_self(conversations): + return ( + newConversation + for newConversation in conversations + if len(newConversation.messages) and any( + not is_message_from_self(message) + for message in newConversation.messages + ) + ) - if moreData["time"] < self._data["time"]: - # If its older, assuming it has nothing new to report - return False - for preferredMoreField in ("id", "name", "time", "relTime", "prettyNumber", "location"): - preferredFieldValue = moreData[preferredMoreField] - if preferredFieldValue: - self._data[preferredMoreField] = preferredFieldValue +class FilterOutReported(object): - messageAppended = False + NULL_TIMESTAMP = datetime.datetime(1, 1, 1) - messageParts = self._data["messageParts"] - for message in moreData["messageParts"]: - messageWithTimestamp = self._append_time(message, moreData["time"]) - if messageWithTimestamp not in messageParts: - messageParts.append(messageWithTimestamp) - messageAppended = True + def __init__(self): + self._lastMessageTimestamp = self.NULL_TIMESTAMP - return messageAppended + def get_last_timestamp(self): + return self._lastMessageTimestamp - @staticmethod - def _append_time(message, exactWhen): - whoFrom, message, when = message - return whoFrom, message, when, exactWhen + def __call__(self, conversations): + filteredConversations = [ + conversation + for conversation in conversations + if self._lastMessageTimestamp < conversation.time + ] + if filteredConversations and self._lastMessageTimestamp < filteredConversations[0].time: + self._lastMessageTimestamp = filteredConversations[0].time + return filteredConversations