[WIP] refactor and add async beacon api

Author: fselmo

tests/beacon/conftest.py

@@ -0,0 +1,4 @@
+def assert_valid_response(response):
+    # assert valid response according to Beacon API spec
+    assert isinstance(response, dict)
+    assert "data" in response

tests/beacon/test_async_beacon.py

@@ -0,0 +1,206 @@
+import pytest
+from random import (
+    randint,
+)
+
+import pytest_asyncio
+
+from web3.beacon import (
+    AsyncBeacon,
+)
+
+from .conftest import (
+    assert_valid_response,
+)
+
+
+@pytest_asyncio.fixture()
+async def async_beacon():
+    return AsyncBeacon(base_url="http://localhost:5051")
+
+
+# Beacon endpoint tests:
+
+
+@pytest.mark.asyncio
+async def test_async_cl_beacon_get_genesis(async_beacon):
+    response = await async_beacon.get_genesis()
+    assert_valid_response(response)
+
+
+@pytest.mark.asyncio
+async def test_async_cl_beacon_get_hash_root(async_beacon):
+    response = await async_beacon.get_hash_root()
+    assert_valid_response(response)
+
+
+@pytest.mark.asyncio
+async def test_async_cl_beacon_get_fork_data(async_beacon):
+    response = await async_beacon.get_fork_data()
+    assert_valid_response(response)
+
+
+@pytest.mark.asyncio
+async def test_async_cl_beacon_get_finality_checkpoint(async_beacon):
+    response = await async_beacon.get_finality_checkpoint()
+    assert_valid_response(response)
+
+
+@pytest.mark.asyncio
+async def test_async_cl_beacon_get_validators(async_beacon):
+    response = await async_beacon.get_validators()
+    assert_valid_response(response)
+
+
+@pytest.mark.asyncio
+async def test_async_cl_beacon_get_validator(async_beacon):
+    validators_response = await async_beacon.get_validators()
+    assert_valid_response(validators_response)
+
+    validators = validators_response["data"]
+    random_validator = validators[randint(0, len(validators))]
+    random_validator_pubkey = random_validator["validator"]["pubkey"]
+
+    response = await async_beacon.get_validator(random_validator_pubkey)
+    assert_valid_response(response)
+
+
+@pytest.mark.asyncio
+async def test_async_cl_beacon_get_validator_balances(async_beacon):
+    response = await async_beacon.get_validator_balances()
+    assert_valid_response(response)
+
+
+@pytest.mark.asyncio
+async def test_async_cl_beacon_get_epoch_committees(async_beacon):
+    response = await async_beacon.get_epoch_committees()
+    assert_valid_response(response)
+
+
+@pytest.mark.asyncio
+async def test_async_cl_beacon_get_block_headers(async_beacon):
+    response = await async_beacon.get_block_headers()
+    assert_valid_response(response)
+
+
+@pytest.mark.asyncio
+async def test_async_cl_beacon_get_block_header(async_beacon):
+    response = await async_beacon.get_block_header("head")
+    assert_valid_response(response)
+
+
+@pytest.mark.asyncio
+async def test_async_cl_beacon_get_block(async_beacon):
+    response = await async_beacon.get_block("head")
+    assert_valid_response(response)
+
+
+@pytest.mark.asyncio
+async def test_async_cl_beacon_get_block_root(async_beacon):
+    response = await async_beacon.get_block_root("head")
+    assert_valid_response(response)
+
+
+@pytest.mark.asyncio
+async def test_async_cl_beacon_get_block_attestations(async_beacon):
+    response = await async_beacon.get_block_attestations("head")
+    assert_valid_response(response)
+
+
+@pytest.mark.asyncio
+async def test_async_cl_beacon_get_attestations(async_beacon):
+    response = await async_beacon.get_attestations()
+    assert_valid_response(response)
+
+
+@pytest.mark.asyncio
+async def test_async_cl_beacon_get_attester_slashings(async_beacon):
+    response = await async_beacon.get_attester_slashings()
+    assert_valid_response(response)
+
+
+@pytest.mark.asyncio
+async def test_async_cl_beacon_get_proposer_slashings(async_beacon):
+    response = await async_beacon.get_proposer_slashings()
+    assert_valid_response(response)
+
+
+@pytest.mark.asyncio
+async def test_async_cl_beacon_get_voluntary_exits(async_beacon):
+    response = await async_beacon.get_voluntary_exits()
+    assert_valid_response(response)
+
+
+# Config endpoint tests:
+
+
+@pytest.mark.asyncio
+async def test_async_cl_config_get_fork_schedule(async_beacon):
+    response = await async_beacon.get_fork_schedule()
+    assert_valid_response(response)
+
+
+@pytest.mark.asyncio
+async def test_async_cl_config_get_spec(async_beacon):
+    response = await async_beacon.get_spec()
+    assert_valid_response(response)
+
+
+@pytest.mark.asyncio
+async def test_async_cl_config_get_deposit_contract(async_beacon):
+    response = await async_beacon.get_deposit_contract()
+    assert_valid_response(response)
+
+
+# Debug endpoint test_asyncs:
+
+
+@pytest.mark.asyncio
+async def test_async_cl_debug_get_beacon_state(async_beacon):
+    response = await async_beacon.get_beacon_state()
+    assert_valid_response(response)
+
+
+@pytest.mark.asyncio
+async def test_async_cl_debug_get_beacon_heads(async_beacon):
+    response = await async_beacon.get_beacon_heads()
+    assert_valid_response(response)
+
+
+# Node endpoint test_asyncs:
+
+
+@pytest.mark.asyncio
+async def test_async_cl_node_get_node_identity(async_beacon):
+    response = await async_beacon.get_node_identity()
+    assert_valid_response(response)
+
+
+@pytest.mark.asyncio
+async def test_async_cl_node_get_peers(async_beacon):
+    response = await async_beacon.get_peers()
+    assert_valid_response(response)
+
+
+@pytest.mark.asyncio
+async def test_async_cl_node_get_peer(async_beacon):
+    response = await async_beacon.get_peer("")
+    assert_valid_response(response)
+
+
+@pytest.mark.asyncio
+async def test_async_cl_node_get_health(async_beacon):
+    response = await async_beacon.get_health()
+    assert response <= 206
+
+
+@pytest.mark.asyncio
+async def test_async_cl_node_get_version(async_beacon):
+    response = await async_beacon.get_version()
+    assert_valid_response(response)
+
+
+@pytest.mark.asyncio
+async def test_async_cl_node_get_syncing(async_beacon):
+    response = await async_beacon.get_syncing()
+    assert_valid_response(response)