FetchObjectTask.java

Go to the documentation of this file.

/****************************************************************
 *
 * Copyright (c) 2011, 2012
 *
 * School of Engineering, Cardiff University, UK
 *
 * +++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
 *
 * Project name: srs EU FP7 (www.srs-project.eu)
 * ROS stack name: srs
 * ROS package name: srs_knowledge
 * Description: 
 *                                                              
 * +++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
 *
 * @author Ze Ji, email: jiz1@cf.ac.uk
 *
 * Date of creation: Oct 2011:
 * ToDo: 
 *
 * +++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
 *
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions are met:
 *
 *       * Redistributions of source code must retain the above copyright
 *         notice, this list of conditions and the following disclaimer.
 *       * Redistributions in binary form must reproduce the above copyright
 *         notice, this list of conditions and the following disclaimer in the
 *         documentation and/or other materials provided with the distribution.
 *       * Neither the name of the school of Engineering, Cardiff University nor 
 *         the names of its contributors may be used to endorse or promote products 
 *         derived from this software without specific prior written permission.
 *
 * This program is free software: you can redistribute it and/or modify
 * it under the terms of the GNU Lesser General Public License LGPL as 
 * published by the Free Software Foundation, either version 3 of the 
 * License, or (at your option) any later version.
 * 
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU Lesser General Public License LGPL for more details.
 * 
 * You should have received a copy of the GNU Lesser General Public 
 * License LGPL along with this program. 
 * If not, see <http://www.gnu.org/licenses/>.
 *
 ****************************************************************/

package org.srs.srs_knowledge.task;

import java.io.*;
import java.util.StringTokenizer;
import java.util.ArrayList;
import java.util.Iterator;
import ros.pkg.srs_knowledge.msg.*;
import ros.pkg.geometry_msgs.msg.Pose2D;
import ros.pkg.geometry_msgs.msg.Pose;
import org.srs.srs_knowledge.knowledge_engine.*;
import com.hp.hpl.jena.rdf.model.*;
import com.hp.hpl.jena.query.QueryExecutionFactory;
import com.hp.hpl.jena.query.ResultSet;
import com.hp.hpl.jena.query.QueryExecution;
import com.hp.hpl.jena.query.QuerySolution;
import com.hp.hpl.jena.ontology.Individual;
import org.srs.srs_knowledge.task.*;

import ros.pkg.srs_symbolic_grounding.srv.*;
//import ros.pkg.srs_symbolic_grounding.msg.*;

import ros.*;
import ros.communication.*;

import org.json.simple.JSONArray;
import org.json.simple.JSONObject;
import org.json.simple.JSONValue;
import org.json.simple.parser.ParseException;
import org.json.simple.parser.JSONParser;

import org.srs.srs_knowledge.utils.*;

public class FetchObjectTask extends org.srs.srs_knowledge.task.Task
{
    //private GetObjectTask.GraspType graspType = GetObjectTask.GraspType.MOVE_AND_GRASP;
    private ConfigInfo.GraspType graspType = ConfigInfo.GraspType.MOVE_AND_GRASP;
    public FetchObjectTask(String targetContent, String userPose) 
    {   
        //      this.nodeHandle = n;
        this.userPose = userPose;
        // this.init(taskType, targetContent, userPose);
        this.initTask(targetContent, this.userPose);
    }
    public FetchObjectTask(String targetContent, String userPose, ConfigInfo.GraspType graspMode) 
    {   
        this.graspType = graspMode;
        //      this.nodeHandle = n;
        this.userPose = userPose;
        // this.init(taskType, targetContent, userPose);
        //this.initTask(targetContent, this.userPose);


        if (this.initTask(targetContent, this.userPose)) {
            if(graspMode == ConfigInfo.GraspType.MOVE_AND_GRASP)  {
                System.out.println("MOVE_AND_GRASP  " + targetContent);
            }
            else {
                System.out.println("JUST_GRASP  " + targetContent);
            }
        }
        else {
            System.out.println("Task not constructed successfully");
        }


    }

    @Override
    protected boolean constructTask() {
        return createGetObjectTask();
    }
    
