Publish camino-package-runtime from 7efe88cdfc5244727d80239c79845b44d1e79ccb

Add native register acknowledgments and idempotent mutation replay, shared optimistic field controllers, overlapping custom setters, non-suspending hooks and explicit Suspense. Carry checked @live provenance through batched queries and hydrate shared browser fields with coverage leases. Update tracker/scaffolds/guides and verify compiler, PostgreSQL, browser and immutable workspace paths.

.quixos-subtree-source.json

@@ -1,7 +1,7 @@
 {
   "version": 1,
   "sourceRepo": "https://gitea-external.egads.tutti.syntaxblitz.net/quixos/quixos",
-  "sourceCommit": "cbf03106e69d3e2867d7f96859741991e04402b7",
+  "sourceCommit": "7efe88cdfc5244727d80239c79845b44d1e79ccb",
   "sourcePath": "quixos-instance/packages/camino-package-runtime",
   "exportName": "camino-package-runtime",
   "mirrorRemote": "https://gitea-external.egads.tutti.syntaxblitz.net/quixos/camino-package-runtime.git"

dist/camino/api_pb.d.ts

@@ -1,5 +1,6 @@
 import type { GenFile, GenMessage, GenService } from "@bufbuild/protobuf/codegenv2";
-import type { PersistencePlan, QuerySelection } from "./schema_pb.js";
+import type { PersistencePlan, QueryRelationalPlan, QuerySelection } from "./schema_pb.js";
+import type { CapabilityRef, FieldEditing } from "../quixos/refs_pb.js";
 import type { Message } from "@bufbuild/protobuf";
 /**
  * Describes the file camino/api.proto.
@@ -207,12 +208,91 @@ export type Value = Message<"camino.Value"> & {
      * @generated from field: camino.ValueSource source = 11;
      */
     source?: ValueSource | undefined;
+    /**
+     * Trusted query coordinator annotation. Travels with values through residual
+     * row selection, then is removed in favor of final-path hydration metadata.
+     *
+     * @generated from field: camino.QueryFieldOrigin query_origin = 12;
+     */
+    queryOrigin?: QueryFieldOrigin | undefined;
 };
 /**
  * Describes the message camino.Value.
  * Use `create(ValueSchema)` to create a new message.
  */
 export declare const ValueSchema: GenMessage<Value>;
+/**
+ * @generated from message camino.QueryFieldOrigin
+ */
+export type QueryFieldOrigin = Message<"camino.QueryFieldOrigin"> & {
+    /**
+     * @generated from field: string selection_id = 1;
+     */
+    selectionId: string;
+    /**
+     * @generated from field: string atom_id = 2;
+     */
+    atomId: string;
+    /**
+     * @generated from field: string interface_revision_id = 3;
+     */
+    interfaceRevisionId: string;
+    /**
+     * @generated from field: string member_id = 4;
+     */
+    memberId: string;
+    /**
+     * @generated from field: camino.StateValueSource source = 5;
+     */
+    source?: StateValueSource | undefined;
+};
+/**
+ * Describes the message camino.QueryFieldOrigin.
+ * Use `create(QueryFieldOriginSchema)` to create a new message.
+ */
+export declare const QueryFieldOriginSchema: GenMessage<QueryFieldOrigin>;
+/**
+ * @generated from message camino.QueryLiveField
+ */
+export type QueryLiveField = Message<"camino.QueryLiveField"> & {
+    /**
+     * @generated from field: repeated camino.QueryPathPart path = 1;
+     */
+    path: QueryPathPart[];
+    /**
+     * @generated from field: string selection_id = 2;
+     */
+    selectionId: string;
+    /**
+     * @generated from field: string object_id = 3;
+     */
+    objectId: string;
+    /**
+     * @generated from field: quixos.CapabilityRef capability = 4;
+     */
+    capability?: CapabilityRef | undefined;
+    /**
+     * @generated from field: string watch_operation_id = 5;
+     */
+    watchOperationId: string;
+    /**
+     * @generated from field: string setter_operation_id = 6;
+     */
+    setterOperationId: string;
+    /**
+     * @generated from field: quixos.FieldEditing editing = 7;
+     */
+    editing?: FieldEditing | undefined;
+    /**
+     * @generated from field: camino.StateValueSource source = 8;
+     */
+    source?: StateValueSource | undefined;
+};
+/**
+ * Describes the message camino.QueryLiveField.
+ * Use `create(QueryLiveFieldSchema)` to create a new message.
+ */
+export declare const QueryLiveFieldSchema: GenMessage<QueryLiveField>;
 /**
  * @generated from message camino.InstallPersistencePlanRequest
  */
@@ -928,6 +1008,14 @@ export type QueryPendingField = Message<"camino.QueryPendingField"> & {
      * @generated from field: string residual_field = 9;
      */
     residualField: string;
+    /**
+     * @generated from field: optional uint32 relational_capture = 10;
+     */
+    relationalCapture?: number | undefined;
+    /**
+     * @generated from field: uint32 captured_object = 11;
+     */
+    capturedObject: number;
 };
 /**
  * Describes the message camino.QueryPendingField.
@@ -966,6 +1054,22 @@ export type QueryStats = Message<"camino.QueryStats"> & {
      * @generated from field: double total_ms = 7;
      */
     totalMs: number;
+    /**
+     * @generated from field: uint32 relational_stages = 8;
+     */
+    relationalStages: number;
+    /**
+     * @generated from field: uint32 captured_candidates = 9;
+     */
+    capturedCandidates: number;
+    /**
+     * @generated from field: double relational_ms = 10;
+     */
+    relationalMs: number;
+    /**
+     * @generated from field: double residual_ms = 11;
+     */
+    residualMs: number;
 };
 /**
  * Describes the message camino.QueryStats.
@@ -1018,12 +1122,137 @@ export type QueryResponse = Message<"camino.QueryResponse"> & {
      * @generated from field: string consistency = 9;
      */
     consistency: string;
+    /**
+     * @generated from field: repeated camino.QueryRelationalCapture relational_captures = 10;
+     */
+    relationalCaptures: QueryRelationalCapture[];
+    /**
+     * @generated from field: repeated camino.QueryLiveField live_fields = 11;
+     */
+    liveFields: QueryLiveField[];
 };
 /**
  * Describes the message camino.QueryResponse.
  * Use `create(QueryResponseSchema)` to create a new message.
  */
 export declare const QueryResponseSchema: GenMessage<QueryResponse>;
+/**
+ * Private coordinator input, removed before publishing a result. Memberships
+ * and native facts share one snapshot; package reads are sampled afterwards.
+ *
+ * @generated from message camino.QueryCapturedMember
+ */
+export type QueryCapturedMember = Message<"camino.QueryCapturedMember"> & {
+    /**
+     * @generated from field: string object_id = 1;
+     */
+    objectId: string;
+    /**
+     * @generated from field: string entry_id = 2;
+     */
+    entryId: string;
+    /**
+     * @generated from field: camino.Value map_key = 3;
+     */
+    mapKey?: Value | undefined;
+};
+/**
+ * Describes the message camino.QueryCapturedMember.
+ * Use `create(QueryCapturedMemberSchema)` to create a new message.
+ */
+export declare const QueryCapturedMemberSchema: GenMessage<QueryCapturedMember>;
+/**
+ * @generated from message camino.QueryCapturedMembers
+ */
+export type QueryCapturedMembers = Message<"camino.QueryCapturedMembers"> & {
+    /**
+     * @generated from field: repeated camino.QueryCapturedMember entries = 1;
+     */
+    entries: QueryCapturedMember[];
+};
+/**
+ * Describes the message camino.QueryCapturedMembers.
+ * Use `create(QueryCapturedMembersSchema)` to create a new message.
+ */
+export declare const QueryCapturedMembersSchema: GenMessage<QueryCapturedMembers>;
+/**
+ * @generated from message camino.QueryCapturedObject
+ */
+export type QueryCapturedObject = Message<"camino.QueryCapturedObject"> & {
+    /**
+     * @generated from field: string object_id = 1;
+     */
+    objectId: string;
+    /**
+     * @generated from field: map<string, camino.Value> fields = 2;
+     */
+    fields: {
+        [key: string]: Value;
+    };
+    /**
+     * @generated from field: map<string, string> field_types = 3;
+     */
+    fieldTypes: {
+        [key: string]: string;
+    };
+    /**
+     * @generated from field: map<string, camino.QueryCapturedMembers> relationships = 4;
+     */
+    relationships: {
+        [key: string]: QueryCapturedMembers;
+    };
+};
+/**
+ * Describes the message camino.QueryCapturedObject.
+ * Use `create(QueryCapturedObjectSchema)` to create a new message.
+ */
+export declare const QueryCapturedObjectSchema: GenMessage<QueryCapturedObject>;
+/**
+ * @generated from message camino.QueryRelationalCapture
+ */
+export type QueryRelationalCapture = Message<"camino.QueryRelationalCapture"> & {
+    /**
+     * @generated from field: repeated camino.QueryPathPart path = 1;
+     */
+    path: QueryPathPart[];
+    /**
+     * @generated from field: camino.QueryRelationalPlan plan = 2;
+     */
+    plan?: QueryRelationalPlan | undefined;
+    /**
+     * @generated from field: string root_object_id = 3;
+     */
+    rootObjectId: string;
+    /**
+     * @generated from field: repeated camino.QueryCapturedObject objects = 4;
+     */
+    objects: QueryCapturedObject[];
+    /**
+     * @generated from field: string variables_json = 5;
+     */
+    variablesJson: string;
+    /**
+     * @generated from field: uint32 row_limit = 6;
+     */
+    rowLimit: number;
+    /**
+     * @generated from field: uint32 candidate_limit = 7;
+     */
+    candidateLimit: number;
+    /**
+     * @generated from field: optional uint32 residual_window = 8;
+     */
+    residualWindow?: number | undefined;
+    /**
+     * @generated from field: repeated string result_path = 9;
+     */
+    resultPath: string[];
+};
+/**
+ * Describes the message camino.QueryRelationalCapture.
+ * Use `create(QueryRelationalCaptureSchema)` to create a new message.
+ */
+export declare const QueryRelationalCaptureSchema: GenMessage<QueryRelationalCapture>;
 /**
  * @generated from message camino.QueryResidualRow
  */
