mirror of
https://github.com/internetarchive/heritrix3.git
synced 2026-09-27 08:05:46 +00:00
rename method so as not to conflict with Processor
This commit is contained in:
@@ -15,7 +15,7 @@ import org.archive.util.ArchiveUtils;
|
||||
public class DnsResponseRecordBuilder extends BaseWARCRecordBuilder {
|
||||
|
||||
@Override
|
||||
public boolean shouldProcess(CrawlURI curi) {
|
||||
public boolean shouldBuildRecord(CrawlURI curi) {
|
||||
return "dns".equals(curi.getUURI().getScheme().toLowerCase());
|
||||
}
|
||||
|
||||
|
||||
+1
-1
@@ -17,7 +17,7 @@ import org.archive.util.anvl.ANVLRecord;
|
||||
public class FtpControlConversationRecordBuilder extends BaseWARCRecordBuilder {
|
||||
|
||||
@Override
|
||||
public boolean shouldProcess(CrawlURI curi) {
|
||||
public boolean shouldBuildRecord(CrawlURI curi) {
|
||||
return "ftp".equals(curi.getUURI().getScheme().toLowerCase());
|
||||
}
|
||||
|
||||
|
||||
@@ -16,7 +16,7 @@ import org.archive.util.ArchiveUtils;
|
||||
public class FtpResponseRecordBuilder extends BaseWARCRecordBuilder {
|
||||
|
||||
@Override
|
||||
public boolean shouldProcess(CrawlURI curi) {
|
||||
public boolean shouldBuildRecord(CrawlURI curi) {
|
||||
return !curi.isRevisit()
|
||||
&& "ftp".equals(curi.getUURI().getScheme().toLowerCase());
|
||||
}
|
||||
|
||||
@@ -15,7 +15,7 @@ import org.archive.util.ArchiveUtils;
|
||||
public class HttpRequestRecordBuilder extends BaseWARCRecordBuilder {
|
||||
|
||||
@Override
|
||||
public boolean shouldProcess(CrawlURI curi) {
|
||||
public boolean shouldBuildRecord(CrawlURI curi) {
|
||||
return curi.getUURI().getScheme().toLowerCase().startsWith("http");
|
||||
}
|
||||
|
||||
|
||||
@@ -25,7 +25,7 @@ import org.archive.util.ArchiveUtils;
|
||||
public class HttpResponseRecordBuilder extends BaseWARCRecordBuilder {
|
||||
|
||||
@Override
|
||||
public boolean shouldProcess(CrawlURI curi) {
|
||||
public boolean shouldBuildRecord(CrawlURI curi) {
|
||||
return !curi.isRevisit()
|
||||
&& curi.getUURI().getScheme().toLowerCase().startsWith("http");
|
||||
}
|
||||
|
||||
@@ -22,7 +22,7 @@ public class MetadataRecordBuilder extends BaseWARCRecordBuilder {
|
||||
* If you don't want metadata records, take this class out of the chain.
|
||||
*/
|
||||
@Override
|
||||
public boolean shouldProcess(CrawlURI curi) {
|
||||
public boolean shouldBuildRecord(CrawlURI curi) {
|
||||
String scheme = curi.getUURI().getScheme().toLowerCase();
|
||||
return scheme.startsWith("http") || "ftp".equals(scheme);
|
||||
}
|
||||
|
||||
@@ -21,7 +21,7 @@ import org.archive.util.ArchiveUtils;
|
||||
public class RevisitRecordBuilder extends BaseWARCRecordBuilder {
|
||||
|
||||
@Override
|
||||
public boolean shouldProcess(CrawlURI curi) {
|
||||
public boolean shouldBuildRecord(CrawlURI curi) {
|
||||
String scheme = curi.getUURI().getScheme().toLowerCase();
|
||||
return curi.isRevisit()
|
||||
&& (scheme.startsWith("http") || scheme.equals("ftp"));
|
||||
|
||||
@@ -8,7 +8,7 @@ import org.archive.modules.CrawlURI;
|
||||
|
||||
public interface WARCRecordBuilder {
|
||||
|
||||
boolean shouldProcess(CrawlURI curi);
|
||||
boolean shouldBuildRecord(CrawlURI curi);
|
||||
|
||||
WARCRecordInfo buildRecord(CrawlURI curi, URI concurrentTo)
|
||||
throws IOException;
|
||||
|
||||
@@ -15,7 +15,7 @@ import org.archive.util.ArchiveUtils;
|
||||
public class WhoisResponseRecordBuilder extends BaseWARCRecordBuilder {
|
||||
|
||||
@Override
|
||||
public boolean shouldProcess(CrawlURI curi) {
|
||||
public boolean shouldBuildRecord(CrawlURI curi) {
|
||||
return "whois".equals(curi.getUURI().getScheme().toLowerCase());
|
||||
}
|
||||
|
||||
|
||||
@@ -128,7 +128,7 @@ public class WARCWriterChainProcessor extends BaseWARCWriterProcessor implements
|
||||
protected void writeRecords(CrawlURI curi, WARCWriter writer) throws IOException {
|
||||
URI concurrentTo = null;
|
||||
for (WARCRecordBuilder recordBuilder: getChain()) {
|
||||
if (recordBuilder.shouldProcess(curi)) {
|
||||
if (recordBuilder.shouldBuildRecord(curi)) {
|
||||
WARCRecordInfo record = recordBuilder.buildRecord(curi, concurrentTo);
|
||||
if (record != null) {
|
||||
writer.writeRecord(record);
|
||||
|
||||
Reference in New Issue
Block a user