~didrocks/unity/altf10

from BaseHTTPServer import (

    HTTPServer,

    BaseHTTPRequestHandler,

    )

from email.message import Message

from email.mime.multipart import MIMEMultipart

from email.mime.text import MIMEText

import httplib

import logging

import os

from signal import SIGKILL

import simplejson

from StringIO import StringIO

import sys

from unittest import TestCase

from urlparse import urlparse

from testtools import ExpectedException

from grackle.client import (

    GrackleClient,

    UnparsableDateRange,

    UnsupportedDisplayType,

    UnsupportedOrder,

    )

from grackle.store import (

    make_json_message,

    MemoryStore,

    )

def make_message(message_id, body='body', headers=None, hidden=False):

    if headers is None:

        headers = {}

    message_headers = {

        'Message-Id': message_id,

        'date': '2005-01-01',

        'subject': 'subject',

        'from': 'author',

        'replies': '',

        }

    message_headers.update(headers.items())

    message = Message()

    message.set_payload(body)

    for key, value in message_headers.items():

        message[key] = value

    return make_json_message(message_id, message.as_string(), hidden)

def make_mime_message(message_id, body='body', headers=None, hidden=False,

                      attachment_type=None):

    parts = MIMEMultipart()

    parts.attach(MIMEText(body))

    if attachment_type is not None:

        attachment = Message()

        attachment.set_payload('attactment data.')

        attachment['Content-Type'] = attachment_type

        attachment['Content-Disposition'] = 'attachment; filename="file.ext"'

        parts.attach(attachment)

    return make_message(message_id, parts.as_string(), headers, hidden)

class ForkedFakeService:

    """A Grackle service fake, as a ContextManager."""

    def __init__(self, port, message_archives=None, write_logs=False):

        """Constructor.

        :param port: The tcp port to use.

        :param message_archives: A dict of lists of dicts representing

            archives of messages. The outer dict represents the archive,

            the list represents the list of messages for that archive.

        :param write_logs: If true, log messages will be written to stdout.

        """

        self.pid = None

        self.port = port

        if message_archives is None:

            self.message_archives = {}

        else:

            self.message_archives = message_archives

        self.read_end, self.write_end = os.pipe()

        self.write_logs = write_logs

    @staticmethod

    def from_client(client, message_archives=None):

        """Instantiate a ForkedFakeService from the client.

        :param port: The client to provide service for.

        :param message_archives: A dict of lists of dicts representing

            archives of messages. The outer dict represents the archive,

            the list represents the list of messages for that archive.

        """

        return ForkedFakeService(client.port, message_archives)

    def is_ready(self):

        """Tell the parent process that the server is ready for writes."""

        os.write(self.write_end, 'asdf')

    def __enter__(self):

        """Run the service.

        Fork and start a server in the child.  Return when the server is ready

        for use."""

        pid = os.fork()

        if pid == 0:

            self.start_server()

        self.pid = pid

        os.read(self.read_end, 1)

        return

    def start_server(self):

        """Start the HTTP server."""

        service = HTTPServer(('', self.port), FakeGrackleRequestHandler)

        service.store = MemoryStore(self.message_archives)

        for archive_id, messages in service.store.message_archives.iteritems():

            for message in messages:

                message.setdefault('headers', {})

        self.is_ready()

        if self.write_logs:

            logging.basicConfig(

                stream=sys.stderr, level=logging.INFO)

        service.serve_forever()

    def __exit__(self, exc_type, exc_val, traceback):

        os.kill(self.pid, SIGKILL)