@@ -1100,6 +1329,14 @@ export type QueryResidualWindow = Message<"camino.QueryResidualWindow"> & {
     fieldTypes: {
         [key: string]: string;
     };
+    /**
+     * @generated from field: bool relational = 9;
+     */
+    relational: boolean;
+    /**
+     * @generated from field: repeated string matched_entries = 10;
+     */
+    matchedEntries: string[];
 };
 /**
  * Describes the message camino.QueryResidualWindow.

dist/camino/schema_pb.d.ts

@@ -364,12 +364,647 @@ export type QuerySelection = Message<"camino.QuerySelection"> & {
      * @generated from field: repeated camino.QuerySelection selection = 8;
      */
     selection: QuerySelection[];
+    /**
+     * @generated from field: camino.QueryRelationalPlan relational = 9;
+     */
+    relational?: QueryRelationalPlan | undefined;
+    /**
+     * @generated from field: camino.QueryPredicate predicate = 10;
+     */
+    predicate?: QueryPredicate | undefined;
+    /**
+     * Stable checked selection identity; empty for ordinary value projections.
+     *
+     * @generated from field: string live_selection_id = 11;
+     */
+    liveSelectionId: string;
 };
 /**
  * Describes the message camino.QuerySelection.
  * Use `create(QuerySelectionSchema)` to create a new message.
  */
 export declare const QuerySelectionSchema: GenMessage<QuerySelection>;
