package dk.daoas.daoadresseservice;

import java.sql.SQLException;
import java.util.Properties;
import java.util.logging.Logger;

import javax.mail.Message;
import javax.mail.Session;
import javax.mail.Transport;
import javax.mail.internet.InternetAddress;
import javax.mail.internet.MimeMessage;
import javax.servlet.ServletContext;

import dk.daoas.daoadresseservice.admin.ServiceConfig;
import dk.daoas.daoadresseservice.db.DatabaseLayerImplementation;

public class DataLoader {
	
	boolean isRunning = false;
	
	ServiceConfig config; 
	
	ServletContext ctxt;
	public DataLoader(ServletContext ctxt,ServiceConfig conf) {
		this.ctxt = ctxt;
		
		config = conf;
	}
	
	public void doLoad() {
		synchronized(this) {
			if (isRunning == false) {
				isRunning = true;
				
				Thread t = new Thread( new DataLoadWorker(this), "SearchDataLoader");
				t.start();
			}
		}
	}
	
	public boolean isRunning() {
		synchronized(this) {
			return isRunning;	
		}		
	}
	
	protected void  setRunningFalse() {
		synchronized(this) {
			isRunning = false;
		}
	}

	
	
	
	public static class DataLoadWorker implements Runnable {
		
		static final Logger logger = Logger.getLogger(DataLoadWorker.class.getName());
		
		DataLoader loader;
		public DataLoadWorker(DataLoader ld) {
			this.loader = ld;
		}
		

		@Override
		public void run() {
    	
	    	
	    	try {
	    		AddressSearch search = new AddressSearch(new DatabaseLayerImplementation(), loader.config);
	    		search.buildSearchStructures();
	    		
	    		AddressSearch oldSearch = (AddressSearch) loader.ctxt.getAttribute("search");
	    		loader.ctxt.setAttribute("search", search);
	    		
	    		if (loader.config.notifyEmail != null && loader.config.notifyEmail.length() > 0) {
	    			sendStatusEmail(search, oldSearch);
	    		}
	    		
	    		if (oldSearch != null) {
	    			oldSearch.clear();
	    		}
	    			    		
	    	} catch (SQLException e) {
	    		System.out.println("Error loading data: " + e.getMessage());
	    	} finally {
	    		loader.setRunningFalse();
	    	}
	    	
		}
		
		protected void sendStatusEmail(AddressSearch newSearch, AddressSearch oldSearch) {
			Properties props = new Properties();
			props.put("mail.smtp.host", "10.30.1.28");
			
			try {
					// create some properties and get the default Session
					Session session = Session.getDefaultInstance(props, null);
					session.setDebug(false);
					
					
					// create a message
					
					MimeMessage msg = new MimeMessage(session);
					msg.setFrom( new InternetAddress("no-reply@daoas.dk") );
					
					msg.setRecipient(Message.RecipientType.TO, new InternetAddress(loader.config.notifyEmail) );
					msg.setSubject("DaoAdresseService status ");			
					msg.setText("--");
					
					Transport.send(msg);
			} catch (Exception e) {
				logger.warning("Unable to send CircuitBreaker notification mail " + e );
			}
		}
		

	}

}