backend/run.py at develop · partner-up-dev/backend · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
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
if __name__ == "__main__":
    print(R"""

        |     |     =     |————\    |—————\   |—————     =     |\     /|
        |     |   =   =   |    —\   |     |   |        =   =   | \   / |
        |—————|  = = = =  |     —|  |—————/   |—————  = = = =  |  \ /  |
        |     |  =     =  |    —/   |    |    |       =     =  |   |   |
        |     |  =     =  |————/    |     \   |—————  =     =  |       |


                    #######################################
                            Anana-Backend-Main
                        --Powered by BlueFirmament--

                    2025(c) all copyrights reserved
                    #######################################


    [LOG OUTPUT]:
    """)

    # Load environment variables first
    import env_loader

    import settings.auth
    from blue_firmament.session.common import CommonSession

    CommonSession.ACCESS_TOKEN_PAYLOAD_ID_CLAIM = "session_id"

    from blue_firmament.log import get_logger

    LOGGER = get_logger(__name__)

    from blue_firmament.core.app import BlueFirmamentApp

    app = BlueFirmamentApp(name="PartnerUpMain")

    # [transport]
    from blue_firmament.transport.http import HTTPTransporter
    from blue_firmament.transport.pubsub import PubSubTransporter

    from settings.transport import get_setting as get_transport_setting

    app.add_transporter(
        HTTPTransporter(
            app,
            get_transport_setting().http_host,
            get_transport_setting().http_port,
        )
    )

    from dal import DefaultRedis

    app.add_transporter(PubSubTransporter(app, DefaultRedis(), "events", name="event"))

    from blue_firmament import event

    event.EVENT_BROKER = DefaultRedis(channel_name="events")

    # [managers]
    from communication.managers.chat import ChatManager
    from communication.managers.message import BaseMessageManager, PlainMessageManager
    from communication.managers.message.approval import ApprovalMessageManager
    from main.managers.partner_request import BasePRManager, PartnerManager
    from main.managers.partner_request.application import PartnerApplicationManager
    from main.managers.partner_request.trip.commute import CommutePRManager
    from main.managers.partner_request.trip.ride_hailing import RideHailingPRManager
    from main.managers.payment import wechat  # for activation
    from main.managers.split_bill import SplitBillManager
    from main.managers.split_bill.contribution import ContributionManager
    from main.managers.base.route import LocationManager

    app.add_managers(
        BasePRManager,
        PartnerManager,
        PartnerApplicationManager,
        RideHailingPRManager,
        CommutePRManager,
        ChatManager,
        BaseMessageManager,
        PlainMessageManager,
        ApprovalMessageManager,
        SplitBillManager,
        ContributionManager,
        LocationManager,
    )

    app.run()