+/**
+ * Resolved IDs, not GraphQL names, determine execution. Response selections
+ * remain separate so aliases and fragments cannot change relational semantics.
+ *
+ * @generated from message camino.QueryPathStep
+ */
+export type QueryPathStep = Message<"camino.QueryPathStep"> & {
+    /**
+     * @generated from oneof camino.QueryPathStep.step
+     */
+    step: {
+        /**
+         * @generated from field: bool source = 1;
+         */
+        value: boolean;
+        case: "source";
+    } | {
+        /**
+         * @generated from field: bool target = 2;
+         */
+        value: boolean;
+        case: "target";
+    } | {
+        /**
+         * @generated from field: camino.QueryRelationPath relation = 3;
+         */
+        value: QueryRelationPath;
+        case: "relation";
+    } | {
+        case: undefined;
+        value?: undefined;
+    };
+};
+/**
+ * Describes the message camino.QueryPathStep.
+ * Use `create(QueryPathStepSchema)` to create a new message.
+ */
+export declare const QueryPathStepSchema: GenMessage<QueryPathStep>;
+/**
+ * @generated from message camino.QueryRelationPath
+ */
+export type QueryRelationPath = Message<"camino.QueryRelationPath"> & {
+    /**
+     * @generated from field: string interface_revision_id = 1;
+     */
+    interfaceRevisionId: string;
+    /**
+     * @generated from field: string member_id = 2;
+     */
+    memberId: string;
+    /**
+     * @generated from field: string target_interface_revision_id = 3;
+     */
+    targetInterfaceRevisionId: string;
+    /**
+     * @generated from field: bool optional = 4;
+     */
+    optional: boolean;
+};
+/**
+ * Describes the message camino.QueryRelationPath.
+ * Use `create(QueryRelationPathSchema)` to create a new message.
+ */
+export declare const QueryRelationPathSchema: GenMessage<QueryRelationPath>;
+/**
+ * @generated from message camino.QueryFieldOperand
+ */
+export type QueryFieldOperand = Message<"camino.QueryFieldOperand"> & {
+    /**
+     * @generated from field: string interface_revision_id = 1;
+     */
+    interfaceRevisionId: string;
+    /**
+     * @generated from field: string member_id = 2;
+     */
+    memberId: string;
+};
+/**
+ * Describes the message camino.QueryFieldOperand.
+ * Use `create(QueryFieldOperandSchema)` to create a new message.
+ */
+export declare const QueryFieldOperandSchema: GenMessage<QueryFieldOperand>;
+/**
+ * @generated from message camino.QueryExpression
+ */
+export type QueryExpression = Message<"camino.QueryExpression"> & {
+    /**
+     * @generated from field: repeated camino.QueryPathStep path = 1;
+     */
+    path: QueryPathStep[];
+    /**
+     * @generated from oneof camino.QueryExpression.leaf
+     */
+    leaf: {
+        /**
+         * @generated from field: camino.QueryFieldOperand field = 2;
+         */
+        value: QueryFieldOperand;
+        case: "field";
+    } | {
+        /**
+         * @generated from field: string ref = 3;
+         */
+        value: string;
+        case: "ref";
+    } | {
+        /**
+         * @generated from field: bool entry = 4;
+         */
+        value: boolean;
+        case: "entry";
+    } | {
+        /**
+         * @generated from field: bool map_key = 5;
+         */
+        value: boolean;
+        case: "mapKey";
+    } | {
+        case: undefined;
+        value?: undefined;
+    };
+    /**
+     * @generated from field: string value_type_json = 6;
+     */
+    valueTypeJson: string;
+};
+/**
+ * Describes the message camino.QueryExpression.
+ * Use `create(QueryExpressionSchema)` to create a new message.
+ */
+export declare const QueryExpressionSchema: GenMessage<QueryExpression>;
+/**
+ * @generated from message camino.QueryReduction
+ */
+export type QueryReduction = Message<"camino.QueryReduction"> & {
+    /**
+     * @generated from field: camino.QueryAggregateOperator operator = 1;
+     */
+    operator: QueryAggregateOperator;
+    /**
+     * @generated from field: camino.QueryExpression operand = 2;
+     */
+    operand?: QueryExpression | undefined;
+    /**
+     * @generated from field: string value_type_json = 3;
+     */
+    valueTypeJson: string;
+};
+/**
+ * Describes the message camino.QueryReduction.
+ * Use `create(QueryReductionSchema)` to create a new message.
+ */
+export declare const QueryReductionSchema: GenMessage<QueryReduction>;
+/**
+ * @generated from message camino.QueryOperand
+ */
+export type QueryOperand = Message<"camino.QueryOperand"> & {
+    /**
+     * @generated from oneof camino.QueryOperand.operand
+     */
+    operand: {
+        /**
+         * @generated from field: camino.QueryExpression expression = 1;
+         */
+        value: QueryExpression;
+        case: "expression";
+    } | {
+        /**
+         * @generated from field: camino.QueryReduction reduction = 2;
+         */
+        value: QueryReduction;
+        case: "reduction";
+    } | {
+        case: undefined;
+        value?: undefined;
+    };
+};
+/**
+ * Describes the message camino.QueryOperand.
+ * Use `create(QueryOperandSchema)` to create a new message.
+ */
+export declare const QueryOperandSchema: GenMessage<QueryOperand>;
+/**
+ * @generated from message camino.QueryComparison
+ */
+export type QueryComparison = Message<"camino.QueryComparison"> & {
+    /**
+     * @generated from field: camino.QueryOperand operand = 1;
+     */
+    operand?: QueryOperand | undefined;
+    /**
+     * @generated from field: camino.QueryComparisonOperator operator = 2;
+     */
+    operator: QueryComparisonOperator;
+    /**
+     * @generated from field: camino.QueryArgument value = 3;
+     */
+    value?: QueryArgument | undefined;
+};
+/**
+ * Describes the message camino.QueryComparison.
+ * Use `create(QueryComparisonSchema)` to create a new message.
+ */
+export declare const QueryComparisonSchema: GenMessage<QueryComparison>;
+/**
+ * @generated from message camino.QueryPredicateList
+ */
+export type QueryPredicateList = Message<"camino.QueryPredicateList"> & {
+    /**
+     * @generated from field: repeated camino.QueryPredicate children = 1;
+     */
+    children: QueryPredicate[];
+};
+/**
+ * Describes the message camino.QueryPredicateList.
+ * Use `create(QueryPredicateListSchema)` to create a new message.
+ */
+export declare const QueryPredicateListSchema: GenMessage<QueryPredicateList>;
+/**
+ * @generated from message camino.QueryRelationPredicate
+ */
+export type QueryRelationPredicate = Message<"camino.QueryRelationPredicate"> & {
+    /**
+     * @generated from field: repeated camino.QueryPathStep path = 1;
+     */
+    path: QueryPathStep[];
+    /**
+     * @generated from field: camino.QueryRelationPath relation = 2;
+     */
+    relation?: QueryRelationPath | undefined;
+    /**
+     * @generated from field: camino.QueryRelationPredicateOperator operator = 3;
+     */
+    operator: QueryRelationPredicateOperator;
+    /**
+     * @generated from field: camino.QueryPredicate predicate = 4;
+     */
+    predicate?: QueryPredicate | undefined;
+    /**
+     * @generated from field: camino.QueryArgument value = 5;
+     */
+    value?: QueryArgument | undefined;
+};
+/**
+ * Describes the message camino.QueryRelationPredicate.
+ * Use `create(QueryRelationPredicateSchema)` to create a new message.
+ */
+export declare const QueryRelationPredicateSchema: GenMessage<QueryRelationPredicate>;
+/**
+ * @generated from message camino.QueryReductionPredicate
+ */
+export type QueryReductionPredicate = Message<"camino.QueryReductionPredicate"> & {
+    /**
+     * @generated from field: repeated camino.QueryPathStep path = 1;
+     */
+    path: QueryPathStep[];
+    /**
+     * @generated from field: camino.QueryRelationPath relation = 2;
+     */
+    relation?: QueryRelationPath | undefined;
+    /**
+     * @generated from field: camino.QueryPredicate where = 3;
+     */
+    where?: QueryPredicate | undefined;
+    /**
+     * @generated from field: camino.QueryPredicate having = 4;
+     */
+    having?: QueryPredicate | undefined;
+};
+/**
+ * Describes the message camino.QueryReductionPredicate.
+ * Use `create(QueryReductionPredicateSchema)` to create a new message.
+ */
+export declare const QueryReductionPredicateSchema: GenMessage<QueryReductionPredicate>;
+/**
+ * @generated from message camino.QueryPredicate
+ */
+export type QueryPredicate = Message<"camino.QueryPredicate"> & {
+    /**
+     * @generated from oneof camino.QueryPredicate.predicate
+     */
+    predicate: {
+        /**
+         * @generated from field: camino.QueryPredicateList and = 1;
+         */
+        value: QueryPredicateList;
+        case: "and";
+    } | {
+        /**
+         * @generated from field: camino.QueryPredicateList or = 2;
+         */
+        value: QueryPredicateList;
+        case: "or";
+    } | {
+        /**
+         * @generated from field: camino.QueryPredicate not = 3;
+         */
+        value: QueryPredicate;
+        case: "not";
+    } | {
+        /**
+         * @generated from field: camino.QueryComparison compare = 4;
+         */
+        value: QueryComparison;
+        case: "compare";
+    } | {
+        /**
+         * @generated from field: camino.QueryRelationPredicate relation = 5;
+         */
+        value: QueryRelationPredicate;
+        case: "relation";
+    } | {
+        /**
+         * @generated from field: camino.QueryReductionPredicate reduce = 6;
+         */
+        value: QueryReductionPredicate;
+        case: "reduce";
+    } | {
+        case: undefined;
+        value?: undefined;
+    };
+};
+/**
+ * Describes the message camino.QueryPredicate.
+ * Use `create(QueryPredicateSchema)` to create a new message.
+ */
+export declare const QueryPredicateSchema: GenMessage<QueryPredicate>;
+/**
+ * @generated from message camino.QueryRow
+ */
+export type QueryRow = Message<"camino.QueryRow"> & {
+    /**
+     * @generated from oneof camino.QueryRow.row
+     */
+    row: {
+        /**
+         * @generated from field: camino.QueryObjectRow object = 1;
+         */
+        value: QueryObjectRow;
+        case: "object";
+    } | {
+        /**
+         * @generated from field: camino.QueryPairRow pair = 2;
+         */
+        value: QueryPairRow;
+        case: "pair";
+    } | {
+        case: undefined;
+        value?: undefined;
+    };
+};
+/**
+ * Describes the message camino.QueryRow.
+ * Use `create(QueryRowSchema)` to create a new message.
+ */
+export declare const QueryRowSchema: GenMessage<QueryRow>;
+/**
+ * @generated from message camino.QueryObjectRow
+ */
+export type QueryObjectRow = Message<"camino.QueryObjectRow"> & {
+    /**
+     * @generated from field: string interface_revision_id = 1;
+     */
+    interfaceRevisionId: string;
+    /**
+     * @generated from field: bool membership = 2;
+     */
+    membership: boolean;
+    /**
+     * @generated from field: string key_type = 3;
+     */
+    keyType: string;
+};
+/**
+ * Describes the message camino.QueryObjectRow.
+ * Use `create(QueryObjectRowSchema)` to create a new message.
+ */
+export declare const QueryObjectRowSchema: GenMessage<QueryObjectRow>;
+/**
+ * @generated from message camino.QueryPairRow
+ */
+export type QueryPairRow = Message<"camino.QueryPairRow"> & {
+    /**
+     * @generated from field: camino.QueryRow source = 1;
+     */
+    source?: QueryRow | undefined;
+    /**
+     * @generated from field: camino.QueryRow target = 2;
+     */
+    target?: QueryRow | undefined;
+};
+/**
+ * Describes the message camino.QueryPairRow.
+ * Use `create(QueryPairRowSchema)` to create a new message.
+ */
+export declare const QueryPairRowSchema: GenMessage<QueryPairRow>;
+/**
+ * @generated from message camino.QueryKey
+ */
+export type QueryKey = Message<"camino.QueryKey"> & {
+    /**
+     * @generated from field: repeated string path = 1;
+     */
+    path: string[];
+    /**
+     * @generated from field: camino.QueryExpression expression = 2;
+     */
+    expression?: QueryExpression | undefined;
+};
+/**
+ * Describes the message camino.QueryKey.
+ * Use `create(QueryKeySchema)` to create a new message.
+ */
+export declare const QueryKeySchema: GenMessage<QueryKey>;
+/**
+ * @generated from message camino.QueryDistinct
+ */
+export type QueryDistinct = Message<"camino.QueryDistinct"> & {
+    /**
+     * @generated from field: repeated camino.QueryKey keys = 1;
+     */
+    keys: QueryKey[];
+};
+/**
+ * Describes the message camino.QueryDistinct.
+ * Use `create(QueryDistinctSchema)` to create a new message.
+ */
+export declare const QueryDistinctSchema: GenMessage<QueryDistinct>;
+/**
+ * @generated from message camino.QueryExpansion
+ */
+export type QueryExpansion = Message<"camino.QueryExpansion"> & {
+    /**
+     * @generated from field: repeated camino.QueryPathStep path = 1;
+     */
+    path: QueryPathStep[];
+    /**
+     * @generated from field: camino.QueryRelationPath relation = 2;
+     */
+    relation?: QueryRelationPath | undefined;
+};
+/**
+ * Describes the message camino.QueryExpansion.
+ * Use `create(QueryExpansionSchema)` to create a new message.
+ */
+export declare const QueryExpansionSchema: GenMessage<QueryExpansion>;
+/**
+ * @generated from message camino.QueryRelationalStage
+ */
+export type QueryRelationalStage = Message<"camino.QueryRelationalStage"> & {
+    /**
+     * @generated from field: uint32 id = 1;
+     */
+    id: number;
+    /**
+     * @generated from field: optional uint32 input = 2;
+     */
+    input?: number | undefined;
+    /**
+     * @generated from field: camino.QueryRow row = 3;
+     */
+    row?: QueryRow | undefined;
+    /**
+     * @generated from oneof camino.QueryRelationalStage.operation
+     */
+    operation: {
+        /**
+         * @generated from field: camino.QueryRelationPath source = 4;
+         */
+        value: QueryRelationPath;
+        case: "source";
+    } | {
+        /**
+         * @generated from field: camino.QueryPredicate filter = 5;
+         */
+        value: QueryPredicate;
+        case: "filter";
+    } | {
+        /**
+         * @generated from field: camino.QueryExpansion expand = 6;
+         */
+        value: QueryExpansion;
+        case: "expand";
+    } | {
+        /**
+         * @generated from field: camino.QueryDistinct distinct = 7;
+         */
+        value: QueryDistinct;
+        case: "distinct";
+    } | {
+        case: undefined;
+        value?: undefined;
+    };
+};
+/**
+ * Describes the message camino.QueryRelationalStage.
+ * Use `create(QueryRelationalStageSchema)` to create a new message.
+ */
+export declare const QueryRelationalStageSchema: GenMessage<QueryRelationalStage>;
+/**
+ * @generated from message camino.QueryReductionProjection
+ */
+export type QueryReductionProjection = Message<"camino.QueryReductionProjection"> & {
+    /**
+     * @generated from field: repeated string path = 1;
+     */
+    path: string[];
+    /**
+     * @generated from field: camino.QueryReduction reduction = 2;
+     */
+    reduction?: QueryReduction | undefined;
+};
+/**
+ * Describes the message camino.QueryReductionProjection.
+ * Use `create(QueryReductionProjectionSchema)` to create a new message.
+ */
+export declare const QueryReductionProjectionSchema: GenMessage<QueryReductionProjection>;
+/**
+ * @generated from message camino.QueryAggregateOrder
+ */
+export type QueryAggregateOrder = Message<"camino.QueryAggregateOrder"> & {
+    /**
+     * @generated from field: camino.QueryOperand operand = 1;
+     */
+    operand?: QueryOperand | undefined;
+    /**
+     * @generated from field: bool descending = 2;
+     */
+    descending: boolean;
+};
+/**
+ * Describes the message camino.QueryAggregateOrder.
+ * Use `create(QueryAggregateOrderSchema)` to create a new message.
+ */
+export declare const QueryAggregateOrderSchema: GenMessage<QueryAggregateOrder>;
+/**
+ * @generated from message camino.QueryRelationalTerminal
+ */
+export type QueryRelationalTerminal = Message<"camino.QueryRelationalTerminal"> & {
+    /**
+     * @generated from field: uint32 stage = 1;
+     */
+    stage: number;
+    /**
+     * @generated from field: repeated string path = 2;
+     */
+    path: string[];
+    /**
+     * @generated from field: bool groups = 3;
+     */
+    groups: boolean;
+    /**
+     * @generated from field: repeated camino.QueryKey keys = 4;
+     */
+    keys: QueryKey[];
+    /**
+     * @generated from field: repeated camino.QueryReductionProjection reductions = 5;
+     */
+    reductions: QueryReductionProjection[];
+    /**
+     * @generated from field: camino.QueryPredicate where = 6;
+     */
+    where?: QueryPredicate | undefined;
+    /**
+     * @generated from field: camino.QueryPredicate having = 7;
+     */
+    having?: QueryPredicate | undefined;
+    /**
+     * @generated from field: repeated camino.QueryAggregateOrder order = 8;
+     */
+    order: QueryAggregateOrder[];
+    /**
+     * @generated from field: camino.QueryArgument first = 9;
+     */
+    first?: QueryArgument | undefined;
+    /**
+     * @generated from field: camino.QueryArgument all = 10;
+     */
+    all?: QueryArgument | undefined;
+    /**
+     * @generated from field: camino.QueryArgument after = 11;
+     */
+    after?: QueryArgument | undefined;
+    /**
+     * @generated from field: repeated camino.QuerySelection selection = 12;
+     */
+    selection: QuerySelection[];
+    /**
+     * @generated from field: bool residual = 13;
+     */
+    residual: boolean;
+    /**
+     * Internal ordinary-relationship residual: yields ordered membership IDs.
+     *
+     * @generated from field: bool rows = 14;
+     */
+    rows: boolean;
+};
+/**
+ * Describes the message camino.QueryRelationalTerminal.
+ * Use `create(QueryRelationalTerminalSchema)` to create a new message.
+ */
+export declare const QueryRelationalTerminalSchema: GenMessage<QueryRelationalTerminal>;
+/**
+ * @generated from message camino.QueryRelationalPlan
+ */
+export type QueryRelationalPlan = Message<"camino.QueryRelationalPlan"> & {
+    /**
+     * @generated from field: repeated camino.QueryRelationalStage stages = 1;
+     */
+    stages: QueryRelationalStage[];
+    /**
+     * @generated from field: repeated camino.QueryRelationalTerminal terminals = 2;
+     */
+    terminals: QueryRelationalTerminal[];
+};
+/**
+ * Describes the message camino.QueryRelationalPlan.
+ * Use `create(QueryRelationalPlanSchema)` to create a new message.
+ */
+export declare const QueryRelationalPlanSchema: GenMessage<QueryRelationalPlan>;
 /**
  * @generated from message camino.QueryReadBinding
  */
