-
Notifications
You must be signed in to change notification settings - Fork 627
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
3 changed files
with
203 additions
and
2 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
201 changes: 201 additions & 0 deletions
201
src/main/java/com/rarchives/ripme/ripper/rippers/FlickrRipper.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,201 @@ | ||
package com.rarchives.ripme.ripper.rippers; | ||
|
||
import java.io.IOException; | ||
import java.net.MalformedURLException; | ||
import java.net.URL; | ||
import java.util.HashSet; | ||
import java.util.Set; | ||
import java.util.regex.Matcher; | ||
import java.util.regex.Pattern; | ||
|
||
import org.apache.log4j.Logger; | ||
import org.jsoup.Jsoup; | ||
import org.jsoup.nodes.Document; | ||
import org.jsoup.nodes.Element; | ||
import org.jsoup.select.Elements; | ||
|
||
import com.rarchives.ripme.ripper.AlbumRipper; | ||
import com.rarchives.ripme.ripper.DownloadThreadPool; | ||
import com.rarchives.ripme.utils.Utils; | ||
|
||
public class FlickrRipper extends AlbumRipper { | ||
|
||
private static final String DOMAIN = "flickr.com", | ||
HOST = "flickr"; | ||
private static final Logger logger = Logger.getLogger(FlickrRipper.class); | ||
|
||
private DownloadThreadPool flickrThreadPool; | ||
private Document albumDoc = null; | ||
|
||
public FlickrRipper(URL url) throws IOException { | ||
super(url); | ||
flickrThreadPool = new DownloadThreadPool(); | ||
} | ||
|
||
@Override | ||
public String getHost() { | ||
return HOST; | ||
} | ||
|
||
public URL sanitizeURL(URL url) throws MalformedURLException { | ||
return url; | ||
} | ||
|
||
public String getAlbumTitle(URL url) throws MalformedURLException { | ||
if (!url.toExternalForm().contains("/sets/")) { | ||
return super.getAlbumTitle(url); | ||
} | ||
try { | ||
// Attempt to use album title as GID | ||
if (albumDoc == null) { | ||
albumDoc = Jsoup.connect(url.toExternalForm()).get(); | ||
} | ||
String user = url.toExternalForm(); | ||
user = user.substring(user.indexOf("/photos/") + "/photos/".length()); | ||
user = user.substring(0, user.indexOf("/")); | ||
String title = albumDoc.select("meta[name=description]").get(0).attr("content"); | ||
if (!title.equals("")) { | ||
return HOST + "_" + user + "_" + title; | ||
} | ||
} catch (Exception e) { | ||
// Fall back to default album naming convention | ||
} | ||
return super.getAlbumTitle(url); | ||
} | ||
|
||
@Override | ||
public String getGID(URL url) throws MalformedURLException { | ||
Pattern p; Matcher m; | ||
|
||
// Root: https://www.flickr.com/photos/115858035@N04/ | ||
// Album: https://www.flickr.com/photos/115858035@N04/sets/72157644042355643/ | ||
|
||
final String userRegex = "[a-zA-Z0-9@]+"; | ||
// Album | ||
p = Pattern.compile("^https?://[wm.]*flickr.com/photos/(" + userRegex + ")/sets/([0-9]+)/?.*$"); | ||
m = p.matcher(url.toExternalForm()); | ||
if (m.matches()) { | ||
return m.group(1) + "_" + m.group(2); | ||
} | ||
|
||
// User page | ||
p = Pattern.compile("^https?://[wm.]*flickr.com/photos/(" + userRegex + ").*$"); | ||
m = p.matcher(url.toExternalForm()); | ||
if (m.matches()) { | ||
return m.group(1); | ||
} | ||
|
||
throw new MalformedURLException( | ||
"Expected flickr.com URL formats: " | ||
+ "flickr.com/photos/username or " | ||
+ "flickr.com/photos/username/sets/albumid" | ||
+ " Got: " + url); | ||
} | ||
|
||
@Override | ||
public void rip() throws IOException { | ||
Set<String> attempted = new HashSet<String>(); | ||
int index = 0; | ||
logger.info(" Retrieving " + this.url.toExternalForm()); | ||
if (albumDoc == null) { | ||
albumDoc = Jsoup.connect(this.url.toExternalForm()).get(); | ||
} | ||
for (Element thumb : albumDoc.select("a[data-track=photo-click]")) { | ||
String imageTitle = null; | ||
if (thumb.hasAttr("title")) { | ||
imageTitle = thumb.attr("title"); | ||
} | ||
String imagePage = thumb.attr("href"); | ||
if (imagePage.startsWith("/")) { | ||
imagePage = "http://www.flickr.com" + imagePage; | ||
} | ||
if (imagePage.contains("/in/")) { | ||
imagePage = imagePage.substring(0, imagePage.indexOf("/in/") + 1); | ||
} | ||
if (!imagePage.endsWith("/")) { | ||
imagePage += "/"; | ||
} | ||
imagePage += "sizes/o/"; | ||
|
||
// Check for duplicates | ||
if (attempted.contains(imagePage)) { | ||
continue; | ||
} | ||
attempted.add(imagePage); | ||
|
||
index += 1; | ||
// Add image page to threadpool to grab the image & download it | ||
FlickrImageThread mit = new FlickrImageThread(new URL(imagePage), imageTitle, index); | ||
flickrThreadPool.addThread(mit); | ||
} | ||
flickrThreadPool.waitForThreads(); | ||
waitForThreads(); | ||
} | ||
|
||
public boolean canRip(URL url) { | ||
return url.getHost().endsWith(DOMAIN); | ||
} | ||
|
||
/** | ||
* Helper class to find and download images found on "image" pages | ||
*/ | ||
private class FlickrImageThread extends Thread { | ||
private URL url; | ||
private String title; | ||
private int index; | ||
|
||
public FlickrImageThread(URL url, String title, int index) { | ||
super(); | ||
this.url = url; | ||
this.title = title; | ||
this.index = index; | ||
} | ||
|
||
@Override | ||
public void run() { | ||
try { | ||
Document doc = getLargestImagePageDocument(this.url); | ||
Elements fullsizeImages = doc.select("div#allsizes-photo img"); | ||
if (fullsizeImages.size() == 0) { | ||
logger.error("Could not find flickr image at " + doc.location() + " - missing 'div#allsizes-photo img'"); | ||
return; | ||
} | ||
else { | ||
String prefix = String.format("%03d_%s_", index, Utils.filesystemSafe(title)); | ||
addURLToDownload(new URL(fullsizeImages.get(0).attr("src")), prefix); | ||
} | ||
} catch (IOException e) { | ||
logger.error("[!] Exception while loading/parsing " + this.url, e); | ||
} | ||
} | ||
|
||
private Document getLargestImagePageDocument(URL url) throws IOException { | ||
// Get current page | ||
Document doc = Jsoup.connect(url.toExternalForm()) | ||
.userAgent(USER_AGENT) | ||
.get(); | ||
// Look for larger image page | ||
String largestImagePage = this.url.toExternalForm(); | ||
for (Element olSize : doc.select("ol.sizes-list > li > ol > li")) { | ||
Elements ola = olSize.select("a"); | ||
if (ola.size() == 0) { | ||
largestImagePage = this.url.toExternalForm(); | ||
} | ||
else { | ||
String candImage = ola.get(0).attr("href"); | ||
if (candImage.startsWith("/")) { | ||
candImage = "http://www.flickr.com" + candImage; | ||
} | ||
largestImagePage = candImage; | ||
} | ||
} | ||
if (!largestImagePage.equals(this.url.toExternalForm())) { | ||
// Found larger image page, get it. | ||
doc = Jsoup.connect(largestImagePage) | ||
.userAgent(USER_AGENT) | ||
.get(); | ||
} | ||
return doc; | ||
} | ||
} | ||
} |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters