mirror of
https://github.com/yacy/yacy_search_server.git
synced 2024-09-19 00:01:41 +02:00
7bcfa033c9
a cache access shall not made directly to the cache any more, all loading attempts shall use the LoaderDispatcher. To control the usage of the cache, a enum instance from CrawlProfile.CacheStrategy shall be used. Some direct loading methods without the usage of a cache strategy have been removed. This affects also the verify-option of the yacysearch servlet. If there is a 'verify=false' now after this commit this does not necessarily mean that no snippets are generated. Instead, all snippets that can be retrieved using the cache only are presented. This still means that the search hit was not verified because the snippet was generated using the cache. If a cache-based generation of snippets is not possible, then the verify=false causes that the link is not rejected. git-svn-id: https://svn.berlios.de/svnroot/repos/yacy/trunk@6936 6c8d7289-2bf4-0310-a012-ef5d649a1542
353 lines
15 KiB
Java
353 lines
15 KiB
Java
// IndexControlRWIs_p.java
|
|
// -----------------------
|
|
// (C) 2004-2007 by Michael Peter Christen; mc@yacy.net, Frankfurt a. M., Germany
|
|
// first published 2004 on http://yacy.net
|
|
//
|
|
// This is a part of YaCy, a peer-to-peer based web search engine
|
|
//
|
|
// $LastChangedDate$
|
|
// $LastChangedRevision$
|
|
// $LastChangedBy$
|
|
//
|
|
// LICENSE
|
|
//
|
|
// This program is free software; you can redistribute it and/or modify
|
|
// it under the terms of the GNU General Public License as published by
|
|
// the Free Software Foundation; either version 2 of the License, or
|
|
// (at your option) any later version.
|
|
//
|
|
// This program is distributed in the hope that it will be useful,
|
|
// but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
// GNU General Public License for more details.
|
|
//
|
|
// You should have received a copy of the GNU General Public License
|
|
// along with this program; if not, write to the Free Software
|
|
// Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
|
|
|
|
import java.io.File;
|
|
import java.io.IOException;
|
|
import java.net.MalformedURLException;
|
|
import java.util.Iterator;
|
|
|
|
import net.yacy.kelondro.data.meta.DigestURI;
|
|
import net.yacy.kelondro.data.meta.URIMetadataRow;
|
|
import net.yacy.kelondro.data.word.Word;
|
|
import net.yacy.kelondro.logging.Log;
|
|
import net.yacy.kelondro.order.Base64Order;
|
|
import net.yacy.kelondro.order.RotateIterator;
|
|
import net.yacy.kelondro.util.DateFormatter;
|
|
|
|
import de.anomic.crawler.CrawlProfile;
|
|
import de.anomic.http.server.RequestHeader;
|
|
import de.anomic.search.MetadataRepository;
|
|
import de.anomic.search.Segment;
|
|
import de.anomic.search.Switchboard;
|
|
import de.anomic.search.SwitchboardConstants;
|
|
import de.anomic.server.serverObjects;
|
|
import de.anomic.server.serverSwitch;
|
|
|
|
public class IndexControlURLs_p {
|
|
|
|
public static serverObjects respond(final RequestHeader header, final serverObjects post, final serverSwitch env) {
|
|
// return variable that accumulates replacements
|
|
final Switchboard sb = (Switchboard) env;
|
|
|
|
final serverObjects prop = new serverObjects();
|
|
|
|
// set default values
|
|
prop.put("urlstring", "");
|
|
prop.put("urlhash", "");
|
|
prop.put("result", "");
|
|
String segmentName = sb.getConfig(SwitchboardConstants.SEGMENT_PUBLIC, "default");
|
|
int i = 0;
|
|
for (String s: sb.indexSegments.segmentNames()) {
|
|
prop.put("segments_" + i + "_name", s);
|
|
prop.put("segments_" + i + "_selected", (segmentName.equals(s)) ? 1 : 0);
|
|
i++;
|
|
}
|
|
Segment segment = sb.indexSegments.segment(segmentName);
|
|
prop.put("segments", i);
|
|
prop.put("ucount", Integer.toString(segment.urlMetadata().size()));
|
|
prop.put("otherHosts", "");
|
|
prop.put("genUrlProfile", 0);
|
|
prop.put("statistics", 1);
|
|
prop.put("statistics_lines", 100);
|
|
prop.put("statisticslines", 0);
|
|
prop.put("reload", 0);
|
|
|
|
// do segment selection
|
|
if (post != null && post.containsKey("segment")) {
|
|
// default values
|
|
segmentName = post.get("segment", segmentName).trim();
|
|
i= 0;
|
|
for (String s: sb.indexSegments.segmentNames()) {
|
|
prop.put("segments_" + i + "_name", s);
|
|
prop.put("segments_" + i + "_selected", (segmentName.equals(s)) ? 1 : 0);
|
|
i++;
|
|
}
|
|
prop.put("segments", i);
|
|
segment = sb.indexSegments.segment(segmentName);
|
|
}
|
|
|
|
// show export messages
|
|
final MetadataRepository.Export export = segment.urlMetadata().export();
|
|
if ((export != null) && (export.isAlive())) {
|
|
// there is currently a running export
|
|
prop.put("lurlexport", 2);
|
|
prop.put("lurlexportfinished", 0);
|
|
prop.put("lurlexporterror", 0);
|
|
prop.put("lurlexport_exportfile", export.file().toString());
|
|
prop.put("lurlexport_urlcount", export.count());
|
|
prop.put("reload", 1);
|
|
} else {
|
|
prop.put("lurlexport", 1);
|
|
prop.put("lurlexport_exportfile", sb.getRootPath() + "/DATA/EXPORT/" + DateFormatter.formatShortSecond());
|
|
if (export == null) {
|
|
// there has never been an export
|
|
prop.put("lurlexportfinished", 0);
|
|
prop.put("lurlexporterror", 0);
|
|
} else {
|
|
// an export was running but has finished
|
|
prop.put("lurlexportfinished", 1);
|
|
prop.put("lurlexportfinished_exportfile", export.file().toString());
|
|
prop.put("lurlexportfinished_urlcount", export.count());
|
|
if (export.failed() == null) {
|
|
prop.put("lurlexporterror", 0);
|
|
} else {
|
|
prop.put("lurlexporterror", 1);
|
|
prop.put("lurlexporterror_exportfile", export.file().toString());
|
|
prop.put("lurlexporterror_exportfailmsg", export.failed());
|
|
}
|
|
}
|
|
}
|
|
|
|
if (post == null || env == null) {
|
|
return prop; // nothing to do
|
|
}
|
|
|
|
// post values that are set on numerous input fields with same name
|
|
String urlstring = post.get("urlstring", "").trim();
|
|
String urlhash = post.get("urlhash", "").trim();
|
|
|
|
if (!urlstring.startsWith("http://") &&
|
|
!urlstring.startsWith("https://") &&
|
|
!urlstring.startsWith("ftp://") &&
|
|
!urlstring.startsWith("smb://") &&
|
|
!urlstring.startsWith("file://")) { urlstring = "http://" + urlstring; }
|
|
|
|
prop.putHTML("urlstring", urlstring);
|
|
prop.putHTML("urlhash", urlhash);
|
|
prop.put("result", " ");
|
|
|
|
if (post.containsKey("urlhashdeleteall")) {
|
|
i = segment.removeAllUrlReferences(urlhash.getBytes(), sb.loader, CrawlProfile.CacheStrategy.IFEXIST);
|
|
prop.put("result", "Deleted URL and " + i + " references from " + i + " word indexes.");
|
|
prop.put("lurlexport", 0);
|
|
prop.put("reload", 0);
|
|
}
|
|
|
|
if (post.containsKey("urlhashdelete")) {
|
|
final URIMetadataRow entry = segment.urlMetadata().load(urlhash.getBytes(), null, 0);
|
|
if (entry == null) {
|
|
prop.putHTML("result", "No Entry for URL hash " + urlhash + "; nothing deleted.");
|
|
} else {
|
|
urlstring = entry.metadata().url().toNormalform(false, true);
|
|
prop.put("urlstring", "");
|
|
sb.urlRemove(segment, urlhash.getBytes());
|
|
prop.putHTML("result", "Removed URL " + urlstring);
|
|
}
|
|
prop.put("lurlexport", 0);
|
|
prop.put("reload", 0);
|
|
}
|
|
|
|
if (post.containsKey("urldelete")) {
|
|
try {
|
|
urlhash = new String((new DigestURI(urlstring, null)).hash());
|
|
} catch (final MalformedURLException e) {
|
|
urlhash = null;
|
|
}
|
|
if ((urlhash == null) || (urlstring == null)) {
|
|
prop.put("result", "No input given; nothing deleted.");
|
|
} else {
|
|
sb.urlRemove(segment, urlhash.getBytes());
|
|
prop.putHTML("result", "Removed URL " + urlstring);
|
|
}
|
|
prop.put("lurlexport", 0);
|
|
prop.put("reload", 0);
|
|
}
|
|
|
|
if (post.containsKey("urlstringsearch")) {
|
|
try {
|
|
final DigestURI url = new DigestURI(urlstring, null);
|
|
urlhash = new String(url.hash());
|
|
prop.put("urlhash", urlhash);
|
|
final URIMetadataRow entry = segment.urlMetadata().load(urlhash.getBytes(), null, 0);
|
|
if (entry == null) {
|
|
prop.putHTML("result", "No Entry for URL " + url.toNormalform(true, true));
|
|
prop.putHTML("urlstring", urlstring);
|
|
prop.put("urlhash", "");
|
|
} else {
|
|
prop.putAll(genUrlProfile(segment, entry, urlhash));
|
|
prop.put("statistics", 0);
|
|
}
|
|
} catch (final MalformedURLException e) {
|
|
prop.putHTML("result", "bad url: " + urlstring);
|
|
prop.put("urlhash", "");
|
|
}
|
|
prop.put("lurlexport", 0);
|
|
prop.put("reload", 0);
|
|
}
|
|
|
|
if (post.containsKey("urlhashsearch")) {
|
|
final URIMetadataRow entry = segment.urlMetadata().load(urlhash.getBytes(), null, 0);
|
|
if (entry == null) {
|
|
prop.putHTML("result", "No Entry for URL hash " + urlhash);
|
|
} else {
|
|
prop.putHTML("urlstring", entry.metadata().url().toNormalform(false, true));
|
|
prop.putAll(genUrlProfile(segment, entry, urlhash));
|
|
prop.put("statistics", 0);
|
|
}
|
|
prop.put("lurlexport", 0);
|
|
prop.put("reload", 0);
|
|
}
|
|
|
|
// generate list
|
|
if (post.containsKey("urlhashsimilar")) {
|
|
try {
|
|
final Iterator<URIMetadataRow> entryIt = new RotateIterator<URIMetadataRow>(segment.urlMetadata().entries(true, urlhash), new String(Base64Order.zero((urlhash == null ? 0 : urlhash.length()))), segment.termIndex().sizesMax());
|
|
final StringBuilder result = new StringBuilder("Sequential List of URL-Hashes:<br />");
|
|
URIMetadataRow entry;
|
|
i = 0;
|
|
int rows = 0, cols = 0;
|
|
prop.put("urlhashsimilar", "1");
|
|
while (entryIt.hasNext() && i < 256) {
|
|
entry = entryIt.next();
|
|
if (entry == null) break;
|
|
prop.put("urlhashsimilar_rows_"+rows+"_cols_"+cols+"_urlHash", new String(entry.hash()));
|
|
cols++;
|
|
if (cols==8) {
|
|
prop.put("urlhashsimilar_rows_"+rows+"_cols", cols);
|
|
cols = 0;
|
|
rows++;
|
|
}
|
|
i++;
|
|
}
|
|
prop.put("statistics", 0);
|
|
prop.put("urlhashsimilar_rows", rows);
|
|
prop.put("result", result.toString());
|
|
} catch (final IOException e) {
|
|
prop.putHTML("result", "No Entries for URL hash " + urlhash);
|
|
}
|
|
prop.put("lurlexport", 0);
|
|
prop.put("reload", 0);
|
|
}
|
|
|
|
if (post.containsKey("lurlexport")) {
|
|
// parse format
|
|
int format = 0;
|
|
final String fname = post.get("format", "url-text");
|
|
final boolean dom = fname.startsWith("dom"); // if dom== false complete urls are exported, otherwise only the domain
|
|
if (fname.endsWith("text")) format = 0;
|
|
if (fname.endsWith("html")) format = 1;
|
|
if (fname.endsWith("rss")) format = 2;
|
|
|
|
// extend export file name
|
|
String s = post.get("exportfile", "");
|
|
if (s.indexOf('.') < 0) {
|
|
if (format == 0) s = s + ".txt";
|
|
if (format == 1) s = s + ".html";
|
|
if (format == 2) s = s + ".xml";
|
|
}
|
|
final File f = new File(s);
|
|
f.getParentFile().mkdirs();
|
|
final String filter = post.get("exportfilter", ".*");
|
|
final MetadataRepository.Export running = segment.urlMetadata().export(f, filter, null, format, dom);
|
|
|
|
prop.put("lurlexport_exportfile", s);
|
|
prop.put("lurlexport_urlcount", running.count());
|
|
if ((running != null) && (running.failed() == null)) {
|
|
prop.put("lurlexport", 2);
|
|
}
|
|
prop.put("reload", 1);
|
|
}
|
|
|
|
if (post.containsKey("deletedomain")) {
|
|
String hp = post.get("hashpart");
|
|
try {
|
|
segment.urlMetadata().deleteDomain(hp);
|
|
} catch (IOException e) {
|
|
// TODO Auto-generated catch block
|
|
Log.logException(e);
|
|
}
|
|
// trigger the loading of the table
|
|
post.put("statistics", "");
|
|
prop.put("reload", 0);
|
|
}
|
|
|
|
if (post.containsKey("statistics")) {
|
|
int count = post.getInt("lines", 100);
|
|
Iterator<MetadataRepository.hostStat> statsiter;
|
|
prop.put("statistics_lines", count);
|
|
int cnt = 0;
|
|
try {
|
|
statsiter = segment.urlMetadata().statistics(count);
|
|
boolean dark = true;
|
|
MetadataRepository.hostStat hs;
|
|
while (statsiter.hasNext() && cnt < count) {
|
|
hs = statsiter.next();
|
|
prop.put("statisticslines_domains_" + cnt + "_dark", (dark) ? "1" : "0");
|
|
prop.put("statisticslines_domains_" + cnt + "_domain", hs.hostname + ((hs.port == 80) ? "" : ":" + hs.port));
|
|
prop.put("statisticslines_domains_" + cnt + "lines", count);
|
|
prop.put("statisticslines_domains_" + cnt + "_hashpart", hs.hosthash);
|
|
prop.put("statisticslines_domains_" + cnt + "_count", hs.count);
|
|
dark = !dark;
|
|
cnt++;
|
|
}
|
|
} catch (IOException e) {
|
|
Log.logException(e);
|
|
}
|
|
prop.put("statisticslines_domains", cnt);
|
|
prop.put("statisticslines", 1);
|
|
prop.put("lurlexport", 0);
|
|
prop.put("reload", 0);
|
|
}
|
|
|
|
// insert constants
|
|
prop.putNum("ucount", segment.urlMetadata().size());
|
|
// return rewrite properties
|
|
return prop;
|
|
}
|
|
|
|
private static serverObjects genUrlProfile(final Segment segment, final URIMetadataRow entry, final String urlhash) {
|
|
final serverObjects prop = new serverObjects();
|
|
if (entry == null) {
|
|
prop.put("genUrlProfile", "1");
|
|
prop.put("genUrlProfile_urlhash", urlhash);
|
|
return prop;
|
|
}
|
|
final URIMetadataRow.Components metadata = entry.metadata();
|
|
final URIMetadataRow le = (entry.referrerHash() == null || entry.referrerHash().length != Word.commonHashLength) ? null : segment.urlMetadata().load(entry.referrerHash(), null, 0);
|
|
if (metadata == null || metadata.url() == null) {
|
|
prop.put("genUrlProfile", "1");
|
|
prop.put("genUrlProfile_urlhash", urlhash);
|
|
return prop;
|
|
}
|
|
prop.put("genUrlProfile", "2");
|
|
prop.putHTML("genUrlProfile_urlNormalform", metadata.url().toNormalform(false, true));
|
|
prop.put("genUrlProfile_urlhash", urlhash);
|
|
prop.put("genUrlProfile_urlDescr", metadata.dc_title());
|
|
prop.put("genUrlProfile_moddate", entry.moddate().toString());
|
|
prop.put("genUrlProfile_loaddate", entry.loaddate().toString());
|
|
prop.put("genUrlProfile_referrer", (le == null) ? 0 : 1);
|
|
prop.putHTML("genUrlProfile_referrer_url", (le == null) ? "<unknown>" : le.metadata().url().toNormalform(false, true));
|
|
prop.put("genUrlProfile_referrer_hash", (le == null) ? "" : new String(le.hash()));
|
|
prop.put("genUrlProfile_doctype", String.valueOf(entry.doctype()));
|
|
prop.put("genUrlProfile_language", entry.language());
|
|
prop.put("genUrlProfile_size", entry.size());
|
|
prop.put("genUrlProfile_wordCount", entry.wordCount());
|
|
return prop;
|
|
}
|
|
|
|
}
|