← Back to branch summary

~didrocks/unity/altf10

« back to all changes in this revision

Viewing changes to grackle/store.py

  • Committer: Curtis Hovey
  • Date: 2012-03-16 15:01:18 UTC
  • Revision ID: curtis.hovey@canonical.com-20120316150118-jqk101q03432af8x
Use a real rfc822 message for mime testing.

Show diffs side-by-side

added added

removed removed

Lines of Context:
grackle/store.py
7
7
from urlparse import parse_qs
8
8
 
9
9
from grackle.error import (
10
 
    ArchiveIdExists,
11
10
    ArchiveIdNotFound,
12
11
    MessageIdNotFound,
13
12
    UnparsableDateRange,
39
38
    return threads.values()
40
39
 
41
40
 
42
 
def get_body_text(message):
43
 
    """Return the first plain/text messaage part."""
44
 
    if not message.is_multipart():
45
 
        return message.get_payload()
46
 
    for part in email.iterators.typed_subpart_iterator(message, 'multipart'):
47
 
        subparts = part.get_payload()
48
 
        for subpart in subparts:
49
 
            if subpart.get_content_type() == 'text/plain':
50
 
                return subpart.get_payload().strip()
51
 
    return ''
52
 
 
53
 
 
54
 
def make_json_message(message_id, raw_message, hidden=False):
 
41
def make_json_message(message_id, raw_message):
55
42
    message = email.message_from_string(raw_message)
56
43
    headers = dict(message.items())
57
44
    message = {
63
50
        'date': headers.get('date'),
64
51
        'subject': headers.get('subject'),
65
52
        'author': headers.get('from'),
66
 
        'hidden': hidden,
 
53
        'hidden': False,
67
54
        'attachments': [],
68
 
        'replies': headers.get('in-reply-to'),
69
 
        'body': get_body_text(message),
 
55
        'replies': [],
 
56
        'body': raw_message,
70
57
        }
71
58
    return message
72
59
 
82
69
    def is_multipart(message):
83
70
        return isinstance(message['body'], list)
84
71
 
85
 
    def put_archive(self, archive_id, raw_archive=None):
86
 
        # XXX sinzui 2012-02-29: this needs to raise an error
87
 
        # if the th archive_id is invalid, or the raw archive is not mbox.
88
 
        if archive_id in self.message_archives:
89
 
            raise ArchiveIdExists()
90
 
        self.message_archives[archive_id] = []
91
 
 
92
72
    def put_message(self, archive_id, message_id, raw_message):
93
73
        # XXX sinzui 2012-02-29: this needs to raise an error
94
74
        # if the th archive_id is invalid, message_id is not base32
196
176
            }
197
177
        return response
198
178
 
199
 
    def hide_message(self, archive_id, message_id, query_string):
200
 
        """Change the visbility of a message in an archive.
 
179
    def hide_message(self, archive_id, query_string):
 
180
        """Return matching messages.
201
181
 
202
182
        :param archive_id: The archive to retrieve from.
203
183
        :param query_string: Contains 'parameters', which is a JSON-format
205
185
        """
206
186
        query = parse_qs(query_string)
207
187
        parameters = simplejson.loads(query['parameters'][0])
 
188
        message_id = parameters['message_id']
208
189
        hidden = parameters['hidden']
209
190
        messages = self.message_archives[archive_id]
210
191
        for message in messages: