feat(data): expose bulkUpdate on PouchDB wrapper
Wraps PouchDB.bulkDocs so callers can flush many docs in one worker round trip, avoiding the read-before-write that data.update does per document.
This commit is contained in:
@@ -7,6 +7,9 @@ import { Model } from "./models/Model"
|
|||||||
export interface DataApi {
|
export interface DataApi {
|
||||||
add<DT extends DataType>(model: Model<DT>): Promise<boolean>
|
add<DT extends DataType>(model: Model<DT>): Promise<boolean>
|
||||||
update<DT extends DataType, T extends Model<DT>>(model: T): Promise<boolean>
|
update<DT extends DataType, T extends Model<DT>>(model: T): Promise<boolean>
|
||||||
|
bulkUpdate<DT extends DataType, T extends Model<DT>>(
|
||||||
|
models: T[]
|
||||||
|
): Promise<boolean>
|
||||||
remove(id: string): Promise<boolean>
|
remove(id: string): Promise<boolean>
|
||||||
get<DT extends DataType, T extends Model<DT>>(id: string): Promise<T | null>
|
get<DT extends DataType, T extends Model<DT>>(id: string): Promise<T | null>
|
||||||
getOrCreate<DT extends DataType, T extends Model<DT>>(
|
getOrCreate<DT extends DataType, T extends Model<DT>>(
|
||||||
|
|||||||
@@ -67,6 +67,19 @@ class Data {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public async bulkUpdate<DT extends DataType, T extends Model<DT>>(
|
||||||
|
models: T[]
|
||||||
|
): Promise<boolean> {
|
||||||
|
if (!this.locale || !models.length) return false
|
||||||
|
try {
|
||||||
|
const result = await this.locale.bulkDocs(models)
|
||||||
|
return result.every((r) => "ok" in r && r.ok)
|
||||||
|
} catch (error) {
|
||||||
|
console.warn(error)
|
||||||
|
return false
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
public async remove(id: string): Promise<boolean> {
|
public async remove(id: string): Promise<boolean> {
|
||||||
try {
|
try {
|
||||||
const doc = await this.get(id)
|
const doc = await this.get(id)
|
||||||
|
|||||||
Reference in New Issue
Block a user