Raw queries against the cell_field table.
Named-relation primitive: each row is (source_id, name) → target_id,
a JSON-object-shaped edge from one cell to another. (source_id, name)
is unique — one target per name per source. Multiplicity by composition
(target a collection cell whose items[] are the multi-valued tags),
not by allowing duplicate field rows.
Reads filter both endpoints by cell.deleted_at IS NULL so relations
dangling off a soft-deleted cell don't surface to the live graph.
query_cell_field_set upserts on the (source_id, name) PK so
re-pointing a name updates target_id in place — JSON-object semantics
(obj.foo = bar overwrites whatever was there).
8 declarations
db/cell_field_queries.ts view source
readonly ["source_id", "name", "target_id", "created_at"] import {CELL_FIELD_COLUMNS} from '@fuzdev/fuz_app/db/cell_field_queries.js'; The full cell_field column set, named explicitly so a row read fails
loud on schema drift (see CELL_COLUMNS in db/cell_queries.ts). Column
order mirrors the Rust twin's field_columns(alias) (fuz_cell). Keep in
sync with CellFieldRow and the cell_field DDL in db/cell_ddl.ts.
db/cell_field_queries.ts view source
CellFieldRow import type {CellFieldRow} from '@fuzdev/fuz_app/db/cell_field_queries.js'; Row shape returned by cell_field SELECTs.
source_idtype Uuid
nametype string
target_idtype Uuid
created_attype string
db/cell_field_queries.ts view source
CellFieldSetQueryInput import type {CellFieldSetQueryInput} from '@fuzdev/fuz_app/db/cell_field_queries.js'; Input for query_cell_field_set.
source_idtype Uuid
nametype string
target_idtype Uuid
db/cell_field_queries.ts view source
(deps: QueryDeps, source_id: string & $brand<"Uuid">, name: string): Promise<CellFieldRow | null> import {query_cell_field_delete} from '@fuzdev/fuz_app/db/cell_field_queries.js'; Delete a field row by primary key. Returns the deleted row so callers can audit the prior target_id without a pre-fetch.
depssource_idstring & $brand<"Uuid">namestringPromise<CellFieldRow | null> the deleted row, or null when no row matched (idempotent
delete: a 200 response is correct even when nothing was deleted)
db/cell_field_queries.ts view source
(deps: QueryDeps, source_id: string & $brand<"Uuid">, name: string): Promise<CellFieldRow | null> import {query_cell_field_get} from '@fuzdev/fuz_app/db/cell_field_queries.js'; Fetch one field row by primary key.
Does NOT JOIN cell — the caller decides whether to filter by
deleted_at. Used by handlers that need the row's current target_id
for audit envelopes before issuing the delete.
depsquery deps
source_idsource cell id
string & $brand<"Uuid">namefield name
stringPromise<CellFieldRow | null> the row or null when not found
db/cell_field_queries.ts view source
(deps: QueryDeps, source_id: string & $brand<"Uuid">, options?: { limit?: number | undefined; name_after?: string | undefined; } | undefined): Promise<CellFieldRow[]> import {query_cell_field_list_for_source} from '@fuzdev/fuz_app/db/cell_field_queries.js'; Forward fields list (source.fields[]).
Filters target by deleted_at IS NULL so relations to tombstoned cells
don't surface; the source filter is the caller's responsibility (gated
upstream by can_view_cell(source)).
depsquery deps
source_idsource cell id
string & $brand<"Uuid">options?limit caps the row count; name_after resumes after a
name (keyset pagination)
{ limit?: number | undefined; name_after?: string | undefined; } | undefinedPromise<CellFieldRow[]> matching rows in lex name order
db/cell_field_queries.ts view source
(deps: QueryDeps, target_id: string & $brand<"Uuid">, options?: { limit?: number | undefined; } | undefined): Promise<CellFieldRow[]> import {query_cell_field_list_for_target} from '@fuzdev/fuz_app/db/cell_field_queries.js'; Reverse fields list (target.upfields[]).
Returns rows whose target_id = $1, joined to cell on source_id so
relations from tombstoned sources don't surface. The caller-side
authz filter (per-source can_view_cell) runs after the SQL fetch
— see the 2-layer authz contract on cell_field_list({target_id}).
Bounded by limit (the wire cell_field_list cap) so a heavily
inbound-linked target can't force an unbounded fetch + per-source authz
pass on the public, IP-rate-limited reverse endpoint.
depsquery deps
target_idtarget cell id
string & $brand<"Uuid">options?limit caps the row count
{ limit?: number | undefined; } | undefinedPromise<CellFieldRow[]> matching rows, oldest field first (by the field row's created_at)
db/cell_field_queries.ts view source
(deps: QueryDeps, input: CellFieldSetQueryInput): Promise<CellFieldRow> import {query_cell_field_set} from '@fuzdev/fuz_app/db/cell_field_queries.js'; Insert or update a field row.
UPSERT on (source_id, name) — re-setting the same name updates
target_id and bumps created_at (timestamp reflects last write).
Idempotent at the row level: caller can re-issue with the same input
without checking existence first.
depsquery deps
inputsource, name, target
Promise<CellFieldRow> the inserted-or-updated row