package com.explosion.utilities.process;
   
   /*
    * =============================================================================
    * 
    * Copyright 2004 Stephen Cowx
    * 
    * Licensed under the Apache License, Version 2.0 (the "License"); you may not
    * use this file except in compliance with the License. You may obtain a copy of
   * the License at
   * 
   * http://www.apache.org/licenses/LICENSE-2.0
   * 
   * Unless required by applicable law or agreed to in writing, software
   * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
   * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
   * License for the specific language governing permissions and limitations under
   * the License.
   * 
   * =============================================================================
   */
  
  import java.io.BufferedReader;
  import java.io.File;
  import java.io.FileReader;
  import java.io.IOException;
  
  import javax.swing.SwingUtilities;
  
  import org.apache.log4j.LogManager;
  import org.apache.log4j.Logger;
  
  import com.explosion.utilities.FileIterator;
  import com.explosion.utilities.exception.ExceptionManagerFactory;
  import com.explosion.utilities.process.threads.Finishable;
  import com.explosion.utilities.process.threads.ProcessThread;
  import com.explosion.utilities.process.threads.UnitisedProcessThread;
  
  /***
   * @author Stephen Cowx Date created:@12-Feb-2003
   */
  public class MultiFileLineByLineParser implements com.explosion.utilities.process.threads.UnitisedProcess
  {
  
      private static Logger log = LogManager.getLogger(MultiFileLineByLineParser.class);
  
      private FileIterator iterator;
  
      private LineProcessor lineProcessor;
  
      private int currentFileIndex = 0;
  
      private String statusText = "Processing";
  
      private boolean processUnitComplete = false;
  
      private ProcessThread parent;
  
      private Finishable finishable;
  
      private boolean initialised = false;
  
      private int numberofLinesProcessed = 0;
      
      private boolean isUserProcess = true;  
  
      public MultiFileLineByLineParser(Finishable finishable, String directoryPath, boolean recursive, String filenamePattern, LineProcessor lineProcessor) throws IOException
      {
          this.lineProcessor = lineProcessor;
          this.finishable = finishable;
          
          iterator = new FileIterator(directoryPath, filenamePattern, true, recursive, true);
  
          parent = new UnitisedProcessThread();
          parent.setProcess(this);
      }
      
      /***
       * Returns a boolean value indicating whther this is a user process or not
       * @return
       */
      public boolean isUserProcess()
      {
          return this.isUserProcess;
      }
      
      /***
       * Sets whtether or not this is a user process.  True means that it is
       * @param truth
       */
      public void setIsUserProcess(boolean truth)
      {
          this.isUserProcess = true;
      }    
  
      public void start()
      {
          parent.start();
      }
 
     public ProcessThread getProcessControl()
     {
         return parent;
     }
 
     public void setProcessControl(ProcessThread processThread)
     {
         parent = processThread;
     }
 
     public final boolean isStopped()
     {
         return parent.getStatus() == ProcessThread.THREAD_STOPPED;
     }
 
     /***
      * @see com.explosion.utilities.process.UnitisedProcess#initialiseProcessing()
      */
     public void initialiseProcessing() throws Exception
     {
         
     }
 
     /***
      * @see com.explosion.utilities.process.UnitisedProcess#finaliseProcessing()
      */
     public void finaliseProcessing() throws Exception
     {
         Runnable doFinished = new Runnable()
         {
 
             public void run()
             {
                 finishable.finish();
             }
         };
         SwingUtilities.invokeLater(doFinished);
         statusText = "Done";
     }
 
     /***
      * @see com.explosion.utilities.process.UnitisedProcess#finaliseProcessing(Exception)
      */
     public void finaliseProcessing(Exception e)
     {
         ExceptionManagerFactory.getExceptionManager().manageException(e, "Experienced exception while processing.");
         try
         {
             finaliseProcessing();
         } catch (Exception e1)
         {
             //tried and failed, just log and ignore
             log.debug("Exception while finalising processing.");
         }
     }
 
     /***
      * @see com.explosion.utilities.process.UnitisedProcess#getPercentCompete()
      */
     public int getPercentComplete()
     {
         return iterator.getPercentComplete();
     }
 
     /***
      * @see com.explosion.utilities.process.UnitisedProcess#getPercentCompete()
      */
     public void setPercentComplete(int percentComplete)
     {}
 
     /***
      * @see com.explosion.utilities.process.UnitisedProcess#getStatusText()
      */
     public String getStatusText()
     {
         return statusText;
     }
 
     /***
      * @see com.explosion.utilities.process.UnitisedProcess#beginProcessUnit()
      */
     public void beginProcessUnit() throws Exception
     {
         processUnitComplete = false;
     }
 
     /***
      * @see com.explosion.utilities.process.UnitisedProcess#processUnit()
      */
     public void processUnit() throws Exception
     {
         if (iterator.hasNext())
         {
             File file = iterator.next();
             statusText = "Searching " + file.getName();
             try
             {
                 processFile(file.getAbsolutePath());
             } catch (Exception e)
             {
                 ExceptionManagerFactory.getExceptionManager().manageException(e, "Exception while processing " + file.getName());
                 //		if (JOptionPane.NO_OPTION ==
                 // JOptionPane.showOptionDialog(Application.getApplicationFrame(),"Continue
                 // with the next file
                 // ?","Error",JOptionPane.YES_NO_OPTION,JOptionPane.ERROR_MESSAGE,null,null,null))
                 //			parent.stop();
             }
         }
         processUnitComplete = true;
     }
 
     /***
      * @see com.explosion.utilities.process.UnitisedProcess#endProcessUnit()
      */
     public void endProcessUnit() throws Exception
     {
         currentFileIndex++;
     }
 
     /***
      * @see com.explosion.utilities.process.UnitisedProcess#processUnitComplete()
      */
     public boolean processUnitComplete()
     {
         return processUnitComplete;
     }
 
     public void processFile(String filepath) throws Exception
     {
         int num = 0;
         BufferedReader reader = null;
         try
         {
             if (!parentStopped())
             {
                 lineProcessor.open();
                 reader = new BufferedReader(new FileReader(filepath));
                 while (!parentStopped() && reader.ready())
                 {
                     String s = reader.readLine();
                     num++;
                     numberofLinesProcessed++;
                     if (s != null)
                         lineProcessor.processLine(s, num, filepath);
                     else
                         break;
                 }
             }
         } finally
         {
             try
             {
                 if (lineProcessor != null) lineProcessor.close();
             } catch (Exception e)
             {
                 ExceptionManagerFactory.getExceptionManager().manageException(e, "Exception caught while closing line action.");
             }
             try
             {
                 if (reader != null) reader.close();
             } catch (Exception e)
             {
                 ExceptionManagerFactory.getExceptionManager().manageException(e, "Exception caught while closing reader.");
             }
         }
     }
 
     public boolean parentStopped()
     {
         return parent.getStatus() == ProcessThread.THREAD_STOPPED;
     }
 
     /***
      * Sets the value ofthestatusText for this process.
      */
     public void setStatusText(String statusText)
     {
         this.statusText = statusText;
     }
 
     public void log(String string)
     {}
 
     public void log(Exception exception, String message)
     {}
 
 }