Collection

Interface: Collection<T, TKey, TUtils, TSchema, TInsertInput>

Defined in: packages/db/src/collection/index.ts:47

Enhanced Collection interface that includes both data type T and utilities TUtils

Extends

Type Parameters

T

T extends object = Record<string, unknown>

The type of items in the collection

TKey

TKey extends string | number = string | number

The type of the key for the collection

TUtils

TUtils extends UtilsRecord = UtilsRecord

The utilities record type

TSchema

TSchema extends StandardSchemaV1 = StandardSchemaV1

TInsertInput

TInsertInput extends object = T

The type for insert operations (can be different from T for schemas with defaults)

Properties

_lifecycle

ts
_lifecycle: CollectionLifecycleManager<T, TKey, TSchema, TInsertInput>;
_lifecycle: CollectionLifecycleManager<T, TKey, TSchema, TInsertInput>;

Defined in: packages/db/src/collection/index.ts:219

Inherited from

CollectionImpl._lifecycle


_state

ts
_state: CollectionStateManager<T, TKey, TSchema, TInsertInput>;
_state: CollectionStateManager<T, TKey, TSchema, TInsertInput>;

Defined in: packages/db/src/collection/index.ts:231

Inherited from

CollectionImpl._state


_sync

ts
_sync: CollectionSyncManager<T, TKey, TSchema, TInsertInput>;
_sync: CollectionSyncManager<T, TKey, TSchema, TInsertInput>;

Defined in: packages/db/src/collection/index.ts:220

Inherited from

CollectionImpl._sync


config

ts
config: CollectionConfig<T, TKey, TSchema>;
config: CollectionConfig<T, TKey, TSchema>;

Defined in: packages/db/src/collection/index.ts:210

Inherited from

CollectionImpl.config


id

ts
id: string;
id: string;

Defined in: packages/db/src/collection/index.ts:209

Inherited from

CollectionImpl.id


singleResult?

ts
readonly optional singleResult: true;
readonly optional singleResult: true;

Defined in: packages/db/src/collection/index.ts:55


utils

ts
readonly utils: TUtils;
readonly utils: TUtils;

Defined in: packages/db/src/collection/index.ts:54

Overrides

CollectionImpl.utils

Accessors

indexes

Get Signature

ts
get indexes(): Map<number, BaseIndex<TKey>>;
get indexes(): Map<number, BaseIndex<TKey>>;

Defined in: packages/db/src/collection/index.ts:496

Get resolved indexes for query optimization

Returns

Map<number, BaseIndex<TKey>>

Inherited from

CollectionImpl.indexes


isLoadingSubset

Get Signature

ts
get isLoadingSubset(): boolean;
get isLoadingSubset(): boolean;

Defined in: packages/db/src/collection/index.ts:362

Check if the collection is currently loading more data

Returns

boolean

true if the collection has pending load more operations, false otherwise

Inherited from

CollectionImpl.isLoadingSubset


size

Get Signature

ts
get size(): number;
get size(): number;

Defined in: packages/db/src/collection/index.ts:399

Get the current size of the collection (cached)

Returns

number

Inherited from

CollectionImpl.size


state

Get Signature

ts
get state(): Map<TKey, TOutput>;
get state(): Map<TKey, TOutput>;

Defined in: packages/db/src/collection/index.ts:683

Gets the current state of the collection as a Map

Example
ts
const itemsMap = collection.state
console.log(`Collection has ${itemsMap.size} items`)

for (const [key, item] of itemsMap) {
  console.log(`${key}: ${item.title}`)
}

// Check if specific item exists
if (itemsMap.has("todo-1")) {
  console.log("Todo 1 exists:", itemsMap.get("todo-1"))
}
const itemsMap = collection.state
console.log(`Collection has ${itemsMap.size} items`)

for (const [key, item] of itemsMap) {
  console.log(`${key}: ${item.title}`)
}

// Check if specific item exists
if (itemsMap.has("todo-1")) {
  console.log("Todo 1 exists:", itemsMap.get("todo-1"))
}
Returns

Map<TKey, TOutput>

Map containing all items in the collection, with keys as identifiers

Inherited from

CollectionImpl.state


status

Get Signature

ts
get status(): CollectionStatus;
get status(): CollectionStatus;

Defined in: packages/db/src/collection/index.ts:317

Gets the current status of the collection

Returns

