MongoRepository
Class: MongoRepository<T>
Defined in: mongodb/src/mongodb.service.ts:144
MongoDB-backed repository for a single model class
Every object is stored as a plain document with _id set to its primary key
and __type set to its model identifier, so several models can share one
collection. The inherited MemoryRepository helpers are only used for primary
key and class filter computation.
Extends
MemoryRepository<T>
Type Parameters
T
T extends ModelClass
Constructors
Constructor
new MongoRepository<
T>(model,pks,getCollection,separator?):MongoRepository<T>
Defined in: mongodb/src/mongodb.service.ts:151
Parameters
model
T
the model class
pks
string[]
primary key field names
getCollection
() => Promise<Collection<Document>>
return the collection, connecting if needed
separator?
string
composite key separator
Returns
MongoRepository<T>
Overrides
MemoryRepository<T>.constructor
Properties
[WEBDA_TEST]
[WEBDA_TEST]:
object
Defined in: models/lib/repositories/memory.d.ts:325
Test utilities - clears all stored data
clear
clear: () =>
Promise<void>
Returns
Promise<void>
Inherited from
MemoryRepository.[WEBDA_TEST]
aggregationOptions
protectedaggregationOptions:AggregationOptions
Defined in: models/lib/repositories/abstract.d.ts:27
Aggregation fallback policy, set by the owning store through configureAggregation
Inherited from
MemoryRepository.aggregationOptions
events
protectedevents:Map<keyofInstanceType<T>[typeofWEBDA_EVENTS],Set<(data) =>void>>
Defined in: models/lib/repositories/abstract.d.ts:25
Registered event listeners keyed by event name
Inherited from
MemoryRepository.events
getCollection
protectedreadonlygetCollection: () =>Promise<Collection<Document>>
Defined in: mongodb/src/mongodb.service.ts:154
return the collection, connecting if needed
Returns
Promise<Collection<Document>>
maxListeners
protectedmaxListeners:number
Defined in: models/lib/repositories/abstract.d.ts:321
Max-listeners hint kept for Node EventEmitter API compatibility. Not
enforced — repositories use an unbounded Set per event.
Inherited from
MemoryRepository.maxListeners
model
protectedmodel:T
Defined in: models/lib/repositories/abstract.d.ts:21
Inherited from
MemoryRepository.model
monitorOptions
protectedmonitorOptions:QueryMonitorOptions
Defined in: models/lib/repositories/abstract.d.ts:29
Query monitoring options, set by the owning store through configureMonitoring
Inherited from
MemoryRepository.monitorOptions
pks
protectedpks:string[]
Defined in: models/lib/repositories/abstract.d.ts:22
Inherited from
MemoryRepository.pks
separator
protectedseparator:string
Defined in: models/lib/repositories/abstract.d.ts:23
Inherited from
MemoryRepository.separator
storage
protectedstorage:Map
Defined in: models/lib/repositories/memory.d.ts:39
Inherited from
MemoryRepository.storage
tableRoot?
protectedoptionaltableRoot?:ModelClass<Storable<any,any>>
Defined in: models/lib/repositories/abstract.d.ts:35
Model owning the untyped rows of the storage (the first model of the store), undefined when not known
Inherited from
MemoryRepository.tableRoot
warnedAggregations
protectedwarnedAggregations:Set<string>
Defined in: models/lib/repositories/abstract.d.ts:31
Fallback shapes already warned about
Inherited from
MemoryRepository.warnedAggregations
Methods
acceptedTypes()
acceptedTypes():
string[]
Defined in: models/lib/repositories/abstract.d.ts:69
Every stored __type value of this model and its transitive subclasses, for stores filtering in their query
language
Returns
string[]
the values, empty when the model carries no Metadata
Inherited from
MemoryRepository.acceptedTypes
aggregate()
aggregate<
G,M>(spec,params?):Promise<AggregationResult<AggregatedRow<InstanceType<T>,G,M>>>
Defined in: models/lib/repositories/abstract.d.ts:256
Keep the full generic signature here (not spec: any): concrete repositories are used
directly in code and tests, and must expose the typed rows.
Type Parameters
G
G extends readonly _NonFunctionPropertyPaths<InstanceType<T>>[] = []
M
M extends Record<string, MetricSpec<InstanceType<T>>> = Record<string, MetricSpec<InstanceType<T>>>
Parameters
spec
AggregationSpec<InstanceType<T>, G, M>
params?
QueryParameters
Returns
Promise<AggregationResult<AggregatedRow<InstanceType<T>, G, M>>>
Inherited from
MemoryRepository.aggregate
aggregateInMemory()
protectedaggregateInMemory(query):Promise<Record<string,unknown>[]>
Defined in: models/lib/repositories/abstract.d.ts:301
Aggregate by streaming the filtered items
Parameters
query
AggregationQuery
the aggregation
Returns
Promise<Record<string, unknown>[]>
the rows
Inherited from
MemoryRepository.aggregateInMemory
applyAssignments()
protectedapplyAssignments<O>(target,assignments):O
Defined in: models/lib/repositories/abstract.d.ts:166
Set the assignments of an UPDATE on an object, creating the intermediate objects of dotted paths
Targets were checked by parseStatement: letters, digits and _ only, no __ segment, no
Object.prototype member name.
Type Parameters
O
O
Parameters
target
O
the object to change in place
assignments
Assignment[]
the SET assignments
Returns
O
the target
Inherited from
MemoryRepository.applyAssignments
belongsToModel()
belongsToModel(
stored?):boolean
Defined in: models/lib/repositories/abstract.d.ts:75
Whether a stored row belongs to this model, for stores filtering in memory
Parameters
stored?
string
the stored __type, undefined for an untyped row
Returns
boolean
true when the row belongs to this model (always without Metadata)
Inherited from
MemoryRepository.belongsToModel
buildAggregationPipeline()
buildAggregationPipeline(
query):any[]
Defined in: mongodb/src/mongodb.service.ts:461
Translate an aggregation to a MongoDB pipeline
Group keys live in _id.gN and are flattened by executeAggregation, since MongoDB
cannot project dotted output names. The query is validated again first: paths and aliases become
field references and output names.
Parameters
query
AggregationQuery
the aggregation
Returns
any[]
the pipeline
buildClassFilter()
protectedbuildClassFilter():string|undefined
Defined in: models/lib/repositories/memory.d.ts:186
Build the WebdaQL class-filter clause __type IN ['A', 'B', ...] covering
this.model's identifier and every transitive descendant.
Returns undefined when the model carries no Metadata.
Returns
string | undefined
the class-filter WebdaQL clause, or undefined when no Metadata
Inherited from
MemoryRepository.buildClassFilter
buildClassFilterIdentifiers()
protectedbuildClassFilterIdentifiers():string[] |undefined
Defined in: models/lib/repositories/memory.d.ts:177
Collect the WebdaQL class-filter identifier list — this.model's
identifier and every transitive descendant.
Returns undefined when the model carries no Metadata (plain unit-test
classes that didn't go through Application.setModelMetadata). In that
case query() skips the prepend and returns everything in storage,
preserving the pre-fix behavior for those bare classes.
Returns
string[] | undefined
the list of identifiers to match, or undefined when no Metadata
Inherited from
MemoryRepository.buildClassFilterIdentifiers
buildFilter()
protectedbuildFilter(expression):any
Defined in: mongodb/src/mongodb.service.ts:443
Translate a WebdaQL filter to a MongoDB filter restricted to this model
Parameters
expression
Expression
the WebdaQL expression
Returns
any
the MongoDB filter
buildItem()
protectedbuildItem(data):InstanceType<T>
Defined in: models/lib/repositories/abstract.d.ts:86
Build the model instance to create from the incoming data
Primary key fields that are undefined or null are dropped from the data so a key generated by the model constructor (e.g. UuidModel) is not overwritten. Repositories must read the storage key from the returned instance.
Parameters
data
Helpers<InstanceType<T>>
the incoming data
Returns
InstanceType<T>
the model instance
Inherited from
MemoryRepository.buildItem
checkAggregationFallback()
protectedcheckAggregationFallback(query,reason):Promise<void>
Defined in: models/lib/repositories/abstract.d.ts:272
Apply the fallback policy before aggregating or counting in memory
Parameters
query
AggregationQuery | undefined
the aggregation, undefined for a count
reason
string
why it cannot run natively
Returns
Promise<void>
Throws
AggregationError AGGREGATION_NOT_NATIVE when the policy is deny
Inherited from
MemoryRepository.checkAggregationFallback
checkCondition()
protectedcheckCondition<K>(item,conditionField?,condition?):void
Defined in: models/lib/repositories/memory.d.ts:67
Verify an optimistic locking condition on an item
Type Parameters
K
K extends string
Parameters
item
InstanceType<T>
The item to check
conditionField?
K | null
Field to validate
condition?
any
Expected value
Returns
void
Throws
Error if the condition does not match
Inherited from
MemoryRepository.checkCondition
checkItemWriteCondition()
protectedcheckItemWriteCondition(item,index,itemWriteConditionField,itemWriteCondition):void
Defined in: models/lib/repositories/memory.d.ts:317
Verify a write condition on a collection item
Parameters
item
any[]
The array to check
index
number
Index of the item in the array
itemWriteConditionField
string
Field name to check on the item
itemWriteCondition
any
Expected value for the field
Returns
void
Throws
Error if the condition does not match
Inherited from
MemoryRepository.checkItemWriteCondition
collectStatementKeys()
protectedcollectStatementKeys(statement):Promise<PrimaryKeyType<InstanceType<T>>[]>
Defined in: models/lib/repositories/abstract.d.ts:173
Keys of the objects matching the WHERE of a statement, collected before any change so an update changing a WHERE field cannot meet the same object twice; at most LIMIT keys
Parameters
statement
Query
the parsed statement
Returns
Promise<PrimaryKeyType<InstanceType<T>>[]>
the primary keys
Inherited from
MemoryRepository.collectStatementKeys
configureAggregation()
configureAggregation(
options):void
Defined in: models/lib/repositories/abstract.d.ts:228
Copy the known options (fallback, maxGroups, warn); undefined values keep the current ones
Parameters
options
Partial<AggregationOptions>
Returns
void
Throws
Error when maxGroups is not a positive integer or fallback is unknown
Inherited from
MemoryRepository.configureAggregation
configureMonitoring()
configureMonitoring(
options):void
Defined in: models/lib/repositories/abstract.d.ts:233
Configure the query monitoring policy, called by the owning store
Parameters
options
Partial<QueryMonitorOptions>
options to override
Returns
void
Inherited from
MemoryRepository.configureMonitoring
count()
count(
filter?,params?,options?):Promise<CountResult>
Defined in: models/lib/repositories/abstract.d.ts:278
Parse the filter, refuse statements, drop ORDER BY / LIMIT / OFFSET and run executeCount
Parameters
filter?
string
params?
QueryParameters
options?
CountOptions
Returns
Promise<CountResult>
Throws
Error when max is not a positive integer
Inherited from
MemoryRepository.count
countInMemory()
protectedcountInMemory(filter,max?):Promise<Omit<CountResult,"native">>
Defined in: models/lib/repositories/abstract.d.ts:295
Count by streaming the filtered items, stopping at max + 1
Parameters
filter
Expression
the filter
max?
number
stop after max objects, undefined for an exact count
Returns
Promise<Omit<CountResult, "native">>
the value and its relation
Inherited from
MemoryRepository.countInMemory
create()
create(
data,save?):Promise<any>
Defined in: mongodb/src/mongodb.service.ts:249
Parameters
data
any
save?
boolean = true
Returns
Promise<any>
Overrides
MemoryRepository.create
currentTypeOf()
protectedcurrentTypeOf(instance,stored?):string|undefined
Defined in: models/lib/repositories/memory.d.ts:140
The __type to attach to a loaded instance: the current identifier of its class, the stored value when it is
unknown or ambiguous (never rewritten to a guess), the repository model identifier for an untyped row
Parameters
instance
any
the loaded instance
stored?
string
the stored __type
Returns
string | undefined
the value to attach
Inherited from
MemoryRepository.currentTypeOf
declaredType()
protecteddeclaredType(item):string|undefined
Defined in: mongodb/src/mongodb.service.ts:189
The type an object written by the application declares: the __type its document was read with
(non-enumerable, set by fromDocument), else the identifier of its class. Plain data declares none.
Parameters
item
any
the object
Returns
string | undefined
the model identifier, undefined for plain data
delete()
delete(
primaryKey,conditionField?,condition?):Promise<void>
Defined in: mongodb/src/mongodb.service.ts:302
Parameters
primaryKey
any
conditionField?
any
condition?
any
Returns
Promise<void>
Overrides
MemoryRepository.delete
deleteItemFromCollection()
deleteItemFromCollection(
primaryKey,collection,index,itemWriteConditionField?,itemWriteCondition?):Promise<void>
Defined in: mongodb/src/mongodb.service.ts:396
Parameters
primaryKey
any
collection
any
index
number
itemWriteConditionField?
any
itemWriteCondition?
any
Returns
Promise<void>
Overrides
MemoryRepository.deleteItemFromCollection
deleteMany()
deleteMany(
statement,params?):Promise<number>
Defined in: mongodb/src/mongodb.service.ts:613
Delete in bulk with one deleteMany: no per-object event (see Repository.deleteMany)
Parameters
statement
string | Query
params?
QueryParameters
Returns
Promise<number>
Overrides
MemoryRepository.deleteMany
deleteManyByKey()
protecteddeleteManyByKey(statement,params?):Promise<number>
Defined in: models/lib/repositories/abstract.d.ts:191
Generic deleteMany: collect the matching keys (up to LIMIT), then delete them one by one with this
repository's delete primitive
Used by stores without a native bulk delete. On a store repository the primitive emits no event.
Parameters
statement
string | Query
the DELETE statement or its parsed form
params?
QueryParameters
values for the placeholders
Returns
Promise<number>
the number of objects deleted
Inherited from
MemoryRepository.deleteManyByKey
deserialize()
deserialize(
item):InstanceType<T>
Defined in: models/lib/repositories/memory.d.ts:121
Unserialize the object from a string
Beyond restoring the concrete type via @webda/serialize's
$serializer.type typeKey, this also surfaces the storage envelope's
__type stamp on the in-memory instance as a NON-ENUMERABLE property. The
non-enumerable bit keeps __type invisible to JSON.stringify and
Object.keys (so API responses and re-serialize cycles are byte-identical
for the model's own fields), while still being readable via direct
property access — which is exactly how WebdaQL's filter eval reads it
(ComparisonExpression.getAttributeValue walks obj[name]).
Backward-compat: legacy rows written before the envelope-stamping was
introduced won't carry __type. In that case we backfill from the
repository's own model.Metadata.Identifier so they look like records of
the parent class — which is exactly what query()'s prepended class
filter expects (parent + descendants). Plain unit-test classes without
Metadata get no stamp at all; their repos opt out of class filtering on
the query side too (see query).
Parameters
item
string
the serialized string
Returns
InstanceType<T>
the deserialized model instance
Inherited from
MemoryRepository.deserialize
deserializeEnvelope()
protecteddeserializeEnvelope(item,raw,stored?):any
Defined in: models/lib/repositories/memory.d.ts:132
Deserialize a serializer envelope
A row written under a model's former identifier (renamed, see @WebdaAlias) names a serializer that no longer
exists: it is deserialized with the serializer of the class its __type resolves to.
Parameters
item
string
the stored string
raw
any
the parsed envelope
stored?
string
the stored __type
Returns
any
the instance
Inherited from
MemoryRepository.deserializeEnvelope
emit()
emit<
K>(event,data):Promise<void>
Defined in: models/lib/repositories/abstract.d.ts:346
Emit an event to all registered listeners and await their completion.
Type Parameters
K
K extends string | number | symbol
Parameters
event
K
The event name to emit
data
InstanceType<T>[typeof WEBDA_EVENTS][K]
The event payload
Returns
Promise<void>
Inherited from
MemoryRepository.emit
excludePrimaryKey()
excludePrimaryKey(
object):any
Defined in: models/lib/repositories/abstract.d.ts:110
Parameters
object
any
Returns
any
Inherited from
MemoryRepository.excludePrimaryKey
executeAggregation()
protectedexecuteAggregation(query):Promise<AggregationResult<any>>
Defined in: mongodb/src/mongodb.service.ts:521
— MongoDB aggregation pipeline
Parameters
query
AggregationQuery
Returns
Promise<AggregationResult<any>>
Overrides
MemoryRepository.executeAggregation
executeCount()
protectedexecuteCount(filter,max?):Promise<CountResult>
Defined in: mongodb/src/mongodb.service.ts:549
— countDocuments, with a limit of max + 1 for a capped count
Parameters
filter
Expression
max?
number
Returns
Promise<CountResult>
Overrides
MemoryRepository.executeCount
exists()
exists(
primaryKey):Promise<boolean>
Defined in: mongodb/src/mongodb.service.ts:311
Parameters
primaryKey
any
Returns
Promise<boolean>
Overrides
MemoryRepository.exists
findModelClass()
protectedfindModelClass(identifier):any
Defined in: models/lib/repositories/memory.d.ts:157
Find the class to hydrate a row typed identifier (a Webda 3 legacy form included): the resolved model when it
is the repository model or one of its transitive subclasses, the repository model for an ancestor type or an
unknown or ambiguous type
Parameters
identifier
string
stored __type
Returns
any
the class, this.model when it carries no Metadata, or undefined for an unrelated model
Inherited from
MemoryRepository.findModelClass
fromDocument()
protectedfromDocument(doc):InstanceType<T>
Defined in: mongodb/src/mongodb.service.ts:206
Convert a stored document into a model instance
Parameters
doc
any
the MongoDB document
Returns
InstanceType<T>
the model instance
fromUID()
fromUID(
uid):ModelRefWithCreate<InstanceType<T>>
Defined in: models/lib/repositories/abstract.d.ts:92
Return a ref from the uuid
Parameters
uid
string
the serialized primary key
Returns
ModelRefWithCreate<InstanceType<T>>
a model reference with create capability
Inherited from
MemoryRepository.fromUID
get()
get(
primaryKey):Promise<any>
Defined in: mongodb/src/mongodb.service.ts:239
Parameters
primaryKey
any
Returns
Promise<any>
Overrides
MemoryRepository.get
getAllowedFields()
getAllowedFields():
string[] |undefined
Defined in: models/lib/repositories/abstract.d.ts:138
Field paths of the model, from its metadata (Reflection and the stored, input and output schemas)
Used to validate UPDATE SET targets.
Returns
string[] | undefined
the field names, undefined when the model carries no field metadata (no validation then)
Inherited from
MemoryRepository.getAllowedFields
getClassFilter()
protectedgetClassFilter():any
Defined in: mongodb/src/mongodb.service.ts:430
Build the MongoDB filter restricting results to this model and its subclasses
Documents without __type are considered as instance of the repository model
Returns
any
the class filter or undefined if the model has no metadata
getCollectionName()
protectedgetCollectionName():string
Defined in: mongodb/src/mongodb.service.ts:640
Name of the underlying collection, used in errors
Returns
string
the collection name
getCompletionFields()
getCompletionFields():
CompletionField[]
Defined in: models/lib/repositories/abstract.d.ts:143
Completion fields of the model, flattened from its schemas
Returns
CompletionField[]
array of completion fields
Inherited from
MemoryRepository.getCompletionFields
getFilter()
protectedgetFilter(key,conditionField?,condition?):any
Defined in: mongodb/src/mongodb.service.ts:230
Return a filter for Mongo command
Parameters
key
string
the primary key
conditionField?
any
field to check
condition?
any
expected value
Returns
any
the filter
getMaxListeners()
getMaxListeners():
number
Defined in: models/lib/repositories/abstract.d.ts:334
EventEmitter-compatibility shim. Returns the max-listeners hint.
Returns
number
the current max-listeners hint
Inherited from
MemoryRepository.getMaxListeners
getPrimaryKey()
Call Signature
getPrimaryKey(
object,forceObject?):PrimaryKeyType<InstanceType<T>>
Defined in: models/lib/repositories/abstract.d.ts:112
Get the primary key value for an object as a scalar or string.
Parameters
object
any
forceObject?
false
Returns
PrimaryKeyType<InstanceType<T>>
Inherited from
MemoryRepository.getPrimaryKey
Call Signature
getPrimaryKey(
object,forceObject):PrimaryKey<InstanceType<T>>
Defined in: models/lib/repositories/abstract.d.ts:114
Get the primary key value for an object as a structured key object.
Parameters
object
any
forceObject
true
Returns
PrimaryKey<InstanceType<T>>
Inherited from
MemoryRepository.getPrimaryKey
getRootModel()
getRootModel():
T
Defined in: models/lib/repositories/abstract.d.ts:47
Returns
T
Inherited from
MemoryRepository.getRootModel
getStatementFilter()
protectedgetStatementFilter(statement):Promise<any>
Defined in: mongodb/src/mongodb.service.ts:588
MongoDB filter of the objects a statement targets: its WHERE and the class filter, restricted to the first LIMIT documents when the statement has a LIMIT (MongoDB bulk writes have none)
Parameters
statement
Query
the parsed statement
Returns
Promise<any>
the filter, undefined when LIMIT is 0
getSync()
protectedgetSync(primaryKey):InstanceType<T>
Defined in: models/lib/repositories/memory.d.ts:55
Synchronous read used by conditional writes to keep check-and-set atomic
Parameters
primaryKey
string | PK<InstanceType<T>, InstanceType<T>[typeof WEBDA_PRIMARY_KEY][number]>
key of the item
Returns
InstanceType<T>
the deserialized item
Inherited from
MemoryRepository.getSync
getTableRoot()
getTableRoot():
ModelClass<Storable<any,any>> |undefined
Defined in: models/lib/repositories/abstract.d.ts:57
Returns
ModelClass<Storable<any, any>> | undefined
the model owning the untyped rows of the storage
Inherited from
MemoryRepository.getTableRoot
getUID()
getUID(
object):string
Defined in: models/lib/repositories/abstract.d.ts:116
Parameters
object
any
Returns
string
Inherited from
MemoryRepository.getUID
hydratePlainRow()
protectedhydratePlainRow(raw):InstanceType<T>
Defined in: models/lib/repositories/memory.d.ts:165
Hydrate a plain JSON row as an instance of the repository model (or of the transitive subclass named by its
__type; an ancestor type hydrates as the repository model), the same way document stores hydrate their rows;
a row typed as an unrelated model is refused
Parameters
raw
any
the parsed row
Returns
InstanceType<T>
the model instance
Inherited from
MemoryRepository.hydratePlainRow
incrementAttribute()
incrementAttribute<
K,L>(primaryKey,info,_conditionField?,_condition?):Promise<void>
Defined in: models/lib/repositories/abstract.d.ts:124
Type Parameters
K
K extends string
L
L extends string
Parameters
primaryKey
PK<InstanceType<T>, InstanceType<T>[typeof WEBDA_PRIMARY_KEY][number]>
info
L | { property: L; value?: number; }
_conditionField?
K | null
_condition?
any
Returns
Promise<void>
Inherited from
MemoryRepository.incrementAttribute
incrementAttributes()
incrementAttributes(
primaryKey,info,conditionField?,condition?):Promise<void>
Defined in: mongodb/src/mongodb.service.ts:334
Parameters
primaryKey
any
info
any
conditionField?
any
condition?
any
Returns
Promise<void>
Overrides
MemoryRepository.incrementAttributes
isPlainRow()
protectedisPlainRow(raw):boolean
Defined in: models/lib/repositories/memory.d.ts:149
Whether a stored row is a plain JSON object without a serializer envelope
Rows written by earlier versions (e.g. a v3 FileStore folder or MemoryStore persistence file) store the
object itself, its type in a top-level __type.
Parameters
raw
any
the parsed row
Returns
boolean
true for a plain object row
Inherited from
MemoryRepository.isPlainRow
iterate()
iterate(
query,params?):AsyncGenerator<InstanceType<T>,any,any>
Defined in: models/lib/repositories/memory.d.ts:260
Add iterator support
Parameters
query
string
the query string
params?
QueryParameters
values for the ? or :name placeholders
Returns
AsyncGenerator<InstanceType<T>, any, any>
Inherited from
MemoryRepository.iterate
listKeysOfModel()
protectedlistKeysOfModel(ids?):string[]
Defined in: models/lib/repositories/memory.d.ts:230
List the storage keys that may belong to this model
A storage shared by several models holds foreign entries whose key shape can be invalid for this
repository: they are skipped from the stored __type before any parsing. Entries are kept when their stored
__type belongs to the model (legacy forms included). Untyped entries, and entries typed as a strict ancestor
of the table root, belong to the table root and its ancestors. Unreadable entries are kept so their error
surfaces.
A TypeIndexedMap storage answers from its type index: only the keys of the model are visited. Any other Map-like storage is scanned, parsing every entry.
Parameters
ids?
string[]
class identifiers (model and subclasses), undefined to keep everything
Returns
string[]
the keys to evaluate
Inherited from
MemoryRepository.listKeysOfModel
matchStorage()
protectedmatchStorage(statement):object[]
Defined in: models/lib/repositories/memory.d.ts:269
Keys of the stored objects of this model matching a statement's WHERE, at most LIMIT
Synchronous: the statement then runs without yielding, so no other write interleaves and an object is never met twice.
Parameters
statement
Query
the parsed statement
Returns
object[]
the storage keys and their objects
Inherited from
MemoryRepository.matchStorage
monitor()
protectedmonitor<R>(operation,query,fn,details):Promise<R>
Defined in: models/lib/repositories/abstract.d.ts:247
Helper that times a query operation, catches and rethrows errors, and calls onQuery safely
Type Parameters
R
R
Parameters
operation
QueryOperation
the query operation
query
string
the query string
fn
() => Promise<R>
the async function to execute and time
details
((r) => object) | ((r) => number)
optional callback to extract result count or pagination details
Returns
Promise<R>
the result of fn
Inherited from
MemoryRepository.monitor
off()
off<
K>(event,listener):void
Defined in: models/lib/repositories/abstract.d.ts:316
Type Parameters
K
K extends string | number | symbol
Parameters
event
K
listener
(data) => void
Returns
void
Inherited from
MemoryRepository.off
on()
on<
K>(event,listener):void
Defined in: models/lib/repositories/abstract.d.ts:312
Type Parameters
K
K extends string | number | symbol
Parameters
event
K
listener
(data) => void
Returns
void
Inherited from
MemoryRepository.on
once()
once<
K>(event,listener):void
Defined in: models/lib/repositories/abstract.d.ts:314
Type Parameters
K
K extends string | number | symbol
Parameters
event
K
listener
(data) => void
Returns
void
Inherited from
MemoryRepository.once
parseLegacyUID()
protectedparseLegacyUID(uid):PrimaryKey<InstanceType<T>> |undefined
Defined in: models/lib/repositories/abstract.d.ts:108
Parse a uid through the model's parseLegacyUID hook
Parameters
uid
string
the raw storage key
Returns
PrimaryKey<InstanceType<T>> | undefined
a key whose string form is the raw uid, or undefined when the model does not recognise it
Inherited from
MemoryRepository.parseLegacyUID
parseStatement()
protectedparseStatement(type,statement,params?):Promise<Query>
Defined in: models/lib/repositories/abstract.d.ts:156
Parse a bulk statement and check it is of the expected type
For an UPDATE, every SET target is checked: no primary key field, no private (__) segment, no
constructor/prototype segment, and a field of the model when its metadata lists them.
Parameters
type
"DELETE" | "UPDATE"
the expected statement type
statement
string | Query
the statement string or its parsed form
params?
QueryParameters
values for the placeholders of a statement string
Returns
Promise<Query>
the parsed statement
Throws
WebdaQLError when the statement has another type or a SET target is refused
Throws
SyntaxError when the statement does not parse, or a SET target is not a field of the model
Inherited from
MemoryRepository.parseStatement
parseUID()
parseUID(
uid,forceObject?):PrimaryKeyType<InstanceType<T>> |PrimaryKey<InstanceType<T>>
Defined in: models/lib/repositories/abstract.d.ts:102
Parse a serialized primary key
A composite key that does not split into the primary key fields is offered to the model's optional
static parseLegacyUID(uid) hook (see WEBDA_LEGACY_UID): the returned key keeps the raw uid as its
string form so it addresses the legacy storage entry. Without a hook, or when the hook declines, the
uid is rejected.
Parameters
uid
string
forceObject?
boolean
Returns
PrimaryKeyType<InstanceType<T>> | PrimaryKey<InstanceType<T>>
Inherited from
MemoryRepository.parseUID
patch()
patch(
primaryKey,data,conditionField?,condition?):Promise<void>
Defined in: mongodb/src/mongodb.service.ts:290
Parameters
primaryKey
any
data
any
conditionField?
any
condition?
any
Returns
Promise<void>
Overrides
MemoryRepository.patch
query()
query(
query):Promise<{continuationToken?:string;results:InstanceType<T>[]; }>
Defined in: mongodb/src/mongodb.service.ts:559
— translate the WebdaQL query to a MongoDB find
Parameters
query
any
Returns
Promise<{ continuationToken?: string; results: InstanceType<T>[]; }>
Overrides
MemoryRepository.query
ref()
ref(
key):ModelRefWithCreate<InstanceType<T>>
Defined in: models/lib/repositories/abstract.d.ts:122
Parameters
key
PK<InstanceType<T>, InstanceType<T>[typeof WEBDA_PRIMARY_KEY][number]>
Returns
ModelRefWithCreate<InstanceType<T>>
Inherited from
MemoryRepository.ref
removeAttribute()
removeAttribute(
primaryKey,attribute,conditionField?,condition?):Promise<void>
Defined in: mongodb/src/mongodb.service.ts:317
Parameters
primaryKey
any
attribute
any
conditionField?
any
condition?
any
Returns
Promise<void>
Overrides
MemoryRepository.removeAttribute
removeListener()
removeListener<
K>(event,listener):void
Defined in: models/lib/repositories/abstract.d.ts:329
EventEmitter-compatibility alias for off. Consumers that treat a
repository as a Node EventEmitter (e.g. @webda/runtime EventIterator)
call removeListener.
Type Parameters
K
K extends string | number | symbol
Parameters
event
K
the event name
listener
(data) => void
the listener to remove
Returns
void
Inherited from
MemoryRepository.removeListener
resolvePath()
protectedresolvePath(item,path):object
Defined in: models/lib/repositories/memory.d.ts:296
Resolve the parent object and last key of a dotted path, creating intermediate objects
Parameters
item
any
root object
path
string
dotted path
Returns
object
the holder and the last key
holder
holder:
any
key
key:
string
Inherited from
MemoryRepository.resolvePath
safeOnQuery()
protectedsafeOnQuery(info):void
Defined in: models/lib/repositories/abstract.d.ts:238
Safely invoke the onQuery callback without throwing into the caller
Parameters
info
QueryExecutionInfo
query execution info
Returns
void
Inherited from
MemoryRepository.safeOnQuery
serialize()
serialize(
item):string
Defined in: models/lib/repositories/memory.d.ts:97
Serialize the object to a string
This method is used to allow switching between different serialization methods
The serialized payload is also stamped with a top-level __type field
carrying the concrete model identifier when available
(item.constructor.Metadata?.Identifier). This lets query() and external
storage backends filter results by class without re-instantiating every
item — important when a single underlying storage map is shared across a
model and its subclasses (the common case in production where each
registered model owns its own MemoryRepository pointing at the same Map).
The stamp lives on the serializer envelope (sibling of value /
$serializer), not inside value. deserialize() re-surfaces it on the
reconstructed instance as a non-enumerable __type property so WebdaQL's
filter eval can read it without it ever leaking into JSON.stringify or
Object.keys output — keeping API responses and re-serialize cycles
byte-identical for the model's own fields.
Models that don't carry Metadata (plain unit-test classes that don't go through Application.setModelMetadata) simply skip the stamp; the resulting payload is byte-identical to the previous implementation.
Parameters
item
InstanceType<T>
to serialize
Returns
string
serialized object
Inherited from
MemoryRepository.serialize
setAttribute()
setAttribute<
K,L>(primaryKey,attribute,value,conditionField?,condition?):Promise<void>
Defined in: models/lib/repositories/abstract.d.ts:120
Type Parameters
K
K extends string
L
L extends string
Parameters
primaryKey
string | PK<InstanceType<T>, InstanceType<T>[typeof WEBDA_PRIMARY_KEY][number]>
attribute
K
value
_PropertyPathType<InstanceType<T>, K>
conditionField?
L | null
condition?
_PropertyPathType<InstanceType<T>, L> | JSONed<_PropertyPathType<InstanceType<T>, L>>
Returns
Promise<void>
Inherited from
MemoryRepository.setAttribute
setMaxListeners()
setMaxListeners(
n):this
Defined in: models/lib/repositories/abstract.d.ts:340
EventEmitter-compatibility shim. Records the max-listeners hint (no enforcement).
Parameters
n
number
the new hint value
Returns
this
this for chaining
Inherited from
MemoryRepository.setMaxListeners
setTableRoot()
setTableRoot(
root?):this
Defined in: models/lib/repositories/abstract.d.ts:53
Set the model owning the untyped rows of the storage
Parameters
root?
ModelClass<Storable<any, any>>
the first model of the store, undefined when not known
Returns
this
this
Inherited from
MemoryRepository.setTableRoot
toDocument()
protectedtoDocument(item,key,fallbackType?):any
Defined in: mongodb/src/mongodb.service.ts:167
Convert an object to the document stored in MongoDB
Parameters
item
any
the model instance or raw data
key
string
the primary key
fallbackType?
string | null | undefined = ...
the type to stamp when the object declares none (null: none)
Returns
any
the document
typeResolver()
protectedtypeResolver():ModelTypeResolver
Defined in: models/lib/repositories/abstract.d.ts:63
Resolver of the stored __type: the installed application one when it knows the model, else the model's own
hierarchy with exact identifiers only
Returns
ModelTypeResolver
the resolver
Inherited from
MemoryRepository.typeResolver
update()
update(
data,conditionField?,condition?):Promise<void>
Defined in: mongodb/src/mongodb.service.ts:268
Parameters
data
any
conditionField?
any
condition?
any
Returns
Promise<void>
Overrides
MemoryRepository.update
updateMany()
updateMany(
statement,params?):Promise<number>
Defined in: mongodb/src/mongodb.service.ts:625
Update in bulk with one updateMany and $set (dotted targets create their parents): no per-object event
(see Repository.updateMany)
Parameters
statement
string | Query
params?
QueryParameters
Returns
Promise<number>
Overrides
MemoryRepository.updateMany
updateManyByKey()
protectedupdateManyByKey(statement,params?):Promise<number>
Defined in: models/lib/repositories/abstract.d.ts:201
Generic updateMany: collect the matching keys (up to LIMIT), then patch them one by one with this
repository's patch primitive. A dotted target reads the object to rewrite its top-level field.
Used by stores without a native bulk update. On a store repository the primitive emits no event.
Parameters
statement
string | Query
the UPDATE statement or its parsed form
params?
QueryParameters
values for the placeholders
Returns
Promise<number>
the number of objects updated
Inherited from
MemoryRepository.updateManyByKey
upsert()
upsert(
data):Promise<InstanceType<T>>
Defined in: models/lib/repositories/abstract.d.ts:118
Parameters
data
Helpers<InstanceType<T>>
Returns
Promise<InstanceType<T>>
Inherited from
MemoryRepository.upsert
upsertItemToCollection()
upsertItemToCollection(
primaryKey,collection,item,index?,itemWriteConditionField?,itemWriteCondition?):Promise<void>
Defined in: mongodb/src/mongodb.service.ts:365
Parameters
primaryKey
any
collection
any
item
any
index?
number
itemWriteConditionField?
any
itemWriteCondition?
any
Returns
Promise<void>
Overrides
MemoryRepository.upsertItemToCollection
writeIfPresent()
protectedwriteIfPresent(key,write):Promise<boolean>
Defined in: models/lib/repositories/abstract.d.ts:181
Run one write of the generic fallback; an object deleted since the keys were collected is skipped
Parameters
key
PrimaryKeyType<InstanceType<T>>
the primary key
write
() => Promise<void>
the write
Returns
Promise<boolean>
true when written, false when the object is gone
Throws
the write error when the object still exists
Inherited from
MemoryRepository.writeIfPresent
simulateFind()
staticsimulateFind<T>(query,uuids,repository):Promise<{continuationToken?:string;results:InstanceType<T>[]; }>
Defined in: models/lib/repositories/memory.d.ts:239
Allow to simulate a find on a list of uuids It is static to be reusable by other repository like FileRepository
Type Parameters
T
T extends ModelClass<Storable<any, any>>
Parameters
query
Query
the parsed query
uuids
any[]
the list of UIDs to search
repository
Repository<T>
the repository to fetch objects from
Returns
Promise<{ continuationToken?: string; results: InstanceType<T>[]; }>
the query results with optional continuation token
Inherited from
MemoryRepository.simulateFind