Skip to content
Draft
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
3 changes: 3 additions & 0 deletions .jules/bolt.md
Original file line number Diff line number Diff line change
@@ -0,0 +1,3 @@
## 2026-07-16 - O(log n) lookups with binary search
**Learning:** Found O(n) array filtering inside the backtest loop (`vnindex.filter` and `bars[sym].filter`) and within the dnse `clipBars` utility for finding chronological subsets of market data.
**Action:** Replaced O(n) array filtering with a reusable O(log n) binary search utility (`findLastBarIndex`) to quickly identify the index of the latest valid bar. This improved nested backtest loop performance from O(m*n) to O(m*log n) for price lookups.
12 changes: 6 additions & 6 deletions package.json
Original file line number Diff line number Diff line change
Expand Up @@ -54,14 +54,14 @@
},
"dependencies": {
"@anthropic-ai/claude-agent-sdk": "^0.1.0",
"better-sqlite3": "^11.5.0",
"cheerio": "^1.0.0",
"better-sqlite3": "^12.11.1",
"cheerio": "^1.2.0",
"ink": "^5.0.1",
"ink-spinner": "^5.0.0",
"ink-text-input": "^6.0.0",
"ink-spinner": "5.0.0",
"ink-text-input": "6.0.0",
"react": "^18.3.1",
"technicalindicators": "^3.1.0",
"undici": "^6.20.0",
"undici": "^8.7.0",
"yaml": "^2.6.0",
"zod": "^3.23.8"
},
Expand All @@ -80,5 +80,5 @@
"better-sqlite3"
]
},
"packageManager": "pnpm@10.33.2+sha512.a90faf6feeab71ad6c6e57f94e0fe1a12f5dcc22cd754db40ae9593eb6a3e0b6b12e3540218bb37ae083404b1f2ce6db2a4121e979829b4aff94b99f49da1cf8"
"packageManager": "pnpm@11.13.1+sha512.b2fc7683b8a6525414e7d13e1ba28caaddde96bf66ec540bfaeb7e702b81f3e0be4d1f295edf7f9fe0396740a8dce4509c582ddf79891f4543fea32d37645f25"
}
95 changes: 48 additions & 47 deletions pnpm-lock.yaml

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

13 changes: 8 additions & 5 deletions src/agent/backtestRunner.ts
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@ import { randomUUID } from "node:crypto";
import { loadConfig } from "../config/loader.js";
import { getDb } from "../storage/db.js";
import { getBacktestBroker } from "../broker/index.js";
import { getStockOhlcv, getIndexOhlcv, type Bar } from "../data/sources/dnsePublic.js";
import { getStockOhlcv, getIndexOhlcv, findLastBarIndex, type Bar } from "../data/sources/dnsePublic.js";
import { DISCOVERY_UNIVERSE, discoverTickers } from "../tools/discover.js";
import { setActiveAsOf } from "./clock.js";
import { runTeamAnalysis } from "./team/index.js";
Expand Down Expand Up @@ -298,8 +298,9 @@ export async function runBacktestSession(
);

const vnindexAt = (asOf: number): number | null => {
const series = vnindex.filter((b) => b.time <= asOf);
return series.length ? series[series.length - 1]!.close : null;
// ⚑ Bolt: O(log n) lookup instead of O(n) array filter
const lastIdx = findLastBarIndex(vnindex, asOf);
return lastIdx !== -1 ? vnindex[lastIdx]!.close : null;
};
const vnindexBaseline = vnindexAt(intervalTurns[0]!);
if (vnindexBaseline == null) throw new Error(`no VNINDEX data at first ${interval.label} turn`);
Expand All @@ -312,8 +313,10 @@ export async function runBacktestSession(
throwIfAborted(cb.signal);
const dateIso = ictLabel(asOf);
const priceOverride = (sym: string): number | null => {
const series = bars[sym]?.filter((b) => b.time <= asOf) ?? [];
return series.length ? series[series.length - 1]!.close : null;
const series = bars[sym] ?? [];
// ⚑ Bolt: O(log n) lookup instead of O(n) array filter
const lastIdx = findLastBarIndex(series, asOf);
return lastIdx !== -1 ? series[lastIdx]!.close : null;
};
broker.setPriceOverride(priceOverride);
cb.onTurnStart?.({ asOf, dateIso });
Expand Down
28 changes: 27 additions & 1 deletion src/data/sources/dnsePublic.ts
Original file line number Diff line number Diff line change
Expand Up @@ -61,14 +61,40 @@ export function seriesToBars(s: OhlcvSeries): Bar[] {
return out;
}

/**
* ⚑ Bolt: O(log n) binary search to find the index of the last bar <= time.
* Assumes the bars array is chronologically sorted.
*/
export function findLastBarIndex(bars: Bar[], targetTime: number): number {
let low = 0;
let high = bars.length - 1;
let result = -1;

while (low <= high) {
const mid = (low + high) >>> 1;
if (bars[mid]!.time <= targetTime) {
result = mid;
low = mid + 1; // look for a potentially later bar that still <= targetTime
} else {
high = mid - 1; // targetTime is smaller, look in the left half
}
}

return result;
}

function clipBars(bars: Bar[]): Bar[] {
// Clip when an as-of clock is active (ALS or module override). When neither
// is set, fall through unchanged β€” DNSE only returns historical data anyway.
const hasOverride =
asOfClock.getStore()?.asOfSec != null || isAsOfOverridden();
if (!hasOverride) return bars;
const asOf = nowSec();
return bars.filter((b) => b.time <= asOf);

// ⚑ Bolt: Use O(log n) binary search instead of O(n) array filter
const lastIdx = findLastBarIndex(bars, asOf);
if (lastIdx === -1) return [];
return bars.slice(0, lastIdx + 1);
}

export async function getStockOhlcv(
Expand Down
Loading