Do webhook validation before handling

Author: zhiltsov-max

packages/examples/cvat/recording-oracle/src/crons/process_exchange_oracle_webhooks.py

@@ -1,8 +1,10 @@
 import logging
 
+from human_protocol_sdk.constants import Status as EscrowStatus
 from sqlalchemy.orm import Session
 
 import src.services.webhook as oracle_db_service
+from src.chain.escrow import validate_escrow
 from src.chain.kvstore import get_exchange_oracle_url
 from src.core.config import Config
 from src.core.types import ExchangeOracleEventTypes, OracleWebhookTypes
@@ -35,12 +37,20 @@ def handle_exchange_oracle_event(webhook: Webhook, *, db_session: Session):
 
     match webhook.event_type:
         case ExchangeOracleEventTypes.job_finished:
+            validate_escrow(webhook.chain_id, webhook.escrow_address)
+
             validate_results(
                 escrow_address=webhook.escrow_address,
                 chain_id=webhook.chain_id,
                 db_session=db_session,
             )
         case ExchangeOracleEventTypes.escrow_cleaned:
+            validate_escrow(
+                webhook.chain_id,
+                webhook.escrow_address,
+                accepted_states=[EscrowStatus.Pending, EscrowStatus.Cancelled],
+            )
+
             clean_escrow(
                 db_session, escrow_address=webhook.escrow_address, chain_id=webhook.chain_id
             )

packages/examples/cvat/recording-oracle/src/handlers/validation.py

@@ -214,8 +214,6 @@ def validate_results(
 ):
     logger = get_function_logger(module_logger_name)
 
-    escrow.validate_escrow(chain_id=chain_id, escrow_address=escrow_address)
-
     manifest = parse_manifest(escrow.get_escrow_manifest(chain_id, escrow_address))
 
     validator = _TaskValidator(