# coding: utf-8
import sys, re, threading, socket, urllib.parse, http.server, socketserver
import requests
from base.spider import Spider
from requests.adapters import HTTPAdapter
from requests.packages.urllib3.util.retry import Retry
try:
from requests.packages import urllib3
urllib3.disable_warnings()
except: pass
class ThreadedHTTPServer(socketserver.ThreadingMixIn, http.server.HTTPServer):
daemon_threads = True
class SlideshowHandler(http.server.BaseHTTPRequestHandler):
def log_message(self, format, *args): pass
def log_error(self, format, *args): pass
def do_GET(self):
spider = getattr(self.server, 'spider', None)
if not spider: return
try:
path_info = urllib.parse.urlparse(self.path)
path, query = path_info.path, urllib.parse.parse_qs(path_info.query)
if path == '/gallery.html': self._handle_gallery(spider, query)
elif path == '/image': self._handle_image(spider, query)
else: self.send_error(404)
except: self.send_error(500)
def _handle_gallery(self, spider, query):
try:
cache_key = query.get('id', [''])[0]
images = spider.post_image_cache.get(cache_key, [])
if not images:
self.send_response(200); self.end_headers()
self.wfile.write(b"Loading...
")
return
img_tags = [f'' for url in images]
html = f"""{"".join(img_tags)}
"""
self.send_response(200); self.send_header('Content-type', 'text/html; charset=utf-8'); self.end_headers()
self.wfile.write(html.encode('utf-8'))
except: pass
def _handle_image(self, spider, query):
try:
target = query.get('url', [''])[0]
if not target: return self.send_error(400)
headers = {'User-Agent': spider.headers['User-Agent']}
with requests.get(target, headers=headers, proxies=spider.proxies, stream=True, verify=False, timeout=30) as resp:
if resp.status_code == 200:
self.send_response(resp.status_code)
self.send_header('Content-Type', resp.headers.get('Content-Type', 'image/jpeg'))
self.send_header('Cache-Control', 'max-age=86400')
self.end_headers()
for chunk in resp.iter_content(chunk_size=65536):
if chunk: self.wfile.write(chunk)
else: self.send_error(resp.status_code)
except: self.send_error(404)
class Spider(Spider):
server = None
server_port = 0
creators_cache = []
post_image_cache = {}
img_pattern = re.compile(r'src=["\']([^"\']+)["\']')
img_exts = {'jpg', 'jpeg', 'png', 'gif', 'webp', 'bmp', 'avif'}
vid_exts = {'mp4', 'mkv', 'mov', 'webm', 'm4v', 'avi', 'flv'}
def getName(self): return "Kemono"
def init(self, extend=""):
try:
super().init(extend)
self.base_url = "https://kemono.cr"
self.api_url = "https://kemono.cr/api/v1"
self.img_base = "https://kemono.cr/data"
self.proxies = {'http': 'http://127.0.0.1:7890', 'https': 'http://127.0.0.1:7890'}
self.session = requests.Session()
self.session.proxies.update(self.proxies)
retries = Retry(total=3, backoff_factor=0.1, status_forcelist=[500, 502, 503, 504])
adapter = HTTPAdapter(pool_connections=20, pool_maxsize=20, max_retries=retries)
self.session.mount('https://', adapter); self.session.mount('http://', adapter)
self.headers = {'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36', 'Referer': f"{self.base_url}/", 'Accept': 'text/css,*/*;q=0.1', 'Accept-Language': 'en-US,en;q=0.9', 'Connection': 'keep-alive'}
self.session.headers.update(self.headers)
self._start_server()
except: pass
def destroy(self):
if self.server:
try: self.server.shutdown(); self.server.server_close()
except: pass
self.server = None
if hasattr(self, 'session'): self.session.close()
def _start_server(self):
if self.server: return
try:
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
sock.bind(('0.0.0.0', 0)); self.server_port = sock.getsockname()[1]; sock.close()
self.server = ThreadedHTTPServer(('0.0.0.0', self.server_port), SlideshowHandler)
self.server.spider = self
t = threading.Thread(target=self.server.serve_forever); t.daemon = True; t.start()
except: pass
def fetch(self, url, headers=None, is_api=False):
try:
req_headers = headers or self.headers
if is_api or '/api/' in url: req_headers['Accept'] = 'text/css'
return self.session.get(url, headers=req_headers, timeout=30, verify=False)
except: return None
def _proxify_url(self, target):
if not target: return ""
if target.startswith('//'): target = 'https:' + target
return f"http://127.0.0.1:{self.server_port}/image?url={urllib.parse.quote(target)}"
def homeContent(self, filter):
services = [{"type_name": n, "type_id": i} for n, i in [("Patreon", "patreon"), ("Pixiv Fanbox", "fanbox"), ("Fantia", "fantia"), ("Discord", "discord"), ("Gumroad", "gumroad"), ("SubscribeStar", "subscribestar"), ("Afdian", "afdian"), ("Boosty", "boosty"), ("DLsite", "dlsite")]]
if not self.creators_cache: threading.Thread(target=self._load_creators_task).start()
return {'class': services}
def _load_creators_task(self):
try:
resp = self.fetch(f"{self.api_url}/creators", is_api=True)
if resp and resp.status_code == 200: self.creators_cache = resp.json()
except: pass
def categoryContent(self, tid, pg, filter, extend):
pg = int(pg)
if tid.startswith('post###'): return self._handle_image_popup_safely(tid)
elif tid.startswith('creator###'): return self._get_post_list(tid, pg)
else: return self._get_creator_list(tid, pg)
def _get_creator_list(self, service_id, pg):
limit = 20
if not self.creators_cache:
self._load_creators_task()
if not self.creators_cache: return {'list': [{'vod_id': 'err', 'vod_name': 'Loading...', 'vod_pic': ''}]}
filtered = [c for c in self.creators_cache if c.get('service') == service_id]
filtered.sort(key=lambda x: x.get('favorited', 0), reverse=True)
total = len(filtered); start, end = (pg - 1) * limit, pg * limit
style = {"type": "list", "ratio": "1.1"}
icon_prefix = f"https://img.kemono.cr/icons/{service_id}/"
vlist = [{'vod_id': f"creator###{service_id}###{item['id']}", 'vod_name': item.get('name'), 'vod_pic': self._proxify_url(icon_prefix + item['id']), 'vod_tag': 'folder', 'vod_remarks': f"♥ {item.get('favorited', 0)}", "style": style} for item in filtered[start:end]]
return {'list': vlist, 'page': pg, 'pagecount': (total + limit - 1) // limit + 1, 'limit': limit, 'total': total}
def _get_post_list(self, tid, pg):
try:
_, service, user_id = tid.split('###')
resp = self.fetch(f"{self.api_url}/{service}/user/{user_id}/posts?o={(pg - 1) * 50}", is_api=True)
vlist = []
if resp and resp.status_code == 200:
for post in resp.json():
files = [post.get('file', {})] + post.get('attachments', [])
cover_path = next((f.get('path') for f in files if f.get('path') and f['path'].split('.')[-1].lower() in self.img_exts), None)
cover = f"https://img.kemono.cr/thumbnail/data{cover_path}" if cover_path else "https://kemono.cr/static/kemono-logo.svg"
has_video = bool(post.get('videos'))
if not has_video: has_video = any(f.get('path', '').split('.')[-1].lower() in self.vid_exts for f in files)
style = {"type": "list", "ratio": "1.1"}
vlist.append({'vod_id': f"{'video' if has_video else 'post'}###{service}###{user_id}###{post.get('id')}", 'vod_name': post.get('title', 'Untitled'), 'vod_pic': self._proxify_url(cover), 'vod_remarks': '▶ Video' if has_video else post.get('published', '')[:10], 'vod_tag': 'folder' if not has_video else '', 'style': style})
return {'list': vlist, 'page': pg, 'pagecount': pg + 1 if len(vlist) >= 50 else pg, 'limit': 50, 'total': 99999}
except: return {'list': []}
def detailContent(self, ids):
try:
tid = ids[0]
if not tid.startswith('video###'): return {'list': []}
_, service, user_id, post_id = tid.split('###')
resp = self.fetch(f"{self.api_url}/{service}/user/{user_id}/post/{post_id}", is_api=True)
if not resp or resp.status_code != 200: return {'list': []}
data = resp.json(); post = data.get('post', data); play_list = []
if post.get('videos'):
for v in post['videos']:
if v.get('path'):
base = v.get('server', '') or ''; path = v.get('path', '')
if not path.startswith('/data'): path = '/data' + path
play_list.append(f"{v.get('name', 'Video')}${base}{path}")
if not play_list:
for idx, f in enumerate([post.get('file')] + post.get('attachments', [])):
if f and f.get('path') and f['path'].split('.')[-1].lower() in self.vid_exts:
full_url = self.img_base + f['path'] if not f['path'].startswith('http') else f['path']
play_list.append(f"{f.get('name', f'Part {idx+1}')}${full_url}")
files = [post.get('file', {})]
first_img = next((f.get('path') for f in files if f.get('path') and f['path'].split('.')[-1].lower() in self.img_exts), None)
pic = self._proxify_url(f"https://img.kemono.cr/thumbnail/data{first_img}") if first_img else ""
vod = {"vod_id": tid, "vod_name": post.get('title', 'Untitled'), "vod_pic": pic, "type_name": service, "vod_year": post.get('published', '')[:4], "vod_pubdate": post.get('published', '')[:10], "vod_area": "Kemono", "vod_remarks": f"♥ {post.get('favorited', 0)}", "vod_content": re.sub(r'<[^>]+>', '', post.get('content', '')).strip()[:500], "vod_play_from": "KemonoPlayer", "vod_play_url": "#".join(play_list) if play_list else "No Video$http://127.0.0.1/"}
return {"list": [vod]}
except: return {'list': []}
def playerContent(self, flag, id, vipFlags):
return {'parse': 0, 'url': id, 'header': {'User-Agent': self.headers['User-Agent']}}
def searchContent(self, key, quick, pg=1):
if not self.creators_cache: self._load_creators_task()
pg, limit = int(pg), 20; key_lower = key.lower()
results = [c for c in self.creators_cache if key_lower in c.get('name', '').lower()]
results.sort(key=lambda x: x.get('favorited', 0), reverse=True)
start, end = (pg - 1) * limit, pg * limit
style = {"type": "list", "ratio": "1.1"}
vlist = [{'vod_id': f"creator###{item['service']}###{item['id']}", 'vod_name': item['name'], 'vod_pic': self._proxify_url(f"https://img.kemono.cr/icons/{item['service']}/{item['id']}"), 'vod_tag': 'folder', 'vod_remarks': item['service'], "style": style} for item in results[start:end]]
return {'list': vlist, 'page': pg, 'pagecount': (len(results) + limit - 1) // limit + 1, 'limit': limit, 'total': len(results)}
def _handle_image_popup_safely(self, tid):
def load_images_and_show():
try:
_, service, user_id, post_id = tid.split('###')
resp = self.fetch(f"{self.api_url}/{service}/user/{user_id}/post/{post_id}", is_api=True)
if not resp or resp.status_code != 200: return
data = resp.json(); post = data.get('post', data); image_urls = []
for f in [post.get('file')] + post.get('attachments', []):
if f and f.get('path') and f['path'].split('.')[-1].lower() in self.img_exts:
image_urls.append(self.img_base + f['path'] if not f['path'].startswith('http') else f['path'])
if post.get('content'):
for img_url in self.img_pattern.findall(post['content']):
if img_url.split('.')[-1].lower() in self.img_exts:
if img_url.startswith('//'): img_url = 'https:' + img_url
elif img_url.startswith('/'): img_url = self.base_url + img_url
image_urls.append(img_url)
if not image_urls: return
seen = set(); proxied_urls = []
for u in image_urls:
if u not in seen: proxied_urls.append(self._proxify_url(u)); seen.add(u)
cache_key = f"{service}_{user_id}_{post_id}"
self.post_image_cache[cache_key] = proxied_urls
self._show_popup_dialog(cache_key)
except: pass
threading.Thread(target=load_images_and_show).start()
return {'list': [{'vod_id': 'ignore', 'vod_name': 'Gallery Loading...', 'vod_pic': '', 'vod_remarks': 'View'}], 'page': 1, 'pagecount': 1, 'limit': 1, 'total': 1}
def _show_popup_dialog(self, cache_key):
def launch_popup():
try:
from java import jclass, dynamic_proxy
from java.lang import Runnable
JClass = jclass("java.lang.Class")
AT = JClass.forName("android.app.ActivityThread")
currentAT = AT.getMethod("currentActivityThread").invoke(None)
mActivities = AT.getDeclaredField("mActivities"); mActivities.setAccessible(True)
values = mActivities.get(currentAT).values()
try: records = values.toArray()
except: records = values.getClass().getMethod("toArray").invoke(values)
act = None
for record in records:
try:
recordClass = record.getClass(); pausedField = recordClass.getDeclaredField("paused"); pausedField.setAccessible(True)
if not pausedField.getBoolean(record):
activityField = recordClass.getDeclaredField("activity"); activityField.setAccessible(True); act = activityField.get(record); break
except: continue
if not act: return
class UiRunner(dynamic_proxy(Runnable)):
def __init__(self, func): super().__init__(); self.func = func
def run(self):
try: self.func()
except: pass
def show_dialog():
try:
Dialog = jclass("android.app.Dialog"); WebView = jclass("android.webkit.WebView"); ColorDrawable = jclass("android.graphics.drawable.ColorDrawable"); Color = jclass("android.graphics.Color")
d = Dialog(act); d.requestWindowFeature(1); win = d.getWindow(); win.getDecorView().setPadding(0, 0, 0, 0); win.setBackgroundDrawable(ColorDrawable(Color.BLACK)); win.setLayout(-1, -1)
w = WebView(act); ws = w.getSettings(); ws.setJavaScriptEnabled(True); ws.setDomStorageEnabled(True); w.setBackgroundColor(Color.BLACK)
w.loadUrl(f"http://127.0.0.1:{self.server_port}/gallery.html?id={cache_key}"); d.setContentView(w); d.show()
except: pass
act.getWindow().getDecorView().post(UiRunner(show_dialog))
except: pass
threading.Thread(target=launch_popup).start()