Commit b7ac9f5d authored by Cristiano Urban's avatar Cristiano Urban
Browse files

Added code portion to handle the 'list' cli command. 



Signed-off-by: default avatarCristiano Urban <cristiano.urban@inaf.it>
parent 3c091245

transfer_service/storage_amqp_server.py

+9 −2
Original line number Diff line number Diff line
@@ -54,7 +54,14 @@ class StorageAMQPServer(AMQPServer): 
        elif requestBody["requestType"] == "STORAGE_RMV":

            pass

        elif requestBody["requestType"] == "STORAGE_LST":            

            pass

            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}...")