From f336bd50c814de0db9654d745d63e06be8c483f6 Mon Sep 17 00:00:00 2001 From: Manuel Polo Date: Sun, 26 Jul 2026 19:27:05 +0200 Subject: [PATCH] fix(test): update the ForcedTradeStrategy fixture to the current engine listener API MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit The fixture no longer compiles against a current engine: onChange took a StateStoreSupport and called initStore(…) to bind a store field, both of which the engine removed. A listener now receives the resolved StateStore directly, as event data handed in with the values it belongs to, and the base class it extends was renamed AbstractOnChangeListener -> AbstractWindowListener. --- src/test/resources/fixtures/ForcedTradeStrategy.java | 11 +++++------ 1 file changed, 5 insertions(+), 6 deletions(-) diff --git a/src/test/resources/fixtures/ForcedTradeStrategy.java b/src/test/resources/fixtures/ForcedTradeStrategy.java index cd1c14d..b27081a 100644 --- a/src/test/resources/fixtures/ForcedTradeStrategy.java +++ b/src/test/resources/fixtures/ForcedTradeStrategy.java @@ -1,9 +1,9 @@ package strategy; -import com.wualabs.qtsurfer.engine.core.state.StateStoreSupport; +import com.wualabs.qtsurfer.engine.core.state.StateStore; import com.wualabs.qtsurfer.engine.indicators.helpers.WindowTimeRTIndicator.WindowTime; import com.wualabs.qtsurfer.engine.indicators.helpers.group.InstrumentGroupRTIndicator; -import com.wualabs.qtsurfer.engine.strategy.AbstractOnChangeListener; +import com.wualabs.qtsurfer.engine.strategy.AbstractWindowListener; import com.wualabs.qtsurfer.engine.strategy.AbstractTickerStrategy; public class ForcedTradeStrategy extends AbstractTickerStrategy { @@ -13,15 +13,14 @@ protected void setupIndicators(InstrumentGroupRTIndicator indicators) { new TradeListener(indicators)); } - private class TradeListener extends AbstractOnChangeListener { + private class TradeListener extends AbstractWindowListener { public TradeListener(InstrumentGroupRTIndicator indicators) { super(ForcedTradeStrategy.this, indicators); } @Override - public void onChange(StateStoreSupport store, double prev, double actual) { - initStore(store); - long count = this.store.inc("count"); + public void onChange(StateStore store, double prev, double actual) { + long count = store.inc("count"); if (count % 120 == 60) { emitBuy(actual); } else if (count % 120 == 0) {