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].typs[typ]:
                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 t in p.typs:
            for r in p.typs[t]:
                n = session.query(schema.Offer.name).filter(and_(schema.Offer.provider==provider, schema.Offer.route==r, schema.Offer.typ==t)).scalar()
                offers[n]=Offer(provider=p,route=r,typ=t,name=n)
        providers[provider]=p

offers={}
providers={}

config.registerReload(loadOffers)