Added more examples

Author: rednafi

.env

@@ -7,7 +7,7 @@ HTTP_TIMEOUT="30"
 REDIS_URL="redis://redis:6380/1"
 
 # API token, SHA-256 key.
-API_TOKEN="$5$1O/inyTZhNvFt.GW$Zfckz9OL.lm2wh3IewTm8YJ914wjz5txFnXG5XW.wb4"
+API_TOKEN='$5$1O/inyTZhNvFt.GW$Zfckz9OL.lm2wh3IewTm8YJ914wjz5txFnXG5XW.wb4'
 
 # Retry parameters.
 MAX_RETRIES="3"

app/services.py

@@ -73,7 +73,7 @@ def send_post_request(webhook_payload: SlingerRequestPayload) -> NoReturn:
             raise WebhookPostFailedError(
                 f"Sending webhook failed.\n"
                 f"to_url: {to_url}\n"
-                f"payload: {payload}\n"
+                f"payload: {payload}\n, code: {response.status_code}"
             )
 
 

config.py

@@ -17,6 +17,10 @@
     "API_TOKEN", "$5$1O/inyTZhNvFt.GW$Zfckz9OL.lm2wh3IewTm8YJ914wjz5txFnXG5XW.wb4"
 )
 
+print("=" * 40)
+print(f"{API_TOKEN=}")
+print("=" * 40)
+
 # Retry parameters.
 MAX_RETRIES: int = int(os.environ.get("MAX_RETRIES", 3))
 INTERVAL: int = int(os.environ.get("INTERVAL", 5))

examples/send_webhook.py

@@ -0,0 +1,42 @@
+# Requires python3.8 and up!
+
+import asyncio
+from http import HTTPStatus
+from pprint import pprint
+
+import httpx
+
+
+async def send_webhook() -> None:
+
+    wh_payload = {
+        "to_url": "https://webhook.site/f864d28d-9162-4ad5-9205-458e2b561c07",
+        "to_auth": "",
+        "tag": "Dhaka",
+        "group": "Bangladesh",
+        "payload": {"greetings": "Hello, world!"},
+    }
+
+    async with httpx.AsyncClient(http2=True) as session:
+        headers = {
+            "Content-Type": "application/json",
+            "Authorization": (
+                "Token $5$1O/inyTZhNvFt.GW$Zfckz9OL.lm2wh3IewTm8YJ914wjz5txFnXG5XW.wb4"
+            ),
+        }
+
+        response = await session.post(
+            "http://localhost:5000/hook_slinger",
+            headers=headers,
+            json=wh_payload,
+            follow_redirects=True,
+        )
+
+        # Hook Slinger returns http code 202, accepted, for a successful request.
+        assert response.status_code == HTTPStatus.ACCEPTED
+        result = response.json()
+        pprint(result)
+
+
+if __name__ == "__main__":
+    asyncio.run(send_webhook())

examples/send_webhook.sh

@@ -0,0 +1,18 @@
+#!/bin/bash
+
+set -euo pipefail
+
+curl -X 'POST' \
+  'http://localhost:5000/hook_slinger/' \
+  -H 'accept: application/json' \
+  -H 'Authorization: Token $5$1O/inyTZhNvFt.GW$Zfckz9OL.lm2wh3IewTm8YJ914wjz5txFnXG5XW.wb4' \
+  -H 'Content-Type: application/json' \
+  -d '{
+  "to_url": "https://webhook.site/37ad9530-59c3-430d-9db6-e68317321a9f",
+  "to_auth": "",
+  "tag": "Dhaka",
+  "group": "Bangladesh",
+  "payload": {
+    "greetings": "Hello, world!"
+  }
+}' | python -m json.tool