source: proiecte/ptvs/src/vnsim/applications/vitp/services/MessageProcessServices.java @ 31

/************************************************************************************
 * Copyright (C) 2008 by Politehnica University of Bucharest and Rutgers University
 * All rights reserved.
 * Refer to LICENSE for terms and conditions of use.
 ***********************************************************************************/
package vnsim.applications.vitp.services;


import java.util.*;

import vnsim.applications.trafficview.SimulatedCarInfo;
import vnsim.applications.vitp.peer.*;
import vnsim.applications.vitp.utils.*;
import vnsim.map.object.*;



public class MessageProcessServices {

        //this module keeps a list of all registered services (modules that know how
        //to serve a particular VITPRequest); this module just dispatches the VITP Request
        //to the appropriate module

        HashMap<String, Service> servicesMap;
        SimulatedCarInfo car;

        public MessageProcessServices(SimulatedCarInfo car) {
                this.car=car;
                servicesMap=new HashMap<String, Service>();
                servicesMap.put("/vehicle/traffic", new VehicleTraffic(car));
                servicesMap.put("/Road/Info", new RouteInfo(car));
                servicesMap.put("/Route/Time", new RouteTime(car));
                
                
                
        }

        public void addService(String name, Service s) {
                servicesMap.put(name,s);
        }

        public void remove(String name){
                servicesMap.remove(name);
        }

        public VITPMessage satisfy(VITPRequest req){
                //tries to find an appropriate Service, in order to serve
                //the request; returns the modified message (it could be a
                //modified request, or a new reply, built as a result of the
                //complete fulfilling of a request)
                String serviceName="/"+URIParser.getType(req.getURI())+"/"+URIParser.getTag(req.getURI());
                Service s=(Service)(servicesMap.get(serviceName));
                if(s==null) {
                        System.out.println("MessageProcessServices - no service found for:"+serviceName);
                        return req;
                }
                
                
                HashMap<String, String> params=new HashMap<String, String>();
                params.put("speed", ""+car.getSpeed());
                
                
                VITPRequest ret=s.satisfy(req, params);
                //check for the completion of the return condition; if true, build a reply
                if(!checkForCompletion(ret)) {
                        //System.out.println("MPS-sending:"+ret);
                        return ret;     
                } else {
                        //change it into a reply = invert source and destination; set REPLY
                        VITPReply repret=ret.getReversedVITP();
                        repret.setStatus("OK");
                        return repret;
                }
        }

        private boolean checkForCompletion(VITPRequest req) {
                //check if the cnt field is 0
                Vector rcs=URIParser.getRCExpressions(req.getURI());
                if(rcs==null) return true; //no cnt field; consider completed
                for(int i=0;i<rcs.size();i++){
                        if(((String)rcs.elementAt(i)).startsWith("cnt")) {
                                String cntSir=(String)rcs.elementAt(i);
                                int i1=cntSir.indexOf('=');
                                if(i1==-1) return false;
                                Integer n=new Integer(cntSir.substring(i1+1));
                                if(n.intValue()==0)
                                        return true;
                                else 
                                        return false;
                        }
                }
                return false;
        }
}