Add script for cronjob to call meeting API.

Author: Partha550

Bot/meeting_scheduler.py

@@ -0,0 +1,64 @@
+#!/usr/bin/env python3
+
+import asyncio
+import asyncpg
+import aiohttp
+
+# --- Configuration ---
+PG_USER = "postgres"
+PG_PASS = "postgres"
+PG_HOST = "localhost"
+PG_PORT = "5432"
+DB_NAME = "lingo_ai"
+API_URL = "http://localhost:8001/meetings/"
+SQL_QUERY = 'SELECT "accessToken", "refreshToken", "botName" FROM bot;'
+PG_CONN_STRING = f"postgresql://{PG_USER}:{PG_PASS}@{PG_HOST}:{PG_PORT}/{DB_NAME}"
+
+
+# Fetch access tokens asynchronously
+async def fetch_data():
+    try:
+        conn = await asyncpg.connect(PG_CONN_STRING)
+        rows = await conn.fetch(SQL_QUERY)
+        await conn.close()
+        return [
+            {
+                "access_token": row["accessToken"],
+                "refresh_token": row["refreshToken"],
+                "bot_name": row["botName"],
+            }
+            for row in rows
+        ]
+    except Exception as e:
+        print(f"[ERROR] Database error: {e}")
+        return []
+
+
+# Make one request
+async def make_request(session, data):
+    headers = {
+        "Authorization": f"Bearer {data["access_token"]}",
+        "Content-Type": "application/json",
+    }
+    body = {"refresh_token": data["refresh_token"], "bot_name": data["bot_name"]}
+    try:
+        async with session.get(
+            API_URL, headers=headers, json=body, timeout=10
+        ) as response:
+            status = response.status
+            print(f"[INFO] Token: {data['access_token'][:10]}... -> Status: {status}")
+    except Exception as e:
+        print(f"[ERROR] Token {data['access_token'][:10]}... failed: {e}")
+
+
+# Main async workflow
+async def main():
+    tokens = await fetch_data()
+    async with aiohttp.ClientSession() as session:
+        tasks = [make_request(session, token) for token in tokens]
+        await asyncio.gather(*tasks)
+
+
+# Entry point
+if __name__ == "__main__":
+    asyncio.run(main())