/*
    * Copyright (C) 2003-2014 eXo Platform SAS.
    *
    * This program is free software: you can redistribute it and/or modify
    * it under the terms of the GNU Affero General Public License as published by
    * the Free Software Foundation, either version 3 of the License, or
    * (at your option) any later version.
    *
    * This program is distributed in the hope that it will be useful,
   * but WITHOUT ANY WARRANTY; without even the implied warranty of
   * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
   * GNU Affero General Public License for more details.
   *
   * You should have received a copy of the GNU Affero General Public License
   * along with this program. If not, see <http://www.gnu.org/licenses/>.
   */
  package org.exoplatform.services.cms.i18n.impl;
  
  import java.util.ArrayList;
  import java.util.Date;
  import java.util.Iterator;
  import java.util.List;
  import java.util.regex.Matcher;
  import java.util.regex.Pattern;
  
  import javax.jcr.NoSuchWorkspaceException;
  import javax.jcr.Node;
  import javax.jcr.PathNotFoundException;
  import javax.jcr.RepositoryException;
  import javax.jcr.Session;
  
  import org.apache.commons.lang.StringUtils;
  import org.exoplatform.container.configuration.ConfigurationManager;
  import org.exoplatform.container.xml.InitParams;
  import org.exoplatform.container.xml.ObjectParameter;
  import org.exoplatform.services.cms.i18n.MultiLanguageService;
  import org.exoplatform.services.deployment.plugins.TranslationDeploymentDescriptor;
  import org.exoplatform.services.jcr.RepositoryService;
  import org.exoplatform.services.jcr.ext.common.SessionProvider;
  import org.exoplatform.services.log.ExoLogger;
  import org.exoplatform.services.log.Log;
  import org.exoplatform.services.wcm.portal.artifacts.CreatePortalPlugin;
  import org.exoplatform.services.wcm.utils.WCMCoreUtils;
  
  /**
   * Created by The eXo Platform SAS
   * Author : eXoPlatform
   *          dongpd@exoplatform.com
   * Oct 12, 2012
   */
  public class AddTranslationPlugin  extends CreatePortalPlugin {
    
    /**
     * Logger.
     */
    private static final Log LOG = ExoLogger.getLogger(AddTranslationPlugin.class.getName());
    
    private static final Pattern FILE_EXPLORER_URL_SYNTAX = Pattern.compile("([^:/]+):(/.*)");
  
    /**
     * The init params.
     */
    private InitParams initParams;
  
    /**
     * The Multilanguage service.
     */
    private MultiLanguageService languageService;
  
    /**
     * Instantiates a new AddTranslationPlugin plugin.
     * 
     * @param initParams
     *          the init params
     * @param languageService
     *          Multilanguage service
     */
    public AddTranslationPlugin(InitParams initParams,
                                ConfigurationManager configurationManager,
                                RepositoryService repositoryService,
                                MultiLanguageService languageService) {
      super(initParams, configurationManager, repositoryService);
      this.initParams = initParams;
      this.languageService = languageService;
    }
  
    @SuppressWarnings("rawtypes")
    @Override
    public void deployToPortal(SessionProvider sessionProvider, String portalName) throws Exception {
      Iterator iterator = initParams.getObjectParamIterator();
      TranslationDeploymentDescriptor translationDescriptor = null;
      while (iterator.hasNext()) {
        ObjectParameter objectParameter = (ObjectParameter) iterator.next();
        translationDescriptor = (TranslationDeploymentDescriptor) objectParameter.getObject();
        List<String> translationPaths = translationDescriptor.getTranslationNodePaths();
        boolean isOverrideExistence = translationDescriptor.isOverrideExistence();
        
        // Replace {portalName} with specific portal
        List<String> translationRealPaths = new ArrayList<String>();
       if (portalName != null && portalName.length() > 0) {
         for (String path : translationPaths) {
           translationRealPaths.add(StringUtils.replace(path, "{portalName}", portalName));
         }
       }
       
       // Add translation
       int numOfTrans = translationRealPaths.size();
       for (int i = 0; i < numOfTrans; i++) {
         Node currNode = this.getNodeByPath(translationRealPaths.get(i));
         if (currNode == null) continue;
         for (int j = i + 1; j < numOfTrans; j++) {
           Node targetTranslationNode = this.getNodeByPath(translationRealPaths.get(j));
           if (targetTranslationNode == null) continue;
           try {
             languageService.addLinkedLanguage(currNode, targetTranslationNode, isOverrideExistence);
             languageService.addLinkedLanguage(targetTranslationNode, currNode, isOverrideExistence);
           } catch (Exception e) {
             if (LOG.isErrorEnabled()) {
               LOG.error("Add translation " + translationRealPaths.get(j) + " for " + translationRealPaths.get(i) + " FAILED at "
                   + new Date().toString() + "\n", e);
             }
           }
         }
       }
     }
   }
   
   /**
    * Get node by node path.
    * 
    * @param nodePath node path of specific node with syntax [workspace:node path]
    * @return Node of specific node nath
    * @throws RepositoryException 
    * @throws Exception
    */
   private Node getNodeByPath(String nodePath) throws RepositoryException
   {
     try
     {
       Matcher matcher = FILE_EXPLORER_URL_SYNTAX.matcher(nodePath);
       if (!matcher.find()) return null;
       String wsName = matcher.group(1);
       nodePath = matcher.group(2);
       Session session = WCMCoreUtils.getSystemSessionProvider().getSession(wsName, WCMCoreUtils.getRepository());
       return (Node)session.getItem(nodePath);
     }
     catch (PathNotFoundException e)
     {
       return null;
     }
     catch (NoSuchWorkspaceException e)
     {
       return null;
     }
   }
 }