introduce template replacements for transfers

src/python/dm/common/processing/plugins/fileProcessor.py

@@ -12,6 +12,11 @@ class FileProcessor:
     @abc.abstractmethod
     def processFile(self, fileInfo):
         return NotImplemented
+
+    def replaceTemplates(self, inputString, fileInfo):
+        experimentName = fileInfo.get('experimentName', ''):
+        outputString = inputString.replace('EXPERIMENT_NAME', experimentName)
+        return outputString
     
     def checkUploadFilesForProcessing(self, filePathsDict, uploadInfo):
         return {}

src/python/dm/common/processing/plugins/gridftpFileTransferPlugin.py

@@ -97,6 +97,8 @@ class GridftpFileTransferPlugin(FileTransferPlugin):
             ftpUtility.getMd5Sum(filePath, fileInfo)
 
         # Transfer file
+        srcUrl = self.replaceTemplates(srcUrl, fileInfo)
+        destUrl = self.replaceTemplates(destUrl, fileInfo)
         self.logger.debug('Starting transfer: %s' % fileInfo)
         self.start(srcUrl, destUrl)
 

src/python/dm/common/processing/plugins/rsyncFileTransferPlugin.py

@@ -60,6 +60,8 @@ class RsyncFileTransferPlugin(FileTransferPlugin):
             FileUtility.getMd5Sum(filePath, fileInfo)
 
         # Transfer file
+        srcUrl = self.replaceTemplates(srcUrl, fileInfo)
+        destUrl = self.replaceTemplates(destUrl, fileInfo)
         self.logger.debug('Starting transfer: %s' % fileInfo)
         self.start(srcUrl, destUrl)