Upgraded SDK V1.11.1 Support Xiaohongshu and Kuaishou API

Author: Evil0ctal

README.md

@@ -75,7 +75,7 @@ client = Client(base_url="https://api.tikhub.io",
                 proxies=None,
                 max_retries=3,
                 max_connections=50,
-                timeout=10,
+                timeout=60,
                 max_tasks=50)
 ```
 
@@ -135,6 +135,12 @@ self.CaptchaSolver = CaptchaSolver(self.client)
 
 # Xigua Video APP V2 | 西瓜视频APP V2
 self.XiguaAppV2 = XiguaAppV2(self.client)
+
+# XiaoHongShu Web | 小红书网页端
+self.XiaohongshuWeb = XiaohongshuWeb(self.client)
+
+# KuaiShou Web | 快手网页端
+self.KuaishouWeb = KuaishouWeb(self.client)
 ```
 
 - 使用`DouyinAppV1`的`fetch_one_video`方法调用接口获取单一视频数据。
@@ -148,6 +154,21 @@ print(video_data)
 - 我们已经使用HTTPX的对大多数端点进行了异步封装，如果你的代码是同步执行的，你可以使用下面的代码防止异步传染。
 
 ```python
+# 导入异步io库 | Import asyncio
+import asyncio
+
+# 导入tikhub | Import tikhub
+from tikhub import Client
+
+# 初始化Client | Initialize Client
+client = Client(base_url="https://api.tikhub.io", 
+                api_key="YOUR_API_TOKEN",
+                proxies=None,
+                max_retries=3,
+                max_connections=50,
+                timeout=60,
+                max_tasks=50)
+
 # 获取抖音单一视频数据 | Get a single video data from Douyin
 def fetch_one_video(aweme_id: str):
     # 创建一个异步事件循环

dist/tikhub-1.11.1-py3-none-any.whl

@@ -13,7 +13,7 @@
 
 setup(
     name="tikhub",
-    version="1.11.0",
+    version="1.11.1",
     author="TikHub.io",
     author_email="tikhub.io@proton.me",
     description="A Python SDK for TikHub RESTful API",

dist/tikhub-1.11.1.tar.gz

@@ -0,0 +1,34 @@
+# 导入API SDK Client类
+import json
+
+from tikhub.http_client.api_client import APIClient
+
+
+class KuaishouWeb:
+
+    def __init__(self, client: APIClient):
+        self.client = client
+
+    # 获取单个作品数据 (Fetch Single Video)
+    async def fetch_one_video(self, photo_id: str):
+        endpoint = "/api/v1/kuaishou/web/fetch_one_video"
+        data = await self.client.fetch_get_json(f"{endpoint}?photo_id={photo_id}")
+        return data
+
+    # 获取单个作品评论数据 (Fetch Single Video Comment Data)
+    async def fetch_one_video_comment(self, photo_id: str, pcursor: str = None):
+        endpoint = "/api/v1/kuaishou/web/fetch_one_video_comment"
+        data = await self.client.fetch_get_json(f"{endpoint}?photo_id={photo_id}&pcursor={pcursor}")
+        return data
+
+    # 获取主页视频数据 (Fetch Home Page Video Data)
+    async def fetch_home_page_video(self, user_id: str, pcursor: str = None):
+        endpoint = "/api/v1/kuaishou/web/fetch_home_page_video"
+        data = await self.client.fetch_get_json(f"{endpoint}?user_id={user_id}&pcursor={pcursor}")
+        return data
+
+    # 获取主页信息数据 (Fetch Home Page Info Data)
+    async def fetch_home_page_info(self, user_id: str):
+        endpoint = "/api/v1/kuaishou/web/fetch_home_page_info"
+        data = await self.client.fetch_get_json(f"{endpoint}?user_id={user_id}")
+        return data

setup.py

@@ -1,16 +1,33 @@
-from fastapi import APIRouter, Query, Request, HTTPException  # 导入FastAPI组件
-from app.api.v1.models.APIResponseModel import ResponseModel, ErrorResponseModel  # 导入响应模型
+# 导入API SDK Client类
+import json
 
-from crawlers.xiaohongshu.web_crawler import *
+from tikhub.http_client.api_client import APIClient
 
-router = APIRouter()
 
+class XiaohongshuWeb:
+    def __init__(self, client: APIClient):
+        self.client = client
 
-@router.get("/test", response_model=ResponseModel, summary="测试接口")
-async def test(request: Request):
-    # 测试函数
-    data = {"message": "即将上线，敬请期待 | Coming soon, stay tuned"}
-    return ResponseModel(code=200,
-                         router=request.url.path,
-                         params=dict(request.query_params),
-                         data=data)
+    # 获取笔记信息
+    async def get_note_info(self, note_id: str):
+        endpoint = "/api/v1/xiaohongshu/web/get_note_info"
+        data = await self.client.fetch_get_json(f"{endpoint}?note_id={note_id}")
+        return data
+
+    # 获取用户信息
+    async def get_user_info(self, user_id: str):
+        endpoint = "/api/v1/xiaohongshu/web/get_user_info"
+        data = await self.client.fetch_get_json(f"{endpoint}?user_id={user_id}")
+        return data
+
+    # 搜索笔记
+    async def search_notes(self, keyword: str, page: int = 1, sort: str = "general", noteType: str = "_0"):
+        endpoint = "/api/v1/xiaohongshu/web/search_notes"
+        data = await self.client.fetch_get_json(f"{endpoint}?keyword={keyword}&page={page}&sort={sort}&noteType={noteType}")
+        return data
+
+    # 获取用户的笔记
+    async def get_user_notes(self, user_id: str, lastCursor: str = None):
+        endpoint = "/api/v1/xiaohongshu/web/get_user_notes"
+        data = await self.client.fetch_get_json(f"{endpoint}?user_id={user_id}&lastCursor={lastCursor}")
+        return data

tikhub/api/v1/endpoints/xiaohongshu/app/__init__.py renamed to tikhub/api/v1/endpoints/kuaishou/__init__.py

@@ -27,6 +27,12 @@
 # Xigua Video APP V2
 from tikhub.api.v1.endpoints.xigua.app.xigua_app_v2 import XiguaAppV2
 
+# XiaoHongShu Web
+from tikhub.api.v1.endpoints.xiaohongshu.web.xiaohongshu_web import XiaohongshuWeb
+
+# KuaiShou Web
+from tikhub.api.v1.endpoints.kuaishou.web.kuaishou_web import KuaishouWeb
+
 
 class Client:
     def __init__(self,
@@ -82,3 +88,9 @@ def __init__(self,
 
         # Xigua Video APP V2
         self.XiguaAppV2 = XiguaAppV2(self.client)
+
+        # XiaoHongShu Web
+        self.XiaohongshuWeb = XiaohongshuWeb(self.client)
+
+        # KuaiShou Web
+        self.KuaishouWeb = KuaishouWeb(self.client)