CollectionStatus

Inherited from

CollectionImpl.status


subscriberCount

Get Signature

ts
get subscriberCount(): number;
get subscriberCount(): number;

Defined in: packages/db/src/collection/index.ts:324

Get the number of subscribers to the collection

Returns

number

Inherited from

CollectionImpl.subscriberCount


toArray

Get Signature

ts
get toArray(): TOutput[];
get toArray(): TOutput[];

Defined in: packages/db/src/collection/index.ts:712

Gets the current state of the collection as an Array

Returns

TOutput[]

An Array containing all items in the collection

Inherited from

CollectionImpl.toArray

Methods

[iterator]()

ts
iterator: IterableIterator<[TKey, T]>;
iterator: IterableIterator<[TKey, T]>;

Defined in: packages/db/src/collection/index.ts:427

Get all entries (virtual derived state)

Returns

IterableIterator<[TKey, T]>

Inherited from

CollectionImpl.[iterator]


cleanup()

ts
cleanup(): Promise<void>;
cleanup(): Promise<void>;

Defined in: packages/db/src/collection/index.ts:846

Clean up the collection by stopping sync and clearing data This can be called manually or automatically by garbage collection

Returns

Promise<void>

Inherited from

CollectionImpl.cleanup


createIndex()

ts
createIndex<TResolver>(indexCallback, config): IndexProxy<TKey>;
createIndex<TResolver>(indexCallback, config): IndexProxy<TKey>;

Defined in: packages/db/src/collection/index.ts:486

Creates an index on a collection for faster queries. Indexes significantly improve query performance by allowing constant time lookups and logarithmic time range queries instead of full scans.

Type Parameters

TResolver

TResolver extends IndexResolver<TKey> = typeof BTreeIndex

The type of the index resolver (constructor or async loader)

Parameters

indexCallback

(row) => any

Function that extracts the indexed value from each item

config

IndexOptions<TResolver> = {}

Configuration including index type and type-specific options

Returns

IndexProxy<TKey>

An index proxy that provides access to the index when ready

Example

ts
// Create a default B+ tree index
const ageIndex = collection.createIndex((row) => row.age)

// Create a ordered index with custom options
const ageIndex = collection.createIndex((row) => row.age, {
  indexType: BTreeIndex,
  options: {
    compareFn: customComparator,
    compareOptions: { direction: 'asc', nulls: 'first', stringSort: 'lexical' }
  },
  name: 'age_btree'
})

// Create an async-loaded index
const textIndex = collection.createIndex((row) => row.content, {
  indexType: async () => {
    const { FullTextIndex } = await import('./indexes/fulltext.js')
    return FullTextIndex
  },
  options: { language: 'en' }
})
// Create a default B+ tree index
const ageIndex = collection.createIndex((row) => row.age)

// Create a ordered index with custom options
const ageIndex = collection.createIndex((row) => row.age, {
  indexType: BTreeIndex,
  options: {
    compareFn: customComparator,
    compareOptions: { direction: 'asc', nulls: 'first', stringSort: 'lexical' }
  },
  name: 'age_btree'
})

// Create an async-loaded index
const textIndex = collection.createIndex((row) => row.content, {
  indexType: async () => {
    const { FullTextIndex } = await import('./indexes/fulltext.js')
    return FullTextIndex
  },
  options: { language: 'en' }
})

Inherited from

CollectionImpl.createIndex


currentStateAsChanges()

ts
currentStateAsChanges(options): 
  | void
  | ChangeMessage<T, string | number>[];
currentStateAsChanges(options): 
  | void
  | ChangeMessage<T, string | number>[];

Defined in: packages/db/src/collection/index.ts:750

Returns the current state of the collection as an array of changes

Parameters

options

CurrentStateAsChangesOptions = {}

Options including optional where filter

Returns

| void | ChangeMessage<T, string | number>[]

An array of changes

Example

ts
// Get all items as changes
const allChanges = collection.currentStateAsChanges()

// Get only items matching a condition
const activeChanges = collection.currentStateAsChanges({
  where: (row) => row.status === 'active'
})

// Get only items using a pre-compiled expression
const activeChanges = collection.currentStateAsChanges({
  whereExpression: eq(row.status, 'active')
})
// Get all items as changes
const allChanges = collection.currentStateAsChanges()

