tests/test_followup_admission.py

_Hub · class · L43-L48 — class _Hub
emitter · method · L44-L45 — def emitter(self, root_frame_id)
broadcast · method · L47-L48 — def broadcast(self, root_frame_id, event)
_Client · class · L51-L114 — class _Client
init · method · L59-L71 — def init(self, tmp_path)
post · method · L73-L91 — def post(self, path, body)
_send · function · L78-L80 — def _send(code, payload, ctype, extra=None)
post_method · method · L93-L111 — def post_method(self, method, path, body)
_send · function · L98-L100 — def _send(code, payload, ctype, extra=None)
message · method · L113-L114 — def message(self, text, **extra)
client · function · L118-L162 — def client(tmp_path)
hook · function · L137-L139 — def hook(args)
test_a_message_that_would_brick_the_session_is_refused · function · L170-L180 — def test_a_message_that_would_brick_the_session_is_refused(client)
test_the_refusal_happens_before_anything_is_written_or_queued · function · L183-L189 — def test_the_refusal_happens_before_anything_is_written_or_queued(client)
test_a_client_that_does_not_wait_is_refused_just_as_loudly · function · L192-L198 — def test_a_client_that_does_not_wait_is_refused_just_as_loudly(client)
test_an_ordinary_long_paste_still_goes_through · function · L201-L209 — def test_an_ordinary_long_paste_still_goes_through(client)
test_the_cap_governs_typed_text_and_not_referenced_files · function · L212-L227 — def test_the_cap_governs_typed_text_and_not_referenced_files(client)
test_a_dangling_model_pin_is_a_conflict_not_a_two_hundred · function · L235-L244 — def test_a_dangling_model_pin_is_a_conflict_not_a_two_hundred(client)
test_the_identity_is_frozen_when_send_is_pressed · function · L247-L255 — def test_the_identity_is_frozen_when_send_is_pressed(client)
_hold_the_head · function · L263-L293 — def _hold_the_head(client)
_hold · function · L279-L282 — def _hold()
_finish · function · L288-L291 — def _finish()
_fill_the_queue · function · L296-L302 — def _fill_the_queue(client)
test_a_full_queue_says_so_instead_of_claiming_a_server_fault · function · L305-L315 — def test_a_full_queue_says_so_instead_of_claiming_a_server_fault(client)
test_the_cap_is_reached_by_queueing_and_not_by_a_single_message · function · L318-L329 — def test_the_cap_is_reached_by_queueing_and_not_by_a_single_message(client)
_pin · function · L337-L346 — def _pin(client, *, body="look at this peak")
_status · function · L349-L350 — def _status(client, annotation_id)
test_a_refused_message_does_not_burn_the_pins_it_carried · function · L353-L378 — def test_a_refused_message_does_not_burn_the_pins_it_carried(client)
test_an_accepted_message_still_consumes_them · function · L381-L391 — def test_an_accepted_message_still_consumes_them(client)
test_an_already_sent_pin_does_not_re_enter_a_prompt · function · L399-L420 — def test_an_already_sent_pin_does_not_re_enter_a_prompt(client)
spy · function · L409-L411 — def spy(frame, project, text, args, *kwargs)
test_a_repeated_id_is_carried_once · function · L423-L440 — def test_a_repeated_id_is_carried_once(client)
spy · function · L428-L430 — def spy(frame, project, text, args, *kwargs)
test_two_concurrent_requests_do_not_both_carry_one_pin · function · L443-L480 — def test_two_concurrent_requests_do_not_both_carry_one_pin(client)
spy · function · L458-L461 — def spy(frame, project, text, args, *kwargs)
send · function · L465-L467 — def send(label)
test_a_finalize_failure_after_acceptance_is_not_reported_as_a_refusal · function · L483-L499 — def test_a_finalize_failure_after_acceptance_is_not_reported_as_a_refusal( client, monkeypatch )
boom · function · L492-L493 — def boom(reservation_id)
test_a_refused_message_releases_only_its_own_reservation · function · L502-L511 — def test_a_refused_message_releases_only_its_own_reservation(client)
test_an_id_that_is_not_a_string_never_reaches_the_query · function · L514-L524 — def test_an_id_that_is_not_a_string_never_reaches_the_query(client)
test_the_accepted_answer_says_what_became_of_the_pins · function · L527-L535 — def test_the_accepted_answer_says_what_became_of_the_pins(client)
test_a_message_with_no_pins_says_nothing_about_them · function · L538-L544 — def test_a_message_with_no_pins_says_nothing_about_them(client)
test_a_pending_consume_is_reported_as_pending · function · L547-L558 — def test_a_pending_consume_is_reported_as_pending(client, monkeypatch)
boom · function · L548-L549 — def boom(reservation_id)
_reserve · function · L566-L571 — def _reserve(client, annotation_id, reservation_id="resv-test")
test_a_reserved_pin_cannot_be_edited_out_from_under_the_turn · function · L574-L585 — def test_a_reserved_pin_cannot_be_edited_out_from_under_the_turn(client)
test_a_reserved_pin_cannot_be_deleted_out_from_under_the_turn · function · L588-L595 — def test_a_reserved_pin_cannot_be_deleted_out_from_under_the_turn(client)
test_an_open_pin_is_still_editable_and_deletable · function · L598-L607 — def test_an_open_pin_is_still_editable_and_deletable(client)
test_a_finalize_names_the_exact_set_it_reserved · function · L610-L638 — def test_a_finalize_names_the_exact_set_it_reserved(client)
test_a_zero_row_claim_reports_none_rather_than_sent · function · L641-L651 — def test_a_zero_row_claim_reports_none_rather_than_sent(client)
test_a_reservation_cannot_be_released_from_another_frame · function · L654-L690 — def test_a_reservation_cannot_be_released_from_another_frame(client, tmp_path)
test_a_reservation_id_is_unique_enough_to_be_a_key · function · L693-L707 — def test_a_reservation_id_is_unique_enough_to_be_a_key(client)
test_the_waiting_branch_reports_the_same_admission_facts · function · L710-L722 — def test_the_waiting_branch_reports_the_same_admission_facts(client)
test_the_waiting_branch_reports_pending_too · function · L725-L735 — def test_the_waiting_branch_reports_pending_too(client, monkeypatch)
boom · function · L726-L727 — def boom(args, *kwargs)
test_an_accepted_admission_is_recorded_with_its_correlation · function · L743-L761 — def test_an_accepted_admission_is_recorded_with_its_correlation(client)
test_a_reconcile_answers_what_happened_to_a_lost_response · function · L764-L775 — def test_a_reconcile_answers_what_happened_to_a_lost_response(client)
test_a_reconcile_from_another_frame_learns_nothing · function · L778-L789 — def test_a_reconcile_from_another_frame_learns_nothing(client)
test_a_refused_admission_is_recorded_as_released · function · L792-L802 — def test_a_refused_admission_is_recorded_as_released(client)
test_a_reservation_stranded_by_a_crash_is_recovered_at_startup · function · L805-L829 — def test_a_reservation_stranded_by_a_crash_is_recovered_at_startup(client, tmp_path)
test_a_packaged_session_does_not_export_a_live_reservation · function · L832-L860 — def test_a_packaged_session_does_not_export_a_live_reservation(client, tmp_path)
test_a_checkpoint_restores_a_reserved_pin_as_open · function · L863-L895 — def test_a_checkpoint_restores_a_reserved_pin_as_open(client)
_second_store · function · L908-L911 — def _second_store(client)
_pin_on · function · L914-L922 — def _pin_on(store, frame, body="pin")
test_an_edit_cannot_race_a_reservation_taken_on_another_connection · function · L925-L947 — def test_an_edit_cannot_race_a_reservation_taken_on_another_connection(client)
test_a_delete_cannot_race_a_reservation_taken_on_another_connection · function · L950-L962 — def test_a_delete_cannot_race_a_reservation_taken_on_another_connection(client)
test_a_public_edit_cannot_invent_a_status · function · L966-L973 — def test_a_public_edit_cannot_invent_a_status(client, status)
test_a_failed_finalize_changes_zero_rows · function · L976-L1013 — def test_a_failed_finalize_changes_zero_rows(client)
test_one_reservation_id_cannot_be_used_in_two_frames · function · L1016-L1051 — def test_one_reservation_id_cannot_be_used_in_two_frames(client)
test_a_ledger_failure_leaves_no_reserved_pin_behind · function · L1054-L1094 — def test_a_ledger_failure_leaves_no_reserved_pin_behind(client, monkeypatch)
_Flaky · class · L1066-L1081 — class _Flaky
getattr · method · L1074-L1075 — def getattr(self, name)
execute · method · L1077-L1081 — def execute(self, sql, args, *kwargs)
test_a_generated_admission_id_carries_full_entropy · function · L1097-L1110 — def test_a_generated_admission_id_carries_full_entropy(client)
test_a_finalize_interleaved_by_another_connection_is_still_all_or_none · function · L1113-L1186 — def test_a_finalize_interleaved_by_another_connection_is_still_all_or_none(client)
hooked · function · L1142-L1146 — def hooked()
interfere · function · L1150-L1158 — def interfere()
test_the_reconcile_route_answers_a_client_whose_answer_was_lost · function · L1189-L1202 — def test_the_reconcile_route_answers_a_client_whose_answer_was_lost(client)
test_the_reconcile_route_is_scoped_to_the_frame · function · L1205-L1215 — def test_the_reconcile_route_is_scoped_to_the_frame(client)
test_the_public_routes_refuse_a_held_pin_over_http · function · L1218-L1233 — def test_the_public_routes_refuse_a_held_pin_over_http(client)
test_an_unknown_status_is_a_client_error_not_a_crash · function · L1236-L1240 — def test_an_unknown_status_is_a_client_error_not_a_crash(client)
test_a_client_supplied_admission_id_survives_a_lost_response · function · L1243-L1269 — def test_a_client_supplied_admission_id_survives_a_lost_response(client)
test_a_replayed_admission_id_is_refused · function · L1272-L1293 — def test_a_replayed_admission_id_is_refused(client)
test_a_malformed_admission_id_is_a_client_error · function · L1297-L1304 — def test_a_malformed_admission_id_is_a_client_error(client, bad)
test_a_real_package_roundtrip_normalises_a_mid_flight_pin · function · L1307-L1364 — def test_a_real_package_roundtrip_normalises_a_mid_flight_pin(client, tmp_path)
test_startup_releases_pins_a_dead_process_left_held · function · L1367-L1404 — def test_startup_releases_pins_a_dead_process_left_held(tmp_path)
test_a_claim_that_got_nothing_leaves_no_live_ledger_row · function · L1407-L1434 — def test_a_claim_that_got_nothing_leaves_no_live_ledger_row(client)
test_the_consume_and_its_ledger_row_move_in_one_transaction · function · L1437-L1473 — def test_the_consume_and_its_ledger_row_move_in_one_transaction(client)
test_a_send_stays_sent_after_the_pin_is_resolved · function · L1476-L1510 — def test_a_send_stays_sent_after_the_pin_is_resolved(client)
test_a_release_and_its_ledger_row_move_in_one_transaction · function · L1513-L1532 — def test_a_release_and_its_ledger_row_move_in_one_transaction(client)
test_an_accepted_turn_that_claimed_nothing_still_records_its_job · function · L1535-L1562 — def test_an_accepted_turn_that_claimed_nothing_still_records_its_job(client)
test_a_refused_request_records_no_job_at_all · function · L1565-L1586 — def test_a_refused_request_records_no_job_at_all(client)
test_the_admission_route_refuses_a_session_that_no_longer_exists · function · L1589-L1617 — def test_the_admission_route_refuses_a_session_that_no_longer_exists(client)
test_the_admission_route_does_not_lean_on_the_deletion_cascade · function · L1620-L1653 — def test_the_admission_route_does_not_lean_on_the_deletion_cascade(client)
test_a_child_frame_cannot_be_admitted_against · function · L1656-L1682 — def test_a_child_frame_cannot_be_admitted_against(client)
test_a_frame_that_does_not_exist_cannot_be_admitted_against · function · L1685-L1702 — def test_a_frame_that_does_not_exist_cannot_be_admitted_against(client)
test_a_pin_cannot_be_filed_against_a_child_frame · function · L1705-L1722 — def test_a_pin_cannot_be_filed_against_a_child_frame(client)
_watch_thread_start · class · L1725-L1745 — class _watch_thread_start
init · method · L1732-L1742 — def init(self)
_spy · function · L1737-L1740 — def _spy(thread, args, *kwargs)
stop · method · L1744-L1745 — def stop(self)
_watch_run_message · function · L1748-L1763 — def _watch_run_message(client)
_spy · function · L1758-L1760 — def _spy(args, *kwargs)
_assert_clean_refusal · function · L1766-L1788 — def _assert_clean_refusal(client, reservation, annotation_id)
_zero_claim_pin · function · L1791-L1802 — def _zero_claim_pin(client)
test_a_ledger_write_failure_does_not_produce_an_accepted_uncorrelated_turn · function · L1814-L1877 — def test_a_ledger_write_failure_does_not_produce_an_accepted_uncorrelated_turn( client, fault )
_fail_once · function · L1837-L1851 — def _fail_once(args, *kwargs)
test_the_correlation_is_durable_before_the_worker_can_read_it · function · L1880-L1918 — def test_the_correlation_is_durable_before_the_worker_can_read_it(client)
_observe · function · L1895-L1897 — def _observe(args, *kwargs)
test_an_unstartable_worker_is_not_reported_as_accepted_either · function · L1921-L1947 — def test_an_unstartable_worker_is_not_reported_as_accepted_either(client)
_refuse · function · L1929-L1932 — def _refuse(self, args, *kwargs)
test_a_recovery_sweep_cannot_overwrite_a_finalize_that_won · function · L1950-L2021 — def test_a_recovery_sweep_cannot_overwrite_a_finalize_that_won(client)
_hold · function · L1979-L1985 — def _hold(args, *kwargs): # Called between finalize_sent's SELECT and its UPDATE, which is # inside its BEGIN IMMEDIATE. Holding here holds the write lock.
_finalize · function · L1989-L1998 — def _finalize()
test_a_recovery_sweep_refuses_a_partial_or_empty_hold · function · L2024-L2060 — def test_a_recovery_sweep_refuses_a_partial_or_empty_hold(client)
test_a_release_refuses_a_partial_or_empty_hold · function · L2063-L2110 — def test_a_release_refuses_a_partial_or_empty_hold(client)