Malin/krawl.es
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

code linting

Browse Source
This commit is contained in:
Lorenzo Venerandi
2026-02-22 16:27:59 +01:00
parent 57fa0ae5a3
commit b500b22041
4 changed files with 7 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/database.py
View File

@@ -358,9 +358,7 @@ class DatabaseManager:
session = self.session session = self.session
try: try:
sanitized_ip = sanitize_ip(ip) sanitized_ip = sanitize_ip(ip)
ip_stats = ( ip_stats = session.query(IpStats).filter(IpStats.ip == sanitized_ip).first()
session.query(IpStats).filter(IpStats.ip == sanitized_ip).first()
)
if not ip_stats: if not ip_stats:
now = datetime.now() now = datetime.now()
@@ -406,9 +404,7 @@ class DatabaseManager:
session = self.session session = self.session
try: try:
sanitized_ip = sanitize_ip(ip) sanitized_ip = sanitize_ip(ip)
ip_stats = ( ip_stats = session.query(IpStats).filter(IpStats.ip == sanitized_ip).first()
session.query(IpStats).filter(IpStats.ip == sanitized_ip).first()
)
if not ip_stats or ip_stats.ban_timestamp is None: if not ip_stats or ip_stats.ban_timestamp is None:
return False return False
@@ -445,9 +441,7 @@ class DatabaseManager:
session = self.session session = self.session
try: try:
sanitized_ip = sanitize_ip(ip) sanitized_ip = sanitize_ip(ip)
ip_stats = ( ip_stats = session.query(IpStats).filter(IpStats.ip == sanitized_ip).first()
session.query(IpStats).filter(IpStats.ip == sanitized_ip).first()
)
if not ip_stats: if not ip_stats:
return { return {

4
src/migrations/runner.py
View File

@@ -59,9 +59,7 @@ def _migrate_ban_state_columns(cursor) -> List[str]:
} }
for col_name, col_type in columns.items(): for col_name, col_type in columns.items():
if not _column_exists(cursor, "ip_stats", col_name): if not _column_exists(cursor, "ip_stats", col_name):
cursor.execute( cursor.execute(f"ALTER TABLE ip_stats ADD COLUMN {col_name} {col_type}")
f"ALTER TABLE ip_stats ADD COLUMN {col_name} {col_type}"
)
added.append(col_name) added.append(col_name)
return added return added

4
src/tasks/analyze_ips.py
View File

@@ -98,7 +98,9 @@ def main():
ips_to_analyze = set(db_manager.get_ips_needing_reevaluation()) ips_to_analyze = set(db_manager.get_ips_needing_reevaluation())
if not ips_to_analyze: if not ips_to_analyze:
app_logger.debug("[Background Task] analyze-ips: No IPs need reevaluation, skipping") app_logger.debug(
"[Background Task] analyze-ips: No IPs need reevaluation, skipping"
)
return return
for ip in ips_to_analyze: for ip in ips_to_analyze:

1
src/tracker.py
View File

@@ -435,4 +435,3 @@ class AccessTracker:
stats["credential_attempts"] = self.db.get_credential_attempts(limit=50) stats["credential_attempts"] = self.db.get_credential_attempts(limit=50)
return stats return stats