1 from manifold.core.query import Query
2 from manifoldapi.manifoldapi import execute_query
4 from django.http import HttpResponse
11 # handles serialization of datetime in json
12 DateEncoder = lambda obj: obj.strftime("%B %d, %Y %H:%M:%S") if isinstance(obj, datetime.datetime) else None
14 # support converting decimal in json
15 json.encoder.FLOAT_REPR = lambda o: format(o, '.2f')
17 # handles decimal numbers serialization in json
18 class DecimalEncoder(json.JSONEncoder):
19 def _iterencode(self, o, markers=None):
20 if isinstance(o, decimal.Decimal):
21 return (str(o) for o in [o])
22 return super(DecimalEncoder, self)._iterencode(o, markers)
24 class ObjectRequest(object):
26 def __init__(self, request, object_type, object_name):
27 self.type = object_type
28 self.name = object_name
33 self.request = request
35 if ((self.type == 'platform') or (self.type == 'testbed')) :
36 self.type = 'local:platform'
38 self.fields = ['platform', 'platform_longname', 'platform_url', 'platform_description','gateway_type'];
39 self.filters['disabled'] = '0'
40 self.filters['gateway_type'] = 'sfa'
41 self.filters['platform'] = '!myslice'
50 # What about key formed of multiple fields???
51 query = Query.get('local:object').filter_by('table', '==', self.type).select('key')
52 results = execute_query(self.request, query)
53 print "key of object = %s" % results
55 for r in results[0]['key'] :
58 raise Exception, 'Manifold db error'
60 def setLocalFields(self):
61 query = Query.get('local:object').filter_by('table', '==', self.type).select('column.name')
62 results = execute_query(self.request, query)
64 for r in results[0]['column'] :
65 self.fields.append(r['name'])
67 raise Exception, 'Manifold db error'
69 def setFields(self, fields):
73 selected_fields.append(p)
74 self.fields = selected_fields
77 if self.id in self.fields :
78 self.fields.remove(self.id)
79 [self.id].extend(self.fields)
81 def applyFilters(self, query, force_filters = False):
82 if (force_filters and not self.filters) :
83 raise Exception, "Filters required"
85 for k, f in self.filters.iteritems() :
87 query.filter_by(k, '!=', f[1:])
88 elif (f[:2] == ">=") :
89 query.filter_by(k, '>=', f[2:])
91 query.filter_by(k, '>', f[1:])
92 elif (f[:2] == "<=") :
93 query.filter_by(k, '<=', f[2:])
95 query.filter_by(k, '<', f[1:])
97 query.filter_by(k, '==', f)
101 query = Query.get(self.type).select(self.fields)
102 query = self.applyFilters(query)
103 return execute_query(self.request, query)
106 query = Query.update(self.type)
107 query = self.applyFilters(query, True)
109 query.set(self.params)
111 raise Exception, "Params are required for update"
112 return execute_query(self.request, query)
115 query = Query.delete(self.type)
116 query = self.applyFilters(query, True)
118 query.set(self.params)
120 raise Exception, "Params are required for update"
121 return execute_query(self.request, query)
124 return HttpResponse(json.dumps(self.get(), cls=DecimalEncoder, default=DateEncoder), content_type="application/json")
127 response = self.get()
129 response_data['fields'] = self.fields
130 response_data['labels'] = self.fields
131 response_data['data'] = []
132 response_data['total'] = len(response)
135 for p in self.fields :
137 response_data['data'].append(d)
139 return HttpResponse(json.dumps(response_data, cls=DecimalEncoder, default=DateEncoder), content_type="application/json")
142 return HttpResponse(json.dumps({'error' : msg}), content_type="application/json")
145 return HttpResponse(json.dumps({'success' : msg}), content_type="application/json")