← 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 16:10:54 UTC
  • Revision ID: curtis.hovey@canonical.com-20120316161054-jk68i83kh81qm2vi
Store the body text only.

Show diffs side-by-side

added added

removed removed

Lines of Context:
grackle/store.py
2
2
    'MemoryStore',
3
3
    ]
4
4
 
 
5
import email
5
6
import simplejson
6
7
from urlparse import parse_qs
7
8
 
8
9
from grackle.error import (
 
10
    ArchiveIdNotFound,
9
11
    MessageIdNotFound,
10
12
    UnparsableDateRange,
11
13
    UnsupportedDisplayType,
36
38
    return threads.values()
37
39
 
38
40
 
39
 
def make_json_message(message_id, body='body', headers=None, hidden=False):
40
 
    if headers is None:
41
 
        headers = {}
42
 
    headers['Message-Id'] = message_id
 
41
def get_body_text(message):
 
42
    """Return the first plain/text messaage part."""
 
43
    if not message.is_multipart():
 
44
        return message.get_payload()
 
45
    for part in email.iterators.typed_subpart_iterator(message, 'multipart'):
 
46
        subparts = part.get_payload()
 
47
        for subpart in subparts:
 
48
            if subpart.get_content_type() == 'text/plain':
 
49
                return subpart.get_payload().strip()
 
50
    return ''
 
51
 
 
52
 
 
53
def make_json_message(message_id, raw_message, hidden=False):
 
54
    message = email.message_from_string(raw_message)
 
55
    headers = dict(message.items())
43
56
    message = {
44
57
        'message_id': message_id,
45
58
        'headers': headers,
46
 
        'thread_id': message_id,
47
 
        'date': headers.get('date', '2005-01-01'),
48
 
        'subject': headers.get('subject', 'subject'),
49
 
        'author': headers.get('author', 'author'),
 
59
        # This is broken because the in-reply-to must be encoded.
 
60
        # X-Message-ID-Hash is calculated from the Base 32.
 
61
        'thread_id': headers.get('in-reply-to', message_id),
 
62
        'date': headers.get('date'),
 
63
        'subject': headers.get('subject'),
 
64
        'author': headers.get('from'),
50
65
        'hidden': hidden,
51
66
        'attachments': [],
52
 
        'replies': headers.get('in-reply-to', None),
53
 
        'body': body,
 
67
        'replies': headers.get('in-reply-to'),
 
68
        'body': get_body_text(message),
54
69
        }
55
70
    return message
56
71
 
66
81
    def is_multipart(message):
67
82
        return isinstance(message['body'], list)
68
83
 
69
 
    def put_message(self, archive_id, message_id, message):
70
 
        # Make a json message.
 
84
    def put_message(self, archive_id, message_id, raw_message):
 
85
        # XXX sinzui 2012-02-29: this needs to raise an error
 
86
        # if the th archive_id is invalid, message_id is not base32
 
87
        # or the raw message is not an email.
 
88
        if archive_id not in self.message_archives:
 
89
            raise ArchiveIdNotFound()
 
90
        if not raw_message:
 
91
            raise ValueError('raw_message is not a message.')
 
92
        json_message = make_json_message(message_id, raw_message)
71
93
        messages = self.message_archives[archive_id]
72
 
        json_message = make_json_message(message_id, body=message)
73
94
        messages.append(json_message)
74
95
 
75
96
    def get_messages(self, archive_id, query_string):