package com.aurea.maven.plugins.sonic.sdm.container.impl;

 import java.io.StringReader;

 import java.util.ArrayList;

 import java.util.Arrays;

 import java.util.List;

 import org.codehaus.plexus.util.StringUtils;

 import org.codehaus.plexus.util.xml.Xpp3Dom;

 import org.codehaus.plexus.util.xml.Xpp3DomBuilder;

 import com.aurea.maven.plugins.sonic.sdm.container.IMFContainer;

 import com.aurea.maven.plugins.sonic.sdo.AbstractDataObjectInstance;

 import commonj.sdo.DataObject;

 public class DefaultMFContainer extends AbstractDataObjectInstance implements IMFContainer {

   @Override

   protected String getNamespace() {

     return "http://www.soa-knowledge.net/ESBPlugin";

   }

   @Override

   protected String getXSDType() {

     return "ESBContainer";

   }

   @Override

   protected String getResourceLocation() {

     return "schema/MFContainer.xsd";

   }

   /**

    * @param _name

    *          _name

    * @param _targetContainer

    *          _targetContainer

    * @param _bootContainer

    *          _bootContainer

    * @param _hosts

    *          _hosts

    */

   public DefaultMFContainer(

                   final String _name, 

                   final String _targetContainer, 

                   final boolean _bootContainer, 

                   final String _backupContainer,

                   final String _hosts,

                   final boolean _clone) {

     doInit(_name, _targetContainer, _bootContainer, _backupContainer, _hosts, _clone);

   }

   public String getSegment(){

           //System.out.println("TIM TIM TIM - Calling getSegment and returning:" + getDataObject().getString("Segment"));

           return getDataObject().getString("Segment");

   }

   public String getLogDirectory(){

           //System.out.println("TIM TIM TIM - Calling getLogDirectory and returning: " + getDataObject().getString("LogDirectory"));

           return getDataObject().getString("LogDirectory");

   }

   public String getContainerParameterSet(){

          // System.out.println("TIM TIM TIM - Calling getContainerParameterSet and returning: " + getDataObject().getString("ContainerParameterSet"));

           return getDataObject().getString("ContainerParameterSet");

   }

   /**

    * {@inheritDoc}

    */

   public String getName() {

           //System.out.println("TIM TIM TIM - Calling getName and returning: " + getDataObject().getString("Id"));

     return getDataObject().getString("Id");

   }

   /**

    * {@inheritDoc}

    */

   public boolean isBootContainer() {

     return getDataObject().getBoolean("BootContainer");

   }

   public boolean isClone(){

           return getDataObject().getBoolean("Clone");

   }

   private void doInit(

                   final String _name, 

                   final String _targetContainer, 

                   final boolean _bootContainer, 

                   final String _backupContainer, 

                   final String _hosts,

                   final boolean _clone) {

     DataObject dObj = getDataObject();

     dObj.set("Id", _name);

     if (_targetContainer != null) {

       dObj.set("TargetContainer", _targetContainer);

     }

     dObj.set("BootContainer", Boolean.valueOf(_bootContainer));

     if(StringUtils.isNotEmpty(_backupContainer)) {

             dObj.set("BackupContainer", _backupContainer);

 //            System.out.println("SETTING THE CLONE VALUE TO: " + _clone);

             dObj.set("Clone", _clone);

     }

 //    if(StringUtils.isNotEmpty(_segment)){

 //            dObj.set("Segment", _segment);

 //    }

     if (_hosts != null) {

       DataObject obj = dObj.createDataObject("Hosts");

       obj.setList("Host", Arrays.asList(_hosts.split(",")));

     }

   }

   /**

    * @param _hosts

    *          _hosts

    */

   @SuppressWarnings("unchecked")

   public void addHosts(final String _hosts) {

     if (_hosts == null) {

       return;

     }

     DataObject obj = getDataObject().getDataObject("Hosts");

     if (obj == null) {

       obj = getDataObject().createDataObject("Hosts");

       obj.setList("Host", Arrays.asList(_hosts.split(",")));

     } else {

       List<String> hostList = new ArrayList<String>();

       hostList.addAll(obj.getList("Host"));

       for (String host : _hosts.split(",")) {

         if (!hostList.contains(host)) {

           hostList.add(host);

         }

       }

       obj.setList("Host", hostList);

     }

   }

   /**

    * {@inheritDoc}

    */

   public Xpp3Dom removeNamespaces() {

     // TODO: fix this

     // quick hack to remove namespaces

     Xpp3Dom element = new Xpp3Dom("ESBContainer");

     try {

       Xpp3Dom dom = Xpp3DomBuilder.build(new StringReader(toString()));

       for (Xpp3Dom child : dom.getChildren()) {

         element.addChild(child);

       }

     } catch (Exception e) {

       // ignore

             e.printStackTrace();

     }

     return element;

   }

   /**

    * {@inheritDoc}

    */

   public Xpp3Dom removeNamespaces8() {

     // TODO: fix this

     // quick hack to remove namespaces

     Xpp3Dom element = new Xpp3Dom("ESBContainer");

     try {

       Xpp3Dom dom = Xpp3DomBuilder.build(new StringReader(toString()));

       for (Xpp3Dom child : dom.getChildren()) {

         if (child.getName().equals("Hosts")) {

             Xpp3Dom changeHosts = new Xpp3Dom("LogicalHosts");

             changeHosts.setValue(child.getValue());

             for(Xpp3Dom changeHost : child.getChildren()){

               Xpp3Dom logicalHost = new Xpp3Dom("LogicalHost");

               logicalHost.setValue(changeHost.getValue());

               changeHosts.addChild(logicalHost);

             }

             element.addChild(changeHosts);

         } else {

           element.addChild(child);

         }

       }

     } catch (Exception e) {

       // ignore

             e.printStackTrace();

     }

     return element;

   }

 }