KevinMidboe/transatlanticTorrentExpress
1
0
Fork 0
mirror of https://github.com/KevinMidboe/transatlanticTorrentExpress.git synced 2025-10-29 18:00:19 +00:00
Code Issues Packages Projects Releases Wiki Activity

All log messages before moving a file should be debug

Browse Source
This commit is contained in:
Kevin
2022-12-10 11:59:33 +01:00
parent 0f5f050448
commit 7dcbd60de4
1 changed files with 7 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
transatlanticTorrentExpress.py
View File

@@ -79,7 +79,7 @@ def estimateFileTransferTime(fileSize, filename):
return estimatedTransferSpeed return estimatedTransferSpeed
def getFiles(path, host=None, user=None): def getFiles(path, host=None, user=None):
logger.info('Getting filenames from path: {}'.format(path), es={'path': path}) logger.debug('Getting filenames from path: {}'.format(path), es={'path': path})
if (host and user): if (host and user):
cmd = "ssh {}@{} ls '{}'".format(user, host, path) cmd = "ssh {}@{} ls '{}'".format(user, host, path)
else: else:
@@ -104,7 +104,7 @@ def transferFiles(files, localPath, remotePath, host=None, user=None):
for file in files: for file in files:
if file in getFiles(localPath): if file in getFiles(localPath):
logger.info('File already exists at remote path. Skipping.') logger.debug('File already exists at remote path. Skipping.')
continue continue
remoteFile = os.path.join(remotePath, file) remoteFile = os.path.join(remotePath, file)
@@ -195,27 +195,25 @@ def main():
remoteFiles = getFiles(remotePath, host, user) remoteFiles = getFiles(remotePath, host, user)
if len(remoteFiles) > 0: if len(remoteFiles) > 0:
logger.info('Remote files found: {}'.format(remoteFiles), es={'files': remoteFiles}) logger.debug('Remote files found: {}'.format(remoteFiles), es={'files': remoteFiles})
else: else:
logger.info('No remote files found') logger.debug('No remote files found')
localFiles = getFiles(localPath) localFiles = getFiles(localPath)
if len(localFiles) > 0: if len(localFiles) > 0:
logger.info('Local files found: {}'.format(localFiles), es={'files': localFiles}) logger.debug('Local files found: {}'.format(localFiles), es={'files': localFiles})
else: else:
logger.info('No local files found') logger.debug('No local files found')
newFiles = filesNotShared(remoteFiles, localFiles) newFiles = filesNotShared(remoteFiles, localFiles)
if newFiles: if newFiles:
logger.info('New files: {}'.format(newFiles), es={'files': newFiles}) logger.info('New files: {}'.format(newFiles), es={'files': newFiles})
exisitingFiles = list(set(remoteFiles).intersection(localFiles))
logger.info('Existing files: {}'.format(exisitingFiles), es={'files': exisitingFiles})
transferedFiles = transferFiles(newFiles, localPath, remotePath, host, user) transferedFiles = transferFiles(newFiles, localPath, remotePath, host, user)
removeFromDeluge(transferedFiles) removeFromDeluge(transferedFiles)
else: else:
logger.info('No new files found to travel on the great transatlantic express') logger.debug('No new files found to travel on the great transatlantic express')
if __name__ == '__main__': if __name__ == '__main__':
main() main()