feat: refine IP reevaluation logic to include unanalyzed addresses
This commit is contained in:
@@ -790,16 +790,22 @@ class DatabaseManager:
|
|||||||
|
|
||||||
def get_ips_needing_reevaluation(self) -> List[str]:
|
def get_ips_needing_reevaluation(self) -> List[str]:
|
||||||
"""
|
"""
|
||||||
Get all IP addresses that have been flagged for reevaluation.
|
Get all IP addresses that need evaluation.
|
||||||
|
|
||||||
Returns:
|
Returns:
|
||||||
List of IP addresses where need_reevaluation is True
|
List of IP addresses where need_reevaluation is True
|
||||||
|
or that have never been analyzed (last_analysis is NULL)
|
||||||
"""
|
"""
|
||||||
session = self.session
|
session = self.session
|
||||||
try:
|
try:
|
||||||
ips = (
|
ips = (
|
||||||
session.query(IpStats.ip)
|
session.query(IpStats.ip)
|
||||||
.filter(IpStats.need_reevaluation == True)
|
.filter(
|
||||||
|
or_(
|
||||||
|
IpStats.need_reevaluation == True,
|
||||||
|
IpStats.last_analysis.is_(None),
|
||||||
|
)
|
||||||
|
)
|
||||||
.all()
|
.all()
|
||||||
)
|
)
|
||||||
return [ip[0] for ip in ips]
|
return [ip[0] for ip in ips]
|
||||||
|
|||||||
Reference in New Issue
Block a user