1 files changed, 101 insertions, 0 deletions
diff --git a/gallery_dl/extractor/kemonoparty.py b/gallery_dl/extractor/kemonoparty.py
new file mode 100644
index 0000000..a5b5e00
--- /dev/null
+++ b/gallery_dl/extractor/kemonoparty.py
@@ -0,0 +1,101 @@
+# -*- coding: utf-8 -*-
+
+# Copyright 2021 Mike Fährmann
+#
+# This program is free software; you can redistribute it and/or modify
+# it under the terms of the GNU General Public License version 2 as
+# published by the Free Software Foundation.
+
+"""Extractors for https://kemono.party/"""
+
+from .common import Extractor, Message
+from .. import text
+
+
+class KemonopartyExtractor(Extractor):
+    """Base class for kemonoparty extractors"""
+    category = "kemonoparty"
+    root = "https://kemono.party"
+    directory_fmt = ("{category}", "{user}")
+    filename_fmt = "{id}_{title}_{filename}.{extension}"
+    archive_fmt = "{user}_{id}_{filename}.{extension}"
+
+    def items(self):
+        for post in self.posts():
+
+            files = []
+            if post["file"]:
+                files.append(post["file"])
+            if post["attachments"]:
+                files.extend(post["attachments"])
+            post["date"] = text.parse_datetime(
+                post["published"], "%a, %d %b %Y %H:%M:%S %Z")
+            yield Message.Directory, post
+
+            for post["num"], file in enumerate(files, 1):
+                text.nameext_from_url(file["name"], post)
+                yield Message.Url, self.root + file["path"], post
+
+
+class KemonopartyUserExtractor(KemonopartyExtractor):
+    """Extractor for all posts from a kemono.party user listing"""
+    subcategory = "user"
+    pattern = r"(?:https?://)?kemono\.party/([^/?#]+)/user/(\d+)/?(?:$|[?#])"
+    test = ("https://kemono.party/fanbox/user/6993449", {
+        "range": "1-25",
+        "count": 25,
+    })
+
+    def __init__(self, match):
+        KemonopartyExtractor.__init__(self, match)
+        service, user_id = match.groups()
+        self.api_url = "{}/api/{}/user/{}".format(self.root, service, user_id)
+
+    def posts(self):
+        url = self.api_url
+        params = {"o": 0}
+
+        while True:
+            posts = self.request(url, params=params).json()
+            yield from posts
+
+            if len(posts) < 25:
+                return
+            params["o"] += 25
+
+
+class KemonopartyPostExtractor(KemonopartyExtractor):
+    """Extractor for a single kemono.party post"""
+    subcategory = "post"
+    pattern = r"(?:https?://)?kemono\.party/([^/?#]+)/user/(\d+)/post/(\d+)"
+    test = ("https://kemono.party/fanbox/user/6993449/post/506575", {
+        "pattern": r"https://kemono\.party/files/fanbox"
+                   r"/6993449/506575/P058kDFYus7DbqAkGlfWTlOr\.jpeg",
+        "keyword": {
+            "added": "Wed, 06 May 2020 20:28:02 GMT",
+            "content": str,
+            "date": "dt:2019-08-11 02:09:04",
+            "edited": None,
+            "embed": dict,
+            "extension": "jpeg",
+            "filename": "P058kDFYus7DbqAkGlfWTlOr",
+            "id": "506575",
+            "num": 1,
+            "published": "Sun, 11 Aug 2019 02:09:04 GMT",
+            "service": "fanbox",
+            "shared_file": False,
+            "subcategory": "post",
+            "title": "c96取り置き",
+            "user": "6993449",
+        },
+    })
+
+    def __init__(self, match):
+        KemonopartyExtractor.__init__(self, match)
+        service, user_id, post_id = match.groups()
+        self.api_url = "{}/api/{}/user/{}/post/{}".format(
+            self.root, service, user_id, post_id)
+
+    def posts(self):
+        posts = self.request(self.api_url).json()
+        return (posts[0],) if len(posts) > 1 else posts