    private boolean createGetObjectTask() {
        /*
        // query for tables
        // move to tables (near -- use grounding)
        // detect milk
        // grap milk
        // back to user
        */
        System.out.println("Create New GET OBJECT Task --- ");

        try {
            workspaces = OntoQueryUtil.getWorkspaceOfObject(this.targetContent, OntoQueryUtil.ObjectNameSpace, OntoQueryUtil.GlobalNameSpace, KnowledgeEngine.ontoDB);
        }
        catch(Exception e) {
            System.out.println(e.getMessage() + "\n" + e.toString());
            return false;
        }
        
        for(Individual u : workspaces) {
            System.out.println(u.getLocalName());
            try{
                //System.out.println("Created HLActionSeq ");
                HighLevelActionSequence subSeq = createSubSequenceForSingleWorkspace(u);
                allSubSeqs.add(subSeq);
               
            }
            catch(RosException e) {
                System.out.println("ROSEXCEPTION -- when calling symbolic grounding for scanning positions.  \t" + e.getMessage() + "\t" + e.toString());
                
            }
            catch(Exception e) {
                System.out.println(e.getMessage());
                System.out.println(e.toString());
            }
        }       
        
        if(allSubSeqs.size() > 0) {
            currentSubAction = 0;
            return true;
        }
        else {
            currentSubAction = -1; // no sub_highlevel_action in list
            return false;
        }
    }

    
    private HighLevelActionSequence createSubSequenceForSingleWorkspace(Individual workspace) throws RosException, Exception {
        HighLevelActionSequence actionList = new HighLevelActionSequence();
        
        // create MoveAndDetectionActionUnit
        //SRSFurnitureGeometry spatialInfo = new SRSFurnitureGeometry();
        ros.pkg.srs_msgs.msg.SRSSpatialInfo spatialInfo = new ros.pkg.srs_msgs.msg.SRSSpatialInfo();
        com.hp.hpl.jena.rdf.model.Statement stm = KnowledgeEngine.ontoDB.getPropertyOf(OntoQueryUtil.GlobalNameSpace, "xCoord",  workspace);
        
        spatialInfo.pose.position.x = stm.getFloat();
        stm = KnowledgeEngine.ontoDB.getPropertyOf(OntoQueryUtil.GlobalNameSpace, "yCoord",  workspace);
        spatialInfo.pose.position.y = stm.getFloat();
        stm = KnowledgeEngine.ontoDB.getPropertyOf(OntoQueryUtil.GlobalNameSpace, "zCoord",  workspace);
        spatialInfo.pose.position.z = stm.getFloat();
                
        stm = KnowledgeEngine.ontoDB.getPropertyOf(OntoQueryUtil.GlobalNameSpace, "widthOfObject",  workspace);
        spatialInfo.w = stm.getFloat();
        stm = KnowledgeEngine.ontoDB.getPropertyOf(OntoQueryUtil.GlobalNameSpace, "heightOfObject",  workspace);
        spatialInfo.h = stm.getFloat();
        stm = KnowledgeEngine.ontoDB.getPropertyOf(OntoQueryUtil.GlobalNameSpace, "lengthOfObject",  workspace);
        spatialInfo.l = stm.getFloat();
        
        stm = KnowledgeEngine.ontoDB.getPropertyOf(OntoQueryUtil.GlobalNameSpace, "qu",  workspace);
        spatialInfo.pose.orientation.w = stm.getFloat();
        stm = KnowledgeEngine.ontoDB.getPropertyOf(OntoQueryUtil.GlobalNameSpace, "qx",  workspace);
        spatialInfo.pose.orientation.x = stm.getFloat();
        stm = KnowledgeEngine.ontoDB.getPropertyOf(OntoQueryUtil.GlobalNameSpace, "qy",  workspace);
        spatialInfo.pose.orientation.y = stm.getFloat();
        stm = KnowledgeEngine.ontoDB.getPropertyOf(OntoQueryUtil.GlobalNameSpace, "qz",  workspace);
        spatialInfo.pose.orientation.z = stm.getFloat();
        
        // call symbolic grounding service for target pose
        ArrayList<Pose2D> posList;
        try {
            posList = calculateScanPositions(spatialInfo);
            //System.out.println(posList.size());
        }
        catch(RosException e) {
            System.out.println(e.toString()); 
            System.out.println(e.getMessage());
            throw e;
        }

        Iterator<Individual> itInd = KnowledgeEngine.ontoDB.getInstancesOfClass(OntoQueryUtil.GlobalNameSpace + this.targetContent);
        int hhid = -1000;
        if(itInd.hasNext()) { 
            stm = KnowledgeEngine.ontoDB.getPropertyOf(OntoQueryUtil.GlobalNameSpace, "houseHoldObjectID",  (Individual)itInd.next());
            hhid = OntoQueryUtil.getIntOfStatement(stm);
        }

        // TODO:
        MoveAndDetectionActionUnit mdAction = new MoveAndDetectionActionUnit(posList, targetContent, hhid, workspace.asResource().getLocalName());
        
        // create MoveAndGraspActionUnit
        HighLevelActionUnit mgAction = null;
        //new MoveAndGraspActionUnit(null, targetContent, hhid, "side", workspace.asResource().getLocalName());
        if(this.graspType == ConfigInfo.GraspType.MOVE_AND_GRASP) {
            mgAction = new MoveAndGraspActionUnit(null, targetContent, hhid, "side", workspace.asResource().getLocalName());
        }
        else if(this.graspType == ConfigInfo.GraspType.JUST_GRASP) {
            mgAction = new JustGraspActionUnit(targetContent, hhid, "side", workspace.asResource().getLocalName());
        }
        else {
            mgAction = new MoveAndGraspActionUnit(null, targetContent, hhid, "side", workspace.asResource().getLocalName());
        }

        // create PutOnTrayActionUnit
        PutOnTrayActionUnit trayAction = new PutOnTrayActionUnit("side");

        // FoldArmActionUnit
        //FoldArmActionUnit foldArmAction = new FoldArmActionUnit();

        // create BackToUserActionUnit
        Pose2D posUser = OntoQueryUtil.parsePose2D(userPose);
        MoveActionUnit mau = new MoveActionUnit(posUser);
        
        // create FinishActionUnit
        FinishActionUnit fau = new FinishActionUnit(true);
        //MoveActionUnit mau1 = new MoveActionUnit(OntoQueryUtil.parsePose2D("home"));
        //actionList.appendHighLevelAction(mau1);

        actionList.appendHighLevelAction(mdAction);
        actionList.appendHighLevelAction(mgAction);
        actionList.appendHighLevelAction(trayAction);
        //actionList.appendHighLevelAction(foldArmAction);
        actionList.appendHighLevelAction(mau);
        actionList.appendHighLevelAction(fau);
                
        //System.out.println("ActionList size is " + actionList.getSizeOfHighLevelActionList());

        // set parameters for the workspace information
        actionList.setParameter("workspaceURI", workspace.asResource().getURI());
        actionList.setParameter("workspace", workspace.asResource().getLocalName());
        actionList.setParameter("workspaceNameSpace", workspace.asResource().getNameSpace());

        return actionList;
    }
    
