zenon/federated-storage
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Merge branch 'master' of https://hyde.infosys.tuwien.ac.at/aic20/g4t2

Browse Source
This commit is contained in:
Martin Schett 2020-12-09 19:04:33 +01:00
commit 7009eb85f8
2 changed files with 23 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
iotclient/iot_client.py
View File

@ -83,8 +83,22 @@ def get_image(identifier):
print_response(response) print_response(response)
return False return False
payload = response.json() payload = response.json()
if not 'id' in payload:
print('no image id')
return False
if not 'metadata' in payload:
print('no metadata')
return False
if not 'image_data' in payload:
print('no Image data')
return False
print(payload['id']) print(payload['id'])
print(payload['metadata']) print(payload['metadata'])
if not 'filename' in payload['metadata']:
print('no filename in metadata')
return False
b64encoded_image = unwrap_file(payload['image_data']) b64encoded_image = unwrap_file(payload['image_data'])
goal_folder_name = "images_fetch" goal_folder_name = "images_fetch"
path = "../../" + goal_folder_name + "/" + payload['metadata']['filename'] path = "../../" + goal_folder_name + "/" + payload['metadata']['filename']
@ -99,6 +113,14 @@ def get_image(identifier):
out.write(b64encoded_image) out.write(b64encoded_image)
out.close() out.close()
os.system(goal_folder_path + os.path.sep + payload['metadata']['filename']) os.system(goal_folder_path + os.path.sep + payload['metadata']['filename'])
txtpath = "../../" + goal_folder_name + "/" + payload['id'] + '.txt'
out = open(txtpath, 'w')
out.write(json.dumps(payload['metadata']))
out.close()
os.system(goal_folder_path + os.path.sep + payload['id'] + '.txt')
except os.error as e: except os.error as e:
print("Error sending request {}".format(e)) print("Error sending request {}".format(e))
except KeyError as e: except KeyError as e:

2
middleware/app_be/views/rest_api.py
View File

@ -97,7 +97,7 @@ class ImageEndpoint:
if not MongoDBService.createSingle(metadata, identifier, decoded_image): if not MongoDBService.createSingle(metadata, identifier, decoded_image):
print("Could not save metadata") print("Could not save metadata")
return JsonResponse({'Result': 'Error - could not upload to MongoDB', 'id': identifier, 'filename': filename}, status=500,safe=False) return JsonResponse({'Result': 'Error - could not upload to MongoDB', 'id': identifier, 'filename': filename},status=500,safe=False)
if not DropboxService.create_file(filename, decoded_image): if not DropboxService.create_file(filename, decoded_image):
print("Could not save image to dropbox") print("Could not save image to dropbox")
return JsonResponse({'Result': 'Error - could not upload to Dropbox', 'id': identifier, 'filename': filename},status=500, safe=False) return JsonResponse({'Result': 'Error - could not upload to Dropbox', 'id': identifier, 'filename': filename},status=500, safe=False)