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

Added check on target dir and files. 



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

transfer_service/import_amqp_server.py

+2 −2
Original line number Diff line number Diff line
@@ -86,7 +86,7 @@ class ImportAMQPServer(AMQPServer): 
                    out.write(f"DIR dir: {dir}\n")

                    out.write(f"DIR pathPrefix: {pathPrefix}\n\n")

                    

                    if pathPrefix + '/' + self.username in dir:

                    if self.path in dir:

                        parentPath = os.path.dirname(dir).split(pathPrefix)[1]

                        nodeName = os.path.basename(dir)
@@ -109,7 +109,7 @@ class ImportAMQPServer(AMQPServer): 


                for flist in files:

                    for file in flist:                

                        if self.md5calc.fileIsValid(file):

                        if self.md5calc.fileIsValid(file) and self.path in os.path.dirname(file):

                            out.write(f"FILE files: {files}\n")

                            out.write(f"FILE flist: {flist}\n")

                            out.write(f"FILE file: {file}\n")