package com.aurea.maven.plugins.sonic.esb;

 import java.io.File;

 import java.util.HashSet;

 import java.util.List;

 import org.codehaus.plexus.util.FileUtils;

 import com.aurea.maven.plugins.sonic.AbstractSonicMojo;

 import com.aurea.maven.plugins.sonic.utils.FileUtilities;

 import com.aurea.maven.plugins.sonic.utils.ProjectAnalyzer;

 import com.progress.sonic.utilities.esb.admin.XarAnalyzer;

 import com.sonicsw.deploy.IArtifact;

 public abstract class AbstractESBMojo extends AbstractSonicMojo {

   /**

    * @parameter default-value="deploy/generated-src/xar"

    */

   protected final File deployGenSrcDir     = null;

   /**

    * @parameter default-value="deploy/generated-src/test-xar"

    */

   protected final File testDeployGenSrcDir = null;

   /**

    * the target directory for the generated testing processes with Stub references.

    * 

    * @parameter default-value="target/generated-test-sources/sonicesb"

    */

   protected File        targetGenTestSrcDir;

   /**

    * the target directory for the buggy workaround on the temp dir issue when analyzin xar files.

    * 

    * @parameter default-value="target/tmp/unzipdir"

    */

   protected File        xarUnzipDir;

   /**

    * @return list of processes found in the dependent artifacts

    */

   protected HashSet<String> getDependencyProcessNames() {

     HashSet<String> hs = new HashSet<String>();

     // get a list of dependent .xar files

     String[] xarFiles = FileUtilities.getFileList(getDependencyDirectory(), "**/*.xar", null);

     for (String currXarFile : xarFiles) {

       File currXarFullPath = new File(getDependencyDirectory(), currXarFile);

       XarAnalyzer xa = new XarAnalyzer(currXarFullPath);

       List<IArtifact> aa = xa.getAllArtifacts();

       getLog().debug("    Searching xar: " + currXarFullPath.getAbsolutePath());

       getLog().debug("    Found artifacts: " + aa);

       for (IArtifact artifact : aa) {

         getLog().debug("      getName: " + artifact.getName());

         getLog().debug("      getPath: " + artifact.getPath());

         getLog().debug("      getRootDirectory: " + artifact.getRootDirectory());

         if ("Processes".equals(artifact.getRootDirectory())) {

           hs.add(artifact.getName());

          // getLog().error("Found a Process: " + artifact.getName());

         }

       }

     }

     return hs;

   }

   /**

    * copies process source files from one location to another, replacing the .esbp extension with .xml in the process.

    * 

    * @param _srcDir

    *          source directory of the copy process. All sub-directories will be automatically included.

    * @param _targetDir

    *          target directory of the copy process. The directory structure will will flattened, so all process files

    *          will be located directly in this directory.

    */

   protected void copyProcessFilesReplacingEsbpWithXml(final String _srcDir, final String _targetDir) {

     getLog().info("Copying process files from " + _srcDir + " to " + _targetDir);

     new File(_targetDir, "ESB").mkdirs();

     new File(_targetDir, "SonicFS").mkdirs();

     getLog().debug("TBO: Directories Created: ESB + SonicFS");

     getLog().debug("TBO: Source-Directory: " + _srcDir);

     for (File processFile : ProjectAnalyzer.getProcessSourceFiles(_srcDir)) {

       getLog().debug("TBO: ProcessFile: " + processFile);

       try {

         getLog().info("  Found process file : " + processFile);

         File processTargetFile = new File(_targetDir, "ESB/Processes/"

           + ProjectAnalyzer.getProcessNameFromFile(processFile) + ".xml");

         processTargetFile.getParentFile().mkdirs();

         FileUtils.copyFile(processFile, processTargetFile);

       } catch (Exception e) {

         getLog().warn("  Error copying process file :" + processFile + e.getMessage());

       }

     }

   }

 }