import user.commons.remotestore.FtpDirectoryLister;\r
import user.commons.remotestore.RemoteStoreProtocol;\r
import user.jobengine.db.IItemManager;\r
-import user.jobengine.server.steps.EscortFiles;\r
import user.jobengine.server.steps.FileArchive;\r
import user.jobengine.server.steps.RundownArchive;\r
import user.jobengine.server.steps.StoryArchive;\r
+import user.jobengine.server.steps.shared.EscortFiles;\r
\r
public class RescueNEXIOMaterials {\r
private static final String SCHEDULED_FORMAT = "yyyy.MM.dd HH:mm";\r
import user.commons.remotestore.RemoteStoreProtocol;\r
import user.jobengine.db.Media;\r
import user.jobengine.server.steps.ArchiveItem;\r
-import user.jobengine.server.steps.EscortFiles;\r
-import user.jobengine.server.steps.FFMpeg;\r
-import user.jobengine.server.steps.MediaCubeClient;\r
import user.jobengine.server.steps.TSMExtendedRetrieveStep;\r
+import user.jobengine.server.steps.shared.EscortFiles;\r
import user.jobengine.server.steps.shared.ExternalCommandExecutor;\r
+import user.jobengine.server.steps.shared.FFMpeg;\r
+import user.jobengine.server.steps.shared.MediaCubeClient;\r
\r
public class SmallTests {\r
class Pojo extends PojoRoot {\r
import user.jobengine.db.MediaFile;\r
import user.jobengine.server.JobRuntime;\r
import user.jobengine.server.steps.ItemManagerExtensions;\r
-import user.jobengine.server.steps.PlanAirExtensions;\r
import user.jobengine.server.steps.ProjectCleanupMountedLocationStep;\r
import user.jobengine.server.steps.RundownArchive;\r
+import user.jobengine.server.steps.shared.PlanAirExtensions;\r
import user.tsm.client.TSMBackupFileObject;\r
import user.tsm.client.TSMClient;\r
import user.tsm.client.TSMException;\r
import user.jobengine.db.Item;\r
import user.jobengine.db.ItemManager;\r
import user.jobengine.db.Media;\r
-import user.jobengine.server.steps.MetadataType;\r
-import user.jobengine.server.steps.MetadataTypeDetector;\r
-import user.jobengine.server.steps.PlanAirExtensions;\r
+import user.jobengine.server.steps.shared.MetadataType;\r
+import user.jobengine.server.steps.shared.MetadataTypeDetector;\r
+import user.jobengine.server.steps.shared.PlanAirExtensions;\r
\r
public class SupportCheckItem {\r
class PlanAirProcessor implements IStatementDecorator, IResultSetConsumer {\r
import user.jobengine.db.ItemManager;\r
import user.jobengine.db.MediaFile;\r
import user.jobengine.db.Store;\r
-import user.jobengine.server.steps.MetadataType;\r
-import user.jobengine.server.steps.MetadataTypeDetector;\r
-import user.jobengine.server.steps.PlanAirExtensions;\r
+import user.jobengine.server.steps.shared.MetadataType;\r
+import user.jobengine.server.steps.shared.MetadataTypeDetector;\r
+import user.jobengine.server.steps.shared.PlanAirExtensions;\r
\r
public class SupportCleanMissingTSM {\r
class PlanAirProcessor implements IStatementDecorator, IResultSetConsumer {\r
import user.commons.mediatool.MediaInfo;\r
import user.jobengine.server.IJobEngine;\r
import user.jobengine.server.IJobRuntime;\r
+import user.jobengine.server.steps.shared.EscortFiles;\r
import user.mediacube.metadata.interfaces.IMetadata;\r
import user.mediacube.metadata.interfaces.IMetadataProvider;\r
import user.mediacube.metadata.interfaces.IMetadataProviderFactory;\r
import user.jobengine.db.Media;\r
import user.jobengine.db.MediaFile;\r
import user.jobengine.db.Store;\r
+import user.jobengine.server.steps.shared.EscortFiles;\r
\r
public class AttachLowresStep extends JobStep {\r
private static final int POLL_INTERVALL = 3000;\r
import user.commons.StoreUri;\r
import user.commons.remotestore.FtpDirectoryLister;\r
import user.commons.remotestore.RemoteStoreProtocol;\r
+import user.jobengine.server.steps.shared.EscortFiles;\r
\r
public class CancelableStep extends JobStep {\r
private static final Logger logger = LogManager.getLogger();\r
import user.jobengine.db.IItemManager;\r
import user.jobengine.server.IJobEngine;\r
import user.jobengine.server.IJobRuntime;\r
+import user.jobengine.server.steps.shared.EscortFiles;\r
+import user.jobengine.server.steps.shared.MetadataType;\r
+import user.jobengine.server.steps.shared.MetadataTypeDetector;\r
\r
public class CopyForArchiveNEXIOMaterialsStep extends JobStep {\r
private static final String SCHEDULED_FORMAT = "yyyy.MM.dd HH:mm";\r
import user.jobengine.db.IItemManager;\r
import user.jobengine.server.IJobEngine;\r
import user.jobengine.server.IJobRuntime;\r
+import user.jobengine.server.steps.shared.EscortFiles;\r
\r
public class CopyForArchiveNEXIORecordingsStep extends JobStep {\r
private static final String MEDIATYPE = "Visszarögzített";\r
import user.jobengine.db.MediaFile;\r
import user.jobengine.server.IJobEngine;\r
import user.jobengine.server.IJobRuntime;\r
+import user.jobengine.server.steps.shared.EscortFiles;\r
\r
public class DuplicateRemoverStep extends JobStep {\r
private static final Logger logger = LogManager.getLogger();\r
\r
import user.commons.StoreUri;\r
import user.commons.remotestore.RemoteStoreProtocol;\r
+import user.jobengine.server.steps.shared.EscortFiles;\r
\r
public class EnsureProxyPathExistanceStep extends JobStep {\r
@StepEntry\r
import org.apache.logging.log4j.message.ParameterizedMessage;\r
\r
import user.commons.StoreUri;\r
+import user.jobengine.server.steps.shared.EscortFiles;\r
\r
public class FileCleanupStep extends JobStep {\r
private static final Logger logger = LogManager.getLogger();\r
import user.jobengine.db.IItemManager;\r
import user.jobengine.server.IJobEngine;\r
import user.jobengine.server.IJobRuntime;\r
+import user.jobengine.server.steps.shared.EscortFiles;\r
\r
public class FileCopyStep extends JobStep {\r
private static final Logger logger = LogManager.getLogger();\r
import user.commons.mediatool.MediaInfo;\r
import user.commons.remotestore.RemoteStoreProtocol;\r
import user.jobengine.db.Media;\r
+import user.jobengine.server.steps.shared.EscortFiles;\r
\r
public class FileValidatorStep extends JobStep {\r
private static final String COLORSPACE = "COLORSPACE";\r
import user.jobengine.db.Store;\r
import user.jobengine.server.IJobEngine;\r
import user.jobengine.server.IJobRuntime;\r
+import user.jobengine.server.steps.shared.EscortFiles;\r
\r
public class ForkDownloadStep extends JobStep {\r
private static final Logger logger = LogManager.getLogger();\r
import user.jobengine.db.Store;\r
import user.jobengine.server.IJobEngine;\r
import user.jobengine.server.IJobRuntime;\r
+import user.jobengine.server.steps.shared.EscortFiles;\r
\r
public class ForkUploadStep extends JobStep {\r
private static final Logger logger = LogManager.getLogger();\r
import user.commons.morpheus.MorpheusStrings;\r
import user.jobengine.server.IJobEngine;\r
import user.jobengine.server.IJobRuntime;\r
+import user.jobengine.server.steps.shared.EscortFiles;\r
+import user.jobengine.server.steps.shared.PlanAirExtensions;\r
\r
public class GenerateMorpheusMetadataStep extends JobStep {\r
private static final Logger logger = LogManager.getLogger();\r
import user.commons.StoreUri;\r
import user.commons.remotestore.RemoteStoreProtocol;\r
import user.jobengine.db.Media;\r
+import user.jobengine.server.steps.shared.EscortFiles;\r
\r
public class GenericArchiveCheckerStep extends JobStep {\r
private static final String DOT_MXF = ".MXF";\r
import user.jobengine.db.Media;\r
import user.jobengine.db.MediaFile;\r
import user.jobengine.db.Store;\r
+import user.jobengine.server.steps.shared.EscortFiles;\r
+import user.jobengine.server.steps.shared.FFMpeg;\r
\r
public class HLSProxyStep extends JobStep {\r
private static final Logger logger = LogManager.getLogger();\r
import user.jobengine.db.IItemManager;\r
import user.jobengine.db.MediaFile;\r
import user.jobengine.db.MediaFileDAO;\r
+import user.jobengine.server.steps.shared.EscortFiles;\r
import user.mediacube.metadata.interfaces.IMetadata;\r
import user.mediacube.metadata.interfaces.IMetadataProvider;\r
import user.mediacube.metadata.interfaces.IMetadataProviderFactory;\r
import user.commons.remotestore.FtpDirectoryLister;\r
import user.commons.remotestore.RemoteStoreProtocol;\r
import user.jobengine.db.Media;\r
+import user.jobengine.server.steps.shared.EscortFiles;\r
\r
public class HarrisMissingMaterialCheckerStep extends JobStep {\r
private static final Logger logger = LogManager.getLogger(HarrisMissingMaterialCheckerStep.class);\r
import user.jobengine.db.MediaFileDAO;\r
import user.jobengine.server.IJobEngine;\r
import user.jobengine.server.IJobRuntime;\r
+import user.jobengine.server.steps.shared.EscortFiles;\r
\r
public class ImportMORPHEUSMissingMaterialsStep extends JobStep {\r
private static final Logger logger = LogManager.getLogger();\r
\r
import user.jobengine.db.IItemManager;\r
import user.jobengine.db.IResultSetConsumer;\r
+import user.jobengine.server.steps.shared.MetadataType;\r
+import user.jobengine.server.steps.shared.MetadataTypeDetector;\r
\r
public class ItemManagerExtensions {\r
\r
import user.jobengine.db.Store;\r
import user.jobengine.server.IJobEngine;\r
import user.jobengine.server.IJobRuntime;\r
+import user.jobengine.server.steps.shared.EscortFiles;\r
\r
public class MXFCutterStep extends JobStep {\r
private static final String TARGETNAMEPATTERN = "-ARCH-%s";\r
import user.jobengine.db.Item;\r
import user.jobengine.db.Media;\r
import user.jobengine.db.MediaFile;\r
+import user.jobengine.server.steps.shared.EscortFiles;\r
\r
public class MetadataPersisterStep extends JobStep {\r
private static final String GENERIC = "Generic";\r
import user.commons.remotestore.RemoteStoreProtocol;\r
import user.jobengine.db.Media;\r
import user.jobengine.db.MediaFile;\r
+import user.jobengine.server.steps.shared.EscortFiles;\r
\r
public class NEXIOArchiveCheckerStep extends JobStep {\r
private static final String DOT_MXF = ".mxf";\r
import user.commons.StoreUri;\r
import user.jobengine.db.Media;\r
import user.jobengine.db.MediaFile;\r
+import user.jobengine.server.steps.shared.EscortFiles;\r
\r
public class NEXIOMetadataPersisterStep extends JobStep {\r
private static final Logger logger = LogManager.getLogger();\r
import user.jobengine.db.ArchivedMedia;\r
import user.jobengine.server.IJobEngine;\r
import user.jobengine.server.IJobRuntime;\r
+import user.jobengine.server.steps.shared.EscortFiles;\r
+import user.jobengine.server.steps.shared.MetadataType;\r
+import user.jobengine.server.steps.shared.MetadataTypeDetector;\r
\r
public class OutputPathAndNameSelectorStep extends JobStep {\r
\r
import user.commons.remotestore.FtpDirectoryLister;\r
import user.commons.remotestore.RemoteStoreProtocol;\r
import user.jobengine.db.Media;\r
-import user.jobengine.server.steps.PBQuery.MMMedia;\r
+import user.jobengine.server.steps.shared.EscortFiles;\r
+import user.jobengine.server.steps.shared.PBQuery;\r
+import user.jobengine.server.steps.shared.PBQuery.MMMedia;\r
\r
public class PeableBeachMissingMaterialCheckerStep extends JobStep {\r
private static final Logger logger = LogManager.getLogger();\r
\r
import user.jobengine.server.IJobEngine;\r
import user.jobengine.server.IJobRuntime;\r
+import user.jobengine.server.steps.shared.MetadataType;\r
+import user.jobengine.server.steps.shared.MetadataTypeDetector;\r
\r
public class ProjectCleanupMountedLocationStep extends JobStep implements FileVisitor<Path> {\r
\r
import user.commons.octopus.OctopusAPI;\r
import user.jobengine.server.IJobEngine;\r
import user.jobengine.server.IJobRuntime;\r
+import user.jobengine.server.steps.shared.EscortFiles;\r
\r
public class RecordingsArchiveItemBuilderStep extends JobStep {\r
private static final String MEDIATYPE = "Visszarögzített";\r
import user.commons.remotestore.RemoteStoreProtocol;\r
import user.jobengine.db.ArchivedMedia;\r
import user.jobengine.db.Media;\r
+import user.jobengine.server.steps.shared.EscortFiles;\r
\r
public class RegisterUserRestoreStep extends JobStep {\r
private static final Logger logger = LogManager.getLogger();\r
import user.commons.StoreUri;\r
import user.commons.remotestore.RemoteStoreProtocol;\r
import user.jobengine.db.Media;\r
+import user.jobengine.server.steps.shared.EscortFiles;\r
\r
public class RegisterVODRestoreStep extends JobStep {\r
private static final Logger logger = LogManager.getLogger();\r
\r
import com.ibm.nosql.json.api.BasicDBObject;\r
\r
+import user.jobengine.server.steps.shared.MediaCubeClient;\r
+\r
/*\r
import user.jobengine.server.steps.MediaCubeClient;\r
*/\r
import user.commons.remotestore.ProgressEvent;\r
import user.jobengine.server.IJobEngine;\r
import user.jobengine.server.IJobRuntime;\r
+import user.jobengine.server.steps.shared.OctopusDataMiner;\r
\r
public class SyncOCTOPUSDataStep extends JobStep {\r
private static final Logger logger = LogManager.getLogger();\r
import user.jobengine.server.IJobEngine;\r
import user.jobengine.server.IJobRuntime;\r
import user.jobengine.server.JobEngineException;\r
+import user.jobengine.server.steps.shared.EscortFiles;\r
\r
public class TSMBackupStep extends JobStep {\r
private static final String MXFEXT = ".MXF";\r
import user.jobengine.db.IItemManager;\r
import user.jobengine.server.IJobEngine;\r
import user.jobengine.server.IJobRuntime;\r
+import user.jobengine.server.steps.shared.EscortFiles;\r
\r
public class TSMExtendedRetrieveStep extends TSMRestoreStep {\r
private static String NEXIO_HOST = System.getProperty("nexio.host");\r
import user.jobengine.db.Store;\r
import user.jobengine.server.IJobEngine;\r
import user.jobengine.server.IJobRuntime;\r
+import user.jobengine.server.steps.shared.EscortFiles;\r
\r
public class TSMRestoreStep extends JobStep {\r
private static final String DOT = ".";\r
import user.jobengine.db.Store;\r
import user.jobengine.server.IJobEngine;\r
import user.jobengine.server.IJobRuntime;\r
+import user.jobengine.server.steps.shared.EscortFiles;\r
\r
public class TSMSystemRestoreStep extends JobStep {\r
private static final Logger logger = LogManager.getLogger();\r
import user.jobengine.server.IJobEngine;\r
import user.jobengine.server.IJobRuntime;\r
import user.jobengine.server.JobEngineException;\r
+import user.jobengine.server.steps.shared.EscortFiles;\r
\r
public class TSMWriterStep extends JobStep {\r
private static final String MXFEXT = ".MXF";\r
import user.jobengine.db.Store;\r
import user.jobengine.server.IJobEngine;\r
import user.jobengine.server.IJobRuntime;\r
+import user.jobengine.server.steps.shared.EscortFiles;\r
\r
public class TranscodeFFAStranStep extends JobStep {\r
private static final int POLL_INTERVALL = 3000;\r
import user.jobengine.db.Store;\r
import user.jobengine.server.IJobEngine;\r
import user.jobengine.server.IJobRuntime;\r
+import user.jobengine.server.steps.shared.EscortFiles;\r
\r
public class TranscodeSELENIOStep extends JobStep {\r
\r
import user.jobengine.db.Store;\r
import user.jobengine.server.IJobEngine;\r
import user.jobengine.server.IJobRuntime;\r
+import user.jobengine.server.steps.shared.MetadataType;\r
+import user.jobengine.server.steps.shared.MetadataTypeDetector;\r
\r
public class UpdateGhostMediaDataStep extends JobStep {\r
private static final Logger logger = LogManager.getLogger();\r
-package user.jobengine.server.steps;\r
+package user.jobengine.server.steps.shared;\r
\r
import java.io.BufferedReader;\r
import java.io.InputStreamReader;\r
-package user.jobengine.server.steps;\r
+package user.jobengine.server.steps.shared;\r
\r
import java.io.ByteArrayInputStream;\r
import java.io.File;\r
-package user.jobengine.server.steps;\r
+package user.jobengine.server.steps.shared;\r
\r
import java.io.FileNotFoundException;\r
import java.nio.file.Files;\r
-package user.jobengine.server.steps;\r
+package user.jobengine.server.steps.shared;\r
\r
import javax.ws.rs.client.Entity;\r
import javax.ws.rs.client.Invocation.Builder;\r
-package user.jobengine.server.steps;\r
+package user.jobengine.server.steps.shared;\r
\r
public enum MetadataType {\r
TrafficMaterial, TrafficPromo, TrafficAD, OctopusStory, OctopusPlaceholder, Generic\r
-package user.jobengine.server.steps;\r
+package user.jobengine.server.steps.shared;\r
\r
import org.apache.commons.lang.StringUtils;\r
\r
-package user.jobengine.server.steps;\r
+package user.jobengine.server.steps.shared;\r
\r
import java.util.Calendar;\r
import java.util.Date;\r
-package user.jobengine.server.steps;\r
+package user.jobengine.server.steps.shared;\r
\r
import java.io.DataInputStream;\r
import java.io.FileNotFoundException;\r
-package user.jobengine.server.steps;\r
+package user.jobengine.server.steps.shared;\r
\r
import java.io.StringWriter;\r
import java.sql.Connection;\r