[[dependency]]
type = "postgres"
alias = "users"
[[dependency]]
type = "rabbitmq"

cian-functional-test-utils deps up

@pytest.fixture(scope='session', autouse=True)
async def start(runner, pg):
    # Так как все микросервисы Циан имеют один и тот же интерфейс,
    # фреймворк знает как их запускать и куда идти за health-check.
    await runner.start_background_python_web()
    # Можно запускать и тестировать не только HTTP API, но и RabbitMQ консюмеры, кроны
    await runner.start_background_python_command('save-users-consumer')
@pytest.fixture(scope='session')
async def pg(postgres_service):
    db = await postgres_service.create_database_by_alias('users')
    # Используем `pathlib.Path` для кроссплатформенности.
    await db.execute_scripts(Path('database_schemas') / 'postgres.sql')
    return db

async def test_v1_get_user(http, pg):  # тот самый pg из conftest.py
    # arrange
    await pg.execute('INSERT INTO users (id, name) VALUES (1, "Bart")')
    # act
    response = await http.request('GET', '/v1/get-user/', params={'id': 1})
    # assert
    assert response.status == 200
    assert response.data == {'id': 1, 'name': 'Bart'}

async def test_save_users_consumer(pg, queue_service):
    # arrange
    # Перед каждым тестов все очереди RabbitMQ удаляются,
    # нужно подождать, пока консюмер пересоздаст её.
    await queue_service.wait_consumer(queue='save-users')
    # act
    await queue_service.publish(
        exchange='users',
        routing_key='user.created',
        payload={'id':1, 'name': 'Bart'},
    )
    await asyncio.sleep(0.5)  # Подождем немного, чтобы консюмер обработал сообщение
    # assert
    row = await pg.fetchrow('SELECT name FROM users WHERE id = 1')
    assert row['name'] == 'Bart'

@pytest.fixture(scope='session')
async def users_mock(http_mock_service):
    # Нужно лишь указать имя микросервиса, который мы хотим замокать,
    # фреймворк автоматически добавит URL мока в настройки микросервиса.
    return await http_mock_service.make_microservice_mock('users')
def test_something(users_mock):
    # arrange
    stub = await users_mock.add_stub(
        method='GET',
        path='/v1/get-user/',
        response=MockResponse(body={'firstName': 'Bart', 'lastName': 'Simpson'}),
    )
    # act
    # do something
    # assert
    # Проверяем, что запрос в мок был сделан с ?userId=234
    request = (await stub.get_requests())[0]
    assert request.params['userId'] == '234'