Commit 469d9d0
Changed files (1)
src
history
src/history/turso.py
@@ -252,7 +252,6 @@ async def get_table_name(client: Client, chat_id: str | int) -> str:
cache.set(f"tablename-{chat_id}", table_name, ttl=0)
# create table and index
- table_names = await turso_list_tables(HISTORY.TURSO_DATABASE, silent=True)
if table_name in table_names:
return table_name
await turso_create_table(table_name, DB_COLUMNS, HISTORY.TURSO_DATABASE)
@@ -278,7 +277,7 @@ async def create_table_index(slim_cid: str, table_name: str) -> None:
for idx_name in idx_names:
logger.debug(f"Creating index on {table_name} for {idx_name}")
resp = await turso_exec(
- [{"type": "execute", "stmt": {"sql": f'CREATE INDEX IF NOT EXISTS idx_{table_name}_{idx_name} ON "{table_name}"({idx_name})'}}],
+ [{"type": "execute", "stmt": {"sql": f'CREATE INDEX IF NOT EXISTS "idx_{slim_cid}_{idx_name}" ON "{table_name}"({idx_name})'}}],
db_name=HISTORY.TURSO_DATABASE,
silent=True,
)