diff options
| author | schneefux <schneefux+commit@schneefux.xyz> | 2017-01-27 13:12:35 +0100 |
|---|---|---|
| committer | schneefux <schneefux+commit@schneefux.xyz> | 2017-01-27 13:12:35 +0100 |
| commit | 16ba2a3e926105b2dd732e8cb28eddcdda1d1fc2 (patch) | |
| tree | f1a7441db5ae6aa94d3c92c1fc0a3122eaebf4cd /api.py | |
| parent | 0c7abdcf1887285a5dccf0073629521a91cc0276 (diff) | |
| download | apigrabber-16ba2a3e926105b2dd732e8cb28eddcdda1d1fc2.tar.gz apigrabber-16ba2a3e926105b2dd732e8cb28eddcdda1d1fc2.zip | |
api: move db queries to sql files
Diffstat (limited to 'api.py')
| -rw-r--r-- | api.py | 4 |
1 files changed, 3 insertions, 1 deletions
@@ -24,6 +24,7 @@ async def recrawl(): api = crawler.Crawler() # TODO: insert API version (force update if changed) + # TODO: create database indices # get or put when the last crawl was executed try: last_match_update = await db.meta("last_match_update") @@ -50,7 +51,7 @@ async def recrawl_soon(): @route("/matches") async def api_matches(request): - data = (await db.select(queries.matches))[0]["data"] + data = (await db.select(queries.queries["recent-matches"]))[0]["data"] return aiohttp.web.Response(text=str(data)) @route("/status") @@ -61,6 +62,7 @@ async def api_status(_): loop = asyncio.get_event_loop() loop.run_until_complete(db.connect("postgres://vgstats@localhost/vgstats")) +loop.run_until_complete(queries.load_queries("queries/")) loop.create_task(recrawl()) app = aiohttp.web.Application(loop=loop) route.add_to_router(app.router) |
