gavindiaz/PolyWeather
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: add payment event loop for scanning blockchain and processing payment intents.

Browse Source
This commit is contained in:
2569718930@qq.com
2026-03-14 13:06:03 +08:00
parent c1fb52551d
commit 2397a7569b
1 changed files with 13 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/payments/event_loop.py
+13 -7
View File
@@ -42,6 +42,13 @@ def _normalize_address(address: Any) -> str:
return Web3.to_checksum_address(text).lower() return Web3.to_checksum_address(text).lower()
def _checksum_address(address: Any) -> str:
text = str(address or "").strip()
if not text or not Web3.is_address(text):
return ""
return Web3.to_checksum_address(text)
def _to_hex(value: Any) -> str: def _to_hex(value: Any) -> str:
try: try:
return str(Web3.to_hex(value or b"")).lower() return str(Web3.to_hex(value or b"")).lower()
@@ -195,13 +202,12 @@ def _runner() -> None:
max_events = _env_int("POLYWEATHER_PAYMENT_EVENT_LOOP_MAX_EVENTS_PER_CYCLE", 200, 10) max_events = _env_int("POLYWEATHER_PAYMENT_EVENT_LOOP_MAX_EVENTS_PER_CYCLE", 200, 10)
state_path = _state_file() state_path = _state_file()
receiver_contracts = sorted( receiver_contract_set: set[str] = set()
{ for token in PAYMENT_CHECKOUT.supported_tokens.values():
_normalize_address(token.receiver_contract) checksum_addr = _checksum_address(token.receiver_contract)
for token in PAYMENT_CHECKOUT.supported_tokens.values() if checksum_addr:
if _normalize_address(token.receiver_contract) receiver_contract_set.add(checksum_addr)
} receiver_contracts = sorted(receiver_contract_set)
)
if not receiver_contracts: if not receiver_contracts:
logger.warning("payment event loop skipped: no receiver contract configured") logger.warning("payment event loop skipped: no receiver contract configured")
return return