Skip to content

models/mailletterdb.py

models.mailletterdb

MailLetterDB

This models will save the record of what the platform send the specific case of mail to user. (like: welcome letter)

The base struct::

{
    "_id" : <user id>,
    "create_at" : <timestamp>,
    "code" : {
        "welcome" : <timestamp>
    }
}

MailLetterDB

Bases: DBBase

MailLetterDB Collection

Source code in models/mailletterdb.py 
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
class MailLetterDB(DBBase):
    ''' MailLetterDB Collection '''

    def __init__(self) -> None:
        super().__init__('mailletter')

    def index(self) -> None:
        ''' To make collection's index

        Indexs:
            - `code.welcome`

        '''
        self.create_index([('code.welcome', 1), ])

    def create(self, uid: str) -> None:
        ''' Add user into sendlist

        Args:
            uid (str): User id.

        '''
        self.find_one_and_update(
            {'_id': uid}, {'$set': {'create_at': time()}}, upsert=True)

    def is_sent(self, uid: str, code: str) -> float:
        ''' Check is sent or not

        Args:
            uid (str): User id.
            code (str): case code.

        Returns:
            The `timestamp` value. `0` has not sent.

        '''
        raw = self.find_one({'_id': uid}, {f'code.{code}': 1})
        if raw and 'code' in raw and code in raw['code']:
            return float(raw['code'][code])

        return 0

    def make_sent(self, uid: str, code: str) -> dict[str, Any]:
        ''' Make sent record

        Args:
            uid (str): User id.
            code (str): Case code.

        Returns:
            Return the inserted / updated data.

        '''
        return self.find_one_and_update(
            {'_id': uid},
            {'$set': {f'code.{code}': time()}},
            upsert=True,
            return_document=ReturnDocument.AFTER,
        )

    def need_to_send(self, code: str) -> Generator[dict[str, Any], None, None]:
        ''' Find need to send the list of user

        Args:
            code (str): Case code.

        Yields:
            The data haven't been sent yet.

        '''
        for raw in self.find({f'code.{code}': {'$exists': False}}):
            yield raw

create 

create(uid: str) -> None

Add user into sendlist

Parameters:

Name Type Description Default
uid str

User id.

 required
Source code in models/mailletterdb.py 
40
41
42
43
44
45
46
47
48
def create(self, uid: str) -> None:
    ''' Add user into sendlist

    Args:
        uid (str): User id.

    '''
    self.find_one_and_update(
        {'_id': uid}, {'$set': {'create_at': time()}}, upsert=True)

index 

index() -> None

To make collection's index

Indexs
  • code.welcome
Source code in models/mailletterdb.py 
31
32
33
34
35
36
37
38
def index(self) -> None:
    ''' To make collection's index

    Indexs:
        - `code.welcome`

    '''
    self.create_index([('code.welcome', 1), ])

is_sent 

is_sent(uid: str, code: str) -> float

Check is sent or not

Parameters:

Name Type Description Default
uid str

User id.

 required
code str

case code.

 required

Returns:

Type Description
float

The timestamp value. 0 has not sent.
Source code in models/mailletterdb.py 
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
def is_sent(self, uid: str, code: str) -> float:
    ''' Check is sent or not

    Args:
        uid (str): User id.
        code (str): case code.

    Returns:
        The `timestamp` value. `0` has not sent.

    '''
    raw = self.find_one({'_id': uid}, {f'code.{code}': 1})
    if raw and 'code' in raw and code in raw['code']:
        return float(raw['code'][code])

    return 0

make_sent 

make_sent(uid: str, code: str) -> dict[str, Any]

Make sent record

Parameters:

Name Type Description Default
uid str

User id.

 required
code str

Case code.

 required

Returns:

Type Description
dict[str, Any]

Return the inserted / updated data.
Source code in models/mailletterdb.py 
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
def make_sent(self, uid: str, code: str) -> dict[str, Any]:
    ''' Make sent record

    Args:
        uid (str): User id.
        code (str): Case code.

    Returns:
        Return the inserted / updated data.

    '''
    return self.find_one_and_update(
        {'_id': uid},
        {'$set': {f'code.{code}': time()}},
        upsert=True,
        return_document=ReturnDocument.AFTER,
    )

need_to_send 

need_to_send(
    code: str,
) -> Generator[dict[str, Any], None, None]

Find need to send the list of user

Parameters:

Name Type Description Default
code str

Case code.

 required

Yields:

Type Description
dict[str, Any]

The data haven't been sent yet.
Source code in models/mailletterdb.py 
85
86
87
88
89
90
91
92
93
94
95
96
def need_to_send(self, code: str) -> Generator[dict[str, Any], None, None]:
    ''' Find need to send the list of user

    Args:
        code (str): Case code.

    Yields:
        The data haven't been sent yet.

    '''
    for raw in self.find({f'code.{code}': {'$exists': False}}):
        yield raw