boxtec
/
yacy_search_server
mirror of https://github.com/yacy/yacy_search_server
4
1
Fork 0
Code Issues Projects Releases Wiki Activity

Add new demonstration module for client-side key-value store (backend:

Browse Source 
triplestore): /DemoServletInteraction.html

Conflicts:
	source/net/yacy/interaction/Interaction.java
pull/1/head
cominch 13 years ago committed by Michael Peter Christen
parent c9dc6cda02
commit b0bc0b4572
6 changed files with 260 additions and 153 deletions
Show Stats Download Patch File Download Diff File

58
htroot/DemoServletInteraction.html
Unescape View File

@ -0,0 +1,58 @@
<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Strict//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-strict.dtd">
<html xmlns="http://www.w3.org/1999/xhtml">
<head>
<title>YaCy '#[clientname]#': Demo-Servlet</title>
<!-- This element contains the jQuery libraries and interaction routines -->
#%env/templates/metas.template%#
</head>
<body id="index">
<p>
JavaScript example: Permanent storage of value
</p>
<br/>
<p>
<input id="SliderSingle" type="slider" name="price" value="0" />
<script type="text/javascript" charset="utf-8">
var oldvalue = loadvalue ('http://virtual.x/document/uniquenameDemo123', 'http://virtual.x/hasvalue');
if (oldvalue == "") {
oldvalue = "0";
}
document.getElementById('SliderSingle').value = oldvalue;
$("#SliderSingle").slider(
{
from: 0,
to: 100,
step: 2.5,
round: 1,
format: { format: '##.0', locale: 'de'},
dimension: '&nbsp; points',
skin: 'round',
onstatechange: function(value) {
storevalue ('http://virtual.x/document/uniquenameDemo123', 'http://virtual.x/hasvalue', value);
}
}
);
</script>
</p>
</body>
</html>

19
htroot/DemoServletInteraction.java
Unescape View File

@ -0,0 +1,19 @@
import net.yacy.cora.protocol.RequestHeader;
import de.anomic.data.BookmarkHelper;
import de.anomic.server.serverObjects;
import de.anomic.server.serverSwitch;
public final class DemoServletInteraction {
public static serverObjects respond(final RequestHeader header,
final serverObjects post, final serverSwitch env) {
// return variable that accumulates replacements
final serverObjects prop = new serverObjects();
prop.put("temperature", "-10°C");
// return rewrite properties
return prop;
}
}

15
htroot/interaction/Triple.java
Unescape View File

@ -73,16 +73,17 @@ public class Triple {
}
if (post.containsKey("url")) {
if (post.containsKey("load")) {
o = Interaction.TripleGet(s, p);
} else {
Interaction.Triple(url, s, p, o, from);
}
} else {
prop.putHTML("url", url);
}
prop.put("result", o);
return prop;

4
htroot/interaction/Triple.json
Unescape View File

@ -1,4 +1,4 @@
{
"url": "#[url]#"
"comment": "#[comment]#"
"url": "#[url]#",
"result": "#[result]#"
}

26
htroot/interaction/interaction.js
Unescape View File

@ -31,4 +31,30 @@ function triple (url, s, p, o, username) {
});
}
function storevalue (s, p, o) {
$.getJSON('/currentyacypeer/interaction/Triple.json?url='+document.location.href+'&s='+s+'&p='+p+'&o='+o, function(data) {
});
}
function loadvalue (s, p) {
var res = {result: "no result"};
$.ajaxSetup({async: false});
$.getJSON('/currentyacypeer/interaction/Triple.json?s='+s+'&p='+p+'&load=true', function (data) {
res = data;
});
return res.result;
}

291
source/net/yacy/interaction/Interaction.java
Unescape View File