// Get only items matching a condition
const activeChanges = collection.currentStateAsChanges({
  where: (row) => row.status === 'active'
})

// Get only items using a pre-compiled expression
const activeChanges = collection.currentStateAsChanges({
  whereExpression: eq(row.status, 'active')
})

Inherited from

CollectionImpl.currentStateAsChanges


delete()

ts
delete(keys, config?): Transaction<any>;
delete(keys, config?): Transaction<any>;

Defined in: packages/db/src/collection/index.ts:660

Deletes one or more items from the collection

Parameters

keys

Single key or array of keys to delete

TKey | TKey[]

config?

OperationConfig

Optional configuration including metadata

Returns

Transaction<any>

A Transaction object representing the delete operation(s)

Examples

ts
// Delete a single item
const tx = collection.delete("todo-1")
await tx.isPersisted.promise
// Delete a single item
const tx = collection.delete("todo-1")
await tx.isPersisted.promise
ts
// Delete multiple items
const tx = collection.delete(["todo-1", "todo-2"])
await tx.isPersisted.promise
// Delete multiple items
const tx = collection.delete(["todo-1", "todo-2"])
await tx.isPersisted.promise
ts
// Delete with metadata
const tx = collection.delete("todo-1", { metadata: { reason: "completed" } })
await tx.isPersisted.promise
// Delete with metadata
const tx = collection.delete("todo-1", { metadata: { reason: "completed" } })
await tx.isPersisted.promise
ts
// Handle errors
try {
  const tx = collection.delete("item-1")
  await tx.isPersisted.promise
  console.log('Delete successful')
} catch (error) {
  console.log('Delete failed:', error)
}
// Handle errors
try {
  const tx = collection.delete("item-1")
  await tx.isPersisted.promise
  console.log('Delete successful')
} catch (error) {
  console.log('Delete failed:', error)
}

Inherited from

CollectionImpl.delete


entries()

ts
entries(): IterableIterator<[TKey, T]>;
entries(): IterableIterator<[TKey, T]>;

Defined in: packages/db/src/collection/index.ts:420

Get all entries (virtual derived state)

Returns

IterableIterator<[TKey, T]>

Inherited from

CollectionImpl.entries


forEach()

ts
forEach(callbackfn): void;
forEach(callbackfn): void;

Defined in: packages/db/src/collection/index.ts:434

Execute a callback for each entry in the collection

Parameters

callbackfn

(value, key, index) => void

Returns

void

Inherited from

CollectionImpl.forEach


get()

ts
get(key): T | undefined;
get(key): T | undefined;

Defined in: packages/db/src/collection/index.ts:385

Get the current value for a key (virtual derived state)

Parameters

key

TKey

Returns

T | undefined

Inherited from

CollectionImpl.get


getKeyFromItem()

ts
getKeyFromItem(item): TKey;
getKeyFromItem(item): TKey;

Defined in: packages/db/src/collection/index.ts:449

Parameters

item

T

Returns

TKey

Inherited from

CollectionImpl.getKeyFromItem


has()

ts
has(key): boolean;
has(key): boolean;

Defined in: packages/db/src/collection/index.ts:392

Check if a key exists in the collection (virtual derived state)

Parameters

key

TKey

Returns

boolean

Inherited from

CollectionImpl.has


insert()

ts
insert(data, config?): 
  | Transaction<Record<string, unknown>>
| Transaction<T>;
insert(data, config?): 
  | Transaction<Record<string, unknown>>
| Transaction<T>;

Defined in: packages/db/src/collection/index.ts:547

Inserts one or more items into the collection

Parameters

data

TInsertInput | TInsertInput[]

config?

InsertConfig

Optional configuration including metadata

Returns

| Transaction<Record<string, unknown>> | Transaction<T>

A Transaction object representing the insert operation(s)

Throws

If the data fails schema validation

Examples

