867572666f0df0188612bd5199186553bd670e30 | 436d3421e4242ab391ef48b4c453bcaed62e7490 | ||
---|---|---|---|
26 | import ldif.util.Identifier | 26 | import ldif.util.Identifier |
27 | import ldif.local.scheduler.{DataSource, ImportJob} | 27 | import ldif.local.scheduler.{DataSource, ImportJob} |
28 | import ldif.workbench.model.modules.dataSource.DataSourceTask | 28 | import ldif.workbench.model.modules.dataSource.DataSourceTask |
29 | import ldif.local.IntegrationJob | ||
30 | import ldif.config.IntegrationConfig | ||
31 | import ldif.workbench.model.modules.integration.IntegrationTask | ||
29 | 32 | ||
30 | class FileWorkspace(file: File) extends Workspace { | 33 | class FileWorkspace(file: File) extends Workspace { |
31 | private val log = LoggerFactory.getLogger(getClass.getName) | 34 | private val log = LoggerFactory.getLogger(getClass.getName) |
... | ... | ||
65 | User().project.importModule.update(ImportTask(job)) | 68 | User().project.importModule.update(ImportTask(job)) |
66 | } | 69 | } |
67 | 70 | ||
71 | override def saveIntegrationJob(name: Identifier, xml: String, properties: String) { | ||
72 | val integrationBaseDir = (file +("/"+ User().project.name +"/integration")).getCanonicalPath | ||
73 | val config = IntegrationConfig.fromString(xml, integrationBaseDir) | ||
74 | User().project.integrationModule.update(IntegrationTask(IntegrationJob(config))) | ||
75 | } | ||
76 | |||
68 | override def importImportJob(file: File) { | 77 | override def importImportJob(file: File) { |
69 | println(file.getCanonicalPath) | 78 | println(file.getCanonicalPath) |
70 | log.info(file.getCanonicalPath) | 79 | log.info(file.getCanonicalPath) |