package com.rarchives.ripme.ripper.rippers; import com.rarchives.ripme.ripper.AbstractHTMLRipper; import com.rarchives.ripme.ripper.DownloadThreadPool; import com.rarchives.ripme.utils.Http; import com.rarchives.ripme.utils.Utils; import java.io.IOException; import java.net.MalformedURLException; import java.net.URI; import java.net.URISyntaxException; import java.net.URL; import java.util.ArrayList; import java.util.List; import java.util.regex.Matcher; import java.util.regex.Pattern; import org.apache.log4j.Logger; import org.jsoup.nodes.Document; import org.jsoup.nodes.Element; import org.jsoup.select.Elements; public class E621Ripper extends AbstractHTMLRipper{ private static final Logger logger = Logger.getLogger(E621Ripper.class); private static Pattern gidPattern=null; private static Pattern gidPattern2=null; private static Pattern gidPatternPool=null; private DownloadThreadPool e621ThreadPool=new DownloadThreadPool("e621"); public E621Ripper(URL url) throws IOException { super(url); } @Override public DownloadThreadPool getThreadPool() { return e621ThreadPool; } @Override public String getDomain() { return "e621.net"; } @Override public String getHost() { return "e621"; } @Override public Document getFirstPage() throws IOException { if(url.getPath().startsWith("/pool/show/")) return Http.url("https://e621.net/pool/show/"+getTerm(url)).get(); else return Http.url("https://e621.net/post/index/1/"+getTerm(url)).get(); } private String getFullSizedImage(String url) { try { return Http.url("https://e621.net" + url).get().select("div > img#image").attr("src"); } catch (IOException e) { logger.error("Unable to get full sized image from " + url); return null; } } @Override public List getURLsFromPage(Document page) { Elements elements = page.select("div > span.thumb > a"); List res = new ArrayList<>(); for(Element e:elements) { if (!e.attr("href").isEmpty()) { String fullSizedImage = getFullSizedImage(e.attr("href")); if (fullSizedImage != null && !fullSizedImage.equals("")) { res.add(getFullSizedImage(e.attr("href"))); } } } return res; } @Override public Document getNextPage(Document page) throws IOException { if (page.select("a.next_page") != null) { return Http.url("https://e621.net" + page.select("a.next_page").attr("href")).get(); } else { throw new IOException("No more pages"); } } @Override public void downloadURL(final URL url, int index) { addURLToDownload(url, getPrefix(index)); } private String getTerm(URL url) throws MalformedURLException{ if(gidPattern==null) gidPattern=Pattern.compile("^https?://(www\\.)?e621\\.net/post/index/[^/]+/([a-zA-Z0-9$_.+!*'(),%-]+)(/.*)?(#.*)?$"); if(gidPatternPool==null) gidPatternPool=Pattern.compile("^https?://(www\\.)?e621\\.net/pool/show/([a-zA-Z0-9$_.+!*'(),%-]+)(\\?.*)?(/.*)?(#.*)?$"); Matcher m = gidPattern.matcher(url.toExternalForm()); if(m.matches()) return m.group(2); m = gidPatternPool.matcher(url.toExternalForm()); if(m.matches()) return m.group(2); throw new MalformedURLException("Expected e621.net URL format: e621.net/post/index/1/searchterm - got "+url+" instead"); } @Override public String getGID(URL url) throws MalformedURLException { try { String prefix=""; if(url.getPath().startsWith("/pool/show/")) prefix="pool_"; return Utils.filesystemSafe(prefix+new URI(getTerm(url)).getPath()); } catch (URISyntaxException ex) { logger.error(ex); } throw new MalformedURLException("Expected e621.net URL format: e621.net/post/index/1/searchterm - got "+url+" instead"); } @Override public URL sanitizeURL(URL url) throws MalformedURLException { if(gidPattern2==null) gidPattern2=Pattern.compile("^https?://(www\\.)?e621\\.net/post/search\\?tags=([a-zA-Z0-9$_.+!*'(),%-]+)(/.*)?(#.*)?$"); Matcher m = gidPattern2.matcher(url.toExternalForm()); if(m.matches()) return new URL("https://e621.net/post/index/1/"+m.group(2).replace("+","%20")); return url; } }