package com.explosion.expfmodules.dbstore;
   /* =============================================================================
    *       
    *     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.File;
  import java.sql.Connection;
  import java.util.HashMap;
  import java.util.Hashtable;
  import java.util.Map;
  import java.util.Properties;
  import java.util.Vector;
  import java.util.prefs.Preferences;
  import javax.swing.JPanel;
  import org.apache.log4j.LogManager;
  import org.apache.log4j.Logger;
  import com.explosion.expf.ExpActionListener;
  import com.explosion.expf.ExpConstants;
  import com.explosion.expf.ExpModuleManager;
  import com.explosion.expf.preferences.SystemPreferences;
  import com.explosion.expfmodules.rdbmsconn.ConnectionDescriptorManager;
  import com.explosion.expfmodules.rdbmsconn.RdbmsConnConstants;
  import com.explosion.expfmodules.rdbmsconn.RdbmsConnModuleManager;
  import com.explosion.expfmodules.rdbmsconn.connect.ConnectionManager;
  import com.explosion.utilities.exception.ExceptionManagerFactory;
  import com.explosion.utilities.preferences.Preference;
  import com.explosion.utilities.preferences.groups.PreferenceGroup;
  /***
   * Author: Stephen Cowx
   * Date: Dec 9, 2002
   * Time: 11:48:47 PM
   * 
   * This class provides the basis for an embedded database to be used 
   * within an application, it is a pluggable component
    */
  public class DbStoreModuleManager implements ExpModuleManager
  {
    private static Logger log = LogManager.getLogger(DbStoreModuleManager.class);
    
    private Vector preferences = new Vector();
    private Hashtable preferenceHash = new Hashtable();
    private static DbStoreModuleManager instance = null;
    private ExpActionListener globalActionListener = null;
      
    public DbStoreModuleManager()
    {
    	instance = this;
    }
    
    public void initialiseGui() throws Exception
    {
      
    }
    
    public String getVersion()
    {
      return "1.0";
    }
  
    public String getName()
    {
      return "Internal persistent store";
    }
  
    public String getDescription()
    {
      return "A persistent store for application data as well as an embedded database for use by application processes";
    }
  
    public void applyPreferences()
    {
    }
  
    public void initialiseCore(Properties properties)
    {
      try
      {
        Preferences prefs = Preferences.userRoot().node(getPreferenceRoot());
        
        /* Find the best directory possible to place the internal store */
        String fs = System.getProperty("file.separator");
        String userHome = System.getProperty("user.home");
        String appPrefix =  (String) SystemPreferences.getPreference(ExpConstants.EXPF_APP_PREFIX).getValue();
        String dir = userHome + fs + "." + appPrefix.substring(1,appPrefix.length()) + fs + "store";
       
       File directory =  new File(dir);
       if (!directory.exists())
       {
           if (! directory.mkdirs())
           {
              log.error("Unable to create directory for internal application store");
              directory = new File(System.getProperty("java.io.tempDir"));
           }
       }
       log.debug("Created directory "+directory.getAbsolutePath()+" for internal application store");
       Preference internalStoreDirectory = new Preference(DbStoreConstants.INTERNAL_STORE_DIRECTORY, Preference.PROPERTY_TYPE_DIRECTORY, directory, prefs);
       internalStoreDirectory.setLongName("Internal store directory");
       internalStoreDirectory.setDescription("This is the directory in which the internal store database of the application is kept.");
       internalStoreDirectory.setEditable(false);
       internalStoreDirectory.setVisible(false);
       
       preferences.addElement(internalStoreDirectory);
       preferenceHash.put(DbStoreConstants.INTERNAL_STORE_DIRECTORY, internalStoreDirectory);
       
       Preference created = new Preference(DbStoreConstants.INTERNAL_STORE_CREATED, Preference.PROPERTY_TYPE_BOOLEAN, new Boolean(false), prefs);
       created.setLongName("Store created");
       created.setDescription("Indicates whether the internal store has been created or not.");
       preferences.addElement(created);
       preferenceHash.put(DbStoreConstants.INTERNAL_STORE_CREATED, created);
       
       /* If the store has never been created */
       if (!((Boolean)created.getValue()).booleanValue())
       {
           log.debug("Creating database tables");
           Connection conn = getConnection();
           ConstructTables ct = new ConstructTables(conn,created.getClass().getClassLoader().getResourceAsStream(DbStoreConstants.DBSTORE_TABLES_FILENAME));
           ct.process();
           conn.close();
           log.debug("Done");
           created.setValue(new Boolean(true));
       }
     }
     catch (Exception e)
     {
       com.explosion.utilities.exception.ExceptionManagerFactory.getExceptionManager().manageException(e, "Exception caught while initialising dbstore properties.");
     }
   }
 
   public Vector getPreferences()
   {
     return preferences;
   }
 
   /***
    * Returns a connectio to this database
    * @return
    */
   public Connection getConnection() 
   {
         try
         {
             /* Get the values for the connection from the wizard values */
             String user = "sa";
             String pass = "";
             
             /* Use a manager to create a ConnectionDescriptor preference group */
             Map store = new HashMap();
             ConnectionDescriptorManager manager = new ConnectionDescriptorManager(RdbmsConnModuleManager.instance().getDriverDescriptorManager(), store);
             PreferenceGroup descriptor = manager.createGroup(DbStoreConstants.DBSTORE_CONNECTION_NAME);
             descriptor.setPreferenceValue(RdbmsConnConstants.CD_DRIVER,"HyperSonic SQL JDBC Driver (1.7.1)");
             descriptor.setPreferenceValue(RdbmsConnConstants.CD_USER,user);
             descriptor.setPreferenceValue(RdbmsConnConstants.CD_PASS,pass);
              
             /* This is a file based store */
             File directory = (File) getPreference(DbStoreConstants.INTERNAL_STORE_DIRECTORY).getValue();
             String location = directory.getAbsolutePath() + System.getProperty("file.separator") + "store";
             descriptor.setPreferenceValue(RdbmsConnConstants.CD_URL,"jdbc:hsqldb:" + location);
             
             int connectionKey = ConnectionManager.getInstance().connect(descriptor, RdbmsConnModuleManager.instance().getDriverDescriptorManager());
             
             return ConnectionManager.getInstance().getConnection(connectionKey);
         } 
         catch (Exception e)
         {
            ExceptionManagerFactory.getExceptionManager().manageException(e,"Caught exception while connecting to internal db store");
         }
         return null;
   }
   
 
   public Preference getPreference(String preferenceName)
   {
   	return (Preference) preferenceHash.get(preferenceName);
   }
   
   public JPanel getPreferencesEditor()
   {
     return null;
   }
   
   public ExpActionListener getGlobalListener()
   {
   	return globalActionListener;
   }
   
   public static DbStoreModuleManager instance()
   {
     return instance;
   }
  
   public String getPreferenceRoot()
   {
     return (String) SystemPreferences.getPreference(ExpConstants.EXPF_APP_PREFIX).getValue()+"/dbstore";
   }
   
 }