From b7ac9f5df87802017b0da885d77b03dbf85d11c2 Mon Sep 17 00:00:00 2001 From: Cristiano Urban Date: Fri, 26 Feb 2021 15:49:45 +0100 Subject: [PATCH] Added code portion to handle the 'list' cli command. Signed-off-by: Cristiano Urban --- transfer_service/storage_amqp_server.py | 11 +++++++++-- 1 file changed, 9 insertions(+), 2 deletions(-) diff --git a/transfer_service/storage_amqp_server.py b/transfer_service/storage_amqp_server.py index 1ed0356..1cad131 100644 --- a/transfer_service/storage_amqp_server.py +++ b/transfer_service/storage_amqp_server.py @@ -53,8 +53,15 @@ class StorageAMQPServer(AMQPServer): return response elif requestBody["requestType"] == "STORAGE_RMV": pass - elif requestBody["requestType"] == "STORAGE_LST": - pass + elif requestBody["requestType"] == "STORAGE_LST": + self.dbConn.connect() + result = self.dbConn.getStorageList() + self.dbConn.disconnect() + + response = { "responseType": "STORAGE_LST_DONE", + "storageList": result } + + return response def run(self): print(f"Starting AMQP server of type {self.type}...") -- GitLab