/**

*

*/

package node.server.coordinator;

import java.util.HashMap;

import java.util.Map;

import node.server.main.DirectoryHandler;

import node.server.main.JSONHandler;

import org.json.simple.JSONObject;

import org.json.simple.JSONValue;

import com.hazelcast.core.EntryEvent;

import com.hazelcast.core.EntryListener;

import com.hazelcast.core.HazelcastInstance;

import com.hazelcast.core.IMap;

/**

* @author dell

*

*/

public class MapTask implements EntryListener<String, String>{

private static HazelcastInstance hz;

private IMap<String, String> mapTask;

//private IMap<String, String> mapStatusTask;

private Map<String, String> mapObjTask = new HashMap<String, String>();

private MapTask mt;

private DirectoryHandler dirHandler;

private JSONHandler jHandler;

public MapTask(){

dirHandler = new DirectoryHandler();

jHandler = new JSONHandler();

}

/*

* Method setHzInstance

* set hazelcast instance from main.

*/

public void setHzInstance(HazelcastInstance hi){

hz = hi;

}

/*

* Method listenerOfTask

* listener of mapTask<>

*/

public void listenerOfTask(){

mt = new MapTask();

mapTask = hz.getMap("maptask");

mapTask.addEntryListener(mt, true);

}

/*

* Method addStateToMap

* add state of task to map<>

*/

public void addStateToMap(){

mapTask = hz.getMap("maptask");

mapTask.clear();

mapTask.put("state", "execution");

}

/*

* Method addMapTask

* add task to map<>

*/

public void addMapTask(String stringIn){

JSONObject objparam = (JSONObject)JSONValue.parse(stringIn);

String status = (String)objparam.get("status");

String q = (String)objparam.get("q");

String geocode = (String)objparam.get("geocode");

String lang = (String)objparam.get("lang");

String locale = (String)objparam.get("locale");

String result_type = (String)objparam.get("result_type");

String count = (String)objparam.get("count");

String until = (String)objparam.get("until");

String since_id = (String)objparam.get("since_id");

String max_id = (String)objparam.get("max_id");

String include_entities = (String)objparam.get("include_entities");

String callback = (String)objparam.get("callback");

// put task to mapTask<>

mapObjTask.put("status", status);

mapObjTask.put("q", q);

mapObjTask.put("geocode", geocode);

mapObjTask.put("lang", lang);

mapObjTask.put("locale", locale);

mapObjTask.put("result_type", result_type);

mapObjTask.put("count", count);

mapObjTask.put("until", until);

mapObjTask.put("since_id", since_id);

mapObjTask.put("max_id", max_id);

mapObjTask.put("include_entities", include_entities);

mapObjTask.put("callback", callback);

String objTask = JSONValue.toJSONString(mapObjTask);

mapTask = hz.getMap("maptask");

mapTask.clear();

mapTask.put("state", "execution");

mapTask.put("task", objTask);

//saveReplicationTask(mapTask);

}

/*

* Method clearMapTask

* clearing mapTask<>

*/

public void clearMapTask(){

mapTask = hz.getMap("maptask");

//mapTask.clear();

mapTask.put("state", "null");

mapTask.put("task", "null");

saveReplicationTask(mapTask);

}

/*

* Method saveReplicationTask

* save replication of task

*/

private void saveReplicationTask(Map<String, String> task){

String namefile = dirHandler.getDirReplication()+"/"+"task";

String jsonText = JSONValue.toJSONString(task);

jHandler.saveToJSON(jsonText, namefile);

}

/*

* (non-Javadoc)

* @see com.hazelcast.core.EntryListener#entryAdded(com.hazelcast.core.EntryEvent)

*/

@Override

public void entryAdded(EntryEvent<String, String> event) {

// TODO Auto-generated method stub

// save replication if maptask added

// System.out.println("map task ~ entry added : " + event.getValue());

mapTask = hz.getMap("maptask");

saveReplicationTask(mapTask);

}

@Override

public void entryEvicted(EntryEvent<String, String> event) {

// TODO Auto-generated method stub

}

@Override

public void entryRemoved(EntryEvent<String, String> event) {

// TODO Auto-generated method stub

}

@Override

public void entryUpdated(EntryEvent<String, String> event) {

// TODO Auto-generated method stub

System.out.println("==============================================================================");

System.out.println("");

System.out.println("GRID INFO ~ TASK : task updated");

System.out.println("GRID INFO ~ TASK : "+ event.getKey() +" -> "+ event.getValue());

System.out.println("");

System.out.println("==============================================================================");

mapTask = hz.getMap("maptask");

saveReplicationTask(mapTask);

}

}