    private CUAction handleFailedMessage() {

        // 
        updateTargetOfFailedAct();

        currentSubAction++;
        
        //System.out.println("HANDLE FAILED MESSAGE.... CURRENTSUBACTION IS AT:  " + currentSubAction);
        
        if(currentSubAction >= allSubSeqs.size()) {
            return null;
        }
        HighLevelActionSequence nextHLActSeq = allSubSeqs.get(currentSubAction);
                
        //      if(nextHLActSeq.hasNextHighLevelActionUnit()) {
        HighLevelActionUnit nextHighActUnit = nextHLActSeq.getCurrentHighLevelActionUnit();
        if(nextHighActUnit != null) {
            int tempI = nextHighActUnit.getNextCUActionIndex(true); 

            CUAction ca = nextHighActUnit.getCUActionAt(tempI);
            
            while (ca == null) {
                
                System.out.println("CUACTION IS NULL....... Keep trying   " + currentSubAction);
                currentSubAction++;
                if(currentSubAction >= allSubSeqs.size()) {
                    return null;
                }
                nextHLActSeq = allSubSeqs.get(currentSubAction);
                nextHighActUnit = nextHLActSeq.getCurrentHighLevelActionUnit();
                
                tempI = nextHighActUnit.getNextCUActionIndex(true);
                ca = nextHighActUnit.getCUActionAt(tempI); 
            }


            // TODO: COULD BE DONE RECURSIVELY. BUT TOO COMPLEX UNNECESSARY AND DIFFICULT TO DEBUG. 
            // SO STUPID CODE HERE
            /*
            if(tempI == HighLevelActionUnit.COMPLETED_SUCCESS || tempI == HighLevelActionUnit.COMPLETED_FAIL || tempI == HighLevelActionUnit.INVALID_INDEX) {
                CUAction ca = new CUAction();
                ca.status = -1;
                return ca;
            }
            else {
                //System.out.println("GET NEXT CU ACTION AT:  " + tempI);
                CUAction ca = nextHighActUnit.getCUActionAt(tempI);

                while (ca == null) {


                    System.out.println("CUACTION IS NULL....... Keep trying   " + currentSubAction);


                    currentSubAction++;
        
        
                    if(currentSubAction >= allSubSeqs.size()) {
                        return null;
                    }
                    nextHLActSeq = allSubSeqs.get(currentSubAction);
                
                    nextHighActUnit = nextHLActSeq.getCurrentHighLevelActionUnit();

                    tempI = nextHighActUnit.getNextCUActionIndex(true);
                    ca = nextHighActUnit.getCUActionAt(tempI); 
                }
            */
        /*
                if(ca == null) {
                    System.out.println("CUACTION IS NULL.......");
                }
                */
                return ca;
                //}
        }
        
        return null;
    }
    
    private boolean updateDBObjectPose() {
        
        return true;
    }
    
