thecoffemaker/Slixfeed
1
0
Fork 0
forked from sch/Slixfeed
Code Pull requests Activity

Don't create new connections while database is engaged

Browse source
This commit is contained in:
Schimon Jehudah 2022-11-23 12:18:12 +00:00
parent 2e23e93584
commit 52fad12660
1 changed files with 5 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
slixfeed.py
View file

@ -302,7 +302,7 @@ async def download_updates(db_file):
sql = "UPDATE feeds SET status = :status, scanned = :scanned WHERE address = :url" sql = "UPDATE feeds SET status = :status, scanned = :scanned WHERE address = :url"
async with DBLOCK: async with DBLOCK:
with create_connection(db_file) as conn: with conn:
cur = conn.cursor() cur = conn.cursor()
cur.execute(sql, {"status": res[1], "scanned": date.today(), "url": source}) cur.execute(sql, {"status": res[1], "scanned": date.today(), "url": source})
@ -320,7 +320,7 @@ async def download_updates(db_file):
valid = 1 valid = 1
sql = "UPDATE feeds SET valid = :validity WHERE address = :url" sql = "UPDATE feeds SET valid = :validity WHERE address = :url"
async with DBLOCK: async with DBLOCK:
with create_connection(db_file) as conn: with conn:
cur = conn.cursor() cur = conn.cursor()
cur.execute(sql, {"validity": valid, "url": source}) cur.execute(sql, {"validity": valid, "url": source})
except (IncompleteReadError, IncompleteRead, error.URLError) as e: except (IncompleteReadError, IncompleteRead, error.URLError) as e:
@ -331,7 +331,7 @@ async def download_updates(db_file):
entries = feed.entries entries = feed.entries
length = len(entries) length = len(entries)
async with DBLOCK: async with DBLOCK:
with create_connection(db_file) as conn: with conn:
await remove_entry(conn, source, length) await remove_entry(conn, source, length)
for entry in entries: for entry in entries:
@ -340,7 +340,7 @@ async def download_updates(db_file):
else: else:
title = feed["feed"]["title"] title = feed["feed"]["title"]
link = source if not entry.link else entry.link link = source if not entry.link else entry.link
with create_connection(db_file) as conn: with conn:
exist = await check_entry(conn, title, link) exist = await check_entry(conn, title, link)
if not exist: if not exist:
@ -355,7 +355,7 @@ async def download_updates(db_file):
#print('~~~~~~summary not in entry') #print('~~~~~~summary not in entry')
entry = (title, summary, link, source, 0); entry = (title, summary, link, source, 0);
async with DBLOCK: async with DBLOCK:
with create_connection(db_file) as conn: with conn:
await add_entry(conn, entry) await add_entry(conn, entry)
await set_date(conn, source) await set_date(conn, source)