@ -7,29 +7,28 @@ import java.util.Map;
import net.yacy.cora.document.UTF8;
import net.yacy.cora.protocol.http.HTTPClient;
import net.yacy.kelondro.blob.Tables;
import net.yacy.kelondro.data.meta.DigestURI;
import net.yacy.kelondro.index.RowSpaceExceededException;
import net.yacy.kelondro.logging.Log;
import net.yacy.peers.Seed;
import net.yacy.search.Switchboard;
import java.util.UUID;
import org.apache.http.entity.mime.content.ContentBody;
import com.hp.hpl.jena.rdf.model.Property;
import com.hp.hpl.jena.rdf.model.Resource;
import com.hp.hpl.jena.rdf.model.StmtIterator;
public class Interaction {
// public static String GetInteractionData (String url) {
//
//
//
//
// // Fetch information from external sciencenet server
//
//
// // TODO: Use internal database
//
//
// Log.logInfo("INTERACTION", "GetInteractionData: "+url);
// try {
// return (UTF8.String(new HTTPClient().GETbytes("http://sciencenet.kit.edu/GetDomainInfoJSON?DomainURL="+url)));
@ -38,102 +37,102 @@ public class Interaction {
// e.printStackTrace();
// return "";
// }
//
//
// }
public static String GetDomain (String url) {
String domain = url;
try {
DigestURI uri = new DigestURI (url);
domain = uri.getHost();
} catch (MalformedURLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return domain;
}
// public static boolean IsInBookmarks (String domain) {
//
//
//
//
// // TODO: Check if this bookmark exists
//
//
// Boolean result = false;
//
//
// DigestURI uri;
// try {
// uri = new DigestURI (domain);
//
//
// Bookmark b = Switchboard.getSwitchboard().bookmarksDB.getBookmark(UTF8.String(uri.hash()));
//
//
// if (!(b == null)) {
// result = true;
// }
//
//
//
//
// } catch (MalformedURLException e) {
// // TODO Auto-generated catch block
// e.printStackTrace();
// }
//
// return result;
//
//
// }
// public static boolean SaveDomainVote (String domain, String vote) {
//
//
//
//
// // TODO: Check if this bookmark exists
//
//
// Boolean result = false;
//
//
// DigestURI uri;
// try {
// uri = new DigestURI (domain);
//
//
// Bookmark b = Switchboard.getSwitchboard().bookmarksDB.getBookmark(UTF8.String(uri.hash()));
//
//
// if (!(b == null)) {
// b.addTag(vote);
// Switchboard.getSwitchboard().bookmarksDB.saveBookmark(b);
// } else {
// Bookmark b2 = Switchboard.getSwitchboard().bookmarksDB.createBookmark(domain, "admin");
//
//
// b2.addTag(vote);
//
//
// Switchboard.getSwitchboard().bookmarksDB.saveBookmark(b2);
// }
//
//
//
//
// } catch (MalformedURLException e) {
// // TODO Auto-generated catch block
// e.printStackTrace();
// }
//
// return result;
//
//
// }
// public static boolean DomainWhite (String domain, String username) {
//
//
//
//
// // Add userinteraction
//
//
// Boolean result = false;
//
//
//// Bookmark b = Interaction.Suggest(domain, username);
////
////
//// //
//
// return result;
//
//
// }
// public static Usercontribution DoUsercontribution(String domain, String uc,
// String username) {
//
@ -146,17 +145,17 @@ public class Interaction {
// }
//
// Usercontribution result = null;
//
//
// if (!existing) {
//
//
// Boolean reject = false;
//
//
//
//
//
//
// // count elements
// Iterator<String> it = sb.usercontributionsDB.getFeedbackitemsIterator(true);
//
//
// int count = 0;
// while(it.hasNext()) {
// it.next();
@ -168,9 +167,9 @@ public class Interaction {
// if (username.equals("crawlbot")) {
// reject = true;
// }
//
//
// }
//
//
// if (!reject) {
//
// try {
@ -203,58 +202,58 @@ public class Interaction {
// return result;
//
// }
//public static String GetURLHash (String url) {
//
//
//
//
// // TODO: Check if this bookmark exists
//
//
// String result = "";
//
//
// DigestURI uri;
// try {
// uri = new DigestURI (url);
//
//
// result = UTF8.String(uri.hash());
//
//
//
//
//
//
// } catch (MalformedURLException e) {
// // TODO Auto-generated catch block
// e.printStackTrace();
// }
//
// return result;
//
//
// }
public static String Suggest (String url, String username) {
final Switchboard sb = Switchboard.getSwitchboard();
if (username == "") {
username = "anonymous";
}
Boolean processlocal = false;
if (!sb.getConfig("interaction.suggest.accumulationpeer", "").equals("")) {
if (sb.getConfig("interaction.suggest.accumulationpeer", "").equals(sb.peers.myName())) {
// Our peer is meant to process the suggestion.
processlocal = true;
} else {
// Forward suggestion to other peer
Log.logInfo("INTERACTION", "Forwarding suggestion to "+sb.getConfig("interaction.suggest.accumulationpeer", "")+": " + url);
try {
Seed host = sb.peers.lookupByName(sb.getConfig("interaction.suggest.accumulationpeer", ""));
return (UTF8.String(new HTTPClient().POSTbytes(
"http://"+host.getPublicAddress()+"/interaction/Suggest.json"
+ "?url=" + url + "&username=" + username,
@ -265,11 +264,11 @@ public class Interaction {
}
}
}
if (processlocal) {
final String date = String.valueOf(System.currentTimeMillis());
final Map<String, byte[]> map = new HashMap<String, byte[]>();
map.put("url", url.getBytes());
@ -285,13 +284,13 @@ public class Interaction {
// TODO Auto-generated catch block
e.printStackTrace();
}
// TODO: Remove the following part for future use
Log.logInfo("INTERACTION", "Forwarding suggestion to bk: " + url);
try {
String reply = (UTF8.String(new HTTPClient().POSTbytes(
"http://hwiki.fzk.de/jss/SiteBookmark?suggestUrl=" + url+"&username="+username,
new HashMap<String, ContentBody>(), false)));
@ -300,9 +299,9 @@ public class Interaction {
e.printStackTrace();
}
}
return "";
}
@ -313,24 +312,24 @@ public static String Feedback(String url, String comment, String from, String pe
if (peer == "") {
peer = sb.peers.myName();
}
Boolean processlocal = false;
if (!sb.getConfig("interaction.feedback.accumulationpeer", "").equals("")) {
if (sb.getConfig("interaction.feedback.accumulationpeer", "").equals(sb.peers.myName())) {
// Our peer is meant to process the feedback.
// Our peer is meant to process the feedback.
processlocal = true;
} else {
// Forward feedback to other peer
Log.logInfo("INTERACTION", "Forwarding feedback to "+sb.getConfig("interaction.feedback.accumulationpeer", "")+": " + url + ": "
+ comment);
try {
Seed host = sb.peers.lookupByName(sb.getConfig("interaction.feedback.accumulationpeer", ""));
return (UTF8.String(new HTTPClient().POSTbytes(
"http://"+host.getPublicAddress()+"/interaction/Feedback.json"
+ "?url=" + url + "&comment=" + comment
@ -343,18 +342,18 @@ public static String Feedback(String url, String comment, String from, String pe
}
}
}
if (processlocal) {
final String date = String.valueOf(System.currentTimeMillis());
final Map<String, byte[]> map = new HashMap<String, byte[]>();
map.put("url", url.getBytes());
map.put("username", from.getBytes());
map.put("peer", peer.getBytes());
map.put("status", "new".getBytes());
map.put("comment", comment.getBytes());
map.put("comment", comment.getBytes());
map.put("timestamp_creation", date.getBytes());
try {
@ -365,9 +364,9 @@ public static String Feedback(String url, String comment, String from, String pe
// TODO Auto-generated catch block
e.printStackTrace();
}
// TODO: Remove the following part for future use
try {
return (UTF8.String(new HTTPClient().POSTbytes(
"http://sciencenet.kit.edu/Feedback?Url=" + url + "&Comment=" + comment
@ -379,8 +378,8 @@ public static String Feedback(String url, String comment, String from, String pe
return "";
}
}
return "";
return "";
}
public static String Contribution(String url, String comment, String from, String peer) {
@ -390,24 +389,24 @@ public static String Contribution(String url, String comment, String from, Strin
if (peer == "") {
peer = sb.peers.myName();
}
Boolean processlocal = false;
if (!sb.getConfig("interaction.contribution.accumulationpeer", "").equals("")) {
if (sb.getConfig("interaction.contribution.accumulationpeer", "").equals(sb.peers.myName())) {
// Our peer is meant to process the feedback.
processlocal = true;
} else {
// Forward feedback to other peer
Log.logInfo("INTERACTION", "Forwarding contribution to "+sb.getConfig("interaction.contribution.accumulationpeer", "")+": " + url + ": "
+ comment);
try {
Seed host = sb.peers.lookupByName(sb.getConfig("interaction.contribution.accumulationpeer", ""));
return (UTF8.String(new HTTPClient().POSTbytes(
"http://"+host.getPublicAddress()+"/interaction/Contribution.json"
+ "?url=" + url + "&comment=" + comment
@ -423,18 +422,18 @@ public static String Contribution(String url, String comment, String from, Strin
// No forward defined
processlocal = true;
}
if (processlocal) {
final String date = String.valueOf(System.currentTimeMillis());
final Map<String, byte[]> map = new HashMap<String, byte[]>();
map.put("url", url.getBytes());
map.put("username", from.getBytes());
map.put("peer", peer.getBytes());
map.put("status", "new".getBytes());
map.put("comment", comment.getBytes());
map.put("comment", comment.getBytes());
map.put("timestamp_creation", date.getBytes());
try {
@ -446,8 +445,8 @@ public static String Contribution(String url, String comment, String from, Strin
e.printStackTrace();
}
}
return "";
return "";
}
public static String Triple(String url, String s, String p, String o, String from) {
@ -456,63 +455,67 @@ public static String Triple(String url, String s, String p, String o, String fro
Resource r = TripleStore.model.getResource(s);
Property pr = TripleStore.model.createProperty(p);
r.addProperty(pr, o);
return "";
Log.logInfo ("TRIPLESTORE", "PUT "+s+"-"+p+"-"+o);
return "";
}
public static String getTriple(String s, String p) {
public static String TripleGet(String s, String p) {
final Switchboard sb = Switchboard.getSwitchboard();
Resource r = TripleStore.model.getResource(s);
Property pr = TripleStore.model.getProperty(p);
StmtIterator iter = TripleStore.model.listStatements(r, pr, (Resource) null);
Log.logInfo ("TRIPLESTORE", "GET "+s+" - "+p);
while (iter.hasNext()) {
return (iter.nextStatement().getObject().toString());
}
return "";
}
public static String GetContribution(String url) {
final Switchboard sb = Switchboard.getSwitchboard();
// Boolean processlocal = false;
//
//
// if (!sb.getConfig("interaction.contribution.accumulationpeer", "").equals("")) {
//
//
// if (sb.getConfig("interaction.contribution.accumulationpeer", "").equals(sb.peers.myName())) {
//
//
// // Our peer is meant to process the feedback.
// processlocal = true;
//
//
// } else {
//
//
// // Forward feedback to other peer
// Log.logInfo("INTERACTION", "Fetching contribution from "+sb.getConfig("interaction.contribution.accumulationpeer", "")+": " + url);
//
//
// try {
//
//
// Seed host = sb.peers.lookupByName(sb.getConfig("interaction.contribution.accumulationpeer", ""));
//
//
// return (UTF8.String(new HTTPClient().POSTbytes(
// "http://"+host.getPublicAddress()+"/interaction/Contribution.json"
// + "?url=" + url + "&comment=" + comment
// + "&from=" + from + "&peer=" + peer,
// new HashMap<String, ContentBody>(), false)));
//
//
// } catch (IOException e) {
// // TODO Auto-generated catch block
// e.printStackTrace();
//
//
// return "";
// }
// }
@ -520,18 +523,18 @@ public static String GetContribution(String url) {
// // No forward defined
// processlocal = true;
// }
//
//
// if (processlocal) {
//
//
// final String date = String.valueOf(System.currentTimeMillis());
//
//
// final Map<String, byte[]> map = new HashMap<String, byte[]>();
//
// map.put("url", url.getBytes());
// map.put("username", from.getBytes());
// map.put("peer", peer.getBytes());
// map.put("status", "new".getBytes());
// map.put("comment", comment.getBytes());
// map.put("comment", comment.getBytes());
// map.put("timestamp_creation", date.getBytes());
//
// try {
@ -543,20 +546,20 @@ public static String GetContribution(String url) {
// e.printStackTrace();
// }
// }
return "";
return "";
}
//public static void Usertracking(String url) {
//
//
// final Switchboard sb = Switchboard.getSwitchboard();
//
//
// Log.logInfo("INTERACTION", "Usertracking "+url);
//
//
//
//
// // TOUCH: HIT +1 TO THE DOMAIN ENTRY
//
//
// try {
// sb.addToIndex(new DigestURI(new DigestURI(url).getHost()), null, null);
// sb.addToIndex(new DigestURI(url), null, null);
@ -570,7 +573,7 @@ public static String GetContribution(String url) {
// // TODO Auto-generated catch block
// e.printStackTrace();
// }
//
//
//}

Write Preview
Loading…
Cancel
Save