@@ -567,4 +1202,111 @@ export declare enum Cardinality {
  * Describes the enum camino.Cardinality.
  */
 export declare const CardinalitySchema: GenEnum<Cardinality>;
+/**
+ * @generated from enum camino.QueryAggregateOperator
+ */
+export declare enum QueryAggregateOperator {
+    /**
+     * @generated from enum value: QUERY_AGGREGATE_OPERATOR_UNSPECIFIED = 0;
+     */
+    UNSPECIFIED = 0,
+    /**
+     * @generated from enum value: QUERY_AGGREGATE_OPERATOR_COUNT = 1;
+     */
+    COUNT = 1,
+    /**
+     * @generated from enum value: QUERY_AGGREGATE_OPERATOR_COUNT_PRESENT = 2;
+     */
+    COUNT_PRESENT = 2,
+    /**
+     * @generated from enum value: QUERY_AGGREGATE_OPERATOR_SUM = 3;
+     */
+    SUM = 3,
+    /**
+     * @generated from enum value: QUERY_AGGREGATE_OPERATOR_AVG = 4;
+     */
+    AVG = 4,
+    /**
+     * @generated from enum value: QUERY_AGGREGATE_OPERATOR_MIN = 5;
+     */
+    MIN = 5,
+    /**
+     * @generated from enum value: QUERY_AGGREGATE_OPERATOR_MAX = 6;
+     */
+    MAX = 6
+}
+/**
+ * Describes the enum camino.QueryAggregateOperator.
+ */
+export declare const QueryAggregateOperatorSchema: GenEnum<QueryAggregateOperator>;
+/**
+ * @generated from enum camino.QueryComparisonOperator
+ */
+export declare enum QueryComparisonOperator {
+    /**
+     * @generated from enum value: QUERY_COMPARISON_OPERATOR_UNSPECIFIED = 0;
+     */
+    UNSPECIFIED = 0,
+    /**
+     * @generated from enum value: QUERY_COMPARISON_OPERATOR_EQ = 1;
+     */
+    EQ = 1,
+    /**
+     * @generated from enum value: QUERY_COMPARISON_OPERATOR_IN = 2;
+     */
+    IN = 2,
+    /**
+     * @generated from enum value: QUERY_COMPARISON_OPERATOR_IS_NULL = 3;
+     */
+    IS_NULL = 3,
+    /**
+     * @generated from enum value: QUERY_COMPARISON_OPERATOR_LT = 4;
+     */
+    LT = 4,
+    /**
+     * @generated from enum value: QUERY_COMPARISON_OPERATOR_LTE = 5;
+     */
+    LTE = 5,
+    /**
+     * @generated from enum value: QUERY_COMPARISON_OPERATOR_GT = 6;
+     */
+    GT = 6,
+    /**
+     * @generated from enum value: QUERY_COMPARISON_OPERATOR_GTE = 7;
+     */
+    GTE = 7
+}
+/**
+ * Describes the enum camino.QueryComparisonOperator.
+ */
+export declare const QueryComparisonOperatorSchema: GenEnum<QueryComparisonOperator>;
+/**
+ * @generated from enum camino.QueryRelationPredicateOperator
+ */
+export declare enum QueryRelationPredicateOperator {
+    /**
+     * @generated from enum value: QUERY_RELATION_PREDICATE_OPERATOR_UNSPECIFIED = 0;
+     */
+    UNSPECIFIED = 0,
+    /**
+     * @generated from enum value: QUERY_RELATION_PREDICATE_OPERATOR_SOME = 1;
+     */
+    SOME = 1,
+    /**
+     * @generated from enum value: QUERY_RELATION_PREDICATE_OPERATOR_NONE = 2;
+     */
+    NONE = 2,
+    /**
+     * @generated from enum value: QUERY_RELATION_PREDICATE_OPERATOR_IS = 3;
+     */
+    IS = 3,
+    /**
+     * @generated from enum value: QUERY_RELATION_PREDICATE_OPERATOR_IS_NULL = 4;
+     */
+    IS_NULL = 4
+}
+/**
+ * Describes the enum camino.QueryRelationPredicateOperator.
+ */
+export declare const QueryRelationPredicateOperatorSchema: GenEnum<QueryRelationPredicateOperator>;
 //# sourceMappingURL=schema_pb.d.ts.map

dist/queries.js

@@ -1,6 +1,6 @@
 import { decodeQxValue } from "./bindings.js";
 export function decodeQuerySnapshot(response, output, runId, sequence) {
-    if (response.preparationToken || response.residualWindows.length)
+    if (response.preparationToken || response.residualWindows.length || response.relationalCaptures.length)
         throw new Error("QUERY_RESULT_UNFINISHED: private preparation is not a query result");
     const fields = [
         ...response.pending.map((field) => ({ path: field.path, status: "pending" })),

dist/quixos/orch_pb.d.ts

@@ -2,7 +2,7 @@ import type { GenFile, GenMessage, GenService } from "@bufbuild/protobuf/codegen
 import type { CaminoObject, CrdtValue, QueryPathPart, QueryRequestSchema, QueryResponse, QueryResponseSchema, Value } from "../camino/api_pb.js";
 import type { InstalledQuery } from "../camino/schema_pb.js";
 import type { PackageDescriptor } from "./package_pb.js";
-import type { CapabilityRef, ConformanceWitness, PackageExportRef } from "./refs_pb.js";
+import type { CapabilityRef, ConformanceWitness, FieldEditing, PackageExportRef } from "./refs_pb.js";
 import type { DerivedDependency } from "./runtime_pb.js";
 import type { Message } from "@bufbuild/protobuf";
 /**
@@ -241,7 +241,7 @@ export type InvokeCapabilityResponse = Message<"quixos.orch.InvokeCapabilityResp
      */
     dependencies: DerivedDependency[];
     /**
-     * @generated from field: quixos.orch.FieldEditing field_editing = 7;
+     * @generated from field: quixos.FieldEditing field_editing = 7;
      */
     fieldEditing?: FieldEditing | undefined;
 };
@@ -250,34 +250,6 @@ export type InvokeCapabilityResponse = Message<"quixos.orch.InvokeCapabilityResp
  * Use `create(InvokeCapabilityResponseSchema)` to create a new message.
  */
 export declare const InvokeCapabilityResponseSchema: GenMessage<InvokeCapabilityResponse>;
-/**
- * Resolved from the checked native getter/setter binding, not Value.source.
- *
- * @generated from message quixos.orch.FieldEditing
- */
-export type FieldEditing = Message<"quixos.orch.FieldEditing"> & {
-    /**
-     * @generated from field: string getter_operation_id = 1;
-     */
-    getterOperationId: string;
-    /**
-     * @generated from field: string setter_operation_id = 2;
-     */
-    setterOperationId: string;
-    /**
-     * @generated from field: string document_type = 3;
-     */
-    documentType: string;
-    /**
-     * @generated from field: string binding_digest = 4;
-     */
-    bindingDigest: string;
-};
-/**
- * Describes the message quixos.orch.FieldEditing.
- * Use `create(FieldEditingSchema)` to create a new message.
- */
-export declare const FieldEditingSchema: GenMessage<FieldEditing>;
 /**
  * @generated from message quixos.orch.EditCapabilityFieldRequest
  */
@@ -300,10 +272,25 @@ export type EditCapabilityFieldRequest = Message<"quixos.orch.EditCapabilityFiel
      * @generated from field: string binding_digest = 4;
      */
     bindingDigest: string;
+    /**
+     * @generated from oneof quixos.orch.EditCapabilityFieldRequest.edit
+     */
+    edit: {
         /**
          * @generated from field: camino.CrdtValue update = 5;
          */
-    update?: CrdtValue | undefined;
+        value: CrdtValue;
+        case: "update";
+    } | {
+        /**
+         * @generated from field: camino.Value replacement = 7;
+         */
+        value: Value;
+        case: "replacement";
+    } | {
+        case: undefined;
+        value?: undefined;
+    };
     /**
      * @generated from field: string client_mutation_id = 6;
      */
@@ -371,7 +358,7 @@ export type WatchCapabilityEvent = Message<"quixos.orch.WatchCapabilityEvent"> &
      */
     initial: boolean;
     /**
-     * @generated from field: quixos.orch.FieldEditing field_editing = 8;
+     * @generated from field: quixos.FieldEditing field_editing = 8;
      */
     fieldEditing?: FieldEditing | undefined;
 };

dist/quixos/refs_pb.d.ts

@@ -1,4 +1,4 @@
-import type { GenFile, GenMessage } from "@bufbuild/protobuf/codegenv2";
+import type { GenEnum, GenFile, GenMessage } from "@bufbuild/protobuf/codegenv2";
 import type { Message } from "@bufbuild/protobuf";
 /**
  * Describes the file quixos/refs.proto.
@@ -28,6 +28,59 @@ export type CapabilityRef = Message<"quixos.CapabilityRef"> & {
  * Use `create(CapabilityRefSchema)` to create a new message.
  */
 export declare const CapabilityRefSchema: GenMessage<CapabilityRef>;
+/**
+ * Resolved native editing semantics. A source snapshot alone grants no writer.
+ *
+ * @generated from message quixos.FieldEditing
+ */
+export type FieldEditing = Message<"quixos.FieldEditing"> & {
+    /**
+     * @generated from field: string getter_operation_id = 1;
+     */
+    getterOperationId: string;
+    /**
+     * @generated from field: string setter_operation_id = 2;
+     */
+    setterOperationId: string;
+    /**
+     * @generated from field: string document_type = 3;
+     */
+    documentType: string;
+    /**
+     * @generated from field: string binding_digest = 4;
+     */
+    bindingDigest: string;
+    /**
+     * @generated from field: quixos.FieldEditing.Mode mode = 5;
+     */
+    mode: FieldEditing_Mode;
+};
+/**
+ * Describes the message quixos.FieldEditing.
+ * Use `create(FieldEditingSchema)` to create a new message.
+ */
+export declare const FieldEditingSchema: GenMessage<FieldEditing>;
+/**
+ * @generated from enum quixos.FieldEditing.Mode
+ */
+export declare enum FieldEditing_Mode {
+    /**
+     * @generated from enum value: UNSPECIFIED = 0;
+     */
+    UNSPECIFIED = 0,
+    /**
+     * @generated from enum value: REGISTER = 1;
+     */
+    REGISTER = 1,
+    /**
+     * @generated from enum value: CRDT = 2;
+     */
+    CRDT = 2
+}
+/**
+ * Describes the enum quixos.FieldEditing.Mode.
+ */
+export declare const FieldEditing_ModeSchema: GenEnum<FieldEditing_Mode>;
 /**
  * @generated from message quixos.ConformanceWitness
  */

dist/quixos/refs_pb.d.ts.map

@@ -1 +1 @@
-{"version":3,"file":"refs_pb.d.ts","sourceRoot":"","sources":["../../src/quixos/refs_pb.ts"],"names":[],"mappings":"AAIA,OAAO,KAAK,EAAE,OAAO,EAAE,UAAU,EAAE,MAAM,8BAA8B,CAAC;AAExE,OAAO,KAAK,EAAE,OAAO,EAAE,MAAM,oBAAoB,CAAC;AAElD;;GAEG;AACH,eAAO,MAAM,gBAAgB,EAAE,OAC21B,CAAC;AAE33B;;GAEG;AACH,MAAM,MAAM,aAAa,GAAG,OAAO,CAAC,sBAAsB,CAAC,GAAG;IAC5D;;OAEG;IACH,mBAAmB,EAAE,MAAM,CAAC;IAE5B;;OAEG;IACH,WAAW,EAAE,MAAM,CAAC;IAEpB;;;;OAIG;IACH,WAAW,CAAC,EAAE,kBAAkB,GAAG,SAAS,CAAC;CAC9C,CAAC;AAEF;;;GAGG;AACH,eAAO,MAAM,mBAAmB,EAAE,UAAU,CAAC,aAAa,CACxB,CAAC;AAEnC;;GAEG;AACH,MAAM,MAAM,kBAAkB,GAAG,OAAO,CAAC,2BAA2B,CAAC,GAAG;IACtE;;OAEG;IACH,QAAQ,EAAE,MAAM,CAAC;IAEjB;;OAEG;IACH,mBAAmB,EAAE,MAAM,CAAC;IAE5B;;OAEG;IACH,aAAa,EAAE,MAAM,CAAC;IAEtB;;OAEG;IACH,mBAAmB,EAAE,MAAM,CAAC;IAE5B;;OAEG;IACH,cAAc,EAAE,MAAM,CAAC;CACxB,CAAC;AAEF;;;GAGG;AACH,eAAO,MAAM,wBAAwB,EAAE,UAAU,CAAC,kBAAkB,CAClC,CAAC;AAEnC;;GAEG;AACH,MAAM,MAAM,gBAAgB,GAAG,OAAO,CAAC,yBAAyB,CAAC,GAAG;IAClE;;OAEG;IACH,iBAAiB,EAAE,MAAM,CAAC;IAE1B;;OAEG;IACH,QAAQ,EAAE,MAAM,CAAC;CAClB,CAAC;AAEF;;;GAGG;AACH,eAAO,MAAM,sBAAsB,EAAE,UAAU,CAAC,gBAAgB,CAC9B,CAAC;AAEnC;;GAEG;AACH,MAAM,MAAM,kBAAkB,GAAG,OAAO,CAAC,2BAA2B,CAAC,GAAG;IACtE;;OAEG;IACH,MAAM,EAAE,MAAM,CAAC;IAEf;;OAEG;IACH,OAAO,EAAE;QACP;;WAEG;QACH,KAAK,EAAE,MAAM,CAAC;QACd,IAAI,EAAE,aAAa,CAAC;KACrB,GAAG;QACF;;WAEG;QACH,KAAK,EAAE,cAAc,CAAC;QACtB,IAAI,EAAE,MAAM,CAAC;KACd,GAAG;QACF;;WAEG;QACH,KAAK,EAAE,MAAM,CAAC;QACd,IAAI,EAAE,qBAAqB,CAAC;KAC7B,GAAG;QACF;;WAEG;QACH,KAAK,EAAE,MAAM,CAAC;QACd,IAAI,EAAE,mBAAmB,CAAC;KAC3B,GAAG;QACF;;WAEG;QACH,KAAK,EAAE,MAAM,CAAC;QACd,IAAI,EAAE,SAAS,CAAC;KACjB,GAAG;QAAE,IAAI,EAAE,SAAS,CAAC;QAAC,KAAK,CAAC,EAAE,SAAS,CAAA;KAAE,CAAC;IAE3C;;;;;OAKG;IACH,QAAQ,EAAE,MAAM,CAAC;CAClB,CAAC;AAEF;;;GAGG;AACH,eAAO,MAAM,wBAAwB,EAAE,UAAU,CAAC,kBAAkB,CAClC,CAAC;AAEnC;;GAEG;AACH,MAAM,MAAM,cAAc,GAAG,OAAO,CAAC,uBAAuB,CAAC,GAAG;IAC9D;;OAEG;IACH,UAAU,EAAE,MAAM,CAAC;IAEnB;;OAEG;IACH,YAAY,EAAE,MAAM,CAAC;CACtB,CAAC;AAEF;;;GAGG;AACH,eAAO,MAAM,oBAAoB,EAAE,UAAU,CAAC,cAAc,CAC1B,CAAC"}
+{"version":3,"file":"refs_pb.d.ts","sourceRoot":"","sources":["../../src/quixos/refs_pb.ts"],"names":[],"mappings":"AAIA,OAAO,KAAK,EAAE,OAAO,EAAE,OAAO,EAAE,UAAU,EAAE,MAAM,8BAA8B,CAAC;AAEjF,OAAO,KAAK,EAAE,OAAO,EAAE,MAAM,oBAAoB,CAAC;AAElD;;GAEG;AACH,eAAO,MAAM,gBAAgB,EAAE,OACsnC,CAAC;AAEtpC;;GAEG;AACH,MAAM,MAAM,aAAa,GAAG,OAAO,CAAC,sBAAsB,CAAC,GAAG;IAC5D;;OAEG;IACH,mBAAmB,EAAE,MAAM,CAAC;IAE5B;;OAEG;IACH,WAAW,EAAE,MAAM,CAAC;IAEpB;;;;OAIG;IACH,WAAW,CAAC,EAAE,kBAAkB,GAAG,SAAS,CAAC;CAC9C,CAAC;AAEF;;;GAGG;AACH,eAAO,MAAM,mBAAmB,EAAE,UAAU,CAAC,aAAa,CACxB,CAAC;AAEnC;;;;GAIG;AACH,MAAM,MAAM,YAAY,GAAG,OAAO,CAAC,qBAAqB,CAAC,GAAG;IAC1D;;OAEG;IACH,iBAAiB,EAAE,MAAM,CAAC;IAE1B;;OAEG;IACH,iBAAiB,EAAE,MAAM,CAAC;IAE1B;;OAEG;IACH,YAAY,EAAE,MAAM,CAAC;IAErB;;OAEG;IACH,aAAa,EAAE,MAAM,CAAC;IAEtB;;OAEG;IACH,IAAI,EAAE,iBAAiB,CAAC;CACzB,CAAC;AAEF;;;GAGG;AACH,eAAO,MAAM,kBAAkB,EAAE,UAAU,CAAC,YAAY,CACtB,CAAC;AAEnC;;GAEG;AACH,oBAAY,iBAAiB;IAC3B;;OAEG;IACH,WAAW,IAAI;IAEf;;OAEG;IACH,QAAQ,IAAI;IAEZ;;OAEG;IACH,IAAI,IAAI;CACT;AAED;;GAEG;AACH,eAAO,MAAM,uBAAuB,EAAE,OAAO,CAAC,iBAAiB,CAC7B,CAAC;AAEnC;;GAEG;AACH,MAAM,MAAM,kBAAkB,GAAG,OAAO,CAAC,2BAA2B,CAAC,GAAG;IACtE;;OAEG;IACH,QAAQ,EAAE,MAAM,CAAC;IAEjB;;OAEG;IACH,mBAAmB,EAAE,MAAM,CAAC;IAE5B;;OAEG;IACH,aAAa,EAAE,MAAM,CAAC;IAEtB;;OAEG;IACH,mBAAmB,EAAE,MAAM,CAAC;IAE5B;;OAEG;IACH,cAAc,EAAE,MAAM,CAAC;CACxB,CAAC;AAEF;;;GAGG;AACH,eAAO,MAAM,wBAAwB,EAAE,UAAU,CAAC,kBAAkB,CAClC,CAAC;AAEnC;;GAEG;AACH,MAAM,MAAM,gBAAgB,GAAG,OAAO,CAAC,yBAAyB,CAAC,GAAG;IAClE;;OAEG;IACH,iBAAiB,EAAE,MAAM,CAAC;IAE1B;;OAEG;IACH,QAAQ,EAAE,MAAM,CAAC;CAClB,CAAC;AAEF;;;GAGG;AACH,eAAO,MAAM,sBAAsB,EAAE,UAAU,CAAC,gBAAgB,CAC9B,CAAC;AAEnC;;GAEG;AACH,MAAM,MAAM,kBAAkB,GAAG,OAAO,CAAC,2BAA2B,CAAC,GAAG;IACtE;;OAEG;IACH,MAAM,EAAE,MAAM,CAAC;IAEf;;OAEG;IACH,OAAO,EAAE;QACP;;WAEG;QACH,KAAK,EAAE,MAAM,CAAC;QACd,IAAI,EAAE,aAAa,CAAC;KACrB,GAAG;QACF;;WAEG;QACH,KAAK,EAAE,cAAc,CAAC;QACtB,IAAI,EAAE,MAAM,CAAC;KACd,GAAG;QACF;;WAEG;QACH,KAAK,EAAE,MAAM,CAAC;QACd,IAAI,EAAE,qBAAqB,CAAC;KAC7B,GAAG;QACF;;WAEG;QACH,KAAK,EAAE,MAAM,CAAC;QACd,IAAI,EAAE,mBAAmB,CAAC;KAC3B,GAAG;QACF;;WAEG;QACH,KAAK,EAAE,MAAM,CAAC;QACd,IAAI,EAAE,SAAS,CAAC;KACjB,GAAG;QAAE,IAAI,EAAE,SAAS,CAAC;QAAC,KAAK,CAAC,EAAE,SAAS,CAAA;KAAE,CAAC;IAE3C;;;;;OAKG;IACH,QAAQ,EAAE,MAAM,CAAC;CAClB,CAAC;AAEF;;;GAGG;AACH,eAAO,MAAM,wBAAwB,EAAE,UAAU,CAAC,kBAAkB,CAClC,CAAC;AAEnC;;GAEG;AACH,MAAM,MAAM,cAAc,GAAG,OAAO,CAAC,uBAAuB,CAAC,GAAG;IAC9D;;OAEG;IACH,UAAU,EAAE,MAAM,CAAC;IAEnB;;OAEG;IACH,YAAY,EAAE,MAAM,CAAC;CACtB,CAAC;AAEF;;;GAGG;AACH,eAAO,MAAM,oBAAoB,EAAE,UAAU,CAAC,cAAc,CAC1B,CAAC"}

dist/quixos/refs_pb.js

@@ -1,33 +1,60 @@
 // @generated by protoc-gen-es v2.12.1 with parameter "target=ts,import_extension=js"
 // @generated from file quixos/refs.proto (package quixos, syntax proto3)
 /* eslint-disable */
-import { fileDesc, messageDesc } from "@bufbuild/protobuf/codegenv2";
+import { enumDesc, fileDesc, messageDesc } from "@bufbuild/protobuf/codegenv2";
 /**
  * Describes the file quixos/refs.proto.
  */
-export const file_quixos_refs = /*@__PURE__*/ fileDesc("ChFxdWl4b3MvcmVmcy5wcm90bxIGcXVpeG9zInUKDUNhcGFiaWxpdHlSZWYSHQoVaW50ZXJmYWNlX3JldmlzaW9uX2lkGAEgASgJEhQKDG9wZXJhdGlvbl9pZBgCIAEoCRIvCgtjb25mb3JtYW5jZRgDIAEoCzIaLnF1aXhvcy5Db25mb3JtYW5jZVdpdG5lc3MilgEKEkNvbmZvcm1hbmNlV2l0bmVzcxIRCglvYmplY3RfaWQYASABKAkSHQoVaW50ZXJmYWNlX3JldmlzaW9uX2lkGAIgASgJEhYKDmNvbmZvcm1hbmNlX2lkGAMgASgJEh0KFXdvcmtzcGFjZV9yZXZpc2lvbl9pZBgEIAEoCRIXCg93b3Jrc3BhY2VfZXBvY2gYBSABKAkiQgoQUGFja2FnZUV4cG9ydFJlZhIbChNwYWNrYWdlX3JldmlzaW9uX2lkGAEgASgJEhEKCWV4cG9ydF9pZBgCIAEoCSLYAQoSSW5qZWN0ZWREZXBlbmRlbmN5Eg8KB3BvcnRfaWQYASABKAkSFwoNc3RhdGVfc2xvdF9pZBgCIAEoCUgAEiYKBGVkZ2UYAyABKAsyFi5xdWl4b3MuRWRnZURlcGVuZGVuY3lIABIfChVpbnRlcmZhY2VfcmV2aXNpb25faWQYBCABKAlIABIdChNjb25zdHJ1Y3Rvcl9hdG9tX2lkGAUgASgJSAASEgoIcXVlcnlfaWQYByABKAlIABIRCglvYmplY3RfaWQYBiABKAlCCQoHYmluZGluZyI9Cg5FZGdlRGVwZW5kZW5jeRIUCgxlZGdlX3R5cGVfaWQYASABKAkSFQoNcHJvamVjdGlvbl9pZBgCIAEoCWIGcHJvdG8z");
+export const file_quixos_refs = /*@__PURE__*/ fileDesc("ChFxdWl4b3MvcmVmcy5wcm90bxIGcXVpeG9zInUKDUNhcGFiaWxpdHlSZWYSHQoVaW50ZXJmYWNlX3JldmlzaW9uX2lkGAEgASgJEhQKDG9wZXJhdGlvbl9pZBgCIAEoCRIvCgtjb25mb3JtYW5jZRgDIAEoCzIaLnF1aXhvcy5Db25mb3JtYW5jZVdpdG5lc3Mi0QEKDEZpZWxkRWRpdGluZxIbChNnZXR0ZXJfb3BlcmF0aW9uX2lkGAEgASgJEhsKE3NldHRlcl9vcGVyYXRpb25faWQYAiABKAkSFQoNZG9jdW1lbnRfdHlwZRgDIAEoCRIWCg5iaW5kaW5nX2RpZ2VzdBgEIAEoCRInCgRtb2RlGAUgASgOMhkucXVpeG9zLkZpZWxkRWRpdGluZy5Nb2RlIi8KBE1vZGUSDwoLVU5TUEVDSUZJRUQQABIMCghSRUdJU1RFUhABEggKBENSRFQQAiKWAQoSQ29uZm9ybWFuY2VXaXRuZXNzEhEKCW9iamVjdF9pZBgBIAEoCRIdChVpbnRlcmZhY2VfcmV2aXNpb25faWQYAiABKAkSFgoOY29uZm9ybWFuY2VfaWQYAyABKAkSHQoVd29ya3NwYWNlX3JldmlzaW9uX2lkGAQgASgJEhcKD3dvcmtzcGFjZV9lcG9jaBgFIAEoCSJCChBQYWNrYWdlRXhwb3J0UmVmEhsKE3BhY2thZ2VfcmV2aXNpb25faWQYASABKAkSEQoJZXhwb3J0X2lkGAIgASgJItgBChJJbmplY3RlZERlcGVuZGVuY3kSDwoHcG9ydF9pZBgBIAEoCRIXCg1zdGF0ZV9zbG90X2lkGAIgASgJSAASJgoEZWRnZRgDIAEoCzIWLnF1aXhvcy5FZGdlRGVwZW5kZW5jeUgAEh8KFWludGVyZmFjZV9yZXZpc2lvbl9pZBgEIAEoCUgAEh0KE2NvbnN0cnVjdG9yX2F0b21faWQYBSABKAlIABISCghxdWVyeV9pZBgHIAEoCUgAEhEKCW9iamVjdF9pZBgGIAEoCUIJCgdiaW5kaW5nIj0KDkVkZ2VEZXBlbmRlbmN5EhQKDGVkZ2VfdHlwZV9pZBgBIAEoCRIVCg1wcm9qZWN0aW9uX2lkGAIgASgJYgZwcm90bzM");
 /**
  * Describes the message quixos.CapabilityRef.
  * Use `create(CapabilityRefSchema)` to create a new message.
  */
 export const CapabilityRefSchema = /*@__PURE__*/ messageDesc(file_quixos_refs, 0);
+/**
+ * Describes the message quixos.FieldEditing.
+ * Use `create(FieldEditingSchema)` to create a new message.
+ */
+export const FieldEditingSchema = /*@__PURE__*/ messageDesc(file_quixos_refs, 1);
+/**
+ * @generated from enum quixos.FieldEditing.Mode
+ */
+export var FieldEditing_Mode;
+(function (FieldEditing_Mode) {
+    /**
+     * @generated from enum value: UNSPECIFIED = 0;
+     */
+    FieldEditing_Mode[FieldEditing_Mode["UNSPECIFIED"] = 0] = "UNSPECIFIED";
+    /**
+     * @generated from enum value: REGISTER = 1;
+     */
+    FieldEditing_Mode[FieldEditing_Mode["REGISTER"] = 1] = "REGISTER";
+    /**
+     * @generated from enum value: CRDT = 2;
+     */
+    FieldEditing_Mode[FieldEditing_Mode["CRDT"] = 2] = "CRDT";
+})(FieldEditing_Mode || (FieldEditing_Mode = {}));
+/**
+ * Describes the enum quixos.FieldEditing.Mode.
+ */
+export const FieldEditing_ModeSchema = /*@__PURE__*/ enumDesc(file_quixos_refs, 1, 0);
 /**
  * Describes the message quixos.ConformanceWitness.
  * Use `create(ConformanceWitnessSchema)` to create a new message.
  */
-export const ConformanceWitnessSchema = /*@__PURE__*/ messageDesc(file_quixos_refs, 1);
+export const ConformanceWitnessSchema = /*@__PURE__*/ messageDesc(file_quixos_refs, 2);
 /**
  * Describes the message quixos.PackageExportRef.
  * Use `create(PackageExportRefSchema)` to create a new message.
  */
-export const PackageExportRefSchema = /*@__PURE__*/ messageDesc(file_quixos_refs, 2);
+export const PackageExportRefSchema = /*@__PURE__*/ messageDesc(file_quixos_refs, 3);
 /**
  * Describes the message quixos.InjectedDependency.
  * Use `create(InjectedDependencySchema)` to create a new message.
  */
-export const InjectedDependencySchema = /*@__PURE__*/ messageDesc(file_quixos_refs, 3);
+export const InjectedDependencySchema = /*@__PURE__*/ messageDesc(file_quixos_refs, 4);
 /**
  * Describes the message quixos.EdgeDependency.
  * Use `create(EdgeDependencySchema)` to create a new message.
  */
-export const EdgeDependencySchema = /*@__PURE__*/ messageDesc(file_quixos_refs, 4);
+export const EdgeDependencySchema = /*@__PURE__*/ messageDesc(file_quixos_refs, 5);

flake.lock

@@ -74,17 +74,17 @@
         "nixpkgs": "nixpkgs_2"
       },
       "locked": {
-        "lastModified": 1789688984,
+        "lastModified": 1789723189,
-        "narHash": "sha256-wwLDdgsgJ5jpm7up/K303TIix62cDmGmwP0uN3HFehQ=",
+        "narHash": "sha256-IsiBSkuu/d2IgASVi4S1ZdKk1mTglS+HMJWrNYQohJM=",
-        "ref": "refs/tags/quixos-reachability/ae0a5064a457ee614f08f551d1be2d0c43c83716",
+        "ref": "refs/tags/quixos-reachability/b0d31ba51c4c1c49ec2ba715c99e5f5327505d01",
-        "rev": "ae0a5064a457ee614f08f551d1be2d0c43c83716",
+        "rev": "b0d31ba51c4c1c49ec2ba715c99e5f5327505d01",
-        "revCount": 84,
+        "revCount": 92,
         "type": "git",
         "url": "https://gitea-external.egads.tutti.syntaxblitz.net/quixos/quixos-protocol.git"
       },
       "original": {
-        "ref": "refs/tags/quixos-reachability/ae0a5064a457ee614f08f551d1be2d0c43c83716",
+        "ref": "refs/tags/quixos-reachability/b0d31ba51c4c1c49ec2ba715c99e5f5327505d01",
-        "rev": "ae0a5064a457ee614f08f551d1be2d0c43c83716",
+        "rev": "b0d31ba51c4c1c49ec2ba715c99e5f5327505d01",
         "type": "git",
         "url": "https://gitea-external.egads.tutti.syntaxblitz.net/quixos/quixos-protocol.git"
       }

