package com.aurea.maven.plugins.sonic;

 import java.io.File;

 import java.io.IOException;

 import org.apache.maven.execution.MavenSession;

 import org.apache.maven.plugin.BuildPluginManager;

 import org.apache.maven.plugin.MojoExecutionException;

 import org.apache.maven.plugin.MojoFailureException;

 import org.codehaus.plexus.util.FileUtils;

 import org.twdata.maven.mojoexecutor.MojoExecutor;

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

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

 import com.progress.sonic.utilities.mfutils.MFUtils;

 import com.progress.sonic.utilities.mfutils.NullArtifactNotificationListener;

 import com.sonicsw.deploy.artifact.SonicFSArtifact;

 import com.sonicsw.deploy.storage.FileArtifactStorage;

 import com.sonicsw.deploy.tools.common.ExportPropertiesArtifact;

 /**

  * exports from the Sonic Domain the ESB artifacts from the current Maven

  * artifact into /deploy/generated-src.

  * 

  * @author Jamie Townsend

  * 

  * @goal unpack-dependencies

  */

 public class SonicUnpackDependenciesMojo extends AbstractSonicMojo {

         private static final int DOMAIN_PING_TIMEOUT = 1000;

         /**

          * The Sonic Domain to connect to.

          * 

          * @parameter property="sonicesb.devDomainName" default-value="Domain1"

          * @required

          */

         private String domain;

         /**

          * The user name used for the connection.

          * 

          * @parameter property="sonicesb.devDomainUser"

          *            default-value="Administrator"

          * @required

          */

         private String user;

         /**

          * The password used for the connection.

          * 

          * @parameter property="sonicesb.devDomainPassword"

          *            default-value="Administrator"

          * @required

          */

         private String password;

         /**

          * The management connection url.

          * 

          * @parameter property="sonicesb.devDomainUrl"

          *            default-value="tcp://localhost:2506"

          * @required

          */

         private String mgmtUrl;

         /**

          * The Maven Session Object.

          * 

          * @parameter default-value="${session}"

          * @required

          * @readonly

          */

         private MavenSession session;

         /**

          * The Maven PluginManager Object.

          * 

          * @component

          * @required

          */

         protected BuildPluginManager pluginManager;

         private File markersDirectory = null;

         /**

    * 

    */

         protected MFUtils mfUtils = null;

         /**

          * @return MFUtils

          * @throws MojoExecutionException

          *             if something goes wrong

          */

         protected MFUtils getMFUtils() throws MojoExecutionException {

                 if (mfUtils == null) {

                         getLog().info("Connecting to Sonic Domain ...");

                         getLog().debug("Domain: " + getDomainName());

                         getLog().debug("ManagementURL: " + getManagementUrl());

                         getLog().debug("User: " + getAdminUser());

                         getLog().debug("Password: " + getAdminPassword());

                         mfUtils = new MFUtils(getDomainName(), getManagementUrl(), getAdminUser(), getAdminPassword());

                 }

                 return mfUtils;

         }

         @Override

         protected void doExecute() throws MojoExecutionException, MojoFailureException {

                 try {

                         markersDirectory = new File(getDependencyDirectory(), "markers");

                         unpackSonicCompile();

                         // TBO: The unpackDxsiXars is now running all the time. It will take

                         // artifacts from the dxsi-distribution

                         // and load it into the SonicDS for operational work.

                         unpackDxsiXars();

                         unpackTopologyConfig();

                         // Tests will need to point out if the unpack sonic provided options

                         // is really needed.

                         // Removed it in order to allow for SDP Package (SDM)

                         // interdependencies in provided mode.

                         // Inserting unpack Sonic Provided but only to allow Service Types

                         // being provided and getting the rules from the snippets

                         unpackSonicProvided();

                         copyDependentJars();

                         copySonicExtensions();

                 } catch (Exception ex) {

                         if (ex.getCause() != null && ex.getCause().getMessage() != null

                                         && ex.getCause().getMessage().contains("MDEP-98")) {

                                 // KNOW ISSUE: throws an exception when using Eclipse Workspace

                                 // referenced projects

                                 ex.printStackTrace();

                         } else {

                                 throw ex;

                         }

                 }

         }

         private void unpackTopologyConfig() throws MojoExecutionException {

                 MojoExecutor.executeMojo(MojoExecutor.plugin(MojoExecutor.groupId("org.apache.maven.plugins"),

                                 MojoExecutor.artifactId("maven-dependency-plugin"), MojoExecutor.version("2.7")), MojoExecutor

                                 .goal("unpack-dependencies"), MojoExecutor.configuration(new MojoExecutor.Element[] {

                                 MojoExecutor.element(MojoExecutor.name("outputDirectory"), getDependencyDirectory() + "/topology"),

                                 MojoExecutor.element(MojoExecutor.name("excludeScope"), "provided"),

                                 MojoExecutor.element(MojoExecutor.name("markersDirectory"), markersDirectory.getAbsolutePath()),

                                 MojoExecutor.element(MojoExecutor.name("includeTypes"), "topology"),

                                 MojoExecutor.element(MojoExecutor.name("useRepositoryLayout"), "false"),

                                 MojoExecutor.element(MojoExecutor.name("useSubDirectoryPerType"), "false") }), MojoExecutor

                                 .executionEnvironment(project, session, pluginManager));

                 try {

                         FileUtils.deleteDirectory(markersDirectory);

                 } catch (IOException e) {

                         // This should never happen and if it does, it shouldn't really

                         // matter

                         e.printStackTrace();

                 }

         }

         private void unpackSonicCompile() throws MojoExecutionException {

                 // projects

                 MojoExecutor.executeMojo(MojoExecutor.plugin(MojoExecutor.groupId("org.apache.maven.plugins"),

                                 MojoExecutor.artifactId("maven-dependency-plugin"), MojoExecutor.version("2.7")), MojoExecutor

                                 .goal("unpack-dependencies"), MojoExecutor.configuration(new MojoExecutor.Element[] {

                                 MojoExecutor.element(MojoExecutor.name("outputDirectory"), getDependencyDirectory() + "/xar/compile"),

                                 MojoExecutor.element(MojoExecutor.name("excludeScope"), "provided"),

                                 MojoExecutor.element(MojoExecutor.name("markersDirectory"), markersDirectory.getAbsolutePath()),

                                 MojoExecutor.element(MojoExecutor.name("includeTypes"), "zip,esb,esbstyp,connect"),

                                 MojoExecutor.element(MojoExecutor.name("useRepositoryLayout"), "true"),

                                 MojoExecutor.element(MojoExecutor.name("useSubDirectoryPerType"), "true") }), MojoExecutor

                                 .executionEnvironment(project, session, pluginManager));

                 try {

                         FileUtils.deleteDirectory(markersDirectory);

                 } catch (IOException e) {

                         // This should never happen and if it does, it shouldn't really

                         // matter

                         e.printStackTrace();

                 }

         }

         private void unpackDxsiXars() throws MojoExecutionException {

                 File dxsiExtractDir = new File(getDependencyDirectory(), "dxsi");

                 File dependencyTmpDir = new File(dxsiExtractDir, "dependencyTmp");

                 File xarTmpDir = new File(dxsiExtractDir, "xarTmp");

                 MojoExecutor.executeMojo(MojoExecutor.plugin(MojoExecutor.groupId("org.apache.maven.plugins"),

                                 MojoExecutor.artifactId("maven-dependency-plugin"), MojoExecutor.version("2.7")), MojoExecutor

                                 .goal("unpack-dependencies"), MojoExecutor.configuration(new MojoExecutor.Element[] {

                                 MojoExecutor.element(MojoExecutor.name("outputDirectory"), dependencyTmpDir.getPath()),

                                 MojoExecutor.element(MojoExecutor.name("excludeScope"), "provided"),

                                 MojoExecutor.element(MojoExecutor.name("includeScope"), "compile"),

                                 MojoExecutor.element(MojoExecutor.name("markersDirectory"), markersDirectory.getAbsolutePath()),

                                 MojoExecutor.element(MojoExecutor.name("includeTypes"), "dxsi"),

                                 MojoExecutor.element(MojoExecutor.name("useRepositoryLayout"), "true"),

                                 MojoExecutor.element(MojoExecutor.name("useSubDirectoryPerType"), "true") }), MojoExecutor

                                 .executionEnvironment(project, session, pluginManager));

                 // TBO

                 // Extracting the xar file to a temp location.

                 String[] xarExtension = { "xar" };

                 String[] xarFiles = FileUtils.getFilesFromExtension(dependencyTmpDir.getPath(), xarExtension);

                 for (String xarFilename : xarFiles) {

                         ZipUtilities.doUnzipAction(xarFilename, xarTmpDir.getPath());

                 }

                 // Removing the ESB Directory ... avoiding the import of the service

                 // instance and endpoint.

                 try {

                         FileUtils.deleteDirectory(new File(xarTmpDir, "ESB"));

                 } catch (IOException e1) {

                         // TODO Auto-generated catch block

                         e1.printStackTrace();

                 }

                 // Uploading the xar content but ignore the Endpoint and Service

                 // Instance

                 try {

                         FileArtifactStorage fas = new FileArtifactStorage();

                         fas.addNotificationListener(new NullArtifactNotificationListener());

                         fas.setRoot(xarTmpDir.getAbsolutePath());

                         ExportPropertiesArtifact expProperties = new ExportPropertiesArtifact();

                         // resources root e.g. JARs

                         expProperties.addRoot(new SonicFSArtifact("/"));

                         // TBO: Ignoring the ESB-Endpoint and ServiceInstance. These need to

                         // be uploaded manually

                         // TBO: By default they are not included ... no ignore needed.

                         // Creating Ignores List

                         // expProperties.addIgnore(new

                         // ESBArtifact(ESBArtifact.CONNECTION_TYPE, "**"));

                         // expProperties.addIgnore(new

                         // ESBArtifact(ESBArtifact.ENDPOINT_TYPE, "**"));

                         // expProperties.addIgnore(new ESBArtifact(ESBArtifact.SERVICE_TYPE,

                         // "**"));

                         // ignores.add(new ESBArtifact(ESBArtifact.SERVICE_TYPE,

                         // "DataXtendSIServiceType"));

                         // just to make sure that no workspace related files get imported,

                         // although that should never happen

                         expProperties.addIgnore(new SonicFSArtifact("workspace/"));

                         // expProperties.addIgnore(ignores.toArray(new ESBArtifact[] {} ));

                         if (!MFUtils.pingDomain(getManagementUrl(), DOMAIN_PING_TIMEOUT)) {

                                 getLog().warn("Could not connect to Sonic Domain at " + getManagementUrl());

                         } else {

                                 new ESBArtifactCopyJob(fas, getMFUtils().getDSArtifactStorage(), expProperties, false).copy();

                                 getLog().info("DXSI Environment Imported!");

                         }

                 } catch (Exception e) {

                         getLog().error("Failed to import ESB Service Type into local DS", e);

                 } finally {

                         getMFUtils().cleanup();

                 }

                 // TBO: REMARK: 2013 - Do we need to delete these directories at this

                 // point? It might be that these are still needed at the time we extract

                 // the generated resource

                 // This is not an issue for the process build in the workbench but is an

                 // issue for the head-less build cycle due to the difference in

                 // dependencies.

                 // try {

                 // FileUtils.deleteDirectory(markersDirectory);

                 // FileUtils.deleteDirectory(dependencyTmpDir);

                 // FileUtils.deleteDirectory(xarTmpDir);

                 // } catch (IOException e) {

                 // // This should never happen and if it does, it shouldn't really

                 // matter

                 // e.printStackTrace();

                 // }

         }

         /**

          * @return String

          * @throws MojoExecutionException

          *             if something goes wrong

          */

         protected String getDomainName() throws MojoExecutionException {

                 return domain;

         }

         /**

          * @return String

          * @throws MojoExecutionException

          *             if something goes wrong

          */

         protected String getAdminUser() throws MojoExecutionException {

                 return user;

         }

         /**

          * @return String

          * @throws MojoExecutionException

          *             if something goes wrong

          */

         protected String getAdminPassword() throws MojoExecutionException {

                 return password;

         }

         /**

          * @return String

          * @throws MojoExecutionException

          *             if something goes wrong

          */

         protected String getManagementUrl() throws MojoExecutionException {

                 return mgmtUrl;

         }

         @SuppressWarnings("unused")

         private void unpackSonicProvided() throws MojoExecutionException {

                 MojoExecutor.executeMojo(MojoExecutor.plugin(MojoExecutor.groupId("org.apache.maven.plugins"),

                                 MojoExecutor.artifactId("maven-dependency-plugin"), MojoExecutor.version("2.7")), MojoExecutor

                                 .goal("unpack-dependencies"), MojoExecutor.configuration(new MojoExecutor.Element[] {

                                 MojoExecutor.element(MojoExecutor.name("outputDirectory"), getDependencyDirectory() + "/xar/provided"),

                                 MojoExecutor.element(MojoExecutor.name("excludeScope"), "compile"),

                                 MojoExecutor.element(MojoExecutor.name("includeScope"), "provided"),

                                 MojoExecutor.element(MojoExecutor.name("markersDirectory"), markersDirectory.getAbsolutePath()),

                                 MojoExecutor.element(MojoExecutor.name("includeTypes"), "esbstyp,esb"), // "zip,esb,esbstyp,dxsi,connect"

                                 MojoExecutor.element(MojoExecutor.name("useRepositoryLayout"), "true"),

                                 MojoExecutor.element(MojoExecutor.name("useSubDirectoryPerType"), "true") }), MojoExecutor

                                 .executionEnvironment(project, session, pluginManager));

                 try {

                         FileUtils.deleteDirectory(markersDirectory);

                 } catch (IOException e) {

                         // This should never happen and if it does, it shouldn't really

                         // matter

                         e.printStackTrace();

                 }

         }

         private void copyDependentJars() throws MojoExecutionException {

                 getLog().debug("TBO-DEBUG- COPY JAR FILES");

                 getLog().debug("TBO-DEBUG- Output Directory: " + getDependencyDirectory() + "/jar");

                 MojoExecutor.executeMojo(MojoExecutor.plugin(MojoExecutor.groupId("org.apache.maven.plugins"),

                                 MojoExecutor.artifactId("maven-dependency-plugin"), MojoExecutor.version("2.7")), MojoExecutor

                                 .goal("copy-dependencies"), MojoExecutor.configuration(new MojoExecutor.Element[] {

                                 MojoExecutor.element(MojoExecutor.name("outputDirectory"), getDependencyDirectory() + "/jar"),

                                 MojoExecutor.element(MojoExecutor.name("excludeScope"), "test"),

                                 MojoExecutor.element(MojoExecutor.name("includeScope"), "runtime"),

                                 MojoExecutor.element(MojoExecutor.name("markersDirectory"), markersDirectory.getAbsolutePath()),

                                 MojoExecutor.element(MojoExecutor.name("excludeGroupIds"),

                                                 "com.aurea.sonic.mq,com.aurea.sonic.esb,junit,org.mockito"),

                                 MojoExecutor.element(MojoExecutor.name("excludeArtifactIds"), "esb_mockups"),

                                 MojoExecutor.element(MojoExecutor.name("includeTypes"), "jar"),

                                 MojoExecutor.element(MojoExecutor.name("useRepositoryLayout"), "true"),

                                 MojoExecutor.element(MojoExecutor.name("useSubDirectoryPerType"), "false") }), MojoExecutor

                                 .executionEnvironment(project, session, pluginManager));

                 getLog().debug("TBO-DEBUG- COPY JAR FILES - END");

                 try {

                         FileUtils.deleteDirectory(markersDirectory);

                 } catch (IOException e) {

                         e.printStackTrace();

                 }

         }

         private void copySonicExtensions() throws MojoExecutionException {

                 MojoExecutor.executeMojo(MojoExecutor.plugin(MojoExecutor.groupId("org.apache.maven.plugins"),

                                 MojoExecutor.artifactId("maven-dependency-plugin"), MojoExecutor.version("2.7")), MojoExecutor

                                 .goal("copy-dependencies"), MojoExecutor.configuration(new MojoExecutor.Element[] {

                                 MojoExecutor.element(MojoExecutor.name("outputDirectory"), getDependencyDirectory() + "/jar"),

                                 MojoExecutor.element(MojoExecutor.name("includeScope"), "runtime"),

                                 MojoExecutor.element(MojoExecutor.name("markersDirectory"), markersDirectory.getAbsolutePath()),

                                 MojoExecutor.element(MojoExecutor.name("includeGroupIds"),

                                                 "com.progress.sonic.mqx,com.progress.sonic.esbx,com.aurea.sonic.mqx,com.aurea.sonic.esbx"),

                                 MojoExecutor.element(MojoExecutor.name("includeTypes"), "jar"),

                                 MojoExecutor.element(MojoExecutor.name("useRepositoryLayout"), "true"),

                                 MojoExecutor.element(MojoExecutor.name("useSubDirectoryPerType"), "false") }), MojoExecutor

                                 .executionEnvironment(project, session, pluginManager));

                 try {

                         FileUtils.deleteDirectory(markersDirectory);

                 } catch (IOException e) {

                         // This should never happen and if it does, it shouldn't really

                         // matter

                         e.printStackTrace();

                 }

         }

 }