test.py

from sbxpy.QueryBuilder import QueryBuilder as Qb
from sbxpy.__init__ import SbxCore as Sc
import asyncio
import os
from dotenv import load_dotenv

'''
This is a test using the os environment:
credentials app: APP-KEY, DOMAIN
credentials user: LOGIN, PASSWORD
'''

load_dotenv()
async def main(sci):

    qb = Qb()
    qb.set_domain(123)
    qb.add_object({'user': 'data'})
    print(qb.compile())

    qb = Qb()
    qb.set_domain(123)
    qb.add_condition('AND', 'name', '=', 'pepe')
    qb.add_condition('AND', 'edad', '>', 50)
    qb.new_group('OR')
    qb.add_condition('AND', 'genero', '=', 'M')
    print(qb.compile())


#    login = await  sci.login(os.environ['LOGIN'], os.environ['PASSWORD'], os.environ['DOMAIN'])
#    domain = await sci.list_domain()
    sci.headers['Authorization'] = 'Bearer ' + os.environ['TOKEN']
    all_data = await sci.with_model(os.environ["MODEL"]).find_all()
    
    print("\n=== Prueba de find_all_generator ===\n")
    async for page_data in sci.with_model(os.environ["MODEL"]).find_all_generator():
        print(f"Número de registros en esta página: {len(page_data["results"])}")

    return all_data



sc = Sc(manage_loop=True)
sc.initialize(os.environ['DOMAIN'], os.environ['APP-KEY'], os.environ['SERVER_URL'])
loop = asyncio.new_event_loop()
data = loop.run_until_complete(main(sc))
print(os.environ["MODEL"])
print(len(data["results"]))
if "fetched_results" in data:
    for key in data["fetched_results"].keys():
        print(key)
        print(len(data["fetched_results"][key].keys()))


# def callback2(error, result):
#     if error is not None:
#         print(error)
#     else:
#         print(result)
#     sc.close_connection()
#
# def callback(error, result):
#     sc.with_model(os.environ['MODEL']).find_all_callback(callback2)
#     if error is not None:
#         print(error)
#     else:
#         print(result)

#sc.loginCallback(os.environ['LOGIN'], os.environ['PASSWORD'], os.environ['DOMAIN'],callback)

#loop.run_forever()