class FakeGrackleRequestHandler(BaseHTTPRequestHandler):

    """A request handler that forwards to server.store."""

    def __init__(self, *args, **kwargs):

        """Constructor.  Sets up logging."""

        self.logger = logging.getLogger('http')

        BaseHTTPRequestHandler.__init__(self, *args, **kwargs)

    def do_PUT(self):

        """Create an archive or message on PUT."""

        scheme, netloc, path, params, query_string, fragments = (

            urlparse(self.path))

        parts = path.split('/')

        if parts[1] != 'archive':

            # This is an unknonwn operation?

            return

        if len(parts) == 3:

            # This expected path is /archive/archive_id.

            try:

                self.server.store.put_archive(parts[2])

                self.send_response(httplib.CREATED)

                self.end_headers()

                self.wfile.close()

            except:

                self.send_error(httplib.BAD_REQUEST)

        if len(parts) == 4:

            # This expected path is /archive/archive_id/message_id.

            try:

                message = self.rfile.read(int(self.headers['content-length']))

                self.server.store.put_message(parts[2], parts[3], message)

                self.send_response(httplib.CREATED)

                self.end_headers()

                self.wfile.close()

            except:

                self.send_error(httplib.BAD_REQUEST)

    def do_POST(self):

        """Change a message on POST."""

        scheme, netloc, path, params, query_string, fragments = (

            urlparse(self.path))

        parts = path.split('/')

        if parts[1] != 'archive':

            # This is an unknonwn operation?

            return

        if len(parts) == 4:

            # This expected path is /archive/archive_id/message_id.

            try:

                # This expected path is /archive/archive_id/message_id.

                response = self.server.store.hide_message(

                    parts[2], parts[3], query_string)

                self.send_response(httplib.OK)

                self.end_headers()

                self.wfile.write(simplejson.dumps(response))

            except:

                self.send_error(httplib.BAD_REQUEST)

    def do_GET(self):

        """Retrieve a list of messages on GET."""

        scheme, netloc, path, params, query_string, fragments = (

            urlparse(self.path))

        parts = path.split('/')

        if parts[1] == 'archive':

            try:

                response = self.server.store.get_messages(

                    parts[2], query_string)

                self.send_response(httplib.OK)

                self.end_headers()

                self.wfile.write(simplejson.dumps(response))

            except Exception, error:

                self.send_response(

                    httplib.BAD_REQUEST, error.__doc__)

                return

    def log_message(self, format, *args):

        """Override log_message to use standard Python logging."""

        message = "%s - - [%s] %s\n" % (

            self.address_string(), self.log_date_time_string(), format % args)

        self.logger.info(message)

class TestPutArchive(TestCase):

    def test_put_message(self):

        client = GrackleClient('localhost', 8410)

        message_archives = {}

        with ForkedFakeService.from_client(client, message_archives):

            client.put_archive('arch1')

            response = client.get_messages('arch1')

        self.assertEqual(0, len(response['messages']))

class TestPutMessage(TestCase):

    def test_put_message(self):

        client = GrackleClient('localhost', 8420)

        message_archives = {'arch1': []}

        with ForkedFakeService.from_client(client, message_archives):

            client.put_message('arch1', 'id1', StringIO('This is a message'))

            response = client.get_messages('arch1')

        self.assertEqual(1, len(response['messages']))

        message = response['messages'][0]

        self.assertEqual('id1', message['message_id'])

    def test_put_message_without_archive(self):

        client = GrackleClient('localhost', 8421)

        message_archives = {'arch1': []}

        with ForkedFakeService.from_client(client, message_archives):

            with ExpectedException(Exception, 'wtf'):

                client.put_message('no-archive', 'id1', StringIO('message'))

