X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=manifold%2Fmetadata.py;h=de9bf2ebbe82a9b2bce21667835ddbc3e291b8d7;hb=804932e8a431ddbf0d7c56457625457967b48d4c;hp=4fbbc0668ef1fb63e43690f71494394e85383bd4;hpb=e6184193b74ac6d5c52289546dae9121bdd99008;p=myslice.git diff --git a/manifold/metadata.py b/manifold/metadata.py index 4fbbc066..de9bf2eb 100644 --- a/manifold/metadata.py +++ b/manifold/metadata.py @@ -4,12 +4,10 @@ import os.path from manifold.manifoldresult import ManifoldResult from manifold.manifoldapi import ManifoldAPI -debug=False -debug=True +from django.contrib import messages -# turn this on if you want to work offline -work_offline=False -#work_offline=True +debug=False +#debug=True class MetaData: @@ -17,34 +15,31 @@ class MetaData: self.auth=auth self.hash_by_object={} - def fetch (self): - offline_filename="%s/../offline-metadata.json"%os.path.dirname(__file__) - if work_offline: - try: - with file(offline_metadata) as f: - self.hash_by_object=json.loads(f.read()) - return - except: - print "metadata.work_offline: failed to decode %s"%offline_filename + def fetch (self, request): manifold_api = ManifoldAPI(self.auth) - fields = ['table', 'column.name', 'column.qualifier', 'column.type', 'column.is_array', 'column.description', 'column.default', 'key', 'capability'] + fields = ['table', 'column.name', 'column.qualifier', 'column.type', + 'column.is_array', 'column.description', 'column.default', 'key', 'capability'] #fields = ['table', 'column.column', # 'column.description','column.header', 'column.title', # 'column.unit', 'column.info_type', # 'column.resource_type', 'column.value_type', # 'column.allowed_values', 'column.platforms.platform', # 'column.platforms.platform_url'] - result = manifold_api.forward({ - 'action': 'get', - 'object': 'local:object', # proposed to replace metadata:table - 'fields': fields - }) + request={ 'action': 'get', + 'object': 'local:object', # proposed to replace metadata:table + 'fields': fields , + } + result = manifold_api.forward(request) + # xxx need a way to export error messages to the UI if result['code'] == 1: # warning - messages.warning(request, result['description']) + # messages.warning(request, result['description']) + print ("METADATA WARNING -",request,result['description']) elif result['code'] == 2: - messages.error(request, result['description']) + # messages.error(request, result['description']) + print ("METADATA ERROR -",request,result['description']) # XXX FAIL HERE XXX + return rows = result.ok_value() # API errors will be handled by the outer logic @@ -52,10 +47,6 @@ class MetaData: # print "Failed to retrieve metadata",rows_result.error() # rows=[] self.hash_by_object = dict ( [ (row['table'], row) for row in rows ] ) - # save for next time we use offline mode - if debug and rows: - with file(offline_filename,'w') as f: - f.write(json.dumps(self.hash_by_object)) def to_json(self): return json.dumps(self.hash_by_object) @@ -67,5 +58,5 @@ class MetaData: return self.hash_by_object[object]['column'].sort() def get_field_type(self, object, field): - print "Temp fix for metadata::get_field_type() -> consider moving to manifold.core.metadata soon" + if debug: print "Temp fix for metadata::get_field_type() -> consider moving to manifold.core.metadata soon" return field