← Back to branch summary

~unity-2d-team/unity-2d/Shell-MultiMonitor

« back to all changes in this revision

Viewing changes to grackle/server/wsgi.py

  • Committer: William Grant
  • Date: 2012-01-20 08:26:17 UTC
  • Revision ID: william.grant@canonical.com-20120120082617-4t3zdb532je063j4
A little bit of server.

Show diffs side-by-side

added added

removed removed

Lines of Context:
grackle/server/wsgi.py
16
16
 
17
17
__metaclass__ = type
18
18
 
19
 
import json
20
 
import uuid
21
 
 
22
19
import web
23
20
 
24
 
from grackle.model import CassandraConnection
 
21
from grackle.server.model import CassandraConnection
25
22
 
26
23
conn = None
27
24
 
45
42
            return self.index(name)
46
43
 
47
44
        if args.op == 'get_messages':
48
 
            return self.get_messages(name, args)
 
45
            return self.get_messages(name)
49
46
 
50
47
    def POST(self, name):
51
48
        data = web.data()
55
52
    def index(self, name):
56
53
        return ('Service for archive %s.' % name)
57
54
 
58
 
    def get_messages(self, name, args):
59
 
        try:
60
 
            count = int(args.count)
61
 
        except (AttributeError, ValueError):
62
 
            count = 10
63
 
        order = getattr(args, 'order', '-date')
64
 
        start = getattr(args, 'start', '')
65
 
        messages, next_memo = conn.get_messages(name, order, count, start)
66
 
        return json.dumps({
67
 
            'messages': messages,
68
 
            'next_memo': next_memo,
69
 
            })
 
55
    def get_messages(self, name):
 
56
        return repr(conn.get_messages(name))
70
57
 
71
58
 
72
59
urls = (
77
64
app = web.application(urls, globals(), autoreload=False)
78
65
 
79
66
if __name__ == "__main__":
80
 
    import logging
81
 
    logging.basicConfig(
82
 
        format='%(asctime)s:%(levelname)s:%(name)s:%(message)s',
83
 
        level=logging.DEBUG)
84
 
    conn = CassandraConnection('grackle', ['localhost:9160'])
 
67
    conn = CassandraConnection('grackle', 'localhost/9160')
85
68
    app.run()