webapp/app/services/notification_service.py

# app/services/product_service.py
import uuid
from sqlalchemy.orm import Session
from typing import Optional, List, Dict
from redis.asyncio import Redis
from app.utils.redis_utils import redis_qpush

class NotificationService:

    def create(redis_client: Redis, ntype: str, user_id:str, channels:List[str], template_id=str, payload=Dict):
        notification_payload = {
            "notification_id": f'nid_{uuid.uuid4().hex}',
            "type": ntype,
            "user_id": user_id,
            "channels": channels,
            "template_id": template_id,
            "payload": payload
        }

        redis_qpush(
            redis_client,
            "vas_notification_queue",
            notification_payload
        )