import json
import os

from appPublic.worker import awaitify
from appPublic.jsonConfig import getConfig
from ahserver.serverenv import ServerEnv
from sqlor.dbpools import DBPools
from ahserver.webapp import webapp
from downloadchannels import load_url_iptv
from time import time
from appbase.init import load_appbase
from rbac.init import load_rbac

def get_module_dbname(m):
	return 'iptvdb'

async def get_channel_by_id(id):
	db = DBPools()
	async with db.sqlorContext('iptvdb') as sor:
		sql = "select * from iptvchannels where id=${id}$"
		recs = await sor.sqlExe(sql, {'id':id})
		if len(recs) < 1:
			return None
		return recs[0]
	return None

def init_func():
	g = ServerEnv()
	load_appbase()
	load_rbac()
	g.get_module_dbname = get_module_dbname
	g.load_url_iptv = load_url_iptv
	g.get_channel_by_id = get_channel_by_id

if __name__ == '__main__':
    webapp(init_func)