/*
    * This file is part of ***  M y C o R e  ***
    * See http://www.mycore.de/ for details.
    *
    * MyCoRe is free software: you can redistribute it and/or modify
    * it under the terms of the GNU General Public License as published by
    * the Free Software Foundation, either version 3 of the License, or
    * (at your option) any later version.
    *
   * MyCoRe 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 General Public License for more details.
   *
   * You should have received a copy of the GNU General Public License
   * along with MyCoRe.  If not, see <http://www.gnu.org/licenses/>.
   */
  
  package org.mycore.services.packaging;
  
  import java.util.Map;
  import java.util.concurrent.ExecutionException;
  import java.util.stream.Collectors;
  
  import org.apache.logging.log4j.LogManager;
  import org.apache.logging.log4j.Logger;
  import org.mycore.common.config.MCRConfiguration2;
  import org.mycore.services.queuedjob.MCRJob;
  import org.mycore.services.queuedjob.MCRJobAction;
  
  /**
   * Used to run a {@link MCRPacker} inside a {@link org.mycore.services.queuedjob.MCRJobQueue}
   *
   * @author Sebastian Hofmann (mcrshofm)
   */
  public class MCRPackerJobAction extends MCRJobAction {
  
      private static final Logger LOGGER = LogManager.getLogger();
  
      private MCRPacker packerInstance;
  
      public MCRPackerJobAction() {
      }
  
      public MCRPackerJobAction(MCRJob job) {
          super(job);
      }
  
      @Override
      public final boolean isActivated() {
          return true;
      }
  
      @Override
      public String name() {
          return "MCRPackerJobAction-" + getPackerId();
      }
  
      private String getPackerId() {
          return getParameters().get("packer");
      }
  
      public MCRPacker getPackerInstance() {
          return this.packerInstance;
      }
  
      @Override
      public final void execute() throws ExecutionException {
          String packerId = getPackerId();
          Map<String, String> packerConfiguration = getConfiguration(packerId);
          packerInstance = MCRConfiguration2.getOrThrow(MCRPacker.PACKER_CONFIGURATION_PREFIX + packerId + ".Class",
              MCRConfiguration2::instantiateClass);
  
          Map<String, String> parameters = getParameters();
  
          packerInstance.setParameter(parameters);
          packerInstance.setConfiguration(packerConfiguration);
          LOGGER.info(() -> {
              StringBuilder messageBuilder = new StringBuilder();
              messageBuilder.append(getPackerId()).append(" starts packing with parameters: ");
              parameters.forEach((key, value) -> messageBuilder.append(key).append("=").append(value).append(";"));
              return messageBuilder.toString();
          });
          packerInstance.pack();
      }
  
      protected final Map<String, String> getParameters() {
          return this.job.getParameters();
      }
  
      public static Map<String, String> getConfiguration(String packerId) {
          String packerConfigPrefix = MCRPacker.PACKER_CONFIGURATION_PREFIX + packerId + ".";
          return MCRConfiguration2.getPropertiesMap()
              .entrySet()
              .stream()
              .filter(p -> p.getKey().startsWith(packerConfigPrefix))
              .collect(
                  Collectors.toMap(e -> e.getKey().substring(packerConfigPrefix.length()), Map.Entry::getValue));
      }
 
     @Override
     public void rollback() {
         if (packerInstance != null) {
             packerInstance.rollback();
         }
     }
 
 }