X-Git-Url: https://git.pterodactylus.net/?a=blobdiff_plain;f=src%2Fnet%2Fpterodactylus%2Farachne%2Fcore%2FURLFetcher.java;h=e0062e34bddc00efe6edf15b645db221234aeb23;hb=8b58c6a6203d8fd6989d92bb5d9fedb9cce37d46;hp=ddfbddd815ac68a385fb0f9a3a8ae3cf1a160cce;hpb=e6d67f8ff35ca69feb69811b4e09c52d3118fa9c;p=arachne.git diff --git a/src/net/pterodactylus/arachne/core/URLFetcher.java b/src/net/pterodactylus/arachne/core/URLFetcher.java index ddfbddd..e0062e3 100644 --- a/src/net/pterodactylus/arachne/core/URLFetcher.java +++ b/src/net/pterodactylus/arachne/core/URLFetcher.java @@ -12,7 +12,8 @@ import java.util.List; import java.util.logging.Level; import java.util.logging.Logger; -import net.pterodactylus.arachne.parser.HtmlEditorKitParser; +import net.pterodactylus.arachne.parser.Parser; +import net.pterodactylus.arachne.parser.ParserFactory; import net.pterodactylus.arachne.parser.ParserListener; import de.ina.util.io.MessageDigestInputStream; import de.ina.util.validation.Validation; @@ -28,6 +29,9 @@ class URLFetcher implements Runnable, ParserListener { /** The logger. */ private static final Logger logger = Logger.getLogger(URLFetcher.class.getName()); + /** The parser factory. */ + private final ParserFactory parserFactory; + /** The URL to fetch. */ private final URL url; @@ -40,17 +44,24 @@ class URLFetcher implements Runnable, ParserListener { /** The collected URLs. */ private final List collectedPages = new ArrayList(); + /** The title of the URL. */ + private String title; + /** * Creates a new fetcher for the given URL. * + * @param parserFactory + * The parser factory that is used to create content-type + * specific parsers * @param url * The URL to fetch * @throws NoSuchAlgorithmException * if no {@link MessageDigest} instance with an * SHA-256 algorithm can be created */ - public URLFetcher(URL url) throws NoSuchAlgorithmException { - Validation.begin().isNotNull("url", url).check(); + public URLFetcher(ParserFactory parserFactory, URL url) throws NoSuchAlgorithmException { + Validation.begin().isNotNull("parserFactory", parserFactory).isNotNull("url", url).check(); + this.parserFactory = parserFactory; this.url = url; messageDigest = MessageDigest.getInstance("SHA-256"); } @@ -60,6 +71,15 @@ class URLFetcher implements Runnable, ParserListener { // /** + * Returns the title of the fetched URL. + * + * @return The fetched URL’s title + */ + public String getTitle() { + return title; + } + + /** * Returns the pages collected while parsing this URL. * * @return The collected pages @@ -85,7 +105,7 @@ class URLFetcher implements Runnable, ParserListener { // /** - * {@inheritdoc} + * {@inheritDoc} * * @see java.lang.Runnable#run() */ @@ -100,8 +120,8 @@ class URLFetcher implements Runnable, ParserListener { logger.log(Level.INFO, "Type is “" + contentType + "”, length is " + contentLength + "."); urlInputStream = urlConnection.getInputStream(); hashInputStream = new MessageDigestInputStream(urlInputStream, messageDigest); - HtmlEditorKitParser htmlEditorKitParser = new HtmlEditorKitParser(); - htmlEditorKitParser.parse(this, hashInputStream, "UTF-8"); + Parser parser = parserFactory.getParser(contentType); + parser.parse(this, hashInputStream, "UTF-8"); hash = messageDigest.digest(); } catch (IOException ioe1) { logger.log(Level.WARNING, "Could not fetch “" + url + "”.", ioe1); @@ -132,6 +152,7 @@ class URLFetcher implements Runnable, ParserListener { * {@inheritDoc} */ public void parsedTitle(InputStream inputStream, String title) { + this.title = title; } }