← 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 20:16:12 UTC
  • Revision ID: curtis.hovey@canonical.com-20120316201612-lr7b32umqgduaja6
Added a rudimentary put_archive.

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,
10
11
    ArchiveIdNotFound,
11
12
    MessageIdNotFound,
12
13
    UnparsableDateRange,
38
39
    return threads.values()
39
40
 
40
41
 
41
 
def make_json_message(message_id, raw_message):
 
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):
42
55
    message = email.message_from_string(raw_message)
43
56
    headers = dict(message.items())
44
57
    message = {
50
63
        'date': headers.get('date'),
51
64
        'subject': headers.get('subject'),
52
65
        'author': headers.get('from'),
53
 
        'hidden': False,
 
66
        'hidden': hidden,
54
67
        'attachments': [],
55
 
        'replies': [],
56
 
        'body': raw_message,
 
68
        'replies': headers.get('in-reply-to'),
 
69
        'body': get_body_text(message),
57
70
        }
58
71
    return message
59
72
 
69
82
    def is_multipart(message):
70
83
        return isinstance(message['body'], list)
71
84
 
 
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
 
72
92
    def put_message(self, archive_id, message_id, raw_message):
73
93
        # XXX sinzui 2012-02-29: this needs to raise an error
74
94
        # if the th archive_id is invalid, message_id is not base32
176
196
            }
177
197
        return response
178
198
 
179
 
    def hide_message(self, archive_id, query_string):
180
 
        """Return matching messages.
 
199
    def hide_message(self, archive_id, message_id, query_string):
 
200
        """Change the visbility of a message in an archive.
181
201
 
182
202
        :param archive_id: The archive to retrieve from.
183
203
        :param query_string: Contains 'parameters', which is a JSON-format
185
205
        """
186
206
        query = parse_qs(query_string)
187
207
        parameters = simplejson.loads(query['parameters'][0])
188
 
        message_id = parameters['message_id']
189
208
        hidden = parameters['hidden']
190
209
        messages = self.message_archives[archive_id]
191
210
        for message in messages: