/* $Id: LoggerMinerServlet.java,v 1.1 2002/06/27 18:13:47 em Exp $
*/
import java.io.* ;
import java.net.* ;
import java.util.* ;
import java.text.* ;
import java.lang.String;
import javax.servlet.*;
import javax.servlet.http.*;
import com.hp.hpl.jena.util.* ;
import com.hp.hpl.mesa.rdf.jena.model.* ;
import com.hp.hpl.mesa.rdf.jena.common.* ;
import com.hp.hpl.mesa.rdf.jena.mem.ModelMem;
import com.hp.hpl.mesa.rdf.jena.vocabulary.RDF;
import com.hp.hpl.mesa.rdf.jena.vocabulary.RDFS;
import vocabulary.DC;
import vocabulary.W3S;
import vocabulary.CYC;
import vocabulary.FOAF;
/** Mine IRC logs (Action Items and potential other useful bits of
* information) from RRSAgent (Logger) logs
*
* Usage: --data URL --verbose --quiet
* --data URL Data source : URL or filename"
* --verbose Verbose - more messages
* --quiet Quiet - less messages
*
* note: for merging purporses, this application incorporates
* ("Accept", "text/xml") http access so --date URL's should not have
* extensions
*
* author - Eric Miller
* version - $Id: LoggerMinerServlet.java,v 1.1 2002/06/27 18:13:47 em Exp $
*/
public class LoggerMinerServlet extends HttpServlet {
static PrintWriter out = null;
public static String ircurl = "";
public void init(ServletConfig config) throws ServletException {
}
public void doGet(HttpServletRequest request,
HttpServletResponse response) throws IOException, ServletException {
// get output
out = response.getWriter();
ircurl = request.getParameter("uri");
if ((ircurl == null) || (ircurl == "")) {
response.setContentType("text/html");
printForm();
} else {
Model model = new ModelMem();
try {
response.setContentType("text/xml");
URL url = new URL (ircurl);
URLConnection connection = url.openConnection();
connection.setRequestProperty("Accept", "text/xml");
// String userpassEncoded = auth.substring(6);
// connection.setRequestProperty("Authorization", "Basic " + userpassEncoded);
// connection.setRequestProperty("Proxy-Authorization", userpassEncoded);
InputStream content = (InputStream) connection.getInputStream();
BufferedReader in = new BufferedReader (new InputStreamReader (content));
// get a Reader from a BufferedReader...
Reader reader = (Reader) in;
model.read(reader, ircurl, null);
mineLog(model);
} catch (Exception e) {
out.println(e);
}
}
out.close();
}
public void doPost(HttpServletRequest request,
HttpServletResponse response) throws IOException, ServletException {
doGet(request, response);
}
static public void printForm() {
out.println("");
out.println("");
out.println("");
out.println("");
out.println("SWAMT LoggerMiner Service");
out.println("");
out.println("");
out.println("SWAMT LoggerMiner Service
");
out.println("");
out.println("");
out.println("");
}
static public void mineLog(Model model) throws RDFException {
String atext = null;
String atitle = null;
String agentName = null;
String name = null;
Resource irclog = null;
Resource agent = null;
Resource iresource = null;
Resource aresource = null;
// check to see if we've got the neccessary stuff
if (model == null) return;
printHeader();
// select all the resources with a FOAF.chatEventList property
ResIterator iter = model.listSubjectsWithProperty(FOAF.chatEventList);
if (iter.hasNext()) {
while (iter.hasNext()) {
irclog = iter.next();
// ok, loop through eventlist and mine log for ...
// Actions
// get seq of chat events
Seq items = irclog.getProperty(FOAF.chatEventList).getSeq();
for (int ai = 1; (ai <= items.size()); ai++) {
iresource = items.getResource(ai);
if (iresource.hasProperty(DC.relation)) {
aresource = (Resource) iresource.getProperty(DC.relation).getObject();
if (aresource.hasProperty(DC.description)) {
// get trimmed title
atext = aresource.getProperty(DC.description).getString().trim();
if (atext.startsWith("ACTION: ")) {
atitle = atext;
render("\n");
// render(" \n");
render(" \n");
// see if we can extract an owner of this action item
int beginidx = atext.indexOf(" ");
int endidx = atext.indexOf(",");
beginidx = beginidx + 1; // skip space
int length = endidx - beginidx;
String owner = null;
owner = String.copyValueOf(atext.toCharArray(), beginidx, length);
if (owner != null) {
// build smart action item
render(" " + owner + "\n");
// ok, at this point we know we've
// got an Action item and an
// owner... trip action title
// accordingly
endidx = endidx + 1; // skip comma
atitle = String.copyValueOf(atext.toCharArray(), endidx, atext.length() - endidx).trim();
}
render(" " + atitle + "\n");
render("\n\n");
}
}
} else {
// ok... its a simple event; let's test to see
// if someone joined the call
if (iresource.hasProperty(DC.description)) {
// get trimmed description
atext = iresource.getProperty(DC.description).getString().trim();
if (atext.startsWith("+")) {
if (iresource.hasProperty(DC.creator)) {
agent = (Resource) iresource.getProperty(DC.creator).getObject();
if (agent.hasProperty(FOAF.nick)) {
agentName = agent.getProperty(FOAF.nick).getString();
if ((agentName != null) && (agentName.equals("Zakim"))) {
// we have a person joining the call
name = String.copyValueOf(atext.toCharArray(), 1, atext.length() - 1).trim();
render("\n");
render(" \n");
render(" " + name + "\n");
render(" \n");
render("\n\n");
}
}
}
}
}
}
}
}
}
// end
printFooter();
}
public static void render (String outputString) {
if ((outputString != null) & (outputString != "")) {
out.print(outputString);
}
}
public static void printHeader() {
render("\n\n");
render("\n\n");
render("\n\n");
}
public static void printFooter() {
render("\n");
}
}