… in-memory engines PostgreSqlStorageAdapter.QueryNodesAsync(IReadOnlyList<ParsedQuery>): - Replace order-dependent `string.Replace` parameter rename with a single `Regex.Replace` keyed on @<name> word boundary that gates on perParams.ContainsKey. Sequential Replace was mangling adjacent tokens (renaming `@p` after `@p1` produced `@q0_q0_p1`) and could clobber `@…` substrings inside string literals / JSONB paths. - Switch from `UNION` to `UNION ALL` wrapped in `SELECT DISTINCT ON (namespace, id) ... ORDER BY namespace, id, last_modified DESC`. Plain UNION dedupes whole rows — two queries observing the same node at slightly-different last_modified would BOTH appear in the output. Path-keyed dedup (= MeshNode identity) with newest-wins tie-break collapses them correctly. PostgreSqlMeshQuery.ObserveQuery<T>: - Parse EVERY query in request.EffectiveQueries and build per-query (basePath, scope) filters; the change-notifier subscription OR-joins them so multi-query observations get delta refreshes triggered by ANY query's path/scope, not just query #0's. The previous shape silently lost live updates from queries #1+. PostgreSqlMeshQuery.QueryNodesUnionAsync + MeshQueryEngine: - Drop the per-query `parsedList[0].Limit = request.Limit` injection. Query #0 hit its limit before yielding the union's most relevant rows, while queries #1+ contributed unbounded — making the result iteration-order dependent. Limit is now enforced post-union via MinLimit(request.Limit, firstParsed.Limit) so a request-level cap can't be circumvented and an in-query `limit:N` still wins when smaller. - MeshQueryEngine: CollectMatchedAsync returns the LIST of every query's basePath; the source:activity post-filter scans every base path's descendants and unions activity-main-paths so queries #1+ aren't filtered against query #0's subtree only. Addresses PR #95 review items #1, #2, #3, #4, #11. Co-Authored-By: Claude Opus 4.7 <noreply@anthropic.com>

Determine back-end contributors #3

Description

Metadata

Metadata

Assignees

Labels

Type

Fields

Projects

Milestone

Relationships

Development

Issue actions