    private ArrayList<Pose2D> calculateScanPositions(ros.pkg.srs_msgs.msg.SRSSpatialInfo furnitureInfo) throws RosException {
        ArrayList<Pose2D> posList = new ArrayList<Pose2D>();
        ServiceClient<SymbolGroundingScanBasePose.Request, SymbolGroundingScanBasePose.Response, SymbolGroundingScanBasePose> sc =
            KnowledgeEngine.nodeHandle.serviceClient("symbol_grounding_scan_base_pose" , new SymbolGroundingScanBasePose(), false);
        
        SymbolGroundingScanBasePose.Request rq = new SymbolGroundingScanBasePose.Request();
        rq.parent_obj_geometry = furnitureInfo;

        SymbolGroundingScanBasePose.Response res = sc.call(rq);
        posList = res.scan_base_pose_list;
        sc.shutdown();
        return posList;
    }

    private Pose2D calculateGraspPosition(ros.pkg.srs_msgs.msg.SRSSpatialInfo furnitureInfo, Pose targetPose) throws RosException {
        Pose2D pos = new Pose2D();
        
        ServiceClient<SymbolGroundingGraspBasePoseExperimental.Request, SymbolGroundingGraspBasePoseExperimental.Response, SymbolGroundingGraspBasePoseExperimental> sc = KnowledgeEngine.nodeHandle.serviceClient("symbol_grounding_grasp_base_pose_experimental" , new SymbolGroundingGraspBasePoseExperimental(), false);
        
        SymbolGroundingGraspBasePoseExperimental.Request rq = new SymbolGroundingGraspBasePoseExperimental.Request();
        rq.parent_obj_geometry = furnitureInfo;
        rq.target_obj_pose = targetPose;

        SymbolGroundingGraspBasePoseExperimental.Response res = sc.call(rq);
        boolean obstacleCheck = res.obstacle_check;
        double reach = res.reach;
        pos = res.grasp_base_pose;

        sc.shutdown();
        if(obstacleCheck) {
            return null;
        }
        return pos;
    }

    private ros.pkg.srs_msgs.msg.SRSSpatialInfo getFurnitureGeometryOf(Individual workspace) {
        ros.pkg.srs_msgs.msg.SRSSpatialInfo spatialInfo = new ros.pkg.srs_msgs.msg.SRSSpatialInfo();
        //SRSFurnitureGeometry spatialInfo = new SRSFurnitureGeometry();
        com.hp.hpl.jena.rdf.model.Statement stm = KnowledgeEngine.ontoDB.getPropertyOf(OntoQueryUtil.GlobalNameSpace, "xCoord",  workspace);
        spatialInfo.pose.position.x = stm.getFloat();
        stm = KnowledgeEngine.ontoDB.getPropertyOf(OntoQueryUtil.GlobalNameSpace, "yCoord",  workspace);
        spatialInfo.pose.position.y = stm.getFloat();
        stm = KnowledgeEngine.ontoDB.getPropertyOf(OntoQueryUtil.GlobalNameSpace, "zCoord",  workspace);
        spatialInfo.pose.position.z = stm.getFloat();
        
        stm = KnowledgeEngine.ontoDB.getPropertyOf(OntoQueryUtil.GlobalNameSpace, "widthOfObject",  workspace);
        spatialInfo.w = stm.getFloat();
        stm = KnowledgeEngine.ontoDB.getPropertyOf(OntoQueryUtil.GlobalNameSpace, "heightOfObject",  workspace);
        spatialInfo.h = stm.getFloat();
        stm = KnowledgeEngine.ontoDB.getPropertyOf(OntoQueryUtil.GlobalNameSpace, "lengthOfObject",  workspace);
        spatialInfo.l = stm.getFloat();
        
        stm = KnowledgeEngine.ontoDB.getPropertyOf(OntoQueryUtil.GlobalNameSpace, "qu",  workspace);
        spatialInfo.pose.orientation.w = stm.getFloat();
        stm = KnowledgeEngine.ontoDB.getPropertyOf(OntoQueryUtil.GlobalNameSpace, "qx",  workspace);
        spatialInfo.pose.orientation.x = stm.getFloat();
        stm = KnowledgeEngine.ontoDB.getPropertyOf(OntoQueryUtil.GlobalNameSpace, "qy",  workspace);
        spatialInfo.pose.orientation.y = stm.getFloat();
        stm = KnowledgeEngine.ontoDB.getPropertyOf(OntoQueryUtil.GlobalNameSpace, "qz",  workspace);
        spatialInfo.pose.orientation.z = stm.getFloat();
        return spatialInfo;
    }

    private boolean initTask(String targetContent, String userPose) {
        acts = new ArrayList<ActionTuple>();
        
        setTaskTarget(targetContent);
        System.out.println("TASK.JAVA: Created CurrentTask " + "get "
                           + targetContent);
        return constructTask();
    }   

