from .dbdefer import dbdefer
from sqlalchemy import and_

import schema
from ..config import config
from ..offer import getProvider, Offer

@dbdefer
def extendProvider(session, user, typ, ps):
    user = session.merge(user)
    ret = []
    for p in ps:
        if p not in ret and user.has_right(typ, offer_name = p): 
                ret.append(p)
        elif user.providers(typ).filter(schema.Offer.provider==p).first():
            for r in providers[p].routes:
                n = user.has_right(typ, provider=p, route=r)
                if n and n not in ret:
                    ret.append(n)
    return ret

@dbdefer
def loadOffers(session):
    offers.clear()
    providers.clear()
    for provider in ( s for s in config.sections() if not s in ["main",]):
        p=getProvider(provider,config.get(provider,"typ"),config.items(provider))
        for r in p.routes:
            for o in  session.query(schema.Offer.name, schema.Offer.typ).filter(and_(schema.Offer.provider==provider,
                schema.Offer.route==r)):
                    offers[o[0]]=Offer(provider=p,route=r,typ=o[1],name=o[0])
        providers[provider]=p

offers={}
providers={}

config.registerReload(loadOffers)