diff --git a/harnessed_reasoning/.init.py.swp b/harnessed_reasoning/.init.py.swp new file mode 100644 index 0000000..9237c08 Binary files /dev/null and b/harnessed_reasoning/.init.py.swp differ diff --git a/harnessed_reasoning/__pycache__/core.cpython-311.pyc b/harnessed_reasoning/__pycache__/core.cpython-311.pyc index 953f1d6..ca7eeaa 100644 Binary files a/harnessed_reasoning/__pycache__/core.cpython-311.pyc and b/harnessed_reasoning/__pycache__/core.cpython-311.pyc differ diff --git a/harnessed_reasoning/core.py b/harnessed_reasoning/core.py index 708f78f..ed80d9c 100644 --- a/harnessed_reasoning/core.py +++ b/harnessed_reasoning/core.py @@ -13,6 +13,7 @@ try: from ahserver.serverenv import ServerEnv from sqlor.dbpools import DBPools from appPublic.log import info, debug, warning, error, exception + from appPublic.jsonConfig import getConfig except ImportError: class ServerEnv: pass @@ -126,7 +127,8 @@ class HermesReasoningEngine: dbname = 'default' try: - db = DBPools() + config = getConfig() + db = DBPools(config.databases) async with db.sqlorContext(dbname) as sor: where = {} if user_id: @@ -197,7 +199,8 @@ class HermesReasoningEngine: skills = [] try: - db = DBPools() + config = getConfig() + db = DBPools(config.databases) async with db.sqlorContext('harnessed_reasoning') as sor: for kw in list(keywords)[:3]: rows = await sor.R('hermes_skills', { @@ -630,7 +633,8 @@ class HermesReasoningEngine: 'created_at': datetime.now(), 'updated_at': datetime.now(), } - db = DBPools() + config = getConfig() + db = DBPools(config.databases) async with db.sqlorContext('harnessed_reasoning') as sor: res = await sor.C('harnessed_reasoning_sessions', data) info(f"Session stored: {session_id}, result={res}") @@ -642,7 +646,8 @@ class HermesReasoningEngine: async def _update_session_status(self, session_id: str, status: str): """Update session status.""" try: - db = DBPools() + config = getConfig() + db = DBPools(config.databases) async with db.sqlorContext('harnessed_reasoning') as sor: await sor.U('harnessed_reasoning_sessions', { 'id': session_id, @@ -665,7 +670,8 @@ class HermesReasoningEngine: pass try: - db = DBPools() + config = getConfig() + db = DBPools(config.databases) async with db.sqlorContext('harnessed_reasoning') as sor: filters = {'id': session_id} if user_id: @@ -702,7 +708,8 @@ class HermesReasoningEngine: pass try: - db = DBPools() + config = getConfig() + db = DBPools(config.databases) async with db.sqlorContext('harnessed_reasoning') as sor: rows = await sor.R('harnessed_reasoning_sessions', {'user_id': user_id, 'sort': 'created_at desc'}) rows = rows or []