    @Override
    public boolean replan(OntologyDB onto, OntoQueryUtil ontoQuery) {
        return false;
    }
    @Override
    public boolean isEmpty() {
        try {
            if(allSubSeqs.size() == 0) {
                return true;
            }
        }
        catch(NullPointerException e) {
            System.out.println(e.getMessage() + "\n" + e.toString());
            return true;
        }
        return false;
    }

    private void updateTargetOfFailedAct() {
        HighLevelActionSequence currentHLActSeq = allSubSeqs.get(currentSubAction);
        HighLevelActionUnit currentActUnit = currentHLActSeq.getCurrentHighLevelActionUnit();
        if(currentActUnit.getActionType().equals("MoveAndDetection")) {
            //this.recentDetectedObject = ActionFeedback.toPose(fb);     
                    
            // update the knowledge (post-processing)
            String currentWorkSpace = (String)currentHLActSeq.getParameter("workspaceURI");
            String mapNameSpace = OntoQueryUtil.ObjectNameSpace;
            String prefix = "PREFIX srs: <http://www.srs-project.eu/ontologies/srs.owl#>\n"
                + "PREFIX rdf: <http://www.w3.org/1999/02/22-rdf-syntax-ns#>\n"
                + "PREFIX mapNamespacePrefix: <" + mapNameSpace + ">\n";
            String queryString = "SELECT DISTINCT ?obj WHERE { \n"
                + "?obj srs:spatiallyRelated <" + currentWorkSpace + "> . \n" 
                + " ?obj a srs:" + this.targetContent + " . \n" 
                + "}";
            //          + " <" + currentWorkSpace + "> a srs:FurniturePiece . \n"

            ArrayList<QuerySolution> rset = KnowledgeEngine.ontoDB.executeQueryRaw(prefix + queryString);
            if(rset.size() == 0) {
                //System.out.println("<<<< NO OBJECT INSTANCE FOUND >>>");   
            }
            else {
                //System.out.println("<<<< FOUND OBJECT INSTANCES ON WORKSPACE " + this.targetContent + " >>>");
                //Individual targetInd = KnowledgeEngine.ontoDB.getIndividual(target);
                //Iterator targetIt = KnowledgeEngine.ontoDB.getInstancesOfClass(OntoQueryUtil.GlobalNameSpace + this.targetContent);
                for (QuerySolution qs : rset) {
                    String temp = qs.get("obj").toString();
                    //System.out.println("<<<<<  " + temp + "  >>>>>");
                    
                    //System.out.println( temp.getNameSpace() + "   " + temp.getLocalName());
                    OntoQueryUtil.removeAllSubPropertiesOf(temp, OntoQueryUtil.GlobalNameSpace + "spatiallyRelated");
                    Pose tmpPose = new Pose();
                    tmpPose.position.x = -1000;
                    tmpPose.position.y = -1000;
                    tmpPose.position.z = -1000;
                    tmpPose.orientation.x = -1000;
                    tmpPose.orientation.y = -1000;
                    tmpPose.orientation.z = -1000;
                    tmpPose.orientation.w = -1000;
                    
                    // update its pose
                    try{
                        OntoQueryUtil.updatePoseOfObject(tmpPose, OntoQueryUtil.GlobalNameSpace, temp.trim());
                        OntoQueryUtil.computeOnSpatialRelation();
                    }
                    catch(Exception e) {
                        System.out.println(e.getMessage());
                    }

                }
            }       
        }
        else if(currentActUnit.getActionType().equals("MoveAndGrasp")) {
            // do nothing
        }
        else if(currentActUnit.getActionType().equals("PutOnTray")) {
            // do nothing
        }
    }


