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:

                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)