/******************************************************************************
    * DatabaseImpl - This object implements the database API for BSAccount
    * 
    * BSAccount - BuckoSoft Web Account Manager 
    * Copyright(c) 2007 - Dick Balaska and BuckoSoft, Corp.
    * 
    */
   
   package com.buckosoft.BSAccount.db;
  
  import java.util.Timer;
  import java.util.TimerTask;
  
  import org.apache.commons.logging.Log;
  import org.apache.commons.logging.LogFactory;
  import org.hibernate.HibernateException;
  import org.hibernate.Session;
  
  import com.buckosoft.BSAccount.domain.AppJumper;
  import com.buckosoft.BSAccount.domain.BSAccount;
  
  /** Database for the BSAccount library. We have one function, login a user.
   * @author dick
   *
   */
  public class DatabaseImpl implements Database {
  	protected final Log log = LogFactory.getLog(getClass());
  	private Timer		dbTimer = new Timer("BSAccountDBCheck", true);
  	private TimerTask	dbTimerTask = new DBTimerTask();
  	private	boolean		refreshNeeded = true;
  	private	int			timerDelay = 60*5;
  
  	private HibernateUtil	hibernateUtil;
  
  	public DatabaseImpl() {
  		hibernateUtil = new HibernateUtil();
  		hibernateUtil.initialize(null);
  		log.info("Initialize database timer to " + timerDelay);
  		dbTimer.schedule(dbTimerTask, timerDelay*1000, timerDelay*1000);
  	}
  
  	class DBTimerTask extends TimerTask {
  		@Override
  		public void run() {
  			if (refreshNeeded) {
  				log.debug("Refresh database");
  				getAccountCount();
  			}
  			refreshNeeded = true;
  		}
  	}
  
  	/* (non-Javadoc)
  	 * @see com.buckosoft.BSAccount.db.Database#getAccount(java.lang.String, java.lang.String)
  	 */
  	@Override
  	public BSAccount getAccount(String username, String password) {
  		Session session = hibernateUtil.getSessionFactory().getCurrentSession();
  		session.getTransaction().begin();
  		BSAccount a = null;
  		try {
  			a = (BSAccount)session.createQuery("from BSAccount a where a.username = :username and password = PASSWORD(:password)")
  									.setParameter("username", username)
  									.setParameter("password", password)
  									.uniqueResult();
  			if (a != null) {
  				a.setLastAccess(null);
  				session.update(a);
  			}
  			refreshNeeded = false;
  		} catch (HibernateException e) {
  			e.printStackTrace();
  		} finally {
  			session.getTransaction().commit();
  		}
  		return(a);
  	}
  
  	/* (non-Javadoc)
  	 * @see com.buckosoft.BSAccount.db.Database#getAccount(int)
  	 */
  	@Override
  	public BSAccount getAccount(int userId) {
  		Session session = hibernateUtil.getSessionFactory().getCurrentSession();
  		session.getTransaction().begin();
  		BSAccount a = null;
  		try {
  			a = (BSAccount)session.createQuery("from BSAccount a where a.userId = :userId")
  									.setParameter("userId", userId)
  									.uniqueResult();
  			if (a != null) {
  				a.setLastAccess(null);
  				session.update(a);
  			}
  			refreshNeeded = false;
  		} catch (HibernateException e) {
  			e.printStackTrace();
  		} finally {
  			session.getTransaction().commit();
 		}
 		return(a);
 	}
 
 	
 	/* (non-Javadoc)
 	 * @see com.buckosoft.BSAccount.db.Database#getAccountCount()
 	 */
 	@Override
 	public int getAccountCount() {
 		Session session = hibernateUtil.getSessionFactory().getCurrentSession();
 		session.getTransaction().begin();
 		try {
 			Long count = (Long)session.createQuery("select count(*) from BSAccount").uniqueResult();
 			refreshNeeded = false;
 			int c = count.intValue();
 			return(c);
 		} catch (Exception e) {
 			e.printStackTrace();
 		} finally {
 			session.getTransaction().commit();
 		}
 		return(0);
 	}
 
 	/* (non-Javadoc)
 	 * @see com.buckosoft.BSAccount.db.Database#getAppJumperUser(long)
 	 */
 	@Override
 	public int getAppJumperUser(long appJumper) {
 		Session session = hibernateUtil.getSessionFactory().getCurrentSession();
 		session.getTransaction().begin();
 		AppJumper a = null;	
 			try {
 				a = (AppJumper)session.createQuery("from AppJumper a where a.jumpToken = :toke")
 						.setParameter("toke", (Long)appJumper)
 						.uniqueResult();
 //				a = (AppJumper)session.createQuery("from AppJumper aj where aj.userId = 1")
 						//.setParameter("toke", (Long)appJumper)
 //						.uniqueResult();
 				if (a != null)
 					return(a.getUserId());
 			} catch (HibernateException e) {
 				e.printStackTrace();
 			} finally {
 				session.getTransaction().commit();
 			}
 		return 0;
 	}
 
 	/* (non-Javadoc)
 	 * @see com.buckosoft.BSAccount.db.Database#setAppJumper(int, long)
 	 */
 	@Override
 	public void setAppJumper(int userId, long appJumper) {
 		AppJumper a = new AppJumper(userId, appJumper);
 		Session session = hibernateUtil.getSessionFactory().getCurrentSession();
 		session.getTransaction().begin();
 		try {
 			session.saveOrUpdate(a);
 			refreshNeeded = false;
 		} catch (Exception e) {
 			session.getTransaction().rollback();
 			e.printStackTrace();
 			return;
 		} finally {
 			session.getTransaction().commit();
 		}
 	}
 	/* (non-Javadoc)
 	 * @see com.buckosoft.BSAccount.db.Database#deleteAppJumper(int, long)
 	 */
 	@Override
 	public void deleteAppJumper(int userId, long appJumper) {
 		Session session = hibernateUtil.getSessionFactory().getCurrentSession();
 		session.getTransaction().begin();
 		try {
 			session.createQuery("delete from AppJumper a where a.jumpToken = :token and a.userId = :id")
 				.setParameter("id", userId)
 				.setParameter("token", appJumper)
 				.executeUpdate();
 
 		} catch (Exception e) {
 			session.getTransaction().rollback();
 			e.printStackTrace();
 			return;
 		} finally {
 			session.getTransaction().commit();
 		}
 	}
 
 }