This commit is contained in:
Em 2021-07-08 10:11:00 -04:00
parent 574792b8f2
commit e8a6a37934
1 changed files with 6 additions and 6 deletions

View File

@ -1,6 +1,6 @@
import asyncpg import asyncpg
import yaml import yaml
from datetime import datetime, timedelta from datetime import datetime, timedelta, timezone
from ipaddress import ip_address from ipaddress import ip_address
from sanic import Sanic, response from sanic import Sanic, response
@ -30,7 +30,7 @@ async def add(request):
proxy["ip"], proxy["ip"],
int(proxy["port"]), int(proxy["port"]),
proxy["proxy_type"], proxy["proxy_type"],
datetime.now(tz='UTC'), datetime.now(tz=timezone.utc),
proxy.get("comment", ""), proxy.get("comment", ""),
) )
) )
@ -68,7 +68,7 @@ async def getproxies(request):
select_query, select_query,
["unscanned"], ["unscanned"],
max_num_failures, max_num_failures,
datetime.now(tz='UTC'), datetime.now(tz=timezone.utc),
proxy_types, proxy_types,
amount, amount,
) )
@ -79,7 +79,7 @@ async def getproxies(request):
select_query, select_query,
["active", "inactive"], ["active", "inactive"],
max_num_failures, max_num_failures,
datetime.now(tz='UTC') - timedelta(seconds=tdelta), datetime.now(tz=timezone.utc) - timedelta(seconds=tdelta),
proxy_types, proxy_types,
amount - len(proxies), amount - len(proxies),
) )
@ -111,7 +111,7 @@ async def updateproxies(request):
proxy["exit_ip"], proxy["exit_ip"],
proxy["proxy_type"], proxy["proxy_type"],
proxy["status"], proxy["status"],
datetime.now(tz='UTC'), datetime.now(tz=timezone.utc),
proxy["comment"], proxy["comment"],
proxy["id"] proxy["id"]
) )
@ -119,7 +119,7 @@ async def updateproxies(request):
await connection.fetch( await connection.fetch(
update_inactive_query, update_inactive_query,
proxy["status"], proxy["status"],
datetime.now(tz='UTC'), datetime.now(tz=timezone.utc),
proxy["comment"], proxy["comment"],
proxy["id"] proxy["id"]
) )