Menu
▾
▴
[Jason-developers] SF.net SVN: jason:[1890] trunk/src/jason
|
From: <jom...@us...> - 2016-04-09 11:44:32
|
Revision: 1890
http://sourceforge.net/p/jason/svn/1890
Author: jomifred
Date: 2016-04-09 11:44:30 +0000 (Sat, 09 Apr 2016)
Log Message:
-----------
remove platform dependent classes from architecture package
Modified Paths:
--------------
trunk/src/jason/architecture/MindInspectorWeb.java
trunk/src/jason/infra/centralised/CentralisedAgArch.java
trunk/src/jason/infra/jade/RunJadeMAS.java
trunk/src/jason/util/Config.java
Added Paths:
-----------
trunk/src/jason/architecture/MindInspectorWebImpl.java
Modified: trunk/src/jason/architecture/MindInspectorWeb.java
===================================================================
--- trunk/src/jason/architecture/MindInspectorWeb.java 2016-04-09 10:45:24 UTC (rev 1889)
+++ trunk/src/jason/architecture/MindInspectorWeb.java 2016-04-09 11:44:30 UTC (rev 1890)
@@ -1,52 +1,26 @@
package jason.architecture;
-import java.io.IOException;
-import java.io.OutputStream;
-import java.io.StringWriter;
-import java.net.BindException;
-import java.net.InetAddress;
-import java.net.InetSocketAddress;
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-import java.util.TreeMap;
-import java.util.concurrent.Executors;
-
import org.w3c.dom.Document;
-import com.sun.net.httpserver.Headers;
-import com.sun.net.httpserver.HttpExchange;
-import com.sun.net.httpserver.HttpHandler;
-import com.sun.net.httpserver.HttpServer;
-
import jason.asSemantics.Agent;
-import jason.runtime.Settings;
import jason.util.Config;
-import jason.util.asl2html;
-import jason.util.asl2xml;
-public class MindInspectorWeb {
+public abstract class MindInspectorWeb {
private static MindInspectorWeb singleton = null;
- private HttpServer httpServer = null;
- private String httpServerURL = "http://localhost:3272";
- private int httpServerPort = 3272;
- private int refreshInterval = 5;
+ protected String httpServerURL = "http://localhost:3272";
+ protected int httpServerPort = 3272;
+ protected int refreshInterval = 5;
- //private Map<String,Boolean> agHasHistory = new HashMap<String, Boolean>();
- private Map<String,List<Document>> histories = new TreeMap<String,List<Document>>();
- private Map<String,Integer> lastStepSeenByUser = new HashMap<String, Integer>();
- private Map<String,Agent> registeredAgents = new HashMap<String, Agent>();
-
public static synchronized MindInspectorWeb get() {
if (singleton == null) {
- singleton = new MindInspectorWeb();
- singleton.startHttpServer();
- singleton.registerRootBrowserView();
- singleton.registerAgentsBrowserView();
- singleton.registerAgView("no_ag");
+ try {
+ singleton = (MindInspectorWeb) Class.forName( Config.get().getMindInspectorWebServerClassName()).newInstance();
+ singleton.startHttpServer();
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
}
return singleton;
}
@@ -62,316 +36,12 @@
return null;
}
- private MindInspectorWeb() {
- }
-
- private synchronized String startHttpServer() {
- if (httpServer == null) {
- try {
- httpServer = HttpServer.create(new InetSocketAddress(httpServerPort), 0);
- httpServer.setExecutor(Executors.newCachedThreadPool());
+ public abstract String startHttpServer();
- httpServer.start();
- httpServerURL = "http://"+InetAddress.getLocalHost().getHostAddress()+":"+httpServerPort;
- System.out.println("Jason Http Server running on "+httpServerURL);
- } catch (BindException e) {
- httpServerPort++;
- return startHttpServer();
- } catch (Exception e) {
- e.printStackTrace();
- return null;
- }
- }
- return httpServerURL;
- }
-
- private void registerRootBrowserView() {
- if (httpServer == null)
- return;
- try {
- httpServer.createContext("/", new HttpHandler() {
- public void handle(HttpExchange exchange) throws IOException {
- String requestMethod = exchange.getRequestMethod();
- Headers responseHeaders = exchange.getResponseHeaders();
- responseHeaders.set("Content-Type", "text/html");
- exchange.sendResponseHeaders(200, 0);
- OutputStream responseBody = exchange.getResponseBody();
-
- if (requestMethod.equalsIgnoreCase("GET")) {
- String path = exchange.getRequestURI().getPath();
- StringWriter so = new StringWriter();
-
- if (path.length() < 2) { // it is the root
- so.append("<html><head><title>Jason Mind Inspector -- Web View</title></head><body>");
- so.append("<iframe width=\"20%\" height=\"100%\" align=left src=\"/agents\" border=5 frameborder=0 ></iframe>");
- so.append("<iframe width=\"78%\" height=\"100%\" align=left src=\"/agent-mind/no_ag\" name=\"am\" border=5 frameborder=0></iframe>");
- so.append("</body></html>");
- } else if (path.indexOf("agent-mind") >= 0) {
- if (tryToIncludeMindInspectorForAg(path))
- so.append("<meta http-equiv=\"refresh\" content=0>");
- else
- so.append("unkown agent!");
- }
- responseBody.write(so.toString().getBytes());
- }
- responseBody.close();
- }
- });
- } catch (Exception e) {
- e.printStackTrace();
- }
- }
-
- private String getAgNameFromPath(String path) {
- int nameStart = path.indexOf("agent-mind");
- if (nameStart < 0) return null;
- nameStart += "agent-mind".length() + 1;
- int nameEnd = path.indexOf("/",nameStart+1);
- if (nameEnd >= 0)
- return path.substring(nameStart,nameEnd).trim();
- else
- return path.substring(nameStart).trim();
- }
-
- private boolean tryToIncludeMindInspectorForAg(String path) {
- try {
- Agent ag = registeredAgents.get(getAgNameFromPath(path));
- if (ag != null) {
- AgArch arch = ag.getTS().getUserAgArch();
- if (arch != null) {
- // should add a new conf for mindinspector, otherwise will start a new gui for the agent
- arch.getTS().getSettings().addOption(Settings.MIND_INSPECTOR,"web(cycle,html,no_history)");
- MindInspectorAgArch miArch = new MindInspectorAgArch();
- arch.insertAgArch(miArch);
- miArch.init();
- miArch.addAgState();
- return true;
- }
- }
- } catch (Exception e) {
- e.printStackTrace();
- }
- return false;
- }
-
- private void registerAgentsBrowserView() {
- if (httpServer == null)
- return;
- try {
- httpServer.createContext("/agents", new HttpHandler() {
- public void handle(HttpExchange exchange) throws IOException {
- String requestMethod = exchange.getRequestMethod();
- Headers responseHeaders = exchange.getResponseHeaders();
- responseHeaders.set("Content-Type", "text/html");
- exchange.sendResponseHeaders(200, 0);
- OutputStream responseBody = exchange.getResponseBody();
-
- if (requestMethod.equalsIgnoreCase("GET")) {
- responseBody.write(("<html><head><title>Jason (list of agents)</title><meta http-equiv=\"refresh\" content=\""+refreshInterval+"\" ></head><body>").getBytes());
- responseBody.write(("<font size=\"+2\"><p style='color: red; font-family: arial;'>Agents</p></font>").getBytes());
- for (String a: histories.keySet()) {
- responseBody.write( ("- <a href=\"/agent-mind/"+a+"/latest\" target=\"am\" style=\"font-family: arial; text-decoration: none\">"+a+"</a><br/>").getBytes());
- }
- }
- responseBody.write("<hr/>by <a href=\"http://jason.sf.net\" target=\"_blank\">Jason</a>".getBytes());
- responseBody.write("</body></html>".getBytes());
- responseBody.close();
- }
- });
- } catch (Exception e) {
- e.printStackTrace();
- }
- }
-
/** add the agent in the list of available agent for mind inspection */
- public synchronized void registerAg(Agent ag) {
- String agName = ag.getTS().getUserAgArch().getAgName();
- if (!agName.equals("no-named")) {
- registeredAgents.put(agName, ag);
- histories.put(agName, new ArrayList<Document>()); // just for the agent name to appear in the list of agents
- }
- }
+ public abstract void registerAg(Agent ag);
- public synchronized void removeAg(Agent ag) {
- String agName = ag.getTS().getUserAgArch().getAgName();
- registeredAgents.remove(agName);
- histories.remove(agName);
- }
+ public abstract void removeAg(Agent ag);
+ public abstract void addAgState(Agent ag, Document mind, boolean hasHistory);
- public synchronized void addAgState(Agent ag, Document mind, boolean hasHistory) {
- String agName = ag.getTS().getUserAgArch().getAgName();
- List<Document> h = histories.get(agName);
- if (h == null) {
- h = new ArrayList<Document>();
- histories.put(agName, h);
- }
- if (h.isEmpty())
- registerAgView(agName); // the first time a state is added for the agent, register in the browser
- if (hasHistory || h.isEmpty())
- h.add(mind);
- else
- h.set(0, mind);
- }
-
- String registerAgView(final String agName) {
- if (httpServer == null)
- return null;
- try {
- String url = "/agent-mind/"+agName;
- httpServer.createContext(url, new HttpHandler() {
- public void handle(HttpExchange exchange) throws IOException {
- String requestMethod = exchange.getRequestMethod();
- Headers responseHeaders = exchange.getResponseHeaders();
- exchange.sendResponseHeaders(200, 0);
- OutputStream responseBody = exchange.getResponseBody();
- responseHeaders.set("Content-Type", "text/html");
-
- if (requestMethod.equalsIgnoreCase("GET")) {
- try {
- StringWriter so = new StringWriter();
- so.append("<html><head><title>"+agName+"</title>");
-
- // test if the url is for this agent
- String path = exchange.getRequestURI().getPath();
- if (!getAgNameFromPath(path).equals(agName)) {
- if (tryToIncludeMindInspectorForAg(path))
- so.append("<meta http-equiv=\"refresh\" content=0>");
- else
- so.append("unkown agent!");
- } else {
-
- List<Document> h = histories.get(agName);
- if (h != null && h.size() > 0) {
- Document agState;
- int i = -1;
- exchange.getRemoteAddress();
-
- String query = exchange.getRequestURI().getRawQuery(); // what follows ?
- String remote = exchange.getRemoteAddress().toString();
-
- if (path.endsWith("hide")) {
- show.put(query,false);
- Integer ii = lastStepSeenByUser.get(remote);
- if (ii != null)
- i = ii;
- } else if (path.endsWith("show")) {
- show.put(query,true);
- Integer ii = lastStepSeenByUser.get(remote);
- if (ii != null)
- i = ii;
- } else if (path.endsWith("clear")) {
- agState = h.get(h.size()-1);
- h.clear();
- h.add(agState);
- } else {
- // see if ends with a number
- try {
- int pos = path.lastIndexOf("/");
- String n = path.substring(pos+1).trim();
- i = new Integer(n);
- } catch (Exception e) {}
- }
- if (i == -1) {
- so.append("<meta http-equiv=\"refresh\" content=\""+refreshInterval+"\">");
- agState = h.get(h.size()-1);
- } else {
- agState = h.get(i-1);
- }
- try {
- lastStepSeenByUser.put(remote, i);
- } catch (Exception e) {
- e.printStackTrace();
- }
- so.append("</head><body>");
- if (h.size() > 1) {
- //so.append("history: ");
- so.append("<a href=/agent-mind/"+agName+"/latest>latest state</a> ");
- for (i=h.size()-1; i>0; i--) {
- so.append("<a href=\"/agent-mind/"+agName+"/"+i+"\" style=\"text-decoration: none\">"+i+"</a> ");
- }
- so.append("<a href=\"/agent-mind/"+agName+"/clear\">clear history</a> ");
- so.append("<hr/>");
- }
- so.append(getAgStateAsString(agState, false));
- //so.append("<hr/><a href=\"/\"> list of agents</a> ");
- } else {
- so.append("select an agent");
- }
- }
- responseBody.write(so.toString().getBytes());
-
- //responseBody.write(("<br/><a href=/agent-code/"+agName+">code</a>").getBytes());
- responseBody.write("</body></html>".getBytes());
- } catch (Exception e) {
- e.printStackTrace();
- }
- }
- responseBody.close();
- }
- });
- return httpServerURL+url;
- } catch (Exception e) {
- e.printStackTrace();
- }
- return null;
- }
-
- /*
- String registerAgCodeBrowserView(String agId, final String agCode) {
- if (httpServer == null)
- return null;
- try {
- String url="/agent-code/"+agId;
- httpServer.createContext(url, new HttpHandler() {
- public void handle(HttpExchange exchange) throws IOException {
- String requestMethod = exchange.getRequestMethod();
- Headers responseHeaders = exchange.getResponseHeaders();
- responseHeaders.set("Content-Type", "text/html");
- exchange.sendResponseHeaders(200, 0);
- OutputStream responseBody = exchange.getResponseBody();
-
- if (requestMethod.equalsIgnoreCase("GET")) {
- responseBody.write(agCode.getBytes());
- }
- responseBody.close();
- }
- });
- return httpServerURL+url;
- } catch (Exception e) {
- e.printStackTrace();
- }
- return null;
- }
- */
-
- protected asl2xml mindInspectorTransformer = null;
- Map<String,Boolean> show = new HashMap<String,Boolean>();
-
- synchronized String getAgStateAsString(Document ag, boolean full) { // full means with show all
- try {
- if (mindInspectorTransformer == null) {
- mindInspectorTransformer = new asl2html("/xml/agInspection.xsl");
-
- show.put("bels", true);
- show.put("annots", Config.get().getBoolean(Config.SHOW_ANNOTS));
- show.put("rules", false);
- show.put("evt", true);
- show.put("mb", false);
- show.put("int", false);
- show.put("int-details", false);
- show.put("plan", false);
- show.put("plan-details", false);
- }
- for (String p: show.keySet())
- if (full)
- mindInspectorTransformer.setParameter("show-"+p, "true");
- else
- mindInspectorTransformer.setParameter("show-"+p, show.get(p)+"");
- return mindInspectorTransformer.transform(ag); // transform to HTML
- } catch (Exception e) {
- e.printStackTrace();
- return "Error XML transformation (MindInspector)";
- }
- }
-
}
Added: trunk/src/jason/architecture/MindInspectorWebImpl.java
===================================================================
--- trunk/src/jason/architecture/MindInspectorWebImpl.java (rev 0)
+++ trunk/src/jason/architecture/MindInspectorWebImpl.java 2016-04-09 11:44:30 UTC (rev 1890)
@@ -0,0 +1,351 @@
+package jason.architecture;
+
+import java.io.IOException;
+import java.io.OutputStream;
+import java.io.StringWriter;
+import java.net.BindException;
+import java.net.InetAddress;
+import java.net.InetSocketAddress;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.TreeMap;
+import java.util.concurrent.Executors;
+
+import org.w3c.dom.Document;
+
+import com.sun.net.httpserver.Headers;
+import com.sun.net.httpserver.HttpExchange;
+import com.sun.net.httpserver.HttpHandler;
+import com.sun.net.httpserver.HttpServer;
+
+import jason.asSemantics.Agent;
+import jason.runtime.Settings;
+import jason.util.Config;
+import jason.util.asl2html;
+import jason.util.asl2xml;
+
+public class MindInspectorWebImpl extends MindInspectorWeb {
+
+ private HttpServer httpServer = null;
+
+ private Map<String,List<Document>> histories = new TreeMap<String,List<Document>>();
+ private Map<String,Integer> lastStepSeenByUser = new HashMap<String, Integer>();
+ private Map<String,Agent> registeredAgents = new HashMap<String, Agent>();
+
+ public MindInspectorWebImpl() {
+ }
+
+ public synchronized String startHttpServer() {
+ try {
+ httpServer = HttpServer.create(new InetSocketAddress(httpServerPort), 0);
+ httpServer.setExecutor(Executors.newCachedThreadPool());
+
+ httpServer.start();
+ httpServerURL = "http://"+InetAddress.getLocalHost().getHostAddress()+":"+httpServerPort;
+ System.out.println("Jason Http Server running on "+httpServerURL);
+ registerRootBrowserView();
+ registerAgentsBrowserView();
+ registerAgView("no_ag");
+
+ return httpServerURL;
+ } catch (BindException e) {
+ httpServerPort++;
+ return startHttpServer();
+ } catch (Exception e) {
+ e.printStackTrace();
+ return null;
+ }
+ }
+
+ private void registerRootBrowserView() {
+ if (httpServer == null)
+ return;
+ try {
+ httpServer.createContext("/", new HttpHandler() {
+ public void handle(HttpExchange exchange) throws IOException {
+ String requestMethod = exchange.getRequestMethod();
+ Headers responseHeaders = exchange.getResponseHeaders();
+ responseHeaders.set("Content-Type", "text/html");
+ exchange.sendResponseHeaders(200, 0);
+ OutputStream responseBody = exchange.getResponseBody();
+
+ if (requestMethod.equalsIgnoreCase("GET")) {
+ String path = exchange.getRequestURI().getPath();
+ StringWriter so = new StringWriter();
+
+ if (path.length() < 2) { // it is the root
+ so.append("<html><head><title>Jason Mind Inspector -- Web View</title></head><body>");
+ so.append("<iframe width=\"20%\" height=\"100%\" align=left src=\"/agents\" border=5 frameborder=0 ></iframe>");
+ so.append("<iframe width=\"78%\" height=\"100%\" align=left src=\"/agent-mind/no_ag\" name=\"am\" border=5 frameborder=0></iframe>");
+ so.append("</body></html>");
+ } else if (path.indexOf("agent-mind") >= 0) {
+ if (tryToIncludeMindInspectorForAg(path))
+ so.append("<meta http-equiv=\"refresh\" content=0>");
+ else
+ so.append("unkown agent!");
+ }
+ responseBody.write(so.toString().getBytes());
+ }
+ responseBody.close();
+ }
+ });
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ }
+
+ private String getAgNameFromPath(String path) {
+ int nameStart = path.indexOf("agent-mind");
+ if (nameStart < 0) return null;
+ nameStart += "agent-mind".length() + 1;
+ int nameEnd = path.indexOf("/",nameStart+1);
+ if (nameEnd >= 0)
+ return path.substring(nameStart,nameEnd).trim();
+ else
+ return path.substring(nameStart).trim();
+ }
+
+ private boolean tryToIncludeMindInspectorForAg(String path) {
+ try {
+ Agent ag = registeredAgents.get(getAgNameFromPath(path));
+ if (ag != null) {
+ AgArch arch = ag.getTS().getUserAgArch();
+ if (arch != null) {
+ // should add a new conf for mindinspector, otherwise will start a new gui for the agent
+ arch.getTS().getSettings().addOption(Settings.MIND_INSPECTOR,"web(cycle,html,no_history)");
+ MindInspectorAgArch miArch = new MindInspectorAgArch();
+ arch.insertAgArch(miArch);
+ miArch.init();
+ miArch.addAgState();
+ return true;
+ }
+ }
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ return false;
+ }
+
+ private void registerAgentsBrowserView() {
+ if (httpServer == null)
+ return;
+ try {
+ httpServer.createContext("/agents", new HttpHandler() {
+ public void handle(HttpExchange exchange) throws IOException {
+ String requestMethod = exchange.getRequestMethod();
+ Headers responseHeaders = exchange.getResponseHeaders();
+ responseHeaders.set("Content-Type", "text/html");
+ exchange.sendResponseHeaders(200, 0);
+ OutputStream responseBody = exchange.getResponseBody();
+
+ if (requestMethod.equalsIgnoreCase("GET")) {
+ responseBody.write(("<html><head><title>Jason (list of agents)</title><meta http-equiv=\"refresh\" content=\""+refreshInterval+"\" ></head><body>").getBytes());
+ responseBody.write(("<font size=\"+2\"><p style='color: red; font-family: arial;'>Agents</p></font>").getBytes());
+ for (String a: histories.keySet()) {
+ responseBody.write( ("- <a href=\"/agent-mind/"+a+"/latest\" target=\"am\" style=\"font-family: arial; text-decoration: none\">"+a+"</a><br/>").getBytes());
+ }
+ }
+ responseBody.write("<hr/>by <a href=\"http://jason.sf.net\" target=\"_blank\">Jason</a>".getBytes());
+ responseBody.write("</body></html>".getBytes());
+ responseBody.close();
+ }
+ });
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ }
+
+ /** add the agent in the list of available agent for mind inspection */
+ public synchronized void registerAg(Agent ag) {
+ String agName = ag.getTS().getUserAgArch().getAgName();
+ if (!agName.equals("no-named")) {
+ registeredAgents.put(agName, ag);
+ histories.put(agName, new ArrayList<Document>()); // just for the agent name to appear in the list of agents
+ }
+ }
+
+ public synchronized void removeAg(Agent ag) {
+ String agName = ag.getTS().getUserAgArch().getAgName();
+ registeredAgents.remove(agName);
+ histories.remove(agName);
+ }
+
+ public synchronized void addAgState(Agent ag, Document mind, boolean hasHistory) {
+ String agName = ag.getTS().getUserAgArch().getAgName();
+ List<Document> h = histories.get(agName);
+ if (h == null) {
+ h = new ArrayList<Document>();
+ histories.put(agName, h);
+ }
+ if (h.isEmpty())
+ registerAgView(agName); // the first time a state is added for the agent, register in the browser
+ if (hasHistory || h.isEmpty())
+ h.add(mind);
+ else
+ h.set(0, mind);
+ }
+
+ String registerAgView(final String agName) {
+ if (httpServer == null)
+ return null;
+ try {
+ String url = "/agent-mind/"+agName;
+ httpServer.createContext(url, new HttpHandler() {
+ public void handle(HttpExchange exchange) throws IOException {
+ String requestMethod = exchange.getRequestMethod();
+ Headers responseHeaders = exchange.getResponseHeaders();
+ exchange.sendResponseHeaders(200, 0);
+ OutputStream responseBody = exchange.getResponseBody();
+ responseHeaders.set("Content-Type", "text/html");
+
+ if (requestMethod.equalsIgnoreCase("GET")) {
+ try {
+ StringWriter so = new StringWriter();
+ so.append("<html><head><title>"+agName+"</title>");
+
+ // test if the url is for this agent
+ String path = exchange.getRequestURI().getPath();
+ if (!getAgNameFromPath(path).equals(agName)) {
+ if (tryToIncludeMindInspectorForAg(path))
+ so.append("<meta http-equiv=\"refresh\" content=0>");
+ else
+ so.append("unkown agent!");
+ } else {
+
+ List<Document> h = histories.get(agName);
+ if (h != null && h.size() > 0) {
+ Document agState;
+ int i = -1;
+ exchange.getRemoteAddress();
+
+ String query = exchange.getRequestURI().getRawQuery(); // what follows ?
+ String remote = exchange.getRemoteAddress().toString();
+
+ if (path.endsWith("hide")) {
+ show.put(query,false);
+ Integer ii = lastStepSeenByUser.get(remote);
+ if (ii != null)
+ i = ii;
+ } else if (path.endsWith("show")) {
+ show.put(query,true);
+ Integer ii = lastStepSeenByUser.get(remote);
+ if (ii != null)
+ i = ii;
+ } else if (path.endsWith("clear")) {
+ agState = h.get(h.size()-1);
+ h.clear();
+ h.add(agState);
+ } else {
+ // see if ends with a number
+ try {
+ int pos = path.lastIndexOf("/");
+ String n = path.substring(pos+1).trim();
+ i = new Integer(n);
+ } catch (Exception e) {}
+ }
+ if (i == -1) {
+ so.append("<meta http-equiv=\"refresh\" content=\""+refreshInterval+"\">");
+ agState = h.get(h.size()-1);
+ } else {
+ agState = h.get(i-1);
+ }
+ try {
+ lastStepSeenByUser.put(remote, i);
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ so.append("</head><body>");
+ if (h.size() > 1) {
+ //so.append("history: ");
+ so.append("<a href=/agent-mind/"+agName+"/latest>latest state</a> ");
+ for (i=h.size()-1; i>0; i--) {
+ so.append("<a href=\"/agent-mind/"+agName+"/"+i+"\" style=\"text-decoration: none\">"+i+"</a> ");
+ }
+ so.append("<a href=\"/agent-mind/"+agName+"/clear\">clear history</a> ");
+ so.append("<hr/>");
+ }
+ so.append(getAgStateAsString(agState, false));
+ //so.append("<hr/><a href=\"/\"> list of agents</a> ");
+ } else {
+ so.append("select an agent");
+ }
+ }
+ responseBody.write(so.toString().getBytes());
+
+ //responseBody.write(("<br/><a href=/agent-code/"+agName+">code</a>").getBytes());
+ responseBody.write("</body></html>".getBytes());
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ }
+ responseBody.close();
+ }
+ });
+ return httpServerURL+url;
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ return null;
+ }
+
+ /*
+ String registerAgCodeBrowserView(String agId, final String agCode) {
+ if (httpServer == null)
+ return null;
+ try {
+ String url="/agent-code/"+agId;
+ httpServer.createContext(url, new HttpHandler() {
+ public void handle(HttpExchange exchange) throws IOException {
+ String requestMethod = exchange.getRequestMethod();
+ Headers responseHeaders = exchange.getResponseHeaders();
+ responseHeaders.set("Content-Type", "text/html");
+ exchange.sendResponseHeaders(200, 0);
+ OutputStream responseBody = exchange.getResponseBody();
+
+ if (requestMethod.equalsIgnoreCase("GET")) {
+ responseBody.write(agCode.getBytes());
+ }
+ responseBody.close();
+ }
+ });
+ return httpServerURL+url;
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ return null;
+ }
+ */
+
+ protected asl2xml mindInspectorTransformer = null;
+ Map<String,Boolean> show = new HashMap<String,Boolean>();
+
+ synchronized String getAgStateAsString(Document ag, boolean full) { // full means with show all
+ try {
+ if (mindInspectorTransformer == null) {
+ mindInspectorTransformer = new asl2html("/xml/agInspection.xsl");
+
+ show.put("bels", true);
+ show.put("annots", Config.get().getBoolean(Config.SHOW_ANNOTS));
+ show.put("rules", false);
+ show.put("evt", true);
+ show.put("mb", false);
+ show.put("int", false);
+ show.put("int-details", false);
+ show.put("plan", false);
+ show.put("plan-details", false);
+ }
+ for (String p: show.keySet())
+ if (full)
+ mindInspectorTransformer.setParameter("show-"+p, "true");
+ else
+ mindInspectorTransformer.setParameter("show-"+p, show.get(p)+"");
+ return mindInspectorTransformer.transform(ag); // transform to HTML
+ } catch (Exception e) {
+ e.printStackTrace();
+ return "Error XML transformation (MindInspector)";
+ }
+ }
+
+}
Modified: trunk/src/jason/infra/centralised/CentralisedAgArch.java
===================================================================
--- trunk/src/jason/infra/centralised/CentralisedAgArch.java 2016-04-09 10:45:24 UTC (rev 1889)
+++ trunk/src/jason/infra/centralised/CentralisedAgArch.java 2016-04-09 11:44:30 UTC (rev 1890)
@@ -23,10 +23,17 @@
package jason.infra.centralised;
+import java.util.ArrayList;
+import java.util.Collection;
+import java.util.List;
+import java.util.Queue;
+import java.util.concurrent.ConcurrentLinkedQueue;
+import java.util.logging.Level;
+import java.util.logging.Logger;
+
import jason.JasonException;
import jason.ReceiverNotFoundException;
import jason.architecture.AgArch;
-import jason.architecture.MindInspectorAgArch;
import jason.asSemantics.ActionExec;
import jason.asSemantics.Agent;
import jason.asSemantics.Circumstance;
@@ -37,15 +44,8 @@
import jason.mas2j.ClassParameters;
import jason.runtime.RuntimeServicesInfraTier;
import jason.runtime.Settings;
+import jason.util.Config;
-import java.util.ArrayList;
-import java.util.Collection;
-import java.util.List;
-import java.util.Queue;
-import java.util.concurrent.ConcurrentLinkedQueue;
-import java.util.logging.Level;
-import java.util.logging.Logger;
-
/**
* This class provides an agent architecture when using Centralised
* infrastructure to run the MAS inside Jason.
@@ -97,7 +97,7 @@
// mind inspector arch
if (stts.getUserParameter(Settings.MIND_INSPECTOR) != null) {
- insertAgArch(new MindInspectorAgArch());
+ insertAgArch( (AgArch)Class.forName( Config.get().getMindInspectorArchClassName()).newInstance() );
getFirstAgArch().init();
}
Modified: trunk/src/jason/infra/jade/RunJadeMAS.java
===================================================================
--- trunk/src/jason/infra/jade/RunJadeMAS.java 2016-04-09 10:45:24 UTC (rev 1889)
+++ trunk/src/jason/infra/jade/RunJadeMAS.java 2016-04-09 11:44:30 UTC (rev 1890)
@@ -45,7 +45,6 @@
import jade.wrapper.ContainerController;
import jade.wrapper.StaleProxyException;
import jason.JasonException;
-import jason.architecture.MindInspectorAgArch;
import jason.asSyntax.ASSyntax;
import jason.asSyntax.Literal;
import jason.asSyntax.StringTerm;
@@ -246,7 +245,7 @@
// mind inspector arch
if (ap.getOption("mindinspector") != null) {
- ap.addArchClass(MindInspectorAgArch.class.getName());
+ ap.addArchClass( Config.get().getMindInspectorArchClassName());
}
for (int cAg = 0; cAg < ap.getNbInstances(); cAg++) {
Modified: trunk/src/jason/util/Config.java
===================================================================
--- trunk/src/jason/util/Config.java 2016-04-09 10:45:24 UTC (rev 1889)
+++ trunk/src/jason/util/Config.java 2016-04-09 11:44:30 UTC (rev 1890)
@@ -23,11 +23,6 @@
package jason.util;
-import jason.asSemantics.Message;
-import jason.asSemantics.TransitionSystem;
-import jason.infra.centralised.CentralisedFactory;
-import jason.infra.jade.JadeFactory;
-
import java.io.BufferedReader;
import java.io.File;
import java.io.FileInputStream;
@@ -41,6 +36,11 @@
import java.util.Properties;
import java.util.StringTokenizer;
+import jason.asSemantics.Message;
+import jason.asSemantics.TransitionSystem;
+import jason.infra.centralised.CentralisedFactory;
+import jason.infra.jade.JadeFactory;
+
/**
* Jason configuration (used by JasonID to generate the project's scripts)
*
@@ -762,4 +762,12 @@
Config.get().fix();
Config.get().store();
}
+
+ public String getMindInspectorArchClassName() {
+ return "jason.architecture.MindInspectorAgArch";
+ }
+
+ public String getMindInspectorWebServerClassName() {
+ return "jason.architecture.MindInspectorWebImpl";
+ }
}
This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.
|
