867572666f0df0188612bd5199186553bd670e30436d3421e4242ab391ef48b4c453bcaed62e7490
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)