jackc/slop-farmer-server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

ran tests against a local sqlite DB

Browse Source 
reports appear to work properly now, will run prod DB migrations and upgrade the server container when I'm home.
This commit is contained in:
Jack Case
2025-10-29 15:30:02 +00:00
parent e420a31127
commit b35c92b96f
1 changed files with 12 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
slopserver/db.py
View File

@@ -38,7 +38,9 @@ def insert_slop(urls: list[ParseResult], engine: Engine, user: User | None = Non
for path in paths: for path in paths:
new_path = Path(path=path) new_path = Path(path=path)
if user: if user:
new_path.reports = list().append(Report(path=new_path, user=user, timestamp=datetime.now())) reports = list()
reports.append(Report(path=new_path, user=user, timestamp=datetime.now()))
new_path.reports = reports
new_paths.append(new_path) new_paths.append(new_path)
new_domain.paths = new_paths new_domain.paths = new_paths
session.add(new_domain) session.add(new_domain)
@@ -50,7 +52,9 @@ def insert_slop(urls: list[ParseResult], engine: Engine, user: User | None = Non
if not path in existing_paths: if not path in existing_paths:
new_path = Path(path=path) new_path = Path(path=path)
if user: if user:
new_path.reports = list().append(Report(path=new_path, user=user, timestamp=datetime.now())) report_list = list()
report_list.append(Report(path=new_path, user=user, timestamp=datetime.now()))
new_path.reports = report_list
existing_domain.paths.append(new_path) existing_domain.paths.append(new_path)
session.add(new_path) session.add(new_path)
@@ -58,7 +62,12 @@ def insert_slop(urls: list[ParseResult], engine: Engine, user: User | None = Non
# domain and path exist, append to the path's reports # domain and path exist, append to the path's reports
if user: if user:
existing_path = existing_paths.get(path) existing_path = existing_paths.get(path)
existing_path.reports.append(Report(path=new_path, user=user, timestamp=datetime.now())) report_dict = {(report.user.id, report.path.id): report for report in existing_path.reports}
existing_report = report_dict.get((user.id, existing_path.id))
if existing_report:
existing_report.timestamp = datetime.now()
else:
existing_path.reports.append(Report(path=existing_path, user=user, timestamp=datetime.now()))
session.commit() session.commit()