import lia.Monitor.JiniClient.Store.Main;

import lia.Monitor.monitor.monPredicate;
import lia.Monitor.monitor.Result;
import lia.Monitor.monitor.eResult;
import lia.Monitor.monitor.ExtResult;
import lia.Monitor.monitor.AccountingResult;

import lia.Monitor.monitor.DataReceiver;

import lia.Monitor.monitor.MFarm;

import lia.Monitor.DataCache.DataSelect;

import lia.Monitor.Store.TransparentStoreFast;
import lia.Monitor.Store.TransparentStoreFactory;

import java.util.Vector;

public class TriggerClient {

    public static void main(String args[]){
        // start the repository service
        Main jClient = new Main();
			
        // register a MyDataReceiver object to receive any new information
        jClient.addDataReceiver(new MyDataReceiver());
					
        try {
            Thread.sleep(60*1000);
        }catch(Throwable t) {
        }

        //Uncomment this if you would like to stop the client when main() exits
        //jClient.stopIt();
    }
    
    
    private static class MyDataReceiver implements DataReceiver {
	
	private Vector vWatchFor;
	
	private TransparentStoreFast store;
    
	public MyDataReceiver(){
	    vWatchFor = new Vector();
	
	    vWatchFor.add(new monPredicate("*", "*", "*", -1, -1, new String[]{"var_i"}, null));
	   
            try{ 
          	store = (TransparentStoreFast) TransparentStoreFactory.getStore();
               }
            catch(Exception ex){
               System.out.println("ERROR: "+ex.toString());
               }
	}
	
	public void addResult(Result r){
	    for (int i=0; i<vWatchFor.size(); i++){
		monPredicate pred = (monPredicate) vWatchFor.get(i);
		
		Result rTemp = DataSelect.matchResult(r, pred);
		
		if (rTemp!=null){
		    System.err.println("Data received : "+rTemp.FarmName+"/"+rTemp.ClusterName+"/"+rTemp.NodeName+" : "+rTemp.param_name[0]+"="+rTemp.param[0]);
		    
		    monPredicate pTemp = new monPredicate(
			rTemp.FarmName!=null ? rTemp.FarmName : "*", 
			rTemp.ClusterName!=null ? rTemp.ClusterName : "*", 
			rTemp.NodeName!=null ? rTemp.NodeName : "*", 
			-30*60*1000, -1, 
			new String[]{rTemp.param_name[0]}, 
			null
		    );
		    
	    	    Vector vData = store.select(pTemp);

		    synchronized (vWatchFor){	// do not overlap the output, this function can be called from different threads
		        System.err.println("\t\tLast 30 minutes values : "+vData.size());
		    
			double d = 0;
		    	for (int j=0; j<vData.size(); j++){
			    Result rt = (Result) vData.get(j);
			    d += rt.param[0];
			}
		    
			System.err.println("\t\tLast 30 minutes average for this data : "+(vData.size()>0 ? ""+(d/vData.size()) : "NA")+"\n");
		    }
		}
	    }
	}
	
	public void addResult(eResult er){
	}
	
	public void addResult(ExtResult er){
	}

	public void addResult(AccountingResult ar){
	}
	
	public void updateConfig(MFarm f){
	}
	    
    }

}