semi-complete

App/Users/UserRoutes.py

@@ -31,8 +31,8 @@ async def register_user(user: RegisterUserRequest):
     existing_user = await User.filter(phoneNumber=user.phoneNumber).first()
     if existing_user:
         raise HTTPException(status_code=status.HTTP_400_BAD_REQUEST, detail="User already exists.")
-
     user.hash_password()
+    
     new_user = await User.create(**user.dict())
     return BaseResponse(code=200, message="User created successfully", payload={"user_id": new_user.id})
 

App/Webhooks/webhookRoute.py

@@ -0,0 +1,46 @@
+from fastapi import FastAPI, Request, HTTPException,APIRouter
+from pydantic import BaseModel
+
+
+webhook_router = APIRouter(tags=["Webhooks"])
+
+WEBHOOK_SECRET = "your_webhook_secret"  # Replace with your secret
+
+class WebhookPayload(BaseModel):
+    event: str
+    data: dict
+
+# Endpoint to receive webhook events
+@webhook_router.post("/webhook/sms_received/")
+async def handle_webhook(request: Request):
+
+    
+    # Parse the webhook payload
+    payload = await request.json()
+    event = payload.get("event")
+    data = payload.get("data")
+
+    # Handle different event types
+    if event == "payment_success":
+        # Process payment success
+        print("Payment was successful:", data)
+    elif event == "user_registered":
+        # Process new user registration
+        print("New user registered:", data)
+    else:
+        print("Received unknown event:", event)
+    
+    # Return a response
+    return {"status": "received"}
+
+# # Optional: Verify the webhook signature
+# def verify_signature(request: Request, signature: str) -> bool:
+#     if not signature:
+#         return False
+#     body = await request.body()
+#     computed_signature = hmac.new(
+#         WEBHOOK_SECRET.encode(),
+#         body,
+#         hashlib.sha256
+#     ).hexdigest()
+#     return hmac.compare_digest(computed_signature, signature)

App/app.py

@@ -1,6 +1,7 @@
 from fastapi import FastAPI
 from tortoise import Tortoise, run_async
 from .Users.UserRoutes import user_router
+from .Webhooks.webhookRoute import webhook_router
 from .modelInit import TORTOISE_ORM
 
 app = FastAPI()
@@ -18,7 +19,7 @@ async def landing_page():
 
 
 app.include_router(user_router)
-
+app.include_router(webhook_router)
 
 
 async def main():

App/modelInit.py

@@ -1,4 +1,7 @@
 from App.discovery import discover_models
+import asyncio
+
+
 
 DATABASE_URL = "sqlite://db.sqlite3"  # Example: SQLite for local development
 
@@ -12,24 +15,4 @@ TORTOISE_ORM = {
     },
 }
 
-# HOST=aws.connect.psdb.cloud
-# USERNAME=kn9rzjlad1tw8bvojqg9
-# PASSWORD=pscale_pw_hSBO8rcekvnQp74bezC9gjnShhAWgkJYUS8GjGdrBKn
-# DATABASE=movie-website
-
-
-# database = databases.Database(
-#     "postgresql+asyncpg://postgres:[email protected]:5432/postgres"
-# )
-# database = databases.Database(
-#     "postgresql+asyncpg://user:password@db:5432/mydatabase"
-# )
-
-# #mysql
-# database = databases.Database(
-#     'mysql+asyncmy://kn9rzjlad1tw8bvojqg9:pscale_pw_hSBO8rcekvnQp74bezC9gjnShhAWgkJYUS8GjGdrBKn@aws.connect.psdb.cloud/movie-website'
-# ,)
-
-
-# databases = databases.Database(**args)