rewrite parts of the cloudflare bypass system
This commit is contained in:
@@ -14,32 +14,28 @@ import urllib.parse
|
|||||||
from . import text
|
from . import text
|
||||||
from .cache import cache
|
from .cache import cache
|
||||||
|
|
||||||
def bypass(url, maxage):
|
def request_func(self, *args):
|
||||||
def decorator(func):
|
cookies = _cookiecache(self.root)
|
||||||
solve = cache(maxage=maxage, keyarg=1)(solve_challenge)
|
if cookies:
|
||||||
def wrap(self, *args):
|
self.session.cookies = cookies
|
||||||
self.session.cookies = solve(self.session, url)
|
response = self.session.get(*args)
|
||||||
return func(self, *args)
|
if response.status_code != 200:
|
||||||
return wrap
|
_cookiecache.invalidate(self.root)
|
||||||
return decorator
|
response = solve_challenge(self.session, response)
|
||||||
|
_cookiecache(self.root, self.session.cookies)
|
||||||
|
return response
|
||||||
|
|
||||||
def bypass_ddos_protection(session, url):
|
def solve_challenge(session, response):
|
||||||
"""Prepare a requests.session to access 'url' behind Cloudflare protection"""
|
session.headers["Referer"] = response.url
|
||||||
session.cookies = solve_challenge(session, url)
|
page = response.text
|
||||||
return session
|
|
||||||
|
|
||||||
def solve_challenge(session, url):
|
|
||||||
session.headers["Referer"] = url
|
|
||||||
page = session.get(url).text
|
|
||||||
params = text.extract_all(page, (
|
params = text.extract_all(page, (
|
||||||
('jschl_vc', 'name="jschl_vc" value="', '"'),
|
('jschl_vc', 'name="jschl_vc" value="', '"'),
|
||||||
('pass' , 'name="pass" value="', '"'),
|
('pass' , 'name="pass" value="', '"'),
|
||||||
))[0]
|
))[0]
|
||||||
params["jschl_answer"] = solve_jschl(url, page)
|
params["jschl_answer"] = solve_jschl(response.url, page)
|
||||||
time.sleep(4)
|
time.sleep(4)
|
||||||
url = urllib.parse.urljoin(url, "/cdn-cgi/l/chk_jschl")
|
url = urllib.parse.urljoin(response.url, "/cdn-cgi/l/chk_jschl")
|
||||||
session.get(url, params=params)
|
return session.get(url, params=params)
|
||||||
return session.cookies
|
|
||||||
|
|
||||||
def solve_jschl(url, page):
|
def solve_jschl(url, page):
|
||||||
"""Solve challenge to get 'jschl_answer' value"""
|
"""Solve challenge to get 'jschl_answer' value"""
|
||||||
@@ -91,3 +87,7 @@ expression_values = {
|
|||||||
"!+": 1,
|
"!+": 1,
|
||||||
"+!!": 1,
|
"+!!": 1,
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@cache(maxage=365*24*60*60, keyarg=0)
|
||||||
|
def _cookiecache(key, item=None):
|
||||||
|
return item
|
||||||
|
|||||||
@@ -8,36 +8,19 @@
|
|||||||
|
|
||||||
"""Extract comic-issues and entire comics from http://kisscomic.us/"""
|
"""Extract comic-issues and entire comics from http://kisscomic.us/"""
|
||||||
|
|
||||||
from .common import Extractor, Message
|
from . import kissmanga
|
||||||
from .. import text, cloudflare, cache
|
from .. import text
|
||||||
import re
|
|
||||||
|
|
||||||
class KisscomicExtractor(Extractor):
|
class KisscomicExtractor(kissmanga.KissmangaExtractor):
|
||||||
"""Base class for kisscomic extractors"""
|
"""Base class for kisscomic extractors"""
|
||||||
category = "kisscomic"
|
category = "kisscomic"
|
||||||
directory_fmt = ["{category}", "{comic}", "{issue:>03}"]
|
directory_fmt = ["{category}", "{comic}", "{issue:>03}"]
|
||||||
filename_fmt = "{comic}_{issue:>03}_{page:>03}.{extension}"
|
filename_fmt = "{comic}_{issue:>03}_{page:>03}.{extension}"
|
||||||
url_base = "http://kisscomic.us"
|
root = "http://kisscomic.us"
|
||||||
|
|
||||||
def __init__(self, match):
|
|
||||||
Extractor.__init__(self)
|
|
||||||
self.url = match.group(0)
|
|
||||||
self.session.headers["Referer"] = self.url_base
|
|
||||||
self.cookies = cache.cache(maxage=365*24*60*60, keyarg=0)(_cache_helper)
|
|
||||||
|
|
||||||
def request(self, url, cookies=None):
|
|
||||||
cookies = self.cookies(self.url_base, cookies)
|
|
||||||
if cookies:
|
|
||||||
self.session.cookies = cookies
|
|
||||||
response = self.session.get(url)
|
|
||||||
if response.status_code != 200:
|
|
||||||
self.cookies.invalidate(self.url_base)
|
|
||||||
cookies = cloudflare.solve_challenge(self.session, self.url_base)
|
|
||||||
response = self.request(url, cookies)
|
|
||||||
return response
|
|
||||||
|
|
||||||
|
|
||||||
class KisscomicMangaExtractor(KisscomicExtractor):
|
class KisscomicMangaExtractor(KisscomicExtractor,
|
||||||
|
kissmanga.KissmangaMangaExtractor):
|
||||||
"""Extractor for comics from kisscomic.us"""
|
"""Extractor for comics from kisscomic.us"""
|
||||||
subcategory = "comic"
|
subcategory = "comic"
|
||||||
pattern = [r"(?:https?://)?(?:www\.)?kisscomic\.us/comics/[^/]+\.html$"]
|
pattern = [r"(?:https?://)?(?:www\.)?kisscomic\.us/comics/[^/]+\.html$"]
|
||||||
@@ -45,11 +28,6 @@ class KisscomicMangaExtractor(KisscomicExtractor):
|
|||||||
"url": "8c180e2ec2492712b089ca091c54909cb0fe3d4a",
|
"url": "8c180e2ec2492712b089ca091c54909cb0fe3d4a",
|
||||||
})]
|
})]
|
||||||
|
|
||||||
def items(self):
|
|
||||||
yield Message.Version, 1
|
|
||||||
for chapter in self.get_chapters():
|
|
||||||
yield Message.Queue, self.url_base + chapter
|
|
||||||
|
|
||||||
def get_chapters(self):
|
def get_chapters(self):
|
||||||
"""Return a list of all chapter urls"""
|
"""Return a list of all chapter urls"""
|
||||||
page = self.request(self.url).text
|
page = self.request(self.url).text
|
||||||
@@ -59,7 +37,8 @@ class KisscomicMangaExtractor(KisscomicExtractor):
|
|||||||
))
|
))
|
||||||
|
|
||||||
|
|
||||||
class KisscomicIssueExtractor(KisscomicExtractor):
|
class KisscomicIssueExtractor(KisscomicExtractor,
|
||||||
|
kissmanga.KissmangaChapterExtractor):
|
||||||
"""Extractor for comic-issues from kisscomic.us"""
|
"""Extractor for comic-issues from kisscomic.us"""
|
||||||
subcategory = "issue"
|
subcategory = "issue"
|
||||||
pattern = [r"(?:https?://)?(?:www\.)?kisscomic\.us/chapters/.+-chapter-\d+\.html"]
|
pattern = [r"(?:https?://)?(?:www\.)?kisscomic\.us/chapters/.+-chapter-\d+\.html"]
|
||||||
@@ -68,16 +47,6 @@ class KisscomicIssueExtractor(KisscomicExtractor):
|
|||||||
"keyword": "a685f92b6989eebf57f8981b1edd6d3de9148ad6",
|
"keyword": "a685f92b6989eebf57f8981b1edd6d3de9148ad6",
|
||||||
})]
|
})]
|
||||||
|
|
||||||
def items(self):
|
|
||||||
page = self.request(self.url).text
|
|
||||||
data = self.get_job_metadata(page)
|
|
||||||
imgs = self.get_image_urls(page)
|
|
||||||
data["count"] = len(imgs)
|
|
||||||
yield Message.Version, 1
|
|
||||||
yield Message.Directory, data
|
|
||||||
for data["page"], url in enumerate(imgs, 1):
|
|
||||||
yield Message.Url, url, text.nameext_from_url(url, data)
|
|
||||||
|
|
||||||
def get_job_metadata(self, page):
|
def get_job_metadata(self, page):
|
||||||
"""Collect metadata for extractor-job"""
|
"""Collect metadata for extractor-job"""
|
||||||
info = text.extract(page, "<title>", " Comic - Read ")[0]
|
info = text.extract(page, "<title>", " Comic - Read ")[0]
|
||||||
@@ -93,7 +62,3 @@ class KisscomicIssueExtractor(KisscomicExtractor):
|
|||||||
def get_image_urls(page):
|
def get_image_urls(page):
|
||||||
"""Extract list of all image-urls for a manga chapter"""
|
"""Extract list of all image-urls for a manga chapter"""
|
||||||
return list(text.extract_iter(page, '<li><img src="', '"'))
|
return list(text.extract_iter(page, '<li><img src="', '"'))
|
||||||
|
|
||||||
|
|
||||||
def _cache_helper(key, item=None):
|
|
||||||
return item
|
|
||||||
|
|||||||
@@ -9,7 +9,7 @@
|
|||||||
"""Extract manga-chapters and entire manga from http://kissmanga.com/"""
|
"""Extract manga-chapters and entire manga from http://kissmanga.com/"""
|
||||||
|
|
||||||
from .common import Extractor, Message
|
from .common import Extractor, Message
|
||||||
from .. import text, cloudflare, cache
|
from .. import text, cloudflare
|
||||||
import re
|
import re
|
||||||
|
|
||||||
class KissmangaExtractor(Extractor):
|
class KissmangaExtractor(Extractor):
|
||||||
@@ -17,24 +17,14 @@ class KissmangaExtractor(Extractor):
|
|||||||
category = "kissmanga"
|
category = "kissmanga"
|
||||||
directory_fmt = ["{category}", "{manga}", "c{chapter:>03}{chapter-minor} - {title}"]
|
directory_fmt = ["{category}", "{manga}", "c{chapter:>03}{chapter-minor} - {title}"]
|
||||||
filename_fmt = "{manga}_c{chapter:>03}{chapter-minor}_{page:>03}.{extension}"
|
filename_fmt = "{manga}_c{chapter:>03}{chapter-minor}_{page:>03}.{extension}"
|
||||||
url_base = "http://kissmanga.com"
|
root = "http://kissmanga.com"
|
||||||
|
|
||||||
def __init__(self, match):
|
def __init__(self, match):
|
||||||
Extractor.__init__(self)
|
Extractor.__init__(self)
|
||||||
self.url = match.group(0)
|
self.url = match.group(0)
|
||||||
self.session.headers["Referer"] = self.url_base
|
self.session.headers["Referer"] = self.root
|
||||||
self.cookies = cache.cache(maxage=365*24*60*60, keyarg=0)(_cache_helper)
|
|
||||||
|
|
||||||
def request(self, url, cookies=None):
|
request = cloudflare.request_func
|
||||||
cookies = self.cookies(self.url_base, cookies)
|
|
||||||
if cookies:
|
|
||||||
self.session.cookies = cookies
|
|
||||||
response = self.session.get(url)
|
|
||||||
if response.status_code != 200:
|
|
||||||
self.cookies.invalidate(self.url_base)
|
|
||||||
cookies = cloudflare.solve_challenge(self.session, self.url_base)
|
|
||||||
response = self.request(url, cookies)
|
|
||||||
return response
|
|
||||||
|
|
||||||
|
|
||||||
class KissmangaMangaExtractor(KissmangaExtractor):
|
class KissmangaMangaExtractor(KissmangaExtractor):
|
||||||
@@ -48,7 +38,7 @@ class KissmangaMangaExtractor(KissmangaExtractor):
|
|||||||
def items(self):
|
def items(self):
|
||||||
yield Message.Version, 1
|
yield Message.Version, 1
|
||||||
for chapter in self.get_chapters():
|
for chapter in self.get_chapters():
|
||||||
yield Message.Queue, self.url_base + chapter
|
yield Message.Queue, self.root + chapter
|
||||||
|
|
||||||
def get_chapters(self):
|
def get_chapters(self):
|
||||||
"""Return a list of all chapter urls"""
|
"""Return a list of all chapter urls"""
|
||||||
@@ -104,7 +94,3 @@ class KissmangaChapterExtractor(KissmangaExtractor):
|
|||||||
def get_image_urls(page):
|
def get_image_urls(page):
|
||||||
"""Extract list of all image-urls for a manga chapter"""
|
"""Extract list of all image-urls for a manga chapter"""
|
||||||
return list(text.extract_iter(page, 'lstImages.push("', '"'))
|
return list(text.extract_iter(page, 'lstImages.push("', '"'))
|
||||||
|
|
||||||
|
|
||||||
def _cache_helper(key, item=None):
|
|
||||||
return item
|
|
||||||
|
|||||||
@@ -8,8 +8,8 @@
|
|||||||
|
|
||||||
"""Extract comic-issues and entire comics from http://readcomiconline.to/"""
|
"""Extract comic-issues and entire comics from http://readcomiconline.to/"""
|
||||||
|
|
||||||
from .. import text
|
|
||||||
from . import kissmanga
|
from . import kissmanga
|
||||||
|
from .. import text
|
||||||
import re
|
import re
|
||||||
|
|
||||||
class ReadcomiconlineExtractor(kissmanga.KissmangaExtractor):
|
class ReadcomiconlineExtractor(kissmanga.KissmangaExtractor):
|
||||||
@@ -17,7 +17,7 @@ class ReadcomiconlineExtractor(kissmanga.KissmangaExtractor):
|
|||||||
category = "readcomiconline"
|
category = "readcomiconline"
|
||||||
directory_fmt = ["{category}", "{comic}", "{issue:>03}"]
|
directory_fmt = ["{category}", "{comic}", "{issue:>03}"]
|
||||||
filename_fmt = "{comic}_{issue:>03}_{page:>03}.{extension}"
|
filename_fmt = "{comic}_{issue:>03}_{page:>03}.{extension}"
|
||||||
url_base = "http://readcomiconline.to"
|
root = "http://readcomiconline.to"
|
||||||
|
|
||||||
|
|
||||||
class ReadcomiconlineComicExtractor(ReadcomiconlineExtractor,
|
class ReadcomiconlineComicExtractor(ReadcomiconlineExtractor,
|
||||||
|
|||||||
Reference in New Issue
Block a user