package fr.ifremer.quadrige2.synchro.server.pages.admin;
   
   /*-
    * #%L
    * Quadrige2 Core :: Quadrige2 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 java.util.List;
  
  import org.apache.wicket.ajax.AjaxRequestTarget;
  import org.apache.wicket.ajax.AjaxSelfUpdatingTimerBehavior;
  import org.apache.wicket.authroles.authorization.strategies.role.annotations.AuthorizeInstantiation;
  import org.apache.wicket.markup.html.basic.Label;
  import org.apache.wicket.markup.html.list.ListItem;
  import org.apache.wicket.markup.html.list.ListView;
  import org.apache.wicket.model.IModel;
  import org.apache.wicket.model.LoadableDetachableModel;
  import org.apache.wicket.model.PropertyModel;
  import org.apache.wicket.model.StringResourceModel;
  import org.apache.wicket.request.mapper.parameter.PageParameters;
  import org.apache.wicket.util.time.Duration;
  
  import fr.ifremer.quadrige2.synchro.server.components.progression.ProgressionPanel;
  import fr.ifremer.quadrige2.synchro.server.pages.BasePage;
  import fr.ifremer.quadrige2.synchro.server.pages.synchro.model.ImportProgressionModel;
  import fr.ifremer.quadrige2.synchro.server.service.ServiceLocator;
  import fr.ifremer.quadrige2.synchro.server.vo.synchro.SynchroJobVO;
  
  @AuthorizeInstantiation("ROLE_ADMIN")
  public class JobManagerPage extends BasePage {
  
      private static final long serialVersionUID = 1L;
      
      public JobManagerPage(PageParameters pageParameters) {
          super(pageParameters);
          
          // Create models (list of progressionModel)
          LoadableDetachableModel<List<SynchroJobVO>> importJobListModel = new LoadableDetachableModel<List<SynchroJobVO>>() {
              private static final long serialVersionUID = 1L;
  
              @Override
              protected List<SynchroJobVO> load() {
                  return ServiceLocator.instance().getSynchroJobService().getImportationJobs();
              }
          };
    
          LoadableDetachableModel<List<SynchroJobVO>> exportJobListModel = new LoadableDetachableModel<List<SynchroJobVO>>() {
              private static final long serialVersionUID = 1L;
  
              @Override
              protected List<SynchroJobVO> load() {
                  return ServiceLocator.instance().getSynchroJobService().getExportationJobs();
              }
          };
   
          add(new Label("importCount", new PropertyModel<Integer>(importJobListModel, "size")));
          add(new Label("exportCount", new PropertyModel<Integer>(exportJobListModel, "size")));
                  
          // List of import jobs
          ListView<SynchroJobVO> importListView = new ListView<SynchroJobVO>("importList", importJobListModel) {
              private static final long serialVersionUID = 1L;
  
              @Override
              protected void populateItem(ListItem<SynchroJobVO> item) {
                  // User infos
                  item.add(new Label("userId", new PropertyModel<Integer>(item.getModel(), "user.id")));
                  item.add(new Label("lastname", new PropertyModel<String>(item.getModel(), "user.lastname")));
                  item.add(new Label("firstname", new PropertyModel<String>(item.getModel(), "user.firstname")));
                  
                  // Progress bar
                  String jobId = item.getModelObject().getId();
                  ProgressionPanel progressionPanel = new ProgressionPanel("progress", new ImportProgressionModel(jobId)) {
                      private static final long serialVersionUID = 1L;
                      
                      @Override
                      public void onComplete(AjaxRequestTarget target) {
                          stop(target);
                      }
                  };
                  progressionPanel.setOutputMarkupId(true);
                 progressionPanel.setOutputMarkupPlaceholderTag(true);
                 item.add(progressionPanel);  
             }
         };
         importListView.setOutputMarkupId(true);
         add(importListView);
         
         // List of export jobs
         ListView<SynchroJobVO> exportListView = new ListView<SynchroJobVO>("exportList", exportJobListModel) {
             private static final long serialVersionUID = 1L;
 
             @Override
             protected void populateItem(ListItem<SynchroJobVO> item) {
                 // User infos
                 item.add(new Label("userId", new PropertyModel<Integer>(item.getModel(), "user.id")));
                 item.add(new Label("lastname", new PropertyModel<String>(item.getModel(), "user.lastname")));
                 item.add(new Label("firstname", new PropertyModel<String>(item.getModel(), "user.firstname")));
                 
                 // Progress bar
                 String jobId = item.getModelObject().getId();
                 ProgressionPanel progressionPanel = new ProgressionPanel("progress", new ImportProgressionModel(jobId)) {
                     private static final long serialVersionUID = 1L;
                     
                     @Override
                     public void onComplete(AjaxRequestTarget target) {
                         stop(target);
                     }
                 };
                 progressionPanel.setOutputMarkupId(true);
                 progressionPanel.setOutputMarkupPlaceholderTag(true);
                 item.add(progressionPanel);  
             }
         };
         exportListView.setOutputMarkupId(true);
         add(exportListView);
         
         add(new AjaxSelfUpdatingTimerBehavior(Duration.seconds(5)));
 
         // Mask feedback panel, to avoid multiple message)
         getFeedbackPanel().setVisibilityAllowed(false);
     }
     
     /* -- internal methods -- */
     protected IModel<String> getTitleModel() {
         return new StringResourceModel("jobmanager.title", this, null);
     }
 
 
 }