class TestGetMessages(TestCase):

    def assertIDOrder(self, ids, messages):

        self.assertEqual(ids, [m['message_id'] for m in messages])

    def assertMessageIDs(self, ids, messages):

        self.assertIDOrder(

            sorted(ids), sorted(messages, key=lambda m: m['message_id']))

    def test_get_messages(self):

        client = GrackleClient('localhost', 8430)

        archive = {

            'baz': [make_message('foo'), make_message('bar')]}

        with ForkedFakeService.from_client(client, archive):

            response = client.get_messages('baz')

        self.assertEqual(['bar', 'foo'], sorted(m['message_id'] for m in

            response['messages']))

        self.assertIs(None, response['next_memo'])

        self.assertIs(None, response['previous_memo'])

    def test_get_messages_by_id(self):

        client = GrackleClient('localhost', 8437)

        archive = {

            'baz': [make_message('foo'), make_message('bar')]}

        with ForkedFakeService.from_client(client, archive):

            response = client.get_messages('baz', message_ids=['foo'])

        message, = response['messages']

        self.assertEqual('foo', message['message_id'])

    def test_get_messages_batching(self):

        client = GrackleClient('localhost', 8438)

        archive = {'baz': [make_message('foo'), make_message('bar')]}

        with ForkedFakeService.from_client(client, archive):

            response = client.get_messages('baz', limit=1)

            self.assertEqual(1, len(response['messages']))

            messages = response['messages']

            response = client.get_messages(

                'baz', limit=1, memo=response['next_memo'])

            self.assertEqual(1, len(response['messages']))

            messages.extend(response['messages'])

            self.assertMessageIDs(['foo', 'bar'], messages)

    def get_messages_member_order_test(self, key):

        client = GrackleClient('localhost', 8439)

        if key == 'author':

            header_name = 'from'

        else:

            header_name = key

        archive = {

            'baz': [

                make_message('foo', headers={header_name: '2011-03-25'}),

                make_message('bar', headers={header_name: '2011-03-24'}),

             ]}

        with ForkedFakeService.from_client(client, archive):

            response = client.get_messages('baz')

            self.assertIDOrder(['foo', 'bar'], response['messages'])

            response = client.get_messages('baz', order=key)

            self.assertIDOrder(['bar', 'foo'], response['messages'])

    def test_get_messages_date_order(self):

        self.get_messages_member_order_test('date')

    def test_get_messages_author_order(self):

        self.get_messages_member_order_test('author')

    def test_get_messages_subject_order(self):

        self.get_messages_member_order_test('subject')

    def test_get_messages_thread_subject_order(self):

        archive = {

            'baz': [

                make_message('bar', headers={'subject': 'y'}),

                make_message('qux', headers={'subject': 'z'}),

                make_message('foo', headers={'subject': 'x',

                                             'in-reply-to': 'qux'}),

             ]}

        client = GrackleClient('localhost', 8439)

        with ForkedFakeService.from_client(client, archive):

            response = client.get_messages('baz')

            self.assertIDOrder(['bar', 'qux', 'foo'], response['messages'])

            response = client.get_messages('baz', order='subject')

            self.assertIDOrder(['foo', 'bar', 'qux'], response['messages'])

            response = client.get_messages('baz', order='thread_subject')

            self.assertIDOrder(['bar', 'qux', 'foo'], response['messages'])

    def test_get_messages_thread_oldest_order(self):

        client = GrackleClient('localhost', 8439)

        archive = {

            'baz': [

                make_message('bar', headers={'date': 'x'}),

                make_message('qux', headers={'date': 'z'}),

                make_message('foo', headers={'date': 'y',

                                             'in-reply-to': 'qux'}),

            ]}

        with ForkedFakeService.from_client(client, archive):

            response = client.get_messages('baz')

            self.assertIDOrder(['bar', 'qux', 'foo'], response['messages'])

            response = client.get_messages('baz', order='date')

            self.assertIDOrder(['bar', 'foo', 'qux'], response['messages'])

            response = client.get_messages('baz', order='thread_oldest')

            self.assertIDOrder(['bar', 'qux', 'foo'], response['messages'])

    def test_get_messages_thread_newest_order(self):

        client = GrackleClient('localhost', 8439)

        archive = {

            'baz': [

                make_message('bar', headers={'date': 'x'}),

                make_message('qux', headers={'date': 'w'}),

                make_message('foo', headers={'date': 'y',

                                             'in-reply-to': 'bar'}),

                make_message('baz', headers={'date': 'z',

                                             'in-reply-to': 'qux'}),

            ]}

        with ForkedFakeService.from_client(client, archive):

            response = client.get_messages('baz', order='date')

            self.assertIDOrder(

                ['qux', 'bar', 'foo', 'baz'], response['messages'])

            response = client.get_messages('baz', order='thread_newest')

            self.assertIDOrder(

                ['bar', 'foo', 'qux', 'baz'], response['messages'])

    def test_get_messages_unsupported_order(self):

        client = GrackleClient('localhost', 8439)

        archive = {

            'baz': [

                make_message('foo', headers={'date': '2011-03-25'}),

                make_message('foo', headers={'date': '2011-03-24'}),

            ]}

        with ForkedFakeService.from_client(client, archive):

            with ExpectedException(UnsupportedOrder, ''):

                client.get_messages('baz', order='nonsense')

    def test_get_messages_headers_no_headers(self):

        client = GrackleClient('localhost', 8440)

        archive = {'baz': [make_message('foo')]}

        with ForkedFakeService.from_client(client, archive):

            response = client.get_messages('baz', headers=[

                'Subject', 'Date', 'X-Launchpad-Message-Rationale'])

        first_message = response['messages'][0]

        self.assertEqual('foo', first_message['message_id'])

        self.assertEqual({}, first_message['headers'])

    def test_get_messages_headers_exclude_headers(self):

        client = GrackleClient('localhost', 8441)

        archive = {

            'baz': [make_message('foo', headers={'From': 'me'})]}

        with ForkedFakeService.from_client(client, archive):

            response = client.get_messages('baz', headers=[

                'Subject', 'Date', 'X-Launchpad-Message-Rationale'])

        first_message = response['messages'][0]

        self.assertEqual('foo', first_message['message_id'])

        self.assertEqual({}, first_message['headers'])

    def test_get_messages_headers_include_headers(self):

        client = GrackleClient('localhost', 8442)

        archive = {

            'baz': [

                make_message('foo', headers={'From': 'me', 'To': 'you'})]}

        with ForkedFakeService.from_client(client, archive):

            response = client.get_messages('baz', headers=[

                'From', 'To'])

        first_message = response['messages'][0]

        self.assertEqual('foo', first_message['message_id'])

        self.assertEqual({'From': 'me', 'To': 'you'}, first_message['headers'])

    def test_get_messages_max_body_length(self):

        client = GrackleClient('localhost', 8443)

        archive = {'baz': [make_message('foo', body=u'abcdefghi')]}

        with ForkedFakeService.from_client(client, archive):

            response = client.get_messages('baz', max_body_length=3)

        first_message = response['messages'][0]

        self.assertEqual('abc', first_message['body'])

    def test_include_hidden(self):

        client = GrackleClient('localhost', 8444)

        archive = {

            'baz': [

                make_message('foo', hidden=True),

                make_message('bar', hidden=False),

            ]}

        with ForkedFakeService.from_client(client, archive):

            response = client.get_messages('baz', include_hidden=True)

            self.assertMessageIDs(['bar', 'foo'], response['messages'])

            response = client.get_messages('baz', include_hidden=False)

            self.assertMessageIDs(['bar'], response['messages'])

    def test_display_type_unknown_value(self):

        client = GrackleClient('localhost', 8445)

        archive = {'baz': [make_message('foo', body=u'abcdefghi')]}

        with ForkedFakeService.from_client(client, archive):

            with ExpectedException(UnsupportedDisplayType, ''):

                client.get_messages('baz', display_type='unknown')

    def test_display_type_headers_only(self):

        client = GrackleClient('localhost', 8446)

        archive = {

            'baz': [

                make_message('foo', body=u'abcdefghi',

                             headers={'From': 'me', 'To': 'you'})]}

        with ForkedFakeService.from_client(client, archive):

            response = client.get_messages('baz', display_type='headers-only')

        first_message = response['messages'][0]

        self.assertEqual('foo', first_message['message_id'])

        self.assertEqual(

            archive['baz'][0]['headers'], first_message['headers'])

        self.assertNotIn('body', first_message)

    def test_display_type_text_only(self):

        client = GrackleClient('localhost', 8446)

        archive = {

            'baz': [

                make_mime_message(

                    'foo', 'abcdefghi',

                    headers={'From': 'me', 'To': 'you'},

                    attachment_type='text/x-diff')]}

        with ForkedFakeService.from_client(client, archive):

            response = client.get_messages('baz', display_type='text-only')

        first_message = response['messages'][0]

        self.assertEqual('foo', first_message['message_id'])

        self.assertEqual('me', first_message['headers']['From'])

        self.assertEqual('you', first_message['headers']['To'])

        self.assertEqual(archive['baz'][0]['body'], first_message['body'])

    def test_display_type_all(self):

        client = GrackleClient('localhost', 8447)

        archive = {

            'baz': [

                make_mime_message(

                    'foo', 'abcdefghi',

                    headers={'From': 'me', 'To': 'you'},

                    attachment_type='text/x-diff')]}

        with ForkedFakeService.from_client(client, archive):

            response = client.get_messages('baz', display_type='all')

        first_message = response['messages'][0]

        self.assertEqual('foo', first_message['message_id'])

        self.assertEqual('me', first_message['headers']['From'])

        self.assertEqual('you', first_message['headers']['To'])

        self.assertEqual(archive['baz'][0]['body'], first_message['body'])

    def test_date_range(self):

        client = GrackleClient('localhost', 8448)

        archive = {

            'baz': [

                make_mime_message(

                    'foo', 'abcdefghi', headers={'date': '2011-12-31'}),

                make_mime_message(

                    'bar', 'abcdefghi', headers={'date': '2012-01-01'}),

                make_mime_message(

                    'qux', 'abcdefghi', headers={'date': '2012-01-15'}),

                make_mime_message(

                    'naf', 'abcdefghi', headers={'date': '2012-01-31'}),

                make_mime_message(

                    'doh', 'abcdefghi', headers={'date': '2012-02-01'}),

                    ]}

        with ForkedFakeService.from_client(client, archive):

            response = client.get_messages(

                'baz', date_range='2012-01-01..2012-01-31')

        ids = sorted(m['message_id'] for m in response['messages'])

        self.assertEqual(['bar', 'naf', 'qux'], ids)

    def test_date_range_unparsabledaterange(self):

        client = GrackleClient('localhost', 8449)

        archive = {'baz': [make_message('foo', body=u'abcdefghi')]}

        with ForkedFakeService.from_client(client, archive):

            with ExpectedException(UnparsableDateRange, ''):

                client.get_messages('baz', date_range='2012-01-01')

    def test_date_range_unparsabledaterange_missing_part(self):

        client = GrackleClient('localhost', 8450)

        archive = {'baz': [make_message('foo', body=u'abcdefghi')]}

        with ForkedFakeService.from_client(client, archive):

            with ExpectedException(UnparsableDateRange, ''):

                client.get_messages('baz', date_range='2012-01-01..')

    def test_date_range_unparsabledaterange_extra_part(self):

        client = GrackleClient('localhost', 8451)

        archive = {'baz': [make_message('foo', body=u'abcdefghi')]}

        with ForkedFakeService.from_client(client, archive):

            with ExpectedException(UnparsableDateRange, ''):

                client.get_messages('baz', date_range='2012-01..12-02..12-03')

class TestHideMessages(TestCase):

    def test_hide_message_true(self):

        client = GrackleClient('localhost', 8470)

        archive = {

            'baz': [

                make_message('foo', hidden=False),

            ]}

        with ForkedFakeService.from_client(client, archive):

            response = client.hide_message('baz', 'foo', hidden=True)

        self.assertEqual('foo', response['message_id'])

        self.assertIs(True, response['hidden'])

    def test_hide_message_false(self):

        client = GrackleClient('localhost', 8470)

        archive = {

            'baz': [

                make_message('foo', hidden=True),

            ]}

        with ForkedFakeService.from_client(client, archive):

            response = client.hide_message('baz', 'foo', hidden=False)

        self.assertEqual('foo', response['message_id'])

        self.assertIs(False, response['hidden'])