package ru.yababay.chat.server;

import java.io.File;
import java.io.FileInputStream;

import java.lang.reflect.Method;

import java.util.Enumeration;
import java.util.Properties;
import java.util.HashMap;

import org.jivesoftware.smack.Chat;
import org.jivesoftware.smack.ChatManager;
import org.jivesoftware.smack.ChatManagerListener;
import org.jivesoftware.smack.ConnectionConfiguration;
import org.jivesoftware.smack.MessageListener;
import org.jivesoftware.smack.SASLAuthentication;
import org.jivesoftware.smack.XMPPConnection;
import org.jivesoftware.smack.XMPPException;
import org.jivesoftware.smack.packet.Message;

import net.sf.lab3f.groovy.Groovyable;
import net.sf.lab3f.util.TuttiFruttiable;

public class Main implements ChatManagerListener, MessageListener {

 private XMPPConnection connection;
 private Properties props = new Properties();
 private ChatManagerListener chatMan;
 private boolean hasGreeting;
 private Groovyable groovy;
 private Object groovyObj;
 private TuttiFruttiable tuttiFrutti;
 private HashMap <String, java.lang.reflect.Method> methods = new HashMap <String, java.lang.reflect.Method> ();
 private final String row = "\n------------------\n";
 
 public void processMessage(Chat cht, Message msg){	 
  try{	 
   String s = msg.getBody().trim();
   int n = s.indexOf('\n');
   if(n > 0 && s.substring(0, n).indexOf("groovy") > -1){
    s = s.substring(n).trim();	   
    cht.sendMessage('\n' + props.getProperty("botReplay1") + row + groovy.eval(s).toString() + row + props.getProperty("botReplay2"));
    return;
   }	   
   n = s.indexOf(':');
   if(n > 0 && methods.get(s.substring(0, n).trim()) != null){
    Method m = methods.get(s.substring(0, n).trim());	   
    Object obj = m.invoke(groovyObj, s.substring(n + 1).trim());
    cht.sendMessage('\n' + props.getProperty("botReplay1") + row + obj.toString().trim() + row + props.getProperty("botReplay2"));
    return;
   }	   
   else cht.sendMessage(props.getProperty("botReplayr3"));
   cht.sendMessage(props.getProperty("botReplay2"));
  }   
  catch(Exception ex){System.out.println(ex);}
 }	 

 public void chatCreated(Chat cht, boolean local){
  String s = cht.getParticipant();
  System.out.println(s);
  if(s.indexOf('/') > 0)s = s.substring(0, s.lastIndexOf('/'));
  if(!s.equals(props.getProperty("adminJidYa")))return;
  cht.addMessageListener(this);
  try{
   if(!hasGreeting){cht.sendMessage(props.getProperty("botGreeting"));hasGreeting = true;}
  }
  catch(XMPPException ex){} 
 }	 

 public final void start() throws Exception {
  props.load(new FileInputStream("conf/jabberbot.properties"));	 
  groovyObj = groovy.eval(new File(props.getProperty("path2Script")));
  Class grClass = groovyObj.getClass();
  Method[] meths = grClass.getMethods();
  for(Method m : meths)methods.put(m.getName(), m);
  chatMan = this;	 
  ping.start();
  hasGreeting = false;
  System.out.println("[INFO] Jabber bot started.");
 }

 public final void stop() throws Exception {
  ping.interrupt();	 
  if(connection != null)connection.disconnect();	 
 }

 private class YandexTalkConnection extends XMPPConnection {
  public YandexTalkConnection() throws XMPPException {
   super(new ConnectionConfiguration("xmpp.yandex.ru", 5222, "ya.ru"));	  
  }	  
 }

 private class GoogleTalkConnection extends XMPPConnection {
  public GoogleTalkConnection() throws XMPPException {
   super(new ConnectionConfiguration("talk.google.com", 5222, "gmail.com"));	  
  }	  
 }

 private Thread ping = new Thread(new Runnable(){
  public void run(){
   while(true){
    try{
     if(connection != null && connection.isConnected()){Thread.sleep(300000);return;}	    
     connection = new YandexTalkConnection();
//     System.setProperty("smack.debugEnabled", "true");
//     connection.DEBUG_ENABLED = true;
     SASLAuthentication.supportSASLMechanism("PLAIN");
     connection.connect();
     connection.login(props.getProperty("botJidYa"), props.getProperty("botPasswdYa"), "");
     ChatManager chMan = connection.getChatManager();
     chMan.addChatListener(chatMan);
    }
    catch(Exception ex){}    
   }	   
  }	  
 }); 
}