    // TODO:   NOT COMPLETED... 
    @Override
    public CUAction getNextCUActionNew(boolean stateLastAction, String jsonFeedback) {
        System.out.println("===> Get Next CUACTION -- from GetObjectTask.java");
        CUAction ca = new CUAction();
        if(allSubSeqs.size() == 0 ) {
            System.out.println("Sequence size is zero");
            return null;   // ??? 
        }
        if(currentSubAction >= 0 && currentSubAction < allSubSeqs.size()) {
            // get the current SubActionSequence item
            System.out.println("Sequence size is " + allSubSeqs.size());
            HighLevelActionSequence subActSeq = allSubSeqs.get(currentSubAction);
            
            HighLevelActionUnit highAct = subActSeq.getCurrentHighLevelActionUnit();
            // decide if the current SubActionSequence is finished or stuck somewhere? 
            // if successfully finished, then finished
            // if stuck (fail), move to the next subActionSequence
            if(highAct != null) {

                // TODO:
                updateDBObjectPose();
                                
                int ni = highAct.getNextCUActionIndex(stateLastAction); 
                switch(ni) {
                case HighLevelActionUnit.COMPLETED_SUCCESS:
                    System.out.println("COMPLETED_SUCCESS");
                    lastStepActUnit = highAct;

                    CUAction retact = null;
                    try {
                        retact = handleSuccessMessageNew(new ActionFeedback(jsonFeedback));
                    }
                    catch(ParseException pe) {
                        System.out.println(pe.toString());
                        return null;
                    }

                    return retact; 
                case HighLevelActionUnit.COMPLETED_FAIL:
                    // The whole task finished (failure). 
                    lastStepActUnit = null;
                    System.out.println("COMPLETED_FAIL");
                    return handleFailedMessage();
                case HighLevelActionUnit.INVALID_INDEX:
                    // The whole task finished failure. Should move to a HighLevelActionUnit in subActSeq of finsihing
                    lastStepActUnit = null;
                    System.out.println("INVALID_INDEX");
                    //currentSubAction++;
                    return handleFailedMessage();
                default: 
                    System.out.println(highAct.getActionType());
                    if(!highAct.ifParametersSet()) {
                        System.out.println("Parameters not set");
                        lastStepActUnit = null;
                        return handleFailedMessage();
                    }
                    ca = highAct.getCUActionAt(ni);

                    // maybe actionUnit is empty
                    if (ca == null)  {
                        return handleFailedMessage();
                    }

                    // since it is going to use String list to represent action info. So cation type is always assumed to be generic, hence the first item in the list actionInfo should contain the action type information...
                    // WARNING: No error checking here
                    //lastActionType = ca.generic.actionInfo.get(0);
                    lastActionType = (String)(SRSJSONParser.decodeJsonActionInfo(ca.generic.jsonActionInfo).get("action"));
                    return ca;
                } 
            }
            else {
                return null;
            }       
            // or if still pending CUAction is available, return CUAction
        }
        else if (currentSubAction == -1) {
        }

        return ca;
    }

