[pixiv] add user-favorite extractor
This commit is contained in:
@@ -28,6 +28,7 @@ class PixivUserExtractor(Extractor):
|
|||||||
Extractor.__init__(self)
|
Extractor.__init__(self)
|
||||||
self.artist_id = match.group(1)
|
self.artist_id = match.group(1)
|
||||||
self.api = PixivAPI(self.session)
|
self.api = PixivAPI(self.session)
|
||||||
|
self.api_call = self.api.user_works
|
||||||
|
|
||||||
def items(self):
|
def items(self):
|
||||||
metadata = self.get_job_metadata()
|
metadata = self.get_job_metadata()
|
||||||
@@ -37,8 +38,6 @@ class PixivUserExtractor(Extractor):
|
|||||||
yield Message.Directory, metadata
|
yield Message.Directory, metadata
|
||||||
|
|
||||||
for work in self.get_works():
|
for work in self.get_works():
|
||||||
work.update(metadata)
|
|
||||||
|
|
||||||
pos = work["extension"].rfind("?", -18)
|
pos = work["extension"].rfind("?", -18)
|
||||||
if pos != -1:
|
if pos != -1:
|
||||||
timestamp = work["extension"][pos:]
|
timestamp = work["extension"][pos:]
|
||||||
@@ -49,7 +48,7 @@ class PixivUserExtractor(Extractor):
|
|||||||
if work["type"] == "ugoira":
|
if work["type"] == "ugoira":
|
||||||
url, framelist = self.parse_ugoira(work)
|
url, framelist = self.parse_ugoira(work)
|
||||||
work["extension"] = "zip"
|
work["extension"] = "zip"
|
||||||
yield Message.Url, url, work.copy()
|
yield Message.Url, url, work
|
||||||
work["extension"] = "txt"
|
work["extension"] = "txt"
|
||||||
yield Message.Url, "text://"+framelist, work
|
yield Message.Url, "text://"+framelist, work
|
||||||
|
|
||||||
@@ -69,24 +68,33 @@ class PixivUserExtractor(Extractor):
|
|||||||
for i in range(work["page_count"]):
|
for i in range(work["page_count"]):
|
||||||
work["num"] = "_p{:02}".format(i)
|
work["num"] = "_p{:02}".format(i)
|
||||||
url = "{}{}_p{}.{}{}".format(url[:off], big, i, ext, timestamp)
|
url = "{}{}_p{}.{}{}".format(url[:off], big, i, ext, timestamp)
|
||||||
yield Message.Url, url, work.copy()
|
yield Message.Url, url, work
|
||||||
|
|
||||||
def get_works(self):
|
def get_works(self):
|
||||||
"""Yield all work-items for a pixiv-member"""
|
"""Yield all work-items for a pixiv-member"""
|
||||||
pagenum = 1
|
pagenum = 1
|
||||||
while True:
|
while True:
|
||||||
data = self.api.user_works(self.artist_id, pagenum)
|
data = self.api_call(self.artist_id, pagenum)
|
||||||
for work in data["response"]:
|
for work in data["response"]:
|
||||||
url = work["image_urls"]["large"]
|
yield self.prepare_work(work)
|
||||||
work["num"] = ""
|
|
||||||
work["url"] = url
|
|
||||||
work["extension"] = url[url.rfind(".")+1:]
|
|
||||||
yield work
|
|
||||||
pinfo = data["pagination"]
|
pinfo = data["pagination"]
|
||||||
if pinfo["current"] == pinfo["pages"]:
|
if pinfo["current"] == pinfo["pages"]:
|
||||||
return
|
return
|
||||||
pagenum = pinfo["next"]
|
pagenum = pinfo["next"]
|
||||||
|
|
||||||
|
def prepare_work(self, work):
|
||||||
|
"""Prepare a work-dictionary with additional keywords"""
|
||||||
|
user = work["user"]
|
||||||
|
url = work["image_urls"]["large"]
|
||||||
|
work["category"] = self.category
|
||||||
|
work["artist-id"] = user["id"]
|
||||||
|
work["artist-name"] = user["name"]
|
||||||
|
work["artist-nick"] = user["account"]
|
||||||
|
work["num"] = ""
|
||||||
|
work["url"] = url
|
||||||
|
work["extension"] = url[url.rfind(".")+1:]
|
||||||
|
return work
|
||||||
|
|
||||||
def parse_ugoira(self, data):
|
def parse_ugoira(self, data):
|
||||||
"""Parse ugoira data"""
|
"""Parse ugoira data"""
|
||||||
# get illust page
|
# get illust page
|
||||||
@@ -135,18 +143,28 @@ class PixivWorkExtractor(PixivUserExtractor):
|
|||||||
self.work = None
|
self.work = None
|
||||||
|
|
||||||
def get_works(self):
|
def get_works(self):
|
||||||
url = self.work["image_urls"]["large"]
|
return (self.prepare_work(self.work),)
|
||||||
self.work["num"] = ""
|
|
||||||
self.work["url"] = url
|
|
||||||
self.work["extension"] = url[url.rfind(".")+1:]
|
|
||||||
return (self.work,)
|
|
||||||
|
|
||||||
def get_job_metadata(self):
|
def get_job_metadata(self, user=None):
|
||||||
"""Collect metadata for extractor-job"""
|
"""Collect metadata for extractor-job"""
|
||||||
self.work = self.api.work(self.illust_id)["response"][0]
|
self.work = self.api.work(self.illust_id)["response"][0]
|
||||||
return PixivUserExtractor.get_job_metadata(self, self.work["user"])
|
return PixivUserExtractor.get_job_metadata(self, self.work["user"])
|
||||||
|
|
||||||
|
|
||||||
|
class PixivFavoriteExtractor(PixivUserExtractor):
|
||||||
|
"""Extract all favorites/bookmarks of a single pixiv-user"""
|
||||||
|
|
||||||
|
directory_fmt = ["{category}", "bookmarks", "{artist-id}-{artist-nick}"]
|
||||||
|
pattern = [r"(?:https?://)?(?:www\.)?pixiv\.net/bookmark\.php\?id=(\d+)"]
|
||||||
|
|
||||||
|
def __init__(self, match):
|
||||||
|
PixivUserExtractor.__init__(self, match)
|
||||||
|
self.api_call = self.api.user_favorite_works
|
||||||
|
|
||||||
|
def prepare_work(self, work):
|
||||||
|
return PixivUserExtractor.prepare_work(self, work["work"])
|
||||||
|
|
||||||
|
|
||||||
def require_login(func):
|
def require_login(func):
|
||||||
"""Decorator: auto-login before api-calls"""
|
"""Decorator: auto-login before api-calls"""
|
||||||
def wrap(self, *args):
|
def wrap(self, *args):
|
||||||
@@ -223,7 +241,7 @@ class PixivAPI():
|
|||||||
def work(self, illust_id):
|
def work(self, illust_id):
|
||||||
"""Query information about a single pixiv work/illustration"""
|
"""Query information about a single pixiv work/illustration"""
|
||||||
params = {
|
params = {
|
||||||
'image_sizes': 'large',
|
"image_sizes": "large",
|
||||||
}
|
}
|
||||||
response = self.session.get(
|
response = self.session.get(
|
||||||
"https://public-api.secure.pixiv.net/v1/works/"
|
"https://public-api.secure.pixiv.net/v1/works/"
|
||||||
@@ -235,9 +253,9 @@ class PixivAPI():
|
|||||||
def user_works(self, user_id, page, per_page=20):
|
def user_works(self, user_id, page, per_page=20):
|
||||||
"""Query information about the works of a pixiv user"""
|
"""Query information about the works of a pixiv user"""
|
||||||
params = {
|
params = {
|
||||||
'page': page,
|
"page": page,
|
||||||
'per_page': per_page,
|
"per_page": per_page,
|
||||||
'image_sizes': 'large',
|
"image_sizes": "large",
|
||||||
}
|
}
|
||||||
response = self.session.get(
|
response = self.session.get(
|
||||||
"https://public-api.secure.pixiv.net/v1/users/"
|
"https://public-api.secure.pixiv.net/v1/users/"
|
||||||
@@ -245,6 +263,21 @@ class PixivAPI():
|
|||||||
)
|
)
|
||||||
return self._parse(response)
|
return self._parse(response)
|
||||||
|
|
||||||
|
@require_login
|
||||||
|
def user_favorite_works(self, user_id, page, per_page=20):
|
||||||
|
"""Query information about the favorites works of a pixiv user"""
|
||||||
|
params = {
|
||||||
|
"page": page,
|
||||||
|
"per_page": per_page,
|
||||||
|
"include_stats": False,
|
||||||
|
"image_sizes": "large",
|
||||||
|
}
|
||||||
|
response = self.session.get(
|
||||||
|
"https://public-api.secure.pixiv.net/v1/users/"
|
||||||
|
"{user}/favorite_works.json".format(user=user_id), params=params
|
||||||
|
)
|
||||||
|
return self._parse(response)
|
||||||
|
|
||||||
@staticmethod
|
@staticmethod
|
||||||
def _parse(response):
|
def _parse(response):
|
||||||
"""Parse a Pixiv Public-API response"""
|
"""Parse a Pixiv Public-API response"""
|
||||||
|
|||||||
Reference in New Issue
Block a user