webhook wip

dev-requirements.txt

@@ -6,4 +6,6 @@ wheel
 setuptools
 twine
 auditwheel; sys_platform == 'linux'
-cibuildwheel
+cibuildwheel
+
+pytest

livekit-api/livekit/api/webhooks.py

@@ -0,0 +1,21 @@
+from .access_token import TokenVerifier
+from livekit.protocol import webhook as proto_webhook
+from google.protobuf.json_format import Parse
+import hashlib
+import base64
+
+
+class WebhookReceiver:
+    def __init__(token_verifier: TokenVerifier):
+        self.token_verifier = token_verifier
+
+    def receive(self, body: str, auth_token: str):
+        claims = self.token_verifier.verify(auth_token)
+
+        body_hash = hashlib.sha256(body).digest()
+        claims_hash = base64.b64decode(claims.sha256)
+
+        if body_hash != claims_hash:
+            raise Exception("hash mismatch")
+
+        Parse(body, proto_webhook.WebhookEvent())