from internal.helpers import rds_query


def get_current_alliance_count(management_schema, **kw):
    for line in rds_query(f"SELECT count(alliance_id) FROM commons.company_alliance "
                          f"WHERE management_company_id = %(management_schema)s "
                          f"AND alliance_id LIKE 'a%%'",
                          {'management_schema': management_schema}):
        return line['count']
    raise RuntimeError('Reality broke, welcome to the world of impossible.')


def get_current_unique_fan_count(management_schema, **kw):
    for line in rds_query(f"SELECT count(*) FROM {management_schema}.fan"):
        return line['count']