style(otp.py): 将清理验证码的定期日志降级为 debug,且增加清理计数
This commit is contained in:
@@ -42,15 +42,17 @@ class OtpMemoryStore(ABC):
|
|||||||
async def _cleanup(self) -> None:
|
async def _cleanup(self) -> None:
|
||||||
while True:
|
while True:
|
||||||
await asyncio.sleep(60)
|
await asyncio.sleep(60)
|
||||||
logger.info(f"[{self.type_name}] 开始定时清理过期验证码。")
|
logger.debug(f"[{self.type_name}] 开始定时清理过期验证码。")
|
||||||
expires = []
|
expires = []
|
||||||
|
count = 0
|
||||||
for address, item in self._store.items():
|
for address, item in self._store.items():
|
||||||
if item.expire_time < time.time():
|
if item.expire_time < time.time():
|
||||||
logger.debug(f"[{self.type_name}] 移除过期的 {address}")
|
logger.debug(f"[{self.type_name}] 移除过期的 {address}")
|
||||||
expires.append(address)
|
expires.append(address)
|
||||||
|
count += 1
|
||||||
for address in expires:
|
for address in expires:
|
||||||
self._store.pop(address)
|
self._store.pop(address)
|
||||||
logger.info(f"[{self.type_name}] 清理完成。")
|
logger.debug(f"[{self.type_name}] 清理完成,清理了 {count} 个过期验证码。")
|
||||||
|
|
||||||
def verify(self, address: str, user_id: int, verify_code: str) -> bool:
|
def verify(self, address: str, user_id: int, verify_code: str) -> bool:
|
||||||
item = self._store.get(address)
|
item = self._store.get(address)
|
||||||
|
|||||||
Reference in New Issue
Block a user