Subversion Repositories SmartDukaan

Rev

Rev 765 | Details | Compare with Previous | Last modification | View Log | RSS feed

Rev Author Line No. Line
304 ashish 1 
#!/usr/bin/env python
2 
#
3431 rajveer 3 
# Autogenerated by Thrift Compiler (0.7.0)
304 ashish 4 
#
5 
# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
6 
#
7 
 
8 
import sys
9 
import pprint
10 
from urlparse import urlparse
11 
from thrift.transport import TTransport
12 
from thrift.transport import TSocket
13 
from thrift.transport import THttpClient
14 
from thrift.protocol import TBinaryProtocol
15 
 
16 
import DataLogger
17 
from ttypes import *
18 
 
19 
if len(sys.argv) <= 1 or sys.argv[1] == '--help':
20 
  print ''
21 
  print 'Usage: ' + sys.argv[0] + ' [-h host:port] [-u url] [-f[ramed]] function [arg1 [arg2...]]'
22 
  print ''
23 
  print 'Functions:'
765 rajveer 24 
  print '  void closeSession()'
304 ashish 25 
  print '  void log(MsgType messageType, string message)'
26 
  print ''
27 
  sys.exit(0)
28 
 
29 
pp = pprint.PrettyPrinter(indent = 2)
30 
host = 'localhost'
31 
port = 9090
32 
uri = ''
33 
framed = False
34 
http = False
35 
argi = 1
36 
 
37 
if sys.argv[argi] == '-h':
3431 rajveer 38 
  parts = sys.argv[argi+1].split(':')
304 ashish 39 
  host = parts[0]
40 
  port = int(parts[1])
41 
  argi += 2
42 
 
43 
if sys.argv[argi] == '-u':
44 
  url = urlparse(sys.argv[argi+1])
3431 rajveer 45 
  parts = url[1].split(':')
304 ashish 46 
  host = parts[0]
47 
  if len(parts) > 1:
48 
    port = int(parts[1])
49 
  else:
50 
    port = 80
51 
  uri = url[2]
3431 rajveer 52 
  if url[4]:
53 
    uri += '?%s' % url[4]
304 ashish 54 
  http = True
55 
  argi += 2
56 
 
57 
if sys.argv[argi] == '-f' or sys.argv[argi] == '-framed':
58 
  framed = True
59 
  argi += 1
60 
 
61 
cmd = sys.argv[argi]
62 
args = sys.argv[argi+1:]
63 
 
64 
if http:
65 
  transport = THttpClient.THttpClient(host, port, uri)
66 
else:
67 
  socket = TSocket.TSocket(host, port)
68 
  if framed:
69 
    transport = TTransport.TFramedTransport(socket)
70 
  else:
71 
    transport = TTransport.TBufferedTransport(socket)
72 
protocol = TBinaryProtocol.TBinaryProtocol(transport)
73 
client = DataLogger.Client(protocol)
74 
transport.open()
75 
 
765 rajveer 76 
if cmd == 'closeSession':
77 
  if len(args) != 0:
78 
    print 'closeSession requires 0 args'
79 
    sys.exit(1)
80 
  pp.pprint(client.closeSession())
81 
 
82 
elif cmd == 'log':
304 ashish 83 
  if len(args) != 2:
84 
    print 'log requires 2 args'
85 
    sys.exit(1)
86 
  pp.pprint(client.log(eval(args[0]),args[1],))
87 
 
3431 rajveer 88 
else:
89 
  print 'Unrecognized method %s' % cmd
90 
  sys.exit(1)
91 
 
304 ashish 92 
transport.close()