    private void updateTargetOfSucceededActNew(ActionFeedback fb) {
        HighLevelActionSequence currentHLActSeq = allSubSeqs.get(currentSubAction);
        HighLevelActionUnit currentActUnit = currentHLActSeq.getCurrentHighLevelActionUnit();
        if(currentActUnit.getActionType().equals("MoveAndDetection")) {
            //this.recentDetectedObject = ActionFeedback.toPose(fb);
            this.recentDetectedObject = fb.getDetectedObjectPose();
            BoundingBoxDim bbDim = InformationRetrieval.retrieveBoundingBoxInfo(OntoQueryUtil.GlobalNameSpace + this.targetContent);
            ros.pkg.srs_msgs.msg.SRSSpatialInfo spaObj = new ros.pkg.srs_msgs.msg.SRSSpatialInfo();
            spaObj.l = bbDim.l;
            spaObj.h = bbDim.h;
            spaObj.w = bbDim.w;

            spaObj.pose = this.recentDetectedObject;

            // update the knowledge (post-processing)
            
            // if there exists one same object on the same workspace, update it --- simple solution
            //String ws = SpatialCalculator.workspaceHolding(spaObj);
            
            String neighbour = SpatialCalculator.nearestObject(spaObj.pose, OntoQueryUtil.GlobalNameSpace + this.targetContent);
            if(!neighbour.trim().equals("")) {
                //System.out.println("Found neighbour of " + neighbour);
                // update its pose
                try{
                    OntoQueryUtil.updatePoseOfObject(spaObj.pose, OntoQueryUtil.GlobalNameSpace, neighbour.trim());
                    OntoQueryUtil.computeOnSpatialRelation();
                }
                catch(Exception e) {
                    System.out.println(e.getMessage());
                }
            }
            
            // if there does not exist such an object, then insert a new one
            // bounding box can be obtained from HHDB
            // TODO
            
        }
        else if(currentActUnit.getActionType().equals("MoveAndGrasp")) {
            // look for the object at the pose 
            // update its relationship with the Robot, and remove its pose information
            //      Individual rob = KnowledgeEngine.ontoDB.getIndividual(OntoQueryUtil.ObjectNameSpace + OntoQueryUtil.RobotName);
            String mapNameSpace = OntoQueryUtil.ObjectNameSpace;
            String prefix = "PREFIX srs: <http://www.srs-project.eu/ontologies/srs.owl#>\n"
                + "PREFIX rdf: <http://www.w3.org/1999/02/22-rdf-syntax-ns#>\n"
                + "PREFIX mapNamespacePrefix: <" + mapNameSpace + ">\n";
            String queryString = "SELECT DISTINCT ?gripper WHERE { "
                + "<" + mapNameSpace + OntoQueryUtil.RobotName + ">"
                + " srs:hasPart ?gripper . " 
                + " ?gripper a srs:RobotGripper . " 
                + "}";

            try {
                String targetObj = SpatialCalculator.nearestObject(this.recentDetectedObject, OntoQueryUtil.GlobalNameSpace + this.targetContent);
                //System.out.println("TARGET OBJECT IS ::: " + targetObj);
                if(!targetObj.trim().equals("")) {
                   
                    Pose tmpPose = new Pose();
                    tmpPose.position.x = -1000;
                    tmpPose.position.y = -1000;
                    tmpPose.position.z = -1000;
                    tmpPose.orientation.x = -1000;
                    tmpPose.orientation.y = -1000;
                    tmpPose.orientation.z = -1000;
                    tmpPose.orientation.w = -1000;
                    
                    // update its pose
                    try{
                        OntoQueryUtil.updatePoseOfObject(tmpPose, OntoQueryUtil.GlobalNameSpace, targetObj.trim());
                        OntoQueryUtil.computeOnSpatialRelation();
                    }
                    catch(Exception e) {
                        System.out.println(e.getMessage());
                    }
                }
                
                // OntoQueryUtil.updatePoseOfObject(tmpPose, OntoQueryUtil.GlobalNameSpace, OntoQueryUtil.ObjectNameSpace, this.targetContent);
                ArrayList<QuerySolution> rset = KnowledgeEngine.ontoDB.executeQueryRaw(prefix + queryString);
                if(rset.size() == 0) {
                    //System.out.println("<<<< NO GRIPPER INSTANCE FOUND >>>");   
                }
                else {
                    //System.out.println("<<<< FOUND GRIPPER INSTANCE >>>");
                    Individual targetInd = KnowledgeEngine.ontoDB.getIndividual(targetObj);
                    
                    OntoQueryUtil.removeAllSubPropertiesOf(targetObj, OntoQueryUtil.GlobalNameSpace + "spatiallyRelated");
                    QuerySolution qs = rset.get(0);

                    String gripper = qs.get("gripper").toString();
                    //System.out.println("<<<<<  " + gripper + "  >>>>>");

                    Individual gripInd = KnowledgeEngine.ontoDB.getIndividual(gripper);
                    Property proExist = KnowledgeEngine.ontoDB.getProperty(OntoQueryUtil.GlobalNameSpace + "spatiallyRelated");
                    
                    Property pro = KnowledgeEngine.ontoDB.getProperty(OntoQueryUtil.GlobalNameSpace + "grippedBy");

                    targetInd.setPropertyValue(pro, gripInd);
                }
            }
            catch (Exception e) {
                //System.out.println(" ==================   " + e.getMessage() + "   " + e.toString());
            }
        }
        else if(currentActUnit.getActionType().equals("PutOnTray")) {
            // look for the object at the pose 
            
            // update its relationship with the Robot, and remove its pose information
            String mapNameSpace = OntoQueryUtil.ObjectNameSpace;
            String prefix = "PREFIX srs: <http://www.srs-project.eu/ontologies/srs.owl#>\n"
                + "PREFIX rdf: <http://www.w3.org/1999/02/22-rdf-syntax-ns#>\n"
                + "PREFIX mapNamespacePrefix: <" + mapNameSpace + ">\n";
            String queryString = "SELECT DISTINCT ?tray WHERE { "
                + "<" + mapNameSpace + OntoQueryUtil.RobotName + ">"
                + " srs:hasPart ?tray . " 
                + " ?tray a srs:COBTray . " 
                + "}";

            try {
                String targetObj = SpatialCalculator.nearestObject(this.recentDetectedObject, OntoQueryUtil.GlobalNameSpace + this.targetContent);
                // System.out.println("TARGET OBJECT IS ::: " + targetObj);
                if(!targetObj.trim().equals("")) {
                   
                    Pose tmpPose = new Pose();
                    tmpPose.position.x = -1000;
                    tmpPose.position.y = -1000;
                    tmpPose.position.z = -1000;
                    tmpPose.orientation.x = -1000;
                    tmpPose.orientation.y = -1000;
                    tmpPose.orientation.z = -1000;
                    tmpPose.orientation.w = -1000;
                    
                    // update its pose
                    try{
                        OntoQueryUtil.updatePoseOfObject(tmpPose, OntoQueryUtil.GlobalNameSpace, targetObj.trim());
                        OntoQueryUtil.computeOnSpatialRelation();
                    }
                    catch(Exception e) {
                        //System.out.println(e.getMessage());
                    }
                }
                
                // OntoQueryUtil.updatePoseOfObject(tmpPose, OntoQueryUtil.GlobalNameSpace, OntoQueryUtil.ObjectNameSpace, this.targetContent);
                ArrayList<QuerySolution> rset = KnowledgeEngine.ontoDB.executeQueryRaw(prefix + queryString);
                if(rset.size() == 0) {
                    //System.out.println("<<<< NO TRAY INSTANCE FOUND >>>");   
                }
                else {
                    //System.out.println("<<<< FOUND TRAY INSTANCE >>>");
                    Individual targetInd = KnowledgeEngine.ontoDB.getIndividual(targetObj);
                    
                    OntoQueryUtil.removeAllSubPropertiesOf(targetObj, OntoQueryUtil.GlobalNameSpace + "spatiallyRelated");
                    QuerySolution qs = rset.get(0);

                    String gripper = qs.get("tray").toString();
                    //System.out.println("<<<<<  " + gripper + "  >>>>>");

                    Individual gripInd = KnowledgeEngine.ontoDB.getIndividual(gripper);
                    Property proExist = KnowledgeEngine.ontoDB.getProperty(OntoQueryUtil.GlobalNameSpace + "spatiallyRelated");
                    
                    Property pro = KnowledgeEngine.ontoDB.getProperty(OntoQueryUtil.GlobalNameSpace + "aboveOf");

                    targetInd.setPropertyValue(pro, gripInd);
                }
            }
            catch (Exception e) {
                System.out.println(" ==================   " + e.getMessage() + " ----  " + e.toString());
            }
            
        }
    }