ts
// Insert a single todo (requires onInsert handler)
const tx = collection.insert({ id: "1", text: "Buy milk", completed: false })
await tx.isPersisted.promise
// Insert a single todo (requires onInsert handler)
const tx = collection.insert({ id: "1", text: "Buy milk", completed: false })
await tx.isPersisted.promise
ts
// Insert multiple todos at once
const tx = collection.insert([
  { id: "1", text: "Buy milk", completed: false },
  { id: "2", text: "Walk dog", completed: true }
])
await tx.isPersisted.promise
// Insert multiple todos at once
const tx = collection.insert([
  { id: "1", text: "Buy milk", completed: false },
  { id: "2", text: "Walk dog", completed: true }
])
await tx.isPersisted.promise
ts
// Insert with metadata
const tx = collection.insert({ id: "1", text: "Buy groceries" },
  { metadata: { source: "mobile-app" } }
)
await tx.isPersisted.promise
// Insert with metadata
const tx = collection.insert({ id: "1", text: "Buy groceries" },
  { metadata: { source: "mobile-app" } }
)
await tx.isPersisted.promise
ts
// Handle errors
try {
  const tx = collection.insert({ id: "1", text: "New item" })
  await tx.isPersisted.promise
  console.log('Insert successful')
} catch (error) {
  console.log('Insert failed:', error)
}
// Handle errors
try {
  const tx = collection.insert({ id: "1", text: "New item" })
  await tx.isPersisted.promise
  console.log('Insert successful')
} catch (error) {
  console.log('Insert failed:', error)
}

Inherited from

CollectionImpl.insert


isReady()

ts
isReady(): boolean;
isReady(): boolean;

Defined in: packages/db/src/collection/index.ts:354

Check if the collection is ready for use Returns true if the collection has been marked as ready by its sync implementation

Returns

boolean

true if the collection is ready, false otherwise

Example

ts
if (collection.isReady()) {
  console.log('Collection is ready, data is available')
  // Safe to access collection.state
} else {
  console.log('Collection is still loading')
}
if (collection.isReady()) {
  console.log('Collection is ready, data is available')
  // Safe to access collection.state
} else {
  console.log('Collection is still loading')
}

Inherited from

CollectionImpl.isReady


keys()

ts
keys(): IterableIterator<TKey>;
keys(): IterableIterator<TKey>;

Defined in: packages/db/src/collection/index.ts:406

Get all keys (virtual derived state)

Returns

IterableIterator<TKey>

Inherited from

CollectionImpl.keys


map()

ts
map<U>(callbackfn): U[];
map<U>(callbackfn): U[];

Defined in: packages/db/src/collection/index.ts:443

Create a new array with the results of calling a function for each entry in the collection

Type Parameters

U

U

Parameters

callbackfn

(value, key, index) => U

Returns

U[]

Inherited from

CollectionImpl.map


off()

ts
off<T>(event, callback): void;
off<T>(event, callback): void;

Defined in: packages/db/src/collection/index.ts:825

Unsubscribe from a collection event

Type Parameters

T

T extends | "status:idle" | "status:loading" | "status:ready" | "status:error" | "status:cleaned-up" | "status:change" | "subscribers:change" | "loadingSubset:change"

Parameters

event

T

callback

CollectionEventHandler<T>

Returns

void

Inherited from

CollectionImpl.off


on()

ts
on<T>(event, callback): () => void;
on<T>(event, callback): () => void;

Defined in: packages/db/src/collection/index.ts:805

Subscribe to a collection event

Type Parameters

T

T extends | "status:idle" | "status:loading" | "status:ready" | "status:error" | "status:cleaned-up" | "status:change" | "subscribers:change" | "loadingSubset:change"

Parameters

event

T

callback

CollectionEventHandler<T>

Returns

ts
(): void;
(): void;
Returns

void

Inherited from

CollectionImpl.on


once()

ts
once<T>(event, callback): () => void;
once<T>(event, callback): () => void;

Defined in: packages/db/src/collection/index.ts:815

Subscribe to a collection event once

Type Parameters

T

T extends | "status:idle" | "status:loading" | "status:ready" | "status:error" | "status:cleaned-up" | "status:change" | "subscribers:change" | "loadingSubset:change"

Parameters

event

T

callback

CollectionEventHandler<T>

Returns

ts
(): void;
(): void;
Returns

void

Inherited from

CollectionImpl.once


onFirstReady()

ts
onFirstReady(callback): void;
onFirstReady(callback): void;

Defined in: packages/db/src/collection/index.ts:338

Register a callback to be executed when the collection first becomes ready Useful for preloading collections

Parameters

callback

() => void

Function to call when the collection first becomes ready

Returns

void

Example

ts
collection.onFirstReady(() => {
  console.log('Collection is ready for the first time')
  // Safe to access collection.state now
})
collection.onFirstReady(() => {
  console.log('Collection is ready for the first time')
  // Safe to access collection.state now
})

