lily_website

📜 Notifications

⬅️ Back

🏠 Docs Root

This module defines the NotificationsRepositoryProvider class, which is an implementation of the NotificationsDataProvider protocol. This provider is designed to interact directly with a database (using SQLAlchemy) for managing notification-related data, serving as a data access layer.

NotificationsRepositoryProvider Class

The NotificationsRepositoryProvider encapsulates the logic for performing CRUD (Create, Read, Update, Delete) operations on notification data in the database. It is intended for use when the bot operates in “direct” data mode.

Initialization (__init__)

def __init__(self, session_factory: Callable[..., AsyncSession]):

Initializes the NotificationsRepositoryProvider.

• session_factory (Callable[..., AsyncSession]): A callable that returns an asynchronous SQLAlchemy session, typically used with async with session_factory() as session:.

get_data Method

async def get_data(self, user_id: int) -> Any:

An example method for retrieving notification data for a specific user from the database.

• user_id (int): The ID of the user for whom to fetch notification data.

Note: The current implementation is a placeholder that returns dummy data. In a full implementation, it would execute a SQLAlchemy query (e.g., select(Notification).filter_by(user_id=user_id)).

Returns: Any: Placeholder data or actual notification data from the database.

create_notification Method

async def create_notification(self, user_id: int, data: dict) -> Any:

A placeholder method for creating a new notification in the database.

• user_id (int): The ID of the user for whom to create the notification.
• data (dict): A dictionary containing the notification data to be stored.

Note: The current implementation is a placeholder. A full implementation would use SQLAlchemy’s insert statement.

Returns: Any: Placeholder data or the created notification object.

update_notification Method

async def update_notification(self, notification_id: int, data: dict) -> Any:

A placeholder method for updating an existing notification in the database.

• notification_id (int): The ID of the notification to update.
• data (dict): A dictionary containing the updated notification data.

Note: The current implementation is a placeholder. A full implementation would use SQLAlchemy’s update statement.

Returns: Any: Placeholder data or the updated notification object.

delete_notification Method

async def delete_notification(self, notification_id: int) -> None:

A placeholder method for deleting a notification from the database.

• notification_id (int): The ID of the notification to delete.

Note: The current implementation is a placeholder. A full implementation would use SQLAlchemy’s delete statement.

Returns: None.