`twtb.logic.shared.db`#

The package for the database system.

Submodules#

`Database`	Main class for the data storage (aka database).
`DatabaseConfigSection`	Database configuration section.

class Database[source]#

Main class for the data storage (aka database).

async subscribe_user(user: int, word: str) → bool[source]#

Subscribe user to the word.

async unsubscribe_user(user: int, word: str) → bool[source]#

Unsubscribe user from the word.

async add_channel(id: str) → bool[source]#

Add channel to our database.

async delete_channel(id: str) → bool[source]#

Delete channel from our database.

async get_all_channels() → Set[str][source]#: Get all channels from database.

async get_user_words(user_id: int) → Set[str][source]#: Get all words, which the user is subscribed to.

async get_all_subscribed_words() → Dict[str, Set[int]][source]#

Get all words, that we need to listen.

Returns:: A dict where key is a word to listen, and value - a list of users to forward message.

class DatabaseConfigSection[source]#

Database configuration section.