Types

interface QueryCursor {
  pageSize: number        // Rows per page
  pagesFetched: number    // Pages retrieved so far
  done: boolean           // True when all pages exhausted
  next(): QueryResult | null   // Fetch next page
  all(): QueryResult           // Collect all remaining pages
  close(): void                // Release the cursor
}

interface LiveQuery {
  viewName: string   // Internal live view name
  cancel(): void     // Stop the subscription and drop the live view
}

interface DeltaEvent {
  added: SubscriptionRow[]     // Rows newly entering the result set
  removed: SubscriptionRow[]   // Rows leaving the result set
  current: SubscriptionRow[]   // Full current result set
  frontier: number             // Monotonic mutation sequence number
}
 
type SubscriptionRow = Record<string, string | number | boolean | null>
type SubscriptionHandler = (event: DeltaEvent) => void

interface SubscribeOptions {
  pollIntervalMs?: number   // How often to check for updates (default: 50ms, min: 10ms)
}

interface NodeSpec {
  label: string
  id: string
  contentHash?: string
  properties?: Record<string, string | number | boolean | null>
}
 
interface EdgeSpec {
  fromId: string
  toId: string
  edgeType: string
  properties?: Record<string, string | number | boolean | null>
}
 
interface GraphDelta {
  addedNodes?: NodeSpec[]
  removedNodeIds?: string[]
  addedEdges?: EdgeSpec[]
  removedEdges?: Array<{ fromId: string; toId: string; edgeType: string }>
}
 
interface DeltaStats {
  nodesAdded: number
  nodesUpdated: number
  nodesSkippedByHash: number
  nodesRemoved: number
  edgesAdded: number
  edgesRemoved: number
}
 
interface ImpactNode {
  id: string
  hop: number
}
 
interface ImpactSubgraph {
  nodes: ImpactNode[]
}