    private CUAction handleSuccessMessageNew(ActionFeedback fb) {
        // TODO: 
        updateTargetOfSucceededActNew(fb);
    
        HighLevelActionSequence currentHLActSeq = allSubSeqs.get(currentSubAction);

        if(currentHLActSeq.hasNextHighLevelActionUnit()) {
            HighLevelActionUnit nextHighActUnit = currentHLActSeq.getNextHighLevelActionUnit();
            // set feedback? 
            if(nextHighActUnit.getActionType().equals("MoveAndGrasp") && !nextHighActUnit.ifParametersSet()) {

                Pose2D posBase = calculateGraspPosFromFBNew(fb);
                if(posBase == null) {
                    return handleFailedMessage();
                }

                String jsonMove = SRSJSONParser.encodeMoveAction("move", posBase.x, posBase.y, posBase.theta);
                if(!nextHighActUnit.setParameters("move", jsonMove, "")) {
                    //currentSubAction++;
                    return handleFailedMessage();               
                }
            }

            if(nextHighActUnit != null) {
                int tempI = nextHighActUnit.getNextCUActionIndex(true); 
                // TODO: COULD BE DONE RECURSIVELY. BUT TOO COMPLEX UNNECESSARY AND DIFFICULT TO DEBUG. 
                // SO STUPID CODE HERE
                
                if(tempI == HighLevelActionUnit.COMPLETED_SUCCESS) {
                    CUAction ca = new CUAction();
                    ca.status = 1;
                    return ca;
                }
                else if(tempI == HighLevelActionUnit.COMPLETED_FAIL || tempI == HighLevelActionUnit.INVALID_INDEX) {
                    CUAction ca = new CUAction();
                    ca.status = -1;
                    return ca;
                }               
                else {
                    CUAction ca = nextHighActUnit.getCUActionAt(tempI);
                    // maybe actionUnit is empty
                    return ca == null ? handleFailedMessage() : ca;
                    
                    //return nextHighActUnit.getCUActionAt(tempI);
                }
            }
        }
        return null;
    }

    private Pose2D calculateGraspPosFromFBNew(ActionFeedback fb) {
        //calculateGraspPosition(SRSFurnitureGeometry furnitureInfo, Pose targetPose)
        // call symbol grounding to get parameters for the MoveAndGrasp action
        try {
            ros.pkg.srs_msgs.msg.SRSSpatialInfo furGeo = getFurnitureGeometryOf(workspaces.get(currentSubAction));
            //ros.pkg.srs_symbolic_grounding.msg.SRSSpatialInfo furGeo = newGetFurnitureGeometryOf(workspaces.get(currentSubAction));
            // TODO: recentDetectedObject should be updated accordingly when the MoveAndDetection action finished successfully
            //recentDetectedObject = ActionFeedback.toPose(fb);
            recentDetectedObject = fb.getDetectedObjectPose();
            if(recentDetectedObject == null) {
                return null;
            }

            Pose2D pos = calculateGraspPosition(furGeo, recentDetectedObject);
            //Pose2D pos = newCalculateGraspPosition(furGeo, recentDetectedObject);
            return pos;
        }
        catch (Exception e) {
            System.out.println(e.getMessage() + " ++ " + e.toString());
            return null;
        }
        
    }

    private ArrayList<Individual> workspaces = new ArrayList<Individual>();
    private int currentSubAction;
    private Pose recentDetectedObject;    // required by MoveAndGraspActionUnit
    private String lastActionType;        // used to handle feedback from last action executed
    private String userPose;
    private HighLevelActionUnit lastStepActUnit;
}