package com.explosion.expfmodules.fileutils;
   
   /* =============================================================================
    *       
    *     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.awt.event.ActionEvent;
  import java.io.DataInputStream;
  import java.io.File;
  import java.io.FileInputStream;
  import java.io.FileOutputStream;
  import java.util.HashMap;
  import java.util.Map;
  
  import org.apache.log4j.LogManager;
  import org.apache.log4j.Logger;
  
  import com.explosion.expf.Application;
  import com.explosion.expf.ExpActionListener;
  import com.explosion.expfmodules.rdbmsconn.dbom.utils.SQLEngine;
  import com.explosion.utilities.FileSystemUtils;
  
  /***
   * @author Stephen Cowx
   */
  public class FileUtilsListener implements ExpActionListener
  {
    private static Logger log = LogManager.getLogger(SQLEngine.class);
    private HashMap map;
    private int newDocumentNumbers = 1;
    
    /***
     * Constructor for TextEditorListener.
     */
    public FileUtilsListener()
    {
      map = new HashMap();
      map.put(FileUtilsConstants.MENU_FILE_SPLIT,FileUtilsConstants.MENU_FILE_SPLIT);
      map.put(FileUtilsConstants.MENU_FILE_UNSPLIT,FileUtilsConstants.MENU_FILE_UNSPLIT);
     }
  
    /***
     * @see package com.explosion.expf.Interfaces.ExpActionListener#getListensFor()
     */
    public Map getListensFor()
    {
      return map;
    }
  
    /***
     * @see java.awt.event.ActionListener#actionPerformed(ActionEvent)
     */
    public void actionPerformed(ActionEvent e)
    {
      try
      {
        if (e.getActionCommand().equals(FileUtilsConstants.MENU_FILE_SPLIT))
        {
        	   File[] files = FileSystemUtils.chooseFiles(Application.getApplicationFrame(), FileSystemUtils.OPENTYPE, false, new File(System.getProperty("user.dir")), FileSystemUtils.FILES_ONLY, "Select file to split.");
        	   
        	   if (files != null && files.length > 0 && files[0] != null)
        	   {
        	     FileInputStream fin = new FileInputStream(files[0].getAbsolutePath());
  			 DataInputStream din = new DataInputStream(fin);
  			 split(files[0].getAbsolutePath(), din);
        	   }
        }
        else if (e.getActionCommand().equals(FileUtilsConstants.MENU_FILE_UNSPLIT))
        {
        	   File[] files1 = FileSystemUtils.chooseFiles(Application.getApplicationFrame(), FileSystemUtils.OPENTYPE, false, new File(System.getProperty("user.dir")), FileSystemUtils.FILES_ONLY, "Select file1 of two to unsplit.");
        	   File[] files2 = FileSystemUtils.chooseFiles(Application.getApplicationFrame(), FileSystemUtils.OPENTYPE, false, new File(System.getProperty("user.dir")), FileSystemUtils.FILES_ONLY, "Select file2 to two to unsplit.");
        	   
        	   if (files1 != null && files1.length > 0 && files1[0] != null
        	   	&& files2 != null && files2.length > 0 && files2[0] != null)
        	   {
        	     File[] files = new File[2];
  			 files[0] = files1[0];
  			 files[1] = files2[0];
  			 unsplit(files[0].getAbsolutePath() + ".joined", files);
        	   }
        }
      }
      catch (Exception ex)
      {
        com.explosion.utilities.exception.ExceptionManagerFactory.getExceptionManager().manageException(ex, "Exception caught while responding to event." );
     }   
     
   }
   
   /***
    * Splits files previously unsplit.
    * @param fileName
    * @throws Exception
    */
   public void split(String fileName, DataInputStream din) throws Exception
 	{
 		File file = new File(fileName);
 		long s = file.length();
 		long segment1Length = 0;
 		long segment2Length = 0;
 		if (s%2 > 0)
 		{
 			segment1Length = (s+1)/2;
 			segment2Length = (s-1)/2;
 		}
 		else
 		{
 			segment1Length = s/2;
 			segment2Length = s/2;
 		}
 		
 		FileOutputStream fout1 = new FileOutputStream(fileName+"_1");
 		FileOutputStream fout2 = new FileOutputStream(fileName+"_2");
 		long read = 0;
 		while (din.available() > 0)
 		{
 			if (read < segment1Length)
 			{
 			   if (din.available() >= 1024)
 			   {
 			   	byte[] bytes = new byte[1024];
 			   	din.read(bytes);
 			   }
 				fout1.write(din.read());
 			   read++;
 			}
 			else
 			{
 			   fout2.write(din.read());
 			}			
 		}
 		
   	    fout1.close();
   	    fout2.close();
 		din.close();
 	}
   
     /***
      * Unsplits files previously split.
      * @param fileName
      * @throws Exception
      */
 	public void unsplit(String newFilename, File[] files) throws Exception
 	{
 		FileOutputStream stream = new FileOutputStream(new File(newFilename));
 		for (int i=0;i<files.length;i++)
 		{
 			FileInputStream fin = new FileInputStream(files[i].getAbsolutePath());
 			DataInputStream din = new DataInputStream(fin);
 			while (din.available() > 0)
 			{
 				stream.write(din.read());
 			}
 			din.close();
 			fin.close();
 		}
 		stream.close();
 	}
 
 
 }