package plugins.Librarian;
import java.util.HashMap;
import java.util.Iterator;
import java.util.LinkedHashSet;
import java.util.Random;
import java.util.Vector;
import freenet.client.FetchException;
import freenet.client.FetchResult;
import freenet.client.HighLevelSimpleClient;
import freenet.clients.http.filter.CommentException;
import freenet.clients.http.filter.FilterCallback;
import freenet.keys.FreenetURI;
import freenet.pluginmanager.FredPlugin;
import freenet.pluginmanager.FredPluginHTTP;
import freenet.pluginmanager.FredPluginThreadless;
import freenet.pluginmanager.PluginHTTPException;
import freenet.pluginmanager.PluginRespirator;
import freenet.support.HTMLEncoder;
import freenet.support.api.HTTPRequest;
public class Librarian implements FredPlugin, FredPluginHTTP, FredPluginThreadless {
private static final String DEFAULT_INDEX_URI = "USK@7H66rhYmxIFgMyw5Dl11JazXGHPhp7dSN7WMa1pbtEo,jQHUQUPTkeRcjmjgrc7t5cDRdDkK3uKkrSzuw5CO9uk,AQACAAE/ENTRY.POINT/11/librarian.idx";
private volatile boolean goon = true;
Random rnd = new Random();
PluginRespirator pr;
private static final String plugName = "Librarian";
public void terminate() {
goon = false;
}
public String handleHTTPPost(HTTPRequest request) throws PluginHTTPException {
return null;
}
private void appendDefaultPageStart(StringBuilder out, String stylesheet) {
out.append("" + plugName + " ");
if(stylesheet != null)
out.append("" + plugName + " ").append(HTMLEncoder.encode(search)).append("
\n");
//String searchWords[] = search.replaceAll("%20", "+").split("+");
// Get search result
String searchWords[] = search.split(" ");
// Return results in order.
LinkedHashSet hs = new LinkedHashSet();
synchronized (hs) { // add all for the first word
Vector keyuris = (Vector)index.get(searchWords[0].toLowerCase().trim());
if (keyuris != null) {
Iterator it = keyuris.iterator();
while (it.hasNext())
hs.add(it.next());
}
}
synchronized (hs) {
for (int i = 1 ; i < searchWords.length ; i++) {
Vector keyuris = (Vector)index.get(searchWords[i].toLowerCase().trim());
Iterator it = hs.iterator();
while (it.hasNext()) {
Object o = it.next();
if (!keyuris.contains(o))
it.remove();
}
}
}
// Output results
int results = 0;
out.append("\n");
Iterator it = hs.iterator();
while (it.hasNext()) {
URIWrapper o = (URIWrapper)it.next();
String showurl = o.URI;
String description = HTMLEncoder.encode(o.descr);
description=description.replaceAll("(\n|<(b|B)(r|R)>)", "\n
\n");
results++;
}
out.append(" \n");
out.append("Found: ").append(results).append(" results
\n");
appendDefaultPageEnd(out);
return out.toString();
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
return e.toString();
}
}
public void runPlugin(PluginRespirator pr) {
this.pr = pr;
//int i = (int)System.currentTimeMillis()%1000;
//while(goon) {
/*
FetchResult fr;
try {
fr = pr.getHLSimpleClient().fetch(new FreenetURI("freenet:CHK@j-v1zc0cuN3wlaCpxlKd6vT6c1jAnT9KiscVjfzLu54,q9FIlJSh8M1I1ymRBz~A0fsIcGkvUYZahZb5j7uepLA,AAEA--8"));
System.err.println(" Got data from key, length = " + fr.size() + " Message: "
+ new String(fr.asByteArray()).trim());
} catch (Exception e) {
}
*/
// try {
// Thread.sleep(300000);
// } catch (InterruptedException e) {
// TODO Auto-generated catch block
//e.printStackTrace();
// }
//}
}
private class URIWrapper implements Comparable {
public String URI;
public String descr;
public int compareTo(Object o) {
if (o instanceof URIWrapper)
return URI.compareTo(((URIWrapper)o).URI);
return -1;
}
}
}