flake.nix

@@ -4,7 +4,7 @@
   inputs = {
     nixpkgs.url = "github:NixOS/nixpkgs/nixos-unstable";
     flake-utils.url = "github:numtide/flake-utils";
-    quixos-protocol.url = "git+https://gitea-external.egads.tutti.syntaxblitz.net/quixos/quixos-protocol.git?ref=refs/tags/quixos-reachability/ae0a5064a457ee614f08f551d1be2d0c43c83716&rev=ae0a5064a457ee614f08f551d1be2d0c43c83716";
+    quixos-protocol.url = "git+https://gitea-external.egads.tutti.syntaxblitz.net/quixos/quixos-protocol.git?ref=refs/tags/quixos-reachability/b0d31ba51c4c1c49ec2ba715c99e5f5327505d01&rev=b0d31ba51c4c1c49ec2ba715c99e5f5327505d01";
     quixosNixHelpers = {
       url = "git+https://gitea-external.egads.tutti.syntaxblitz.net/quixos/quixos-nix-helpers.git?ref=refs/tags/quixos-reachability/7177130c0365f2fa58ea4877366e1c5d17db4c01&rev=7177130c0365f2fa58ea4877366e1c5d17db4c01";
       flake = false;

src/queries.ts

@@ -35,7 +35,7 @@ export function decodeQuerySnapshot<T>(
   runId: string,
   sequence: bigint,
 ): QxQuerySnapshot<T> {
-  if (response.preparationToken || response.residualWindows.length)
+  if (response.preparationToken || response.residualWindows.length || response.relationalCaptures.length)
     throw new Error("QUERY_RESULT_UNFINISHED: private preparation is not a query result");
   const fields = [
     ...response.pending.map((field) => ({ path: field.path, status: "pending" as const })),

src/quixos/refs_pb.ts

@@ -2,15 +2,15 @@
 // @generated from file quixos/refs.proto (package quixos, syntax proto3)
 /* eslint-disable */
 
-import type { GenFile, GenMessage } from "@bufbuild/protobuf/codegenv2";
+import type { GenEnum, GenFile, GenMessage } from "@bufbuild/protobuf/codegenv2";
-import { fileDesc, messageDesc } from "@bufbuild/protobuf/codegenv2";
+import { enumDesc, fileDesc, messageDesc } from "@bufbuild/protobuf/codegenv2";
 import type { Message } from "@bufbuild/protobuf";
 
 /**
  * Describes the file quixos/refs.proto.
  */
 export const file_quixos_refs: GenFile = /*@__PURE__*/
-  fileDesc("ChFxdWl4b3MvcmVmcy5wcm90bxIGcXVpeG9zInUKDUNhcGFiaWxpdHlSZWYSHQoVaW50ZXJmYWNlX3JldmlzaW9uX2lkGAEgASgJEhQKDG9wZXJhdGlvbl9pZBgCIAEoCRIvCgtjb25mb3JtYW5jZRgDIAEoCzIaLnF1aXhvcy5Db25mb3JtYW5jZVdpdG5lc3MilgEKEkNvbmZvcm1hbmNlV2l0bmVzcxIRCglvYmplY3RfaWQYASABKAkSHQoVaW50ZXJmYWNlX3JldmlzaW9uX2lkGAIgASgJEhYKDmNvbmZvcm1hbmNlX2lkGAMgASgJEh0KFXdvcmtzcGFjZV9yZXZpc2lvbl9pZBgEIAEoCRIXCg93b3Jrc3BhY2VfZXBvY2gYBSABKAkiQgoQUGFja2FnZUV4cG9ydFJlZhIbChNwYWNrYWdlX3JldmlzaW9uX2lkGAEgASgJEhEKCWV4cG9ydF9pZBgCIAEoCSLYAQoSSW5qZWN0ZWREZXBlbmRlbmN5Eg8KB3BvcnRfaWQYASABKAkSFwoNc3RhdGVfc2xvdF9pZBgCIAEoCUgAEiYKBGVkZ2UYAyABKAsyFi5xdWl4b3MuRWRnZURlcGVuZGVuY3lIABIfChVpbnRlcmZhY2VfcmV2aXNpb25faWQYBCABKAlIABIdChNjb25zdHJ1Y3Rvcl9hdG9tX2lkGAUgASgJSAASEgoIcXVlcnlfaWQYByABKAlIABIRCglvYmplY3RfaWQYBiABKAlCCQoHYmluZGluZyI9Cg5FZGdlRGVwZW5kZW5jeRIUCgxlZGdlX3R5cGVfaWQYASABKAkSFQoNcHJvamVjdGlvbl9pZBgCIAEoCWIGcHJvdG8z");
+  fileDesc("ChFxdWl4b3MvcmVmcy5wcm90bxIGcXVpeG9zInUKDUNhcGFiaWxpdHlSZWYSHQoVaW50ZXJmYWNlX3JldmlzaW9uX2lkGAEgASgJEhQKDG9wZXJhdGlvbl9pZBgCIAEoCRIvCgtjb25mb3JtYW5jZRgDIAEoCzIaLnF1aXhvcy5Db25mb3JtYW5jZVdpdG5lc3Mi0QEKDEZpZWxkRWRpdGluZxIbChNnZXR0ZXJfb3BlcmF0aW9uX2lkGAEgASgJEhsKE3NldHRlcl9vcGVyYXRpb25faWQYAiABKAkSFQoNZG9jdW1lbnRfdHlwZRgDIAEoCRIWCg5iaW5kaW5nX2RpZ2VzdBgEIAEoCRInCgRtb2RlGAUgASgOMhkucXVpeG9zLkZpZWxkRWRpdGluZy5Nb2RlIi8KBE1vZGUSDwoLVU5TUEVDSUZJRUQQABIMCghSRUdJU1RFUhABEggKBENSRFQQAiKWAQoSQ29uZm9ybWFuY2VXaXRuZXNzEhEKCW9iamVjdF9pZBgBIAEoCRIdChVpbnRlcmZhY2VfcmV2aXNpb25faWQYAiABKAkSFgoOY29uZm9ybWFuY2VfaWQYAyABKAkSHQoVd29ya3NwYWNlX3JldmlzaW9uX2lkGAQgASgJEhcKD3dvcmtzcGFjZV9lcG9jaBgFIAEoCSJCChBQYWNrYWdlRXhwb3J0UmVmEhsKE3BhY2thZ2VfcmV2aXNpb25faWQYASABKAkSEQoJZXhwb3J0X2lkGAIgASgJItgBChJJbmplY3RlZERlcGVuZGVuY3kSDwoHcG9ydF9pZBgBIAEoCRIXCg1zdGF0ZV9zbG90X2lkGAIgASgJSAASJgoEZWRnZRgDIAEoCzIWLnF1aXhvcy5FZGdlRGVwZW5kZW5jeUgAEh8KFWludGVyZmFjZV9yZXZpc2lvbl9pZBgEIAEoCUgAEh0KE2NvbnN0cnVjdG9yX2F0b21faWQYBSABKAlIABISCghxdWVyeV9pZBgHIAEoCUgAEhEKCW9iamVjdF9pZBgGIAEoCUIJCgdiaW5kaW5nIj0KDkVkZ2VEZXBlbmRlbmN5EhQKDGVkZ2VfdHlwZV9pZBgBIAEoCRIVCg1wcm9qZWN0aW9uX2lkGAIgASgJYgZwcm90bzM");
 
 /**
  * @generated from message quixos.CapabilityRef
@@ -41,6 +41,71 @@ export type CapabilityRef = Message<"quixos.CapabilityRef"> & {
 export const CapabilityRefSchema: GenMessage<CapabilityRef> = /*@__PURE__*/
   messageDesc(file_quixos_refs, 0);
 
+/**
+ * Resolved native editing semantics. A source snapshot alone grants no writer.
+ *
+ * @generated from message quixos.FieldEditing
+ */
+export type FieldEditing = Message<"quixos.FieldEditing"> & {
+  /**
+   * @generated from field: string getter_operation_id = 1;
+   */
+  getterOperationId: string;
+
+  /**
+   * @generated from field: string setter_operation_id = 2;
+   */
+  setterOperationId: string;
+
+  /**
+   * @generated from field: string document_type = 3;
+   */
+  documentType: string;
+
+  /**
+   * @generated from field: string binding_digest = 4;
+   */
+  bindingDigest: string;
+
+  /**
+   * @generated from field: quixos.FieldEditing.Mode mode = 5;
+   */
+  mode: FieldEditing_Mode;
+};
+
+/**
+ * Describes the message quixos.FieldEditing.
+ * Use `create(FieldEditingSchema)` to create a new message.
+ */
+export const FieldEditingSchema: GenMessage<FieldEditing> = /*@__PURE__*/
+  messageDesc(file_quixos_refs, 1);
+
+/**
+ * @generated from enum quixos.FieldEditing.Mode
+ */
+export enum FieldEditing_Mode {
+  /**
+   * @generated from enum value: UNSPECIFIED = 0;
+   */
+  UNSPECIFIED = 0,
+
+  /**
+   * @generated from enum value: REGISTER = 1;
+   */
+  REGISTER = 1,
+
+  /**
+   * @generated from enum value: CRDT = 2;
+   */
+  CRDT = 2,
+}
+
+/**
+ * Describes the enum quixos.FieldEditing.Mode.
+ */
+export const FieldEditing_ModeSchema: GenEnum<FieldEditing_Mode> = /*@__PURE__*/
+  enumDesc(file_quixos_refs, 1, 0);
+
 /**
  * @generated from message quixos.ConformanceWitness
  */
@@ -76,7 +141,7 @@ export type ConformanceWitness = Message<"quixos.ConformanceWitness"> & {
  * Use `create(ConformanceWitnessSchema)` to create a new message.
  */
 export const ConformanceWitnessSchema: GenMessage<ConformanceWitness> = /*@__PURE__*/
-  messageDesc(file_quixos_refs, 1);
+  messageDesc(file_quixos_refs, 2);
 
 /**
  * @generated from message quixos.PackageExportRef
@@ -98,7 +163,7 @@ export type PackageExportRef = Message<"quixos.PackageExportRef"> & {
  * Use `create(PackageExportRefSchema)` to create a new message.
  */
 export const PackageExportRefSchema: GenMessage<PackageExportRef> = /*@__PURE__*/
-  messageDesc(file_quixos_refs, 2);
+  messageDesc(file_quixos_refs, 3);
 
 /**
  * @generated from message quixos.InjectedDependency
@@ -158,7 +223,7 @@ export type InjectedDependency = Message<"quixos.InjectedDependency"> & {
  * Use `create(InjectedDependencySchema)` to create a new message.
  */
 export const InjectedDependencySchema: GenMessage<InjectedDependency> = /*@__PURE__*/
-  messageDesc(file_quixos_refs, 3);
+  messageDesc(file_quixos_refs, 4);
 
 /**
  * @generated from message quixos.EdgeDependency
@@ -180,5 +245,5 @@ export type EdgeDependency = Message<"quixos.EdgeDependency"> & {
  * Use `create(EdgeDependencySchema)` to create a new message.
  */
 export const EdgeDependencySchema: GenMessage<EdgeDependency> = /*@__PURE__*/
-  messageDesc(file_quixos_refs, 4);
+  messageDesc(file_quixos_refs, 5);
 

test/queries.test.mjs

@@ -5,6 +5,14 @@ import { QueryResponseSchema } from "../dist/camino/api_pb.js";
 import { InjectedDependencySchema } from "../dist/quixos/refs_pb.js";
 import { createRuntimeContext, decodeQuerySnapshot, jsToProtoValue, protoValueToJs } from "../dist/index.js";
 
+test("private relational captures cannot be decoded as a completed public query", () => {
+  const response = create(QueryResponseSchema, { relationalCaptures: [{ rootObjectId: "obj:private" }] });
+  assert.throws(
+    () => decodeQuerySnapshot(response, { kind: "record", fields: {} }, "run", 1n),
+    /QUERY_RESULT_UNFINISHED/,
+  );
+});
+
 test("query ports carry only an injected query identity and root", async () => {
   let seen;
   const context = createRuntimeContext(