feat: add 400 checks

Author: null8626

README.md

@@ -165,10 +165,7 @@ import topgg
 import asyncio
 import os
 
-port = 8080
-secret = os.getenv('MY_TOPGG_WEBHOOK_SECRET')
-
-webhooks = topgg.Webhooks(secret, port)
+webhooks = topgg.Webhooks(os.getenv('MY_TOPGG_WEBHOOK_SECRET'), 8080)
 
 @webhooks.on_vote('/votes')
 def voted(vote: topgg.Vote) -> None:

topgg/webhooks.py

@@ -24,10 +24,11 @@
 """
 
 from collections.abc import Awaitable, Callable
+from aiohttp import web, ContentTypeError
 from typing import Any, Optional, Union
+from json import JSONDecodeError
 from inspect import isawaitable
 from urllib import parse
-from aiohttp import web
 
 
 RawCallback = Callable[[web.Request], Awaitable[web.StreamResponse]]
@@ -134,7 +135,12 @@ async def handler(request: web.Request) -> web.Response:
         if request.headers.get('Authorization', '') != auth:
           return web.Response(status=401, text='Unauthorized')
 
-        response = inner_callback(Vote(await request.json()))
+        try:
+          vote = Vote(await request.json())
+        except (JSONDecodeError, ContentTypeError):
+          return web.Response(status=400, text='Bad request')
+
+        response = inner_callback(vote)
 
         if isawaitable(response):
           await response