check_distributor

async def fetch_clawback_dt(address: str) -> datetime | None:
    """
        Tries to find clawback IX for a given Distributor address.

        Ideally it should be the last transaction, but it can happen so that
        after clawback there are some failed transaction that will be returned by this method.

        So we iterate over the whole page that `get_signatures_for_address` returns.

    Args:
        address: address of the Distributor

    Returns:
        datetime of clawback, parsed from `block_time` of the clawback transaction
    """
    async with AsyncClient(settings.SOLANA_RPC_URL) as client:
        signatures = await client.get_signatures_for_address(Pubkey.from_string(address))
        for sig in signatures.value:
            tx = await client.get_transaction(sig.signature, max_supported_transaction_version=1)
            if not tx.value or not tx.value.block_time:
                continue
            transaction = tx.value.transaction.transaction
            if not hasattr(transaction, "message"):
                continue
            for ix in transaction.message.instructions:
                if getattr(ix, "data", None) == CLAWBACK_IX_ENCODED:
                    return datetime.fromtimestamp(tx.value.block_time)
    return None