"""Практика к уроку про идемпотентность: три ответа и одна цена.

ЗАЧЕМ ОТДЕЛЬНЫЙ ФАЙЛ. Задачи урока проверяются сборкой
(scripts/validate-practice.mjs): показанный читателю код обязан построчно быть
в скрипте, верный вариант — дословно встречаться в записи прогона, а
заявленное число — печататься самой программой.

ЧТО ЗДЕСЬ ПРОВЕРЯЕТСЯ. Два места, где ошибаются чаще всего. Первое: сколько
раз применяется эффект при четырёх повторах без ключа, с ключом и при
одновременных повторах, когда ключ записан после работы. Второе: во сколько
раз больше эффектов даёт новый ключ на каждую попытку.

Сервис и клиент берутся из `keys.py`, чтобы задача и разбор урока стояли на
одном и том же коде.

ЗАПУСК: python3 bench/idempotency/practice.py
Вывод: runs/practice.txt
"""

import os
import sys
import threading

sys.path.insert(0, os.path.dirname(os.path.abspath(__file__)))

from keys import Service, call  # noqa: E402


def retries(use_keys: bool, times: int = 4) -> int:
    """Сколько раз применился эффект при `times` одинаковых повторах."""
    service = Service(use_keys=use_keys)
    for _ in range(times):
        call(service.port, "order-1")
    applied = service.applied
    service.close()
    return applied


def simultaneous(claim_key: bool) -> int:
    """Два повтора в один момент: ключ занимают до работы или пишут после."""
    service = Service(use_keys=True, slow_reply=0.05, claim_key=claim_key)
    threads = [
        threading.Thread(target=call, args=(service.port, "order-2")) for _ in range(2)
    ]
    for thread in threads:
        thread.start()
    for thread in threads:
        thread.join()
    applied = service.applied
    service.close()
    return applied


def fresh_key_each_time(times: int = 3) -> int:
    """Новый ключ на каждую попытку: сколько эффектов."""
    service = Service(use_keys=True)
    for i in range(times):
        call(service.port, f"attempt-{i}")
    applied = service.applied
    service.close()
    return applied


def main() -> None:
    print(f"Python {sys.version.split()[0]} · Linux {os.uname().release} · loopback")
    print("an effect is one increment of a counter: the thing that must not happen twice")
    print()

    # --- Часть 1: три ответа о поведении --------------------------------
    without_key = retries(use_keys=False)
    with_key = retries(use_keys=True)
    late_key = simultaneous(claim_key=False)
    print(without_key)
    print(with_key)
    print(late_key)

    # --- Часть 2: цена нового ключа на каждую попытку --------------------
    #
    # ПОЧЕМУ КРАТНОСТЬ ПЕЧАТАЕТ ПРОГРАММА. Деление в уме на стороне редакции —
    # ровно тот шаг, где вкрадывается ошибка, которую потом нечем поймать.
    one_key = retries(use_keys=True, times=3)
    many_keys = fresh_key_each_time(3)
    print()
    print(f"attempts in each case                {3}")
    print(f"effects with one key                 {one_key}")
    print(f"effects with a new key each time     {many_keys}")
    print(f"times more effects                   {many_keys / one_key:.1f}")


if __name__ == "__main__":
    main()