mirror of
https://github.com/jxxghp/MoviePilot.git
synced 2026-05-14 07:26:45 +00:00
5a585839ba
- Remove unused imports in anthropic.py, tmdbv3api/__init__.py, tv.py, test files - Rename conflicting function names in subscribe.py and webhook.py - Clean up unused re-exports in tmdbv3api/__init__.py (15 unused exports) - Apply consistent formatting across API endpoints
47 lines
1.4 KiB
Python
47 lines
1.4 KiB
Python
from typing import Any, Annotated
|
||
|
||
from fastapi import APIRouter, BackgroundTasks, Request, Depends
|
||
|
||
from app import schemas
|
||
from app.chain.webhook import WebhookChain
|
||
from app.core.security import verify_apitoken
|
||
|
||
router = APIRouter()
|
||
|
||
|
||
def start_webhook_chain(body: Any, form: Any, args: Any):
|
||
"""
|
||
启动链式任务
|
||
"""
|
||
WebhookChain().message(body=body, form=form, args=args)
|
||
|
||
|
||
@router.post("/", summary="Webhook消息响应", response_model=schemas.Response)
|
||
async def webhook_message(
|
||
background_tasks: BackgroundTasks,
|
||
request: Request,
|
||
_: Annotated[str, Depends(verify_apitoken)],
|
||
) -> Any:
|
||
"""
|
||
Webhook响应，配置请求中需要添加参数：token=API_TOKEN&source=媒体服务器名
|
||
"""
|
||
body = await request.body()
|
||
form = await request.form()
|
||
args = request.query_params
|
||
background_tasks.add_task(start_webhook_chain, body, form, args)
|
||
return schemas.Response(success=True)
|
||
|
||
|
||
@router.get("/", summary="Webhook消息响应", response_model=schemas.Response)
|
||
async def webhook_message_get(
|
||
background_tasks: BackgroundTasks,
|
||
request: Request,
|
||
_: Annotated[str, Depends(verify_apitoken)],
|
||
) -> Any:
|
||
"""
|
||
Webhook响应，配置请求中需要添加参数：token=API_TOKEN&source=媒体服务器名
|
||
"""
|
||
args = request.query_params
|
||
background_tasks.add_task(start_webhook_chain, None, None, args)
|
||
return schemas.Response(success=True)
|