X-Git-Url: https://git.pterodactylus.net/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fnet%2Fpterodactylus%2Frhynodge%2Fwatchers%2FPirateBayWatcher.java;h=b99d6e56878dcefbfd46efe905f0b2ccaa2a44b4;hb=b1c7de25c9ce6b9ced6a659539bb2dab68c09866;hp=e56388324a82e9c6dd4fbf8045ec038647d571a8;hpb=e20bba90f59d60bc749f89b28f8a369483ab47be;p=rhynodge.git diff --git a/src/main/java/net/pterodactylus/rhynodge/watchers/PirateBayWatcher.java b/src/main/java/net/pterodactylus/rhynodge/watchers/PirateBayWatcher.java index e563883..b99d6e5 100644 --- a/src/main/java/net/pterodactylus/rhynodge/watchers/PirateBayWatcher.java +++ b/src/main/java/net/pterodactylus/rhynodge/watchers/PirateBayWatcher.java @@ -17,6 +17,8 @@ package net.pterodactylus.rhynodge.watchers; +import static net.pterodactylus.rhynodge.filters.BlacklistFilter.createDefaultBlacklistFilter; + import java.io.UnsupportedEncodingException; import java.net.URLEncoder; import java.util.List; @@ -45,8 +47,16 @@ public class PirateBayWatcher extends DefaultWatcher { * @param searchTerms * The terms to search for */ - public PirateBayWatcher(String searchTerms) { - super(createHttpQuery(searchTerms), createFilters(), createTrigger()); + public PirateBayWatcher(String searchTerms, String proxy) { + super(createHttpQuery(searchTerms, extractProxyHost(proxy), extractProxyPort(proxy)), createFilters(), createTrigger()); + } + + private static String extractProxyHost(String proxy) { + return proxy.split(":")[0]; + } + + private static int extractProxyPort(String proxy) { + return Integer.valueOf(proxy.split(":")[1]); } // @@ -60,9 +70,9 @@ public class PirateBayWatcher extends DefaultWatcher { * The search terms of the query * @return The query of the watcher */ - private static Query createHttpQuery(String searchTerms) { + private static Query createHttpQuery(String searchTerms, String proxyHost, int proxyPort) { try { - return new HttpQuery("http://thepiratebay.se/search/" + URLEncoder.encode(searchTerms, "UTF-8") + "/0/3/0"); + return new HttpQuery("http://thepiratebay.org/search/" + URLEncoder.encode(searchTerms, "UTF-8") + "/0/3/0", proxyHost, proxyPort); } catch (UnsupportedEncodingException uee1) { /* will not happen. */ return null; @@ -75,7 +85,7 @@ public class PirateBayWatcher extends DefaultWatcher { * @return The filters of the watcher */ private static List createFilters() { - return ImmutableList.of(new HtmlFilter(), new PirateBayFilter()); + return ImmutableList.of(new HtmlFilter(), new PirateBayFilter(), createDefaultBlacklistFilter()); } /**