Inherited from

CollectionImpl.onFirstReady


preload()

ts
preload(): Promise<void>;
preload(): Promise<void>;

Defined in: packages/db/src/collection/index.ts:378

Preload the collection data by starting sync if not already started Multiple concurrent calls will share the same promise

Returns

Promise<void>

Inherited from

CollectionImpl.preload


startSyncImmediate()

ts
startSyncImmediate(): void;
startSyncImmediate(): void;

Defined in: packages/db/src/collection/index.ts:370

Start sync immediately - internal method for compiled queries This bypasses lazy loading for special cases like live query results

Returns

void

Inherited from

CollectionImpl.startSyncImmediate


stateWhenReady()

ts
stateWhenReady(): Promise<Map<TKey, T>>;
stateWhenReady(): Promise<Map<TKey, T>>;

Defined in: packages/db/src/collection/index.ts:697

Gets the current state of the collection as a Map, but only resolves when data is available Waits for the first sync commit to complete before resolving

Returns

Promise<Map<TKey, T>>

Promise that resolves to a Map containing all items in the collection

Inherited from

CollectionImpl.stateWhenReady


subscribeChanges()

ts
subscribeChanges(callback, options): CollectionSubscription;
subscribeChanges(callback, options): CollectionSubscription;

Defined in: packages/db/src/collection/index.ts:795

Subscribe to changes in the collection

Parameters

callback

(changes) => void

Function called when items change

options

SubscribeChangesOptions = {}

Subscription options including includeInitialState and where filter

Returns

CollectionSubscription

Unsubscribe function - Call this to stop listening for changes

Examples

ts
// Basic subscription
const subscription = collection.subscribeChanges((changes) => {
  changes.forEach(change => {
    console.log(`${change.type}: ${change.key}`, change.value)
  })
})

// Later: subscription.unsubscribe()
// Basic subscription
const subscription = collection.subscribeChanges((changes) => {
  changes.forEach(change => {
    console.log(`${change.type}: ${change.key}`, change.value)
  })
})

// Later: subscription.unsubscribe()
ts
// Include current state immediately
const subscription = collection.subscribeChanges((changes) => {
  updateUI(changes)
}, { includeInitialState: true })
// Include current state immediately
const subscription = collection.subscribeChanges((changes) => {
  updateUI(changes)
}, { includeInitialState: true })
ts
// Subscribe only to changes matching a condition
const subscription = collection.subscribeChanges((changes) => {
  updateUI(changes)
}, {
  includeInitialState: true,
  where: (row) => row.status === 'active'
})
// Subscribe only to changes matching a condition
const subscription = collection.subscribeChanges((changes) => {
  updateUI(changes)
}, {
  includeInitialState: true,
  where: (row) => row.status === 'active'
})
ts
// Subscribe using a pre-compiled expression
const subscription = collection.subscribeChanges((changes) => {
  updateUI(changes)
}, {
  includeInitialState: true,
  whereExpression: eq(row.status, 'active')
})
// Subscribe using a pre-compiled expression
const subscription = collection.subscribeChanges((changes) => {
  updateUI(changes)
}, {
  includeInitialState: true,
  whereExpression: eq(row.status, 'active')
})

Inherited from

CollectionImpl.subscribeChanges


toArrayWhenReady()

ts
toArrayWhenReady(): Promise<T[]>;
toArrayWhenReady(): Promise<T[]>;

Defined in: packages/db/src/collection/index.ts:722

Gets the current state of the collection as an Array, but only resolves when data is available Waits for the first sync commit to complete before resolving

Returns

Promise<T[]>

Promise that resolves to an Array containing all items in the collection

Inherited from

CollectionImpl.toArrayWhenReady


update()

Call Signature

ts
update(key, callback): Transaction;
update(key, callback): Transaction;

Defined in: packages/db/src/collection/index.ts:592

Updates one or more items in the collection using a callback function

Parameters
key

unknown[]

callback

(drafts) => void

Returns

Transaction

A Transaction object representing the update operation(s)

Throws

If the updated data fails schema validation

