package fr.ifremer.quadrige3.synchro.server.pages.admin;
   
   /*-
    * #%L
    * Quadrige3 Core :: Quadrige3 Synchro server
    * $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.synchro.server.application.WebSession;
  import fr.ifremer.quadrige3.synchro.server.components.progression.ProgressionPanel;
  import fr.ifremer.quadrige3.synchro.server.pages.BasePage;
  import fr.ifremer.quadrige3.synchro.server.service.ServiceLocator;
  import fr.ifremer.quadrige3.synchro.server.service.synchro.ReferentialSynchroService;
  import fr.ifremer.quadrige3.synchro.server.service.synchro.job.SynchroNewInstallDbJob;
  import fr.ifremer.quadrige3.synchro.vo.SynchroProgressionModel;
  import fr.ifremer.quadrige3.synchro.vo.SynchroProgressionStatus;
  import org.apache.wicket.ajax.AbstractAjaxTimerBehavior;
  import org.apache.wicket.ajax.AjaxRequestTarget;
  import org.apache.wicket.ajax.markup.html.form.AjaxButton;
  import org.apache.wicket.authroles.authorization.strategies.role.annotations.AuthorizeInstantiation;
  import org.apache.wicket.markup.html.form.Form;
  import org.apache.wicket.model.CompoundPropertyModel;
  import org.apache.wicket.model.IModel;
  import org.apache.wicket.model.Model;
  import org.apache.wicket.model.StringResourceModel;
  import org.apache.wicket.request.mapper.parameter.PageParameters;
  import org.apache.wicket.util.time.Duration;
  import org.springframework.core.task.AsyncTaskExecutor;
  
  import java.sql.Timestamp;
  import java.text.DateFormat;
  import java.util.Date;
  import java.util.Set;
  
  @AuthorizeInstantiation("ROLE_ADMIN")
  public class ToolsPage extends BasePage {
      private static final long serialVersionUID = 1L;
  
      private final ProgressionPanel progressionPanel;
  
      private boolean isRefreshLastUpdateRunning;
  
      private boolean isNewInstallDbRunning;
  
      private String lastUpdateDate;
  
      private ImportProgressionModel progressionModel;
  
      private AbstractAjaxTimerBehavior selfUpdatingTimer;
  
      public ToolsPage(final PageParameters parameters) {
          super(parameters);
          
          IModel<ToolsPage> model = new CompoundPropertyModel<>(this);
  
          isRefreshLastUpdateRunning = false;
          isNewInstallDbRunning = false;
  
          // Progression panel
          progressionModel = new ImportProgressionModel(getSession().getId());
          progressionPanel = new ProgressionPanel("progress", progressionModel) {
              private static final long serialVersionUID = 1L;
              @Override
              protected void onConfigure() {
                  super.onConfigure();
                  setVisibilityAllowed(isNewInstallDbRunning);
              }
  
              @Override
              public void onComplete(AjaxRequestTarget target) {
                  ToolsPage.this.onNewInstallDbComplete(target);
              }
          };
          progressionPanel.setOutputMarkupId(true);
          progressionPanel.setOutputMarkupPlaceholderTag(true);
          add(progressionPanel);
  
          Form<ToolsPage> form = new Form<>("form", model);
          form.setOutputMarkupId(true);
          add(form);
  
         // Refresh last update date button
         AjaxButton refreshLastUpdateDateButton = new AjaxButton("refreshLastUpdateDateButton", form) {
             private static final long serialVersionUID = 1L;
 
             @Override
             protected void onAfterSubmit(AjaxRequestTarget target, Form<?> form) {
                 super.onAfterSubmit(target, form);
                 // Refresh the last update date and get the new date
                 startRefreshReferentialLastUpdateDate(target);
             }
         };
         form.add(refreshLastUpdateDateButton);
 
         // New installation DB button
         AjaxButton newInstallDbButton = new AjaxButton("newInstallDbButton", form) {
             private static final long serialVersionUID = 1L;
 
             @Override
             protected void onAfterSubmit(AjaxRequestTarget target, Form<?> form) {
                 super.onAfterSubmit(target, form);
 
                 startNewInstallDb(target);
             }
         };
         form.add(newInstallDbButton);
 
 
         // auto refresh
         selfUpdatingTimer = new AbstractAjaxTimerBehavior(Duration.seconds(5)) {
             @Override
             protected void onTimer(AjaxRequestTarget target) {
                 String message;
                 if (isRefreshLastUpdateRunning) {
                     message = new StringResourceModel("tools.refreshLastUpdateDate.running", ToolsPage.this, null).getString();
                 }
                 else {
                     message = new StringResourceModel("tools.refreshLastUpdateDate.done", ToolsPage.this, new Model<>(ToolsPage.this)).getString();
                     stop(target);
                 }
 
                 info(message);
                 target.add(ToolsPage.this);
             }
         };
         selfUpdatingTimer.stop(null);
         add(selfUpdatingTimer);
     }
 
     @Override
     protected void onConfigure() {
         super.onConfigure();
         SynchroProgressionModel progression = progressionModel.getObject();
 
         if (progression != null) {
             // Refresh fields
             isNewInstallDbRunning = progression.getStatus() == SynchroProgressionStatus.WAITING_EXECUTION || progression.getStatus() == SynchroProgressionStatus.RUNNING;
             if (isNewInstallDbRunning) {
                 getFeedbackPanel().setVisibilityAllowed(false);
             }
         }
         else {
             isNewInstallDbRunning = false;
         }
     }
 
     /* -- internal methods -- */
 
     protected IModel<String> getTitleModel() {
         return new StringResourceModel("tools.title", this, null);
     }
 
     public String getLastUpdateDate() {
         return lastUpdateDate;
     }
 
     protected WebSession getWebSession() {
         return (WebSession)getSession();
     }
 
 
 
     protected void startRefreshReferentialLastUpdateDate(AjaxRequestTarget target) {
         final DateFormat dateFormat = DateFormat.getDateTimeInstance(DateFormat.LONG, DateFormat.LONG, getWebSession().getLocale());
 
         final Set<String> programCodes = getConfiguration().getSynchroProgramCodeIncludes();
 
         Runnable job = () -> {
             // Clearing cache
             ServiceLocator.instance().getCacheService().clearCache(ReferentialSynchroService.REFERENTIAL_UPDATE_DATE_CACHE);
 
             // Then recompute the new value
             Timestamp updateDate = ServiceLocator.instance().getReferentialSynchroService().getLastUpdateDate(programCodes);
 
             // Save it back to field
             try {
                 lastUpdateDate = dateFormat.format(new Date(updateDate.getTime()));
             }
             catch(Exception e) {
                 lastUpdateDate = null;
             }
             finally {
                 isRefreshLastUpdateRunning = false;
             }
         };
 
         AsyncTaskExecutor taskExecutor = ServiceLocator.instance().getTaskExecutor();
         taskExecutor.submit(job);
 
         isRefreshLastUpdateRunning = true;
         selfUpdatingTimer.restart(target);
 
         // Display that's running, and refresh page
         getFeedbackPanel().getFeedbackMessages().clear();
         info(new StringResourceModel("tools.refreshLastUpdateDate.running", ToolsPage.this, null).getString());
         target.add(ToolsPage.this);
 
     }
 
     protected void startNewInstallDb(AjaxRequestTarget target) {
         isRefreshLastUpdateRunning = true;
 
         // Refresh the last update date and get the new date
         WebSession session = getWebSession();
         SynchroNewInstallDbJob job = ServiceLocator.instance().getSynchroJobService().startNewInstallDb(
                 session.getId(),
                 session.getLocale());
 
         progressionPanel.setDefaultModelObject(job.getProgressionModel());
         progressionPanel.restart(target);
 
         // Mask feedback panel, to avoid multiple message)
         getFeedbackPanel().setVisibilityAllowed(false);
 
         target.add(ToolsPage.this);
     }
 
 
     protected void onNewInstallDbComplete(AjaxRequestTarget target) {
         // Restore the UI
         progressionPanel.setVisibilityAllowed(false);
         getFeedbackPanel().setVisibilityAllowed(true);
 
         target.add(this);
     }
 }