codfrm/MoviePilot
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix webhook

Browse Source
This commit is contained in:
jxxghp
2023-07-14 21:00:59 +08:00
parent 085409049d
commit 98762e711c
2 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
README.md
View File

@ -197,7 +197,7 @@ docker pull jxxghp/moviepilot:latest
- 通过下载器监控实现资源下载后自动整理入库刮削。 - 通过下载器监控实现资源下载后自动整理入库刮削。
- 通过微信/Telegram/Slack远程搜索下载、订阅和管理设置，其中Telegram将会自动添加操作菜单。微信回调相对路径为`/api/v1/message/`。 - 通过微信/Telegram/Slack远程搜索下载、订阅和管理设置，其中Telegram将会自动添加操作菜单。微信回调相对路径为`/api/v1/message/`。
- 通过WEB进行管理，将WEB添加到手机桌面获得类App使用效果，管理界面端口：`3000`。 - 通过WEB进行管理，将WEB添加到手机桌面获得类App使用效果，管理界面端口：`3000`。
- 设置媒体服务器Webhook，通过MoviePilot发送播放通知，以及后续播放限速等插件功能。Webhook回调相对路径为`/api/v1/message?token=moviepilot`，其中`moviepilot`为设置的`API_TOKEN`。 - 设置媒体服务器Webhook，通过MoviePilot发送播放通知，以及后续播放限速等插件功能。Webhook回调相对路径为`/api/v1/webhook?token=moviepilot`，其中`moviepilot`为设置的`API_TOKEN`。
- 将MoviePilot做为Radarr或Sonarr服务器添加到Overseerr或Jellyseerr，可使用Overseerr/Jellyseerr选片。 - 将MoviePilot做为Radarr或Sonarr服务器添加到Overseerr或Jellyseerr，可使用Overseerr/Jellyseerr选片。
![image](https://github.com/jxxghp/MoviePilot/assets/51039935/b8f0238d-847f-4f9d-b210-e905837362b9) ![image](https://github.com/jxxghp/MoviePilot/assets/51039935/b8f0238d-847f-4f9d-b210-e905837362b9)

8
app/api/endpoints/webhook.py
View File

@ -17,15 +17,15 @@ def start_webhook_chain(body: Any, form: Any, args: Any):
@router.post("/", summary="Webhook消息响应", response_model=schemas.Response) @router.post("/", summary="Webhook消息响应", response_model=schemas.Response)
def webhook_message(background_tasks: BackgroundTasks, async def webhook_message(background_tasks: BackgroundTasks,
token: str, request: Request) -> Any: token: str, request: Request) -> Any:
""" """
Webhook响应 Webhook响应
""" """
if token != settings.API_TOKEN: if token != settings.API_TOKEN:
return schemas.Response(success=False, message="token认证不通过") return schemas.Response(success=False, message="token认证不通过")
body = request.body() body = await request.body()
form = request.form() form = await request.form()
args = request.query_params args = request.query_params
background_tasks.add_task(start_webhook_chain, body, form, args) background_tasks.add_task(start_webhook_chain, body, form, args)
return schemas.Response(success=True) return schemas.Response(success=True)