/*
    * (c) Copyright 2006-2020 by rapiddweller GmbH & Volker Bergmann. All rights reserved.
    *
    * Redistribution and use in source and binary forms, with or without
    * modification, is permitted under the terms of the
    * GNU General Public License.
    *
    * For redistributing this software or a derivative work under a license other
    * than the GPL-compatible Free Software License as defined by the Free
   * Software Foundation or approved by OSI, you must first obtain a commercial
   * license to this software product from rapiddweller GmbH & Volker Bergmann.
   *
   * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
   * WITHOUT A WARRANTY OF ANY KIND. ALL EXPRESS OR IMPLIED CONDITIONS,
   * REPRESENTATIONS AND WARRANTIES, INCLUDING ANY IMPLIED WARRANTY OF
   * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE OR NON-INFRINGEMENT, ARE
   * HEREBY EXCLUDED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE
   * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
   * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
   * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
   * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
   * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
   * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
   * POSSIBILITY OF SUCH DAMAGE.
   */
  
  package com.rapiddweller.benerator.composite;
  
  import com.rapiddweller.benerator.BeneratorConstants;
  import com.rapiddweller.benerator.GeneratorContext;
  import com.rapiddweller.benerator.engine.BeneratorContext;
  import com.rapiddweller.benerator.wrapper.ProductWrapper;
  import com.rapiddweller.common.MessageHolder;
  import com.rapiddweller.common.Resettable;
  import com.rapiddweller.common.ThreadAware;
  import com.rapiddweller.common.ThreadUtil;
  import org.apache.logging.log4j.LogManager;
  import org.apache.logging.log4j.Logger;
  
  import java.io.Closeable;
  import java.util.ArrayList;
  import java.util.List;
  
  /**
   * Offers support for entity or array component generation with or without variable generation.<br/><br/>
   * Created: 13.01.2011 10:52:43
   *
   * @param <E> the type parameter
   * @author Volker Bergmann
   * @since 0.6.4
   */
  public class ComponentAndVariableSupport<E> implements ThreadAware, MessageHolder, Resettable, Closeable {
  
    private static final Logger LOGGER = LogManager.getLogger(ComponentAndVariableSupport.class);
    private static final Logger STATE_LOGGER = LogManager.getLogger(BeneratorConstants.STATE_LOGGER);
  
    private final String instanceName;
    private final List<GeneratorComponent<E>> components;
    private String message;
  
    /**
     * Instantiates a new Component and variable support.
     *
     * @param instanceName the instance name
     * @param components   the components
     * @param context      the context
     */
    public ComponentAndVariableSupport(String instanceName, List<GeneratorComponent<E>> components,
                                       GeneratorContext context) {
      this.instanceName = instanceName;
      this.components = (components != null ? components : new ArrayList<>());
    }
  
    /**
     * Init.
     *
     * @param context the context
     */
    public void init(BeneratorContext context) {
      for (GeneratorComponent<?> component : components) {
        component.init(context);
      }
    }
  
    /**
     * Apply boolean.
     *
     * @param target  the target
     * @param context the context
     * @return the boolean
     */
    public boolean apply(E target, BeneratorContext context) {
      BeneratorContext subContext = context.createSubContext(instanceName);
      subContext.setCurrentProduct(new ProductWrapper<>(target));
      for (GeneratorComponent<E> component : components) {
        try {
          if (!component.execute(subContext)) {
            message = "Component generator for '" + instanceName +
                "' is not available any longer: " + component;
           STATE_LOGGER.debug(message);
           return false;
         }
       } catch (Exception e) {
         throw new RuntimeException("Failure in generation of '" + instanceName + "', " +
             "Failed component: " + component, e);
       }
     }
     LOGGER.debug("Generated {}", target);
     subContext.close();
     return true;
   }
 
   @Override
   public void reset() {
     for (GeneratorComponent<E> component : components) {
       component.reset();
     }
   }
 
   @Override
   public void close() {
     for (GeneratorComponent<E> component : components) {
       component.close();
     }
   }
 
   @Override
   public String getMessage() {
     return message;
   }
 
 
   // ThreadAware interface implementation ----------------------------------------------------------------------------
 
   @Override
   public boolean isParallelizable() {
     return ThreadUtil.allParallelizable(components);
   }
 
   @Override
   public boolean isThreadSafe() {
     return ThreadUtil.allThreadSafe(components);
   }
 
 
   // java.lang.Object overrides --------------------------------------------------------------------------------------
 
   @Override
   public String toString() {
     return getClass().getSimpleName() + components;
   }
 
 }