velvox
/
litecord
mirror of https://gitlab.com/litecord/litecord.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

add basic connection and usage in run

This commit is contained in:
Luna 2020-02-10 22:24:08 -03:00
parent 9dc56e9808
commit fd1099607b
2 changed files with 10 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
run.py
View File

@ -19,6 +19,7 @@ along with this program. If not, see <http://www.gnu.org/licenses/>.
import asyncio import asyncio
import sys import sys
from multiprocessing.managers import BaseManager
import asyncpg import asyncpg
import logbook import logbook
@ -257,6 +258,12 @@ async def init_app_db(app_):
def init_app_managers(app_: Quart, *, init_voice=True): def init_app_managers(app_: Quart, *, init_voice=True):
"""Initialize singleton classes.""" """Initialize singleton classes."""
app.state = BaseManager(("", 36969), b"awooawoo")
app.state.register("get_test")
app.state.connect()
print(app.state)
print(app.state.get_test())
app_.loop = asyncio.get_event_loop() app_.loop = asyncio.get_event_loop()
app_.ratelimiter = RatelimitManager(app_.config.get("_testing")) app_.ratelimiter = RatelimitManager(app_.config.get("_testing"))
app_.state_manager = StateManager() app_.state_manager = StateManager()

5
state.py
View File

@ -9,11 +9,12 @@ def test():
def main(): def main():
logging.basicConfig(level=logging.INFO) logging.basicConfig(level=logging.DEBUG)
manager = BaseManager(("", 36969), b"awooawoo") manager = BaseManager(("", 36969), b"awooawoo")
manager.register("get_test", test) manager.register("get_test", test)
server = manager.get_server() server = manager.get_server()
log.info("serving state service") print(repr(server))
log.info("serving state service: %r", manager.address)
server.serve_forever() server.serve_forever()