o Us  zHTestConsecutiveDeterioratingCounter.test_resets_on_watch_or_healthy_readcCs2i}dD] }tt||}q||dddS)zA symbol bouncing between STALE and UNHEALTHY without ever touching WATCH/HEALTHY should still accumulate -- this is exactly the TJGC pattern (STALE the whole time, never UNHEALTHY, never recovering).)rrrrrN)rrrr )r"r#rawrrr1test_mixed_state_reads_all_count_as_deterioratingJszUTestConsecutiveDeterioratingCounter.test_mixed_state_reads_all_count_as_deterioratingN)__name__ __module__ __qualname__r%r(r+r-rrrrr1s  rc@s<eZdZddZddZddZddZd d Zd d Zd S)"TestShouldForceExitOnDeteriorationcCsddd|_dS)NTrexit_on_deterioration_enabledexit_confirm_reads)cfgr"rrrsetUpVsz(TestShouldForceExitOnDeterioration.setUpcC|tddi|jdS)Nrr)) assertFalser"should_force_exit_on_deteriorationr5r6rrrtest_false_below_thresholdY  z=TestShouldForceExitOnDeterioration.test_false_below_thresholdcCr8)Nrr assertTruerr:r5r6rrrtest_true_at_threshold]r<z9TestShouldForceExitOnDeterioration.test_true_at_thresholdcCr8)Nrr=r6rrrtest_true_above_thresholdar<zrr:r9r6rrr(test_defaults_used_when_cfg_keys_missingjs  zKTestShouldForceExitOnDeterioration.test_defaults_used_when_cfg_keys_missingN) r.r/r0r7r;r?rArDrErrrrr1Us r1c@s$eZdZddZddZddZdS)FakePositionManagercCst||_g|_dSN)list_open exit_calls)r" open_symbolsrrr__init__ss  zFakePositionManager.__init__cCs t|jSrG)rHrIr6rrrget_open_symbolsws z$FakePositionManager.get_open_symbolscCs|j|||fdSrG)rJappend)r"r pricereasonrrr exit_positionzsz!FakePositionManager.exit_positionN)r.r/r0rLrMrQrrrrrFrs rFc@seZdZddZdS) FakeStreamcs"ttjfddtdDS)Nc s(g|]}t|dddddddqS))minutes %@d)tohlcv)r).0inowrr sz'FakeStream.get_bars..r@)rr`rutcr)r"r rr_rget_barss  zFakeStream.get_barsN)r.r/r0rcrrrrrR~s rRc@s>eZdZddZdddZddZdd Zd d Zd d ZdS)$TestMonitorForcesExitOnDeteriorationcCsVtjtj|_ddidddd|j_t|j_dd|j_d d id d ig|j_dS) Nmin_avg_daily_volumei Trr2)universercSsiSrGrrrrrz.r rOTHER) monitorSessionOrchestrator__new__orchr5rRstream_get_volume_baselines premarket_20r6rrrr7s  z*TestMonitorForcesExitOnDeterioration.setUpNc s ||j_|p dd|j_ttdi}ttdJ}ttd4}i|j_d|j_fdd}||j _ t j |j _ |j |WdWdWdS1sWwYWdn1sfwYWddSWddS1s~wYdS)NcSsdSrGr)r rrrrgrhz;TestMonitorForcesExitOnDeterioration._run..r data_store top_stockscs*t}|ddd}|d|_||fS)Nrrrstatert)rgetr )r barsavg_vol_baseline health_statereadingentryhealth_state_entriesrrfake_evaluate_symbols  zGTestMonitorForcesExitOnDeterioration._run..fake_evaluate_symbol)rm position_mgr_handle_slot_freedrobjectrjload_health_state return_valuesave_health_stateevaluate_symbol side_effectrr:_update_intraday_health)r"r~r|handle_slot_freed mock_healthmock_dsmock_top_stocksr}rr{r_runs$    z)TestMonitorForcesExitOnDeterioration._runcCstdgd}g}|j|ddddi|jd|t|jd|jd\}}}||d||d ||d ||dgd dS) NrrKrrrs)rrHEALTH_DETERIORATIONrUz=slot should be freed exactly once for the force-exited symbol)rFrrNr lenrJ)r"pmfreedr rOrPrrr,test_open_position_force_exited_at_thresholds     zQTestMonitorForcesExitOnDeterioration.test_open_position_force_exited_at_thresholdcCs6tdgd}||ddddi||jgddS)Nrrr)rrsz?2 consecutive reads is below the exit_confirm_reads=3 threshold)rFrr rJr"rrrr-test_open_position_not_exited_below_thresholds zRTestMonitorForcesExitOnDeterioration.test_open_position_not_exited_below_thresholdcCsLtdgd}||dddddddd d |jD}||dgd S) zOTHER has no open position -- deteriorating health should only affect its entry eligibility (handled elsewhere), never trigger exit_position for a symbol with no position to exit.rrrrrsrTr')rricSsg|]}|dqS)rr)r]r[rrrraszxTestMonitorForcesExitOnDeterioration.test_non_open_position_symbol_never_exited_regardless_of_health..N)rFrrJr )r"rsymbols_exitedrrr?test_non_open_position_symbol_never_exited_regardless_of_healths zdTestMonitorForcesExitOnDeterioration.test_non_open_position_symbol_never_exited_regardless_of_healthcCsFd|jjdd<tdgd}||ddddi||jgd dS) NFrr3rrrTrrszJdisabling the flag should suppress the force-exit even well past threshold)rmr5rFrr rJrrrr&test_disabled_flag_prevents_force_exits zKTestMonitorForcesExitOnDeterioration.test_disabled_flag_prevents_force_exitrG) r.r/r0r7rrrrrrrrrrds  rd__main__) __doc__builtins @py_builtins_pytest.assertion.rewrite assertionrewrite @pytest_arsysosunittest unittest.mockrrrrrpathinsertdirnameabspath__file__rrjrTestCaserr1rFrRrdr.mainrrrrs$"& $  R