Examples
ts
// Update single item by key
const tx = collection.update("todo-1", (draft) => {
  draft.completed = true
})
await tx.isPersisted.promise
// Update single item by key
const tx = collection.update("todo-1", (draft) => {
  draft.completed = true
})
await tx.isPersisted.promise
ts
// Update multiple items
const tx = collection.update(["todo-1", "todo-2"], (drafts) => {
  drafts.forEach(draft => { draft.completed = true })
})
await tx.isPersisted.promise
// Update multiple items
const tx = collection.update(["todo-1", "todo-2"], (drafts) => {
  drafts.forEach(draft => { draft.completed = true })
})
await tx.isPersisted.promise
ts
// Update with metadata
const tx = collection.update("todo-1",
  { metadata: { reason: "user update" } },
  (draft) => { draft.text = "Updated text" }
)
await tx.isPersisted.promise
// Update with metadata
const tx = collection.update("todo-1",
  { metadata: { reason: "user update" } },
  (draft) => { draft.text = "Updated text" }
)
await tx.isPersisted.promise
ts
// Handle errors
try {
  const tx = collection.update("item-1", draft => { draft.value = "new" })
  await tx.isPersisted.promise
  console.log('Update successful')
} catch (error) {
  console.log('Update failed:', error)
}
// Handle errors
try {
  const tx = collection.update("item-1", draft => { draft.value = "new" })
  await tx.isPersisted.promise
  console.log('Update successful')
} catch (error) {
  console.log('Update failed:', error)
}
Inherited from

CollectionImpl.update

Call Signature

ts
update(
   keys, 
   config, 
   callback): Transaction;
update(
   keys, 
   config, 
   callback): Transaction;

Defined in: packages/db/src/collection/index.ts:598

Updates one or more items in the collection using a callback function

Parameters
keys

unknown[]

Single key or array of keys to update

config

OperationConfig

callback

(drafts) => void

Returns

Transaction

A Transaction object representing the update operation(s)

Throws

If the updated data fails schema validation

Examples
ts
// Update single item by key
const tx = collection.update("todo-1", (draft) => {
  draft.completed = true
})
await tx.isPersisted.promise
// Update single item by key
const tx = collection.update("todo-1", (draft) => {
  draft.completed = true
})
await tx.isPersisted.promise
ts
// Update multiple items
const tx = collection.update(["todo-1", "todo-2"], (drafts) => {
  drafts.forEach(draft => { draft.completed = true })
})
await tx.isPersisted.promise
// Update multiple items
const tx = collection.update(["todo-1", "todo-2"], (drafts) => {
  drafts.forEach(draft => { draft.completed = true })
})
await tx.isPersisted.promise
ts
// Update with metadata
const tx = collection.update("todo-1",
  { metadata: { reason: "user update" } },
  (draft) => { draft.text = "Updated text" }
)
await tx.isPersisted.promise
// Update with metadata
const tx = collection.update("todo-1",
  { metadata: { reason: "user update" } },
  (draft) => { draft.text = "Updated text" }
)
await tx.isPersisted.promise
ts
// Handle errors
try {
  const tx = collection.update("item-1", draft => { draft.value = "new" })
  await tx.isPersisted.promise
  console.log('Update successful')
} catch (error) {
  console.log('Update failed:', error)
}
// Handle errors
try {
  const tx = collection.update("item-1", draft => { draft.value = "new" })
  await tx.isPersisted.promise
  console.log('Update successful')
} catch (error) {
  console.log('Update failed:', error)
}
Inherited from

CollectionImpl.update

Call Signature

ts
update(id, callback): Transaction;
update(id, callback): Transaction;

Defined in: packages/db/src/collection/index.ts:605

Updates one or more items in the collection using a callback function

Parameters
id

unknown

callback

(draft) => void

Returns

Transaction

A Transaction object representing the update operation(s)

Throws

If the updated data fails schema validation

Examples
ts
// Update single item by key
const tx = collection.update("todo-1", (draft) => {
  draft.completed = true
})
await tx.isPersisted.promise
// Update single item by key
const tx = collection.update("todo-1", (draft) => {
  draft.completed = true
})
await tx.isPersisted.promise
ts
// Update multiple items
const tx = collection.update(["todo-1", "todo-2"], (drafts) => {
  drafts.forEach(draft => { draft.completed = true })
})
await tx.isPersisted.promise
// Update multiple items
const tx = collection.update(["todo-1", "todo-2"], (drafts) => {
  drafts.forEach(draft => { draft.completed = true })
})
await tx.isPersisted.promise
ts
// Update with metadata
const tx = collection.update("todo-1",
  { metadata: { reason: "user update" } },
  (draft) => { draft.text = "Updated text" }
)
await tx.isPersisted.promise
// Update with metadata
const tx = collection.update("todo-1",
  { metadata: { reason: "user update" } },
  (draft) => { draft.text = "Updated text" }
)
await tx.isPersisted.promise
ts
// Handle errors
try {
  const tx = collection.update("item-1", draft => { draft.value = "new" })
  await tx.isPersisted.promise
  console.log('Update successful')
} catch (error) {
  console.log('Update failed:', error)
}
// Handle errors
try {
  const tx = collection.update("item-1", draft => { draft.value = "new" })
  await tx.isPersisted.promise
  console.log('Update successful')
} catch (error) {
  console.log('Update failed:', error)
}
Inherited from

CollectionImpl.update

Call Signature

ts
update(
   id, 
   config, 
   callback): Transaction;
update(
   id, 
   config, 
   callback): Transaction;

Defined in: packages/db/src/collection/index.ts:611

Updates one or more items in the collection using a callback function

Parameters
id

unknown

config

OperationConfig

callback

(draft) => void

Returns

Transaction

A Transaction object representing the update operation(s)

Throws

If the updated data fails schema validation

Examples
ts
// Update single item by key
const tx = collection.update("todo-1", (draft) => {
  draft.completed = true
})
await tx.isPersisted.promise
// Update single item by key
const tx = collection.update("todo-1", (draft) => {
  draft.completed = true
})
await tx.isPersisted.promise
ts
// Update multiple items
const tx = collection.update(["todo-1", "todo-2"], (drafts) => {
  drafts.forEach(draft => { draft.completed = true })
})
await tx.isPersisted.promise
// Update multiple items
const tx = collection.update(["todo-1", "todo-2"], (drafts) => {
  drafts.forEach(draft => { draft.completed = true })
})
await tx.isPersisted.promise
ts
// Update with metadata
const tx = collection.update("todo-1",
  { metadata: { reason: "user update" } },
  (draft) => { draft.text = "Updated text" }
)
await tx.isPersisted.promise
// Update with metadata
const tx = collection.update("todo-1",
  { metadata: { reason: "user update" } },
  (draft) => { draft.text = "Updated text" }
)
await tx.isPersisted.promise
ts
// Handle errors
try {
  const tx = collection.update("item-1", draft => { draft.value = "new" })
  await tx.isPersisted.promise
  console.log('Update successful')
} catch (error) {
  console.log('Update failed:', error)
}
// Handle errors
try {
  const tx = collection.update("item-1", draft => { draft.value = "new" })
  await tx.isPersisted.promise
  console.log('Update successful')
} catch (error) {
  console.log('Update failed:', error)
}
Inherited from

CollectionImpl.update


validateData()

ts
validateData(
   data, 
   type, 
   key?): T;
validateData(
   data, 
   type, 
   key?): T;

Defined in: packages/db/src/collection/index.ts:503

Validates the data against the schema

Parameters

data

unknown

type

"insert" | "update"

key?

TKey

Returns

T

Inherited from

CollectionImpl.validateData


values()

ts
values(): IterableIterator<T>;
values(): IterableIterator<T>;

Defined in: packages/db/src/collection/index.ts:413

Get all values (virtual derived state)

Returns

IterableIterator<T>

Inherited from

CollectionImpl.values


waitFor()

ts
waitFor<T>(event, timeout?): Promise<AllCollectionEvents[T]>;
waitFor<T>(event, timeout?): Promise<AllCollectionEvents[T]>;

Defined in: packages/db/src/collection/index.ts:835

Wait for a collection event

Type Parameters

T

T extends | "status:idle" | "status:loading" | "status:ready" | "status:error" | "status:cleaned-up" | "status:change" | "subscribers:change" | "loadingSubset:change"

Parameters

event

T

timeout?

number

Returns

Promise<AllCollectionEvents[T]>

Inherited from

CollectionImpl.waitFor

Subscribe to Bytes

Your weekly dose of JavaScript news. Delivered every Monday to over 100,000 devs, for free.

Bytes

No spam. Unsubscribe at any time.

Subscribe to Bytes

Your weekly dose of JavaScript news. Delivered every Monday to over 100,000 devs, for free.

Bytes

No spam. Unsubscribe at any time.