package fr.ifremer.quadrige3.ui.swing.synchro.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.security.AuthenticationInfo;
  import fr.ifremer.quadrige3.core.service.ClientServiceLocator;
  import fr.ifremer.quadrige3.synchro.service.client.SynchroRestClientService;
  import fr.ifremer.quadrige3.synchro.vo.SynchroImportContextVO;
  import fr.ifremer.quadrige3.synchro.vo.SynchroProgressionStatus;
  import fr.ifremer.quadrige3.synchro.vo.SynchroProgressionVO;
  import fr.ifremer.quadrige3.ui.swing.synchro.SynchroUIHandler;
  import org.apache.commons.logging.Log;
  import org.apache.commons.logging.LogFactory;
  import org.nuiton.i18n.I18n;
  
  import java.beans.PropertyChangeListener;
  
  import static org.nuiton.i18n.I18n.t;
  
  /**
   * <p>ImportSynchroStartAction class.</p>
   *
   * @author Ludovic Pecquot <ludovic.pecquot@e-is.pro>
   */
  public class ImportSynchroStartAction extends AbstractSynchroAction {
  
      private static final Log log = LogFactory.getLog(ImportSynchroStartAction.class);
  
      private boolean silentIfNoData = false;
  
      /**
       * <p>Constructor for ImportSynchroStartAction.</p>
       *
       * @param handler a {@link SynchroUIHandler} object.
       */
      public ImportSynchroStartAction(SynchroUIHandler handler) {
          super(handler);
      }
  
      public void setSilentIfNoData(boolean silentIfNoData) {
          this.silentIfNoData = silentIfNoData;
      }
  
      /**
       * {@inheritDoc}
       */
      @Override
      public boolean initAction() {
          super.initAction();
  
          getModel().getProgressionModel().clear();
          getModel().getProgressionModel().setTotal(100);
          getHandler().showProgressCard();
  
          return true;
      }
  
      /**
       * {@inheritDoc}
       */
      @Override
      public void doAction() throws Exception {
  
          if (log.isDebugEnabled()) {
              log.debug(String.format("try to connect to synchronization site : %s", getBaseUri()));
          }
  
          boolean silentIfErrorOrNoData = getModel().getImportJobId() != null;
  
          // Set model as RUNNING
          getModel().setStatus(SynchroProgressionStatus.RUNNING);
  
          SynchroRestClientService service = ClientServiceLocator.instance().getSynchroRestClientService();
  
          // No authentication (=Anonymous) if user is not authenticate or as local user (mantis #26658)
          AuthenticationInfo authenticationInfo = !getContext().isAuthenticated() || getContext().isAuthenticatedAsLocalUser()
                  ? null
                  : getContext().getAuthenticationInfo();
 
         // Add a property change listener in SynchroImportContext to retrieve jobId from the service
         PropertyChangeListener listener = evt -> {
             if (SynchroImportContextVO.PROPERTY_JOB_ID.equals(evt.getPropertyName())) {
                 // Save import context to file when the jobId is set
                 getModel().saveImportContext();
             }
         };
         getModel().getSynchroImportContext().addPropertyChangeListener(listener);
 
         // Start import
         SynchroProgressionVO serverImportResult = service.startImport(
                 authenticationInfo,
                 getModel().getSynchroImportContext(),
                 getModel().getProgressionModel());
 
         SynchroProgressionStatus serverImportStatus = SynchroProgressionStatus.valueOf(serverImportResult.getStatus());
 
         // Can remove the listener
         getModel().getSynchroImportContext().removePropertyChangeListener(listener);
 
         // If error or no data, but silent mode, do nothing (see mantis #24916)
         if ((silentIfNoData && serverImportStatus == SynchroProgressionStatus.NO_DATA)
                 ||
                 (silentIfErrorOrNoData
                         && (serverImportStatus == SynchroProgressionStatus.FAILED
                         || serverImportStatus == SynchroProgressionStatus.NO_DATA))) {
 
             // Reset the import context
             getModel().resetImportContext();
             getModel().saveImportContext();
         }
 
         // If failed, throw an exception with the message from ProgressionUIModel
         else if (serverImportStatus == SynchroProgressionStatus.FAILED) {
             throw new SynchroException(I18n.t("quadrige3.error.synchro.status", getModel().getProgressionModel().getMessage()));
         }
 
         // If no data : display message
         else if (serverImportStatus == SynchroProgressionStatus.NO_DATA) {
             throw new SynchroException(I18n.t("quadrige3.error.synchro.import.noData"));
         }
 
         // If still running (not stopped elsewhere, e.g. in SynchroStopAction): update UI model
         else if (getModel().getStatus() == SynchroProgressionStatus.RUNNING) {
             getModel().setStatus(serverImportStatus);
             getModel().setImportJobId(serverImportResult.getJobId());
             getModel().setTransferFilename(serverImportResult.getFileName());
         }
     }
 
     /**
      * {@inheritDoc}
      */
     @Override
     public void doneAction() {
 
         getModel().saveImportContext();
 
         // if action launched with lock, don't chain action
         if (isWait()) {
             return;
         }
 
         SynchroProgressionStatus serverImportStatus = getModel().getStatus();
 
         if (serverImportStatus == SynchroProgressionStatus.SUCCESS) {
             // download
             ImportSynchroDownloadAction action
                     = getContext().getActionFactory().createNonBlockingUIAction(handler, ImportSynchroDownloadAction.class);
             action.execute();
         }
 
         // If NOT_STARTED (could append) if job was previously launched
         // (see mantis #24916 - Server error "Invalid Context")
         else if (serverImportStatus == SynchroProgressionStatus.NOT_STARTED) {
             // reset UI to default state
             getUI().getHandler().report(t("quadrige3.synchro.report.idle"), false);
         }
     }
 
     @Override
     public void disposeAction() {
         super.disposeAction();
         silentIfNoData = false;
     }
 }