package fr.ifremer.quadrige3.ui.swing.action;
   
   /*-
    * #%L
    * Quadrige3 Core :: Quadrige3 UI Common
    * $Id:$
    * $HeadURL:$
    * %%
    * Copyright (C) 2017 Ifremer
   * %%
   * 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 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/>.
   * #L%
   */
  
  import fr.ifremer.quadrige3.core.dao.technical.Assert;
  import fr.ifremer.quadrige3.core.exception.QuadrigeTechnicalException;
  import fr.ifremer.quadrige3.ui.swing.AbstractUIHandler;
  import fr.ifremer.quadrige3.ui.swing.ApplicationUIContext;
  import org.apache.commons.lang3.reflect.ConstructorUtils;
  import org.nuiton.i18n.I18n;
  import org.nuiton.jaxx.application.swing.AbstractApplicationUIHandler;
  import org.nuiton.jaxx.application.swing.action.AbstractApplicationAction;
  import org.nuiton.jaxx.application.swing.action.ApplicationActionFactory;
  
  import javax.swing.AbstractButton;
  import java.util.concurrent.*;
  
  /**
   * Action Factory
   */
  public class ActionFactory extends ApplicationActionFactory {
  
      /**
       * {@inheritDoc}
       */
      @Override
      public <A extends AbstractApplicationAction> A createLogicAction(AbstractApplicationUIHandler handler, Class<A> actionName) {
          ApplicationUIContext context = (ApplicationUIContext) handler.getContext();
          if (AbstractMainUIAction.class.isAssignableFrom(actionName) && context.getMainUI() != null) {
              handler = context.getMainUI().getHandler();
          }
  
          return super.createLogicAction(handler, actionName);
      }
  
      /**
       * <p>createNonBlockingUIAction.</p>
       *
       * @param handler    a {@link AbstractUIHandler} object.
       * @param actionName a {@link Class} object.
       * @param <A>        a A object.
       * @return a A object.
       */
      public <A extends AbstractWorkerAction> A createNonBlockingUIAction(AbstractUIHandler handler, Class<A> actionName) {
          return createNonBlockingUIAction(handler, actionName, null);
      }
  
      /**
       * <p>createNonBlockingUIAction.</p>
       *
       * @param handler    a {@link AbstractUIHandler} object.
       * @param actionName a {@link Class} object.
       * @param button     a {@link AbstractButton} object.
       * @param <A>        a A object.
       * @return a A object.
       */
      public <A extends AbstractWorkerAction> A createNonBlockingUIAction(AbstractUIHandler handler, Class<A> actionName, AbstractButton button) {
          try {
              // create action
              A action = ConstructorUtils.invokeConstructor(actionName, handler);
  
              if (button != null) {
                  action.setActionIcon(button.getIcon());
                  action.setActionName(button.getText());
                  action.setActionDescription(button.getToolTipText());
                  action.setActionMnemonic(button.getMnemonic());
              }
  
              return action;
          } catch (Exception e) {
              throw new QuadrigeTechnicalException(I18n.t("quadrige3.error.create.action", actionName.getName()), e);
          }
  
      }
  
      public enum ExecutionMode {
          UNIQUE,
          CUMULATIVE,
         LATEST
     }
 
     /**
      * Create a ThreadPoolExecutor with pool active option
      *
      * @param executionMode value of the mode of execution:<br/>
      *                      UNIQUE : create an executor allowing only one execution. An exception is raised if a second call happens.<br/>
      *                      CUMULATIVE : create a poolable executor allowing cumulative calls but reject silently the other calls.<br/>
      *                      LATEST: create a (scheduled) poolable executor allowing multiple calls but always executes the last (after a short delay). Useful for UI interactions.<br/>
      * @return a ThreadPoolExecutor
      */
     public static ThreadPoolExecutor createSingleThreadExecutor(ExecutionMode executionMode) {
 
         Assert.notNull(executionMode);
 
         if (executionMode == ExecutionMode.LATEST) {
 
             return new ScheduledThreadPoolExecutor(1) {
                 @Override
                 public void execute(Runnable command) {
 
                     getQueue().forEach(runnable -> {
                         if (runnable instanceof Future<?>) {
                             ((Future<?>) runnable).cancel(false);
                         }
                     });
 
                     schedule(command, 200, TimeUnit.MILLISECONDS);
                 }
             };
 
         } else {
 
             RejectedExecutionHandler rejectedExecutionHandler = null;
             int queueCapacity = 0;
             switch (executionMode) {
                 case UNIQUE:
                     rejectedExecutionHandler = new ThreadPoolExecutor.AbortPolicy();
                     queueCapacity = 1;
                     break;
                 case CUMULATIVE:
                     rejectedExecutionHandler = new ThreadPoolExecutor.DiscardPolicy();
                     queueCapacity = 2;
                     break;
             }
 
             Assert.notNull(rejectedExecutionHandler);
             BlockingQueue<Runnable> queue = new LinkedBlockingDeque<>(queueCapacity);
             return new ThreadPoolExecutor(1, 1, 1, TimeUnit.MINUTES, queue, rejectedExecutionHandler);
         }
     }
 }