blob: 3fb828fe9aa653c9592359c71399e9911acfb12c (
plain) (
blame)
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
|
from sanic import Sanic
import config
from asyncpg import create_pool
import jinja2_sanic
from jinja2 import FileSystemLoader
import logging
from .in_log import LOG_SETTINGS
from .util import URLCoder
from .schema import schema_up
blure = Sanic(__name__, log_config=LOG_SETTINGS)
log = logging.getLogger('blure')
jinja2_sanic.setup(blure, loader=FileSystemLoader('app/templates'))
blure.config.from_object(config)
blure.static('/static', './app/static')
blure.url = URLCoder(blure.config.APP_SECRET[::2]) # cut secret, because it is too long
@blure.listener('before_server_start')
async def setup_db(_app, loop):
_app.pool = await create_pool(_app.config.PG_URI, loop=loop)
async with _app.pool.acquire() as conn:
await create_tables(conn)
@blure.listener('after_server_stop')
async def close_db_conns(_app, loop):
await _app.pool.close()
from . import views # noqa # unused-import, E402
async def create_tables(conn):
async with conn.transaction():
for statement in schema_up:
await conn.execute(statement)
|
