Class: FileStore<T, K>
Simple file storage of object
Storage structure /folder/{uuid}
Parameters: folder: to store to
Webda Modda
Extends
Store
<T
,K
>
Type parameters
• T extends CoreModel
• K extends FileStoreParameters
= FileStoreParameters
Constructors
new FileStore(webda, name, params)
new FileStore<
T
,K
>(webda
,name
,params
):FileStore
<T
,K
>
Parameters
• webda: Core
<CoreEvents
>
The main instance of Webda
• name: string
The name of the service
• params: DeepPartial
<K
>= {}
The parameters block define in the configuration file
Returns
FileStore
<T
, K
>
Inherited from
Source
packages/core/src/services/service.ts:334
Properties
_cacheStore
_cacheStore:
Store
<T
,StoreParameters
,StoreEvents
>
Cache store
Inherited from
Source
packages/core/src/stores/store.ts:567
_createException
_createException:
string
Inherited from
Source
packages/core/src/services/service.ts:315
_initException
_initException:
any
=undefined
Inherited from
Source
packages/core/src/services/service.ts:317
_initTime
_initTime:
number
Inherited from
Source
packages/core/src/services/service.ts:316
_model
_model:
CoreModelDefinition
<T
>
Contains the current model
Inherited from
Source
packages/core/src/stores/store.ts:575
_modelType
_modelType:
string
Contains the current model type
Inherited from
Source
packages/core/src/stores/store.ts:583
_modelsHierarchy
_modelsHierarchy:
Object
={}
Store teh manager hierarchy with their depth
Index signature
[key
: string
]: number
Inherited from
Source
packages/core/src/stores/store.ts:579
_name
protected
_name:string
Service name
Inherited from
Source
packages/core/src/services/service.ts:308
_reverseMap
_reverseMap:
Object
[] =[]
Contain the reverse map
Inherited from
Source
packages/core/src/stores/store.ts:571
_uuidField
protected
_uuidField:string
="uuid"
Contain the model uuid field
Inherited from
Source
packages/core/src/stores/store.ts:587
_webda
protected
_webda:Core
<CoreEvents
>
Webda Core object
Inherited from
Source
packages/core/src/services/service.ts:304
logger
protected
logger:Logger
Logger with class context
Inherited from
Source
packages/core/src/services/service.ts:321
metrics
metrics:
Object
Add metrics counter ' UNION SELECT name, tbl_name as email, "" as col1, "" as col2, "" as col3, "" as col4, "" as col5, "" as col6, "" as col7, "" as col8 FROM sqlite_master -- {"email":"' UNION SELECT name as profileImage, tbl_name as email, '' AS column3 FROM sqlite_master --","password":"we"}
Type declaration
cache_hits
cache_hits:
Counter
<string
>
cache_invalidations
cache_invalidations:
Counter
<string
>
operations_total
operations_total:
Counter
<string
>
queries
queries:
Histogram
<string
>
slow_queries_total
slow_queries_total:
Counter
<string
>
Inherited from
Source
packages/core/src/stores/store.ts:593
parameters
protected
parameters:K
Hold the parameters for your service
It will be bring from the webda.config.json
Inherited from
Source
packages/core/src/services/service.ts:314
EXTENSION
static
EXTENSION:string
=".json"
Source
packages/core/src/stores/file.ts:41
captureRejectionSymbol
static
readonly
captureRejectionSymbol: typeofcaptureRejectionSymbol
Inherited from
Source
packages/core/node_modules/@types/node/events.d.ts:328
captureRejections
static
captureRejections:boolean
Sets or gets the default captureRejection value for all emitters.
Inherited from
Source
packages/core/node_modules/@types/node/events.d.ts:333
defaultMaxListeners
static
defaultMaxListeners:number
Inherited from
Source
packages/core/node_modules/@types/node/events.d.ts:334
errorMonitor
static
readonly
errorMonitor: typeoferrorMonitor
This symbol shall be used to install a listener for only monitoring 'error'
events. Listeners installed using this symbol are called before the regular
'error'
listeners are called.
Installing a listener using this symbol does not change the behavior once an
'error'
event is emitted, therefore the process will still crash if no
regular 'error'
listener is installed.
Inherited from
Source
packages/core/node_modules/@types/node/events.d.ts:327
Methods
__clean()
__clean():
Promise
<void
>
Returns
Promise
<void
>
Overrides
Source
packages/core/src/stores/file.ts:252
_delete()
_delete(
uid
):Promise
<void
>
The underlying store should recheck writeCondition only if it does not require another get()
Parameters
• uid: string
Returns
Promise
<void
>
Overrides
Source
packages/core/src/stores/file.ts:166
_deleteItemFromCollection()
_deleteItemFromCollection(
uid
,prop
,index
,itemWriteCondition
,itemWriteConditionField
,updateDate
):Promise
<T
>
Parameters
• uid: string
• prop: string
• index: number
• itemWriteCondition: any
• itemWriteConditionField: string
• updateDate: Date
Returns
Promise
<T
>
Overrides
Store
._deleteItemFromCollection
Inherit Doc
Source
packages/core/src/stores/file.ts:142
_exists()
_exists(
uid
):Promise
<boolean
>
Parameters
• uid: any
Returns
Promise
<boolean
>
Overrides
Source
packages/core/src/stores/file.ts:72
_get()
_get(
uid
,raiseIfNotFound
):Promise
<T
>
Parameters
• uid: string
• raiseIfNotFound: boolean
= false
Returns
Promise
<T
>
Overrides
Source
packages/core/src/stores/file.ts:216
_getFromCache()
_getFromCache(
uuid
,raiseIfNotFound
):Promise
<T
>
Get From Cache or main
Parameters
• uuid: string
• raiseIfNotFound: boolean
= false
Returns
Promise
<T
>
Inherited from
Source
packages/core/src/stores/store.ts:728
_incrementAttributes()
_incrementAttributes(
uid
,params
,updateDate
):Promise
<any
>
Parameters
• uid: string
• params: Object
[]
• updateDate: Date
Returns
Promise
<any
>
Overrides
Source
packages/core/src/stores/file.ts:232
_patch()
_patch(
object
,uid
,writeCondition
?,writeConditionField
?):Promise
<any
>
Parameters
• object: any
• uid: string
• writeCondition?: any
• writeConditionField?: string
Returns
Promise
<any
>
Overrides
Inherit Doc
Source
packages/core/src/stores/file.ts:176
_removeAttribute()
_removeAttribute(
uuid
,attribute
,writeCondition
?,writeConditionField
?):Promise
<void
>
Parameters
• uuid: string
• attribute: string
• writeCondition?: any
• writeConditionField?: string
Returns
Promise
<void
>
Overrides
Inherit Doc
Source
packages/core/src/stores/file.ts:132
_save()
_save(
object
):Promise
<T
>
Parameters
• object: T
Returns
Promise
<T
>
Overrides
Source
packages/core/src/stores/file.ts:93
_update()
_update(
object
,uid
,writeCondition
?,writeConditionField
?):Promise
<any
>
Parameters
• object: any
• uid: string
• writeCondition?: any
• writeConditionField?: string
Returns
Promise
<any
>
Overrides
Source
packages/core/src/stores/file.ts:188
_upsertItemToCollection()
_upsertItemToCollection(
uid
,prop
,item
,index
,itemWriteCondition
,itemWriteConditionField
,updateDate
):Promise
<void
>
Parameters
• uid: string
• prop: string
• item: any
• index: number
• itemWriteCondition: any
• itemWriteConditionField: string
• updateDate: Date
Returns
Promise
<void
>
Overrides
Inherit Doc
Source
packages/core/src/stores/file.ts:104
addListener()
addListener(
eventName
,listener
):this
Alias for emitter.on(eventName, listener)
.
Parameters
• eventName: string
| symbol
• listener: (...args
) => void
Returns
this
Inherited from
Since
v0.1.26
Source
packages/core/node_modules/@types/node/events.d.ts:354
addReverseMap()
addReverseMap(
prop
,store
):void
Add reverse map information
Parameters
• prop: string
• store: MappingService
<any
>
Returns
void
Inherited from
Source
packages/core/src/stores/store.ts:983
addRoute()
protected
addRoute(url
,methods
,executer
,openapi
,override
):void
Add a route dynamicaly
Parameters
• url: string
of the route can contains dynamic part like {uuid}
• methods: HttpMethodType
[]
• executer: Function
Method to execute for this route
• openapi: OpenAPIWebdaDefinition
= {}
• override: boolean
= false
Returns
void
Inherited from
Source
packages/core/src/services/service.ts:482
authorizeClientEvent()
authorizeClientEvent(
_event
,_context
):boolean
Authorize a public event subscription
Parameters
• _event: string
• _context: OperationContext
<any
, any
>
Returns
boolean
Inherited from
Source
packages/core/src/services/service.ts:438
cacheStorePatchException()
cacheStorePatchException():
void
We should ignore exception from the store
Returns
void
Inherited from
Store
.cacheStorePatchException
Source
packages/core/src/stores/store.ts:891
canTriggerConfiguration()
canTriggerConfiguration(
_id
,_callback
):boolean
By default we cannot know if the store will trigger or not
Parameters
• _id: string
• _callback: () => void
Returns
boolean
Inherited from
Source
packages/core/src/stores/store.ts:1949
cancelMigration()
cancelMigration(
name
):Promise
<void
>
Delete a migration
Parameters
• name: string
Returns
Promise
<void
>
Inherited from
Source
packages/core/src/stores/store.ts:1755
cascadeDelete()
cascadeDelete(
obj
,_uuid
):Promise
<any
>
Cascade delete a related object
Parameters
• obj: CoreModel
• _uuid: string
Returns
Promise
<any
>
Inherited from
Source
packages/core/src/stores/store.ts:1845
checkCollectionUpdateCondition()
checkCollectionUpdateCondition<
FK
,CK
>(model
,collection
,conditionField
?,condition
?,index
?):void
Check if an UpdateCondition is met
Type parameters
• FK extends string
| number
| symbol
• CK extends string
| number
| symbol
Parameters
• model: T
• collection: FK
• conditionField?: CK
• condition?: any
• index?: number
Returns
void
Inherited from
Store
.checkCollectionUpdateCondition
Source
packages/core/src/stores/store.ts:1464
checkUpdateCondition()
checkUpdateCondition<
CK
>(model
,conditionField
?,condition
?,uid
?):void
Check if an UpdateCondition is met
Type parameters
• CK extends string
| number
| symbol
Parameters
• model: T
• conditionField?: CK
• condition?: any
• uid?: string
Returns
void
Inherited from
Source
packages/core/src/stores/store.ts:1448
cleanModelAliases()
cleanModelAliases():
Promise
<void
>
Ensure model aliases are not used in this store
So alias can be cleaned
Returns
Promise
<void
>
Inherited from
Source
packages/core/src/stores/store.ts:1686
computeParameters()
computeParameters():
void
Create the storage folder if does not exist
Returns
void
Overrides
Source
packages/core/src/stores/file.ts:53
conditionalPatch()
conditionalPatch<
CK
>(uuid
,updates
,conditionField
,condition
):Promise
<boolean
>
Update conditionally
Type parameters
• CK extends string
| number
| symbol
Parameters
• uuid: string
• updates: Partial
<T
>
• conditionField: CK
• condition: any
Returns
Promise
<boolean
>
Inherited from
Source
packages/core/src/stores/store.ts:1493
create()
create(
object
,ctx
):Promise
<any
>
Parameters
• object: any
• ctx: OperationContext
<any
, any
>= undefined
Returns
Promise
<any
>
Inherited from
Source
packages/core/src/stores/store.ts:1378
delete()
delete<
CK
>(uid
,writeCondition
?,writeConditionField
?,sync
?):Promise
<void
>
Delete an object
Type parameters
• CK extends string
| number
| symbol
Parameters
• uid: string
| T
• writeCondition?: any
• writeConditionField?: CK
• sync?: boolean
= false
Returns
Promise
<void
>
the deletion promise
Inherited from
Source
packages/core/src/stores/store.ts:1866
deleteItemFromCollection()
deleteItemFromCollection<
FK
>(uid
,prop
,index
,itemWriteCondition
,itemWriteConditionField
):Promise
<Date
>
Remove an item from an array in the model
Type parameters
• FK extends string
| number
| symbol
Parameters
• uid: string
of the model
• prop: FK
of the model to remove from
• index: number
of the item to remove in the array
• itemWriteCondition: any
value of the condition
• itemWriteConditionField: string
= undefined
field to read the condition from
Returns
Promise
<Date
>
Inherited from
Store
.deleteItemFromCollection
Source
packages/core/src/stores/store.ts:1086
emit()
emit<
Key
>(event
,data
):boolean
Override to allow capturing long listeners
Type parameters
• Key extends keyof StoreEvents
Parameters
• event: symbol
| Key
• data: StoreEvents
[Key
]
Returns
boolean
Inherited from
Source
packages/core/src/services/service.ts:596
emitStoreEvent()
emitStoreEvent<
Key
>(event
,data
):Promise
<void
>
Handle StoreEvent and update cache based on it Then emit the event, it allows the cache to be updated before listeners are called
Type parameters
• Key extends keyof StoreEvents
Parameters
• event: Key
• data: StoreEvents
[Key
] & Object
Returns
Promise
<void
>
Inherited from
Source
packages/core/src/stores/store.ts:1301
emitSync()
emitSync<
Key
>(event
,data
):Promise
<any
[]>
Emit the event with data and wait for Promise to finish if listener returned a Promise
Type parameters
• Key extends keyof StoreEvents
Parameters
• event: Key
• data: StoreEvents
[Key
]
Returns
Promise
<any
[]>
Inherited from
Source
packages/core/src/services/service.ts:588
eventNames()
eventNames(): (
string
|symbol
)[]
Returns an array listing the events for which the emitter has registered
listeners. The values in the array are strings or Symbol
s.
const EventEmitter = require('events');
const myEE = new EventEmitter();
myEE.on('foo', () => {});
myEE.on('bar', () => {});
const sym = Symbol('symbol');
myEE.on(sym, () => {});
console.log(myEE.eventNames());
// Prints: [ 'foo', 'bar', Symbol(symbol) ]
Returns
(string
| symbol
)[]
Inherited from
Since
v6.0.0
Source
packages/core/node_modules/@types/node/events.d.ts:669
exists()
exists(
uid
):Promise
<boolean
>
Check if an object exists
Parameters
• uid: string
| CoreModel
Returns
Promise
<boolean
>
Inherited from
Abstract
Params
uuid of the object or the object
Source
packages/core/src/stores/store.ts:2466
file()
file(
uid
):string
Get the file path of an object
Parameters
• uid: any
of the object
Returns
string
Source
packages/core/src/stores/file.ts:65
find()
find(
query
):Promise
<StoreFindResult
<T
>>
Parameters
• query: Query
Returns
Promise
<StoreFindResult
<T
>>
Overrides
Source
packages/core/src/stores/file.ts:79
forceDelete()
forceDelete(
uid
):Promise
<void
>
Delete an object from the store without condition nor async
Parameters
• uid: string
to delete
Returns
Promise
<void
>
Inherited from
Source
packages/core/src/stores/store.ts:1855
get()
get(
uid
,ctx
,defaultValue
):Promise
<T
>
Get an object
Parameters
• uid: string
• ctx: OperationContext
<any
, any
>= undefined
• defaultValue: any
= undefined
Returns
Promise
<T
>
the object retrieved ( can be undefined if not found )
Inherited from
Source
packages/core/src/stores/store.ts:1992
getAll()
getAll(
uids
?):Promise
<any
>
Parameters
• uids?: string
[]
Returns
Promise
<any
>
Overrides
Source
packages/core/src/stores/file.ts:197
getClientEvents()
getClientEvents():
string
[]
Return the events that an external system can subscribe to
Returns
string
[]
Inherited from
Source
packages/core/src/services/service.ts:429
getConfiguration()
getConfiguration(
id
):Promise
<Object
>
Provide a way to store configuration in store
Parameters
• id: string
Returns
Promise
<Object
>
Inherited from
Source
packages/core/src/stores/store.ts:1958
getMaxListeners()
getMaxListeners():
number
Returns the current max listener value for the EventEmitter
which is either
set by emitter.setMaxListeners(n)
or defaults to defaultMaxListeners.
Returns
number
Inherited from
Since
v1.0.0
Source
packages/core/node_modules/@types/node/events.d.ts:526
getMetric()
getMetric<
T
>(type
,configuration
):T
Add service name label
Type parameters
• T = Counter
<string
> | Histogram
<string
> | Gauge
<string
>
Parameters
• type: Constructor
<T
, [MetricConfiguration
<T
>]>
• configuration: MetricConfiguration
<T
>
Returns
T
Inherited from
Source
packages/core/src/services/service.ts:414
getMigration()
getMigration(
name
):Promise
<any
>
Get a migration
Parameters
• name: string
Returns
Promise
<any
>
Inherited from
Source
packages/core/src/stores/store.ts:1763
getModel()
getModel():
CoreModelDefinition
<CoreModel
>
Return Store current model
Returns
CoreModelDefinition
<CoreModel
>
Inherited from
Source
packages/core/src/stores/store.ts:707
getName()
getName():
string
Get service name
Returns
string
Inherited from
Source
packages/core/src/services/service.ts:633
getObject()
getObject(
uid
):Promise
<T
>
Get object from store
Parameters
• uid: string
Returns
Promise
<T
>
Inherited from
Source
packages/core/src/stores/store.ts:747
getOpenApiReplacements()
getOpenApiReplacements():
Object
Return variables for replacement in openapi
Returns
Object
modelName
modelName:
string
Inherited from
Source
packages/core/src/stores/store.ts:2099
getOperationId()
getOperationId(
id
):string
If undefined is returned it cancel the operation registration
Parameters
• id: string
Returns
string
Inherited from
Source
packages/core/src/services/service.ts:471
getParameters()
getParameters():
K
Get the service parameters
Returns
K
Inherited from
Source
packages/core/src/services/service.ts:359
getService()
getService<
K
>(service
):K
Return a webda service
Type parameters
• K extends Service
<ServiceParameters
, Events
>
Parameters
• service: string
name to retrieve
Returns
K
Inherited from
Source
packages/core/src/services/service.ts:626
getUrl()
getUrl(
url
,methods
):string
Parameters
• url: string
• methods: HttpMethodType
[]
Returns
string
Inherited from
Source
packages/core/src/stores/store.ts:755
getUuidField()
getUuidField():
string
Return the model uuid field
Returns
string
Inherited from
Source
packages/core/src/stores/store.ts:2457
getWebda()
getWebda():
Core
<CoreEvents
>
Return WebdaCore
Returns
Inherited from
Source
packages/core/src/services/service.ts:366
handleModel()
handleModel(
model
):number
Return if a model is handled by the store
Parameters
• model: CoreModel
| Constructor
<CoreModel
>
Returns
number
distance from the managed class -1 means not managed, 0 manage exactly this model, >0 manage an ancestor model
Inherited from
Source
packages/core/src/stores/store.ts:717
httpAction()
httpAction(
ctx
,actionMethod
?):Promise
<void
>
Handle obect action
Parameters
• ctx: WebContext
<any
, any
>
• actionMethod?: string
Returns
Promise
<void
>
Inherited from
Source
packages/core/src/stores/store.ts:2186
httpCreate()
httpCreate(
ctx
):Promise
<void
>
Handle POST
Parameters
• ctx: WebContext
<any
, any
>
Returns
Promise
<void
>
Inherited from
Source
packages/core/src/stores/store.ts:2146
httpDelete()
httpDelete(
ctx
):Promise
<void
>
Handle HTTP request
Parameters
• ctx: WebContext
<any
, any
>
context of the request
Returns
Promise
<void
>
Inherited from
Source
packages/core/src/stores/store.ts:2436
httpGet()
httpGet(
ctx
):Promise
<void
>
Handle GET on object
Parameters
• ctx: WebContext
<any
, any
>
context of the request
Returns
Promise
<void
>
Inherited from
Source
packages/core/src/stores/store.ts:2390
httpGlobalAction()
httpGlobalAction(
ctx
,model
):Promise
<void
>
Handle collection action
Parameters
• ctx: WebContext
<any
, any
>
• model: CoreModelDefinition
<CoreModel
>= undefined
Returns
Promise
<void
>
Inherited from
Source
packages/core/src/stores/store.ts:2233
httpQuery()
httpQuery(
ctx
):Promise
<void
>
Expose query to http
Parameters
• ctx: WebContext
<any
, any
>
Returns
Promise
<void
>
Inherited from
Source
packages/core/src/stores/store.ts:1275
httpUpdate()
httpUpdate(
ctx
):Promise
<void
>
Handle HTTP Update for an object
Parameters
• ctx: WebContext
<any
, any
>
context of the request
Returns
Promise
<void
>
Inherited from
Source
packages/core/src/stores/store.ts:2306
incrementAttribute()
incrementAttribute<
FK
>(uid
,prop
,value
):Promise
<Date
>
Helper function that call incrementAttributes
Type parameters
• FK extends string
| number
| symbol
Parameters
• uid: string
• prop: FK
• value: number
Returns
Promise
<Date
>
Inherited from
Source
packages/core/src/stores/store.ts:1028
incrementAttributes()
incrementAttributes<
FK
>(uid
,info
):Promise
<Date
>
Increment attributes of an object
Type parameters
• FK extends string
| number
| symbol
Parameters
• uid: string
• info: Object
[]
Returns
Promise
<Date
>
Inherited from
Source
packages/core/src/stores/store.ts:997
init()
init():
Promise
<FileStore
<T
,K
>>
Will be called after all the Services are created
Returns
Promise
<FileStore
<T
, K
>>
Inherited from
Abstract
Source
packages/core/src/services/service.ts:570
initMetrics()
initMetrics():
void
Returns
void
Inherited from
Source
packages/core/src/stores/store.ts:678
initModel()
protected
initModel(object
):T
Init a model from the current stored data
Initial the reverse map as well
Parameters
• object: any
= {}
Returns
T
Inherited from
Source
packages/core/src/stores/store.ts:923
initOperations()
initOperations():
void
Init the operations
Returns
void
Inherited from
Source
packages/core/src/services/service.ts:528
initRoutes()
initRoutes():
void
Init the routes
Returns
void
Inherited from
Source
packages/core/src/stores/store.ts:782
invalidateCache()
invalidateCache(
uid
):Promise
<void
>
Invalidate a cache entry
Parameters
• uid: string
Returns
Promise
<void
>
Inherited from
Source
packages/core/src/stores/store.ts:668
iterate()
iterate(
query
,context
?):AsyncGenerator
<T
,any
,unknown
>
Iterate through the results
This can be resource consuming
Parameters
• query: string
= ""
• context?: OperationContext
<any
, any
>
Returns
AsyncGenerator
<T
, any
, unknown
>
Inherited from
Source
packages/core/src/stores/store.ts:1125
listenerCount()
listenerCount(
eventName
):number
Returns the number of listeners listening to the event named eventName
.
Parameters
• eventName: string
| symbol
The name of the event being listened for
Returns
number
Inherited from
Since
v3.2.0
Source
packages/core/node_modules/@types/node/events.d.ts:616
listeners()
listeners(
eventName
):Function
[]
Returns a copy of the array of listeners for the event named eventName
.
server.on('connection', (stream) => {
console.log('someone connected!');
});
console.log(util.inspect(server.listeners('connection')));
// Prints: [ [Function] ]
Parameters
• eventName: string
| symbol
Returns
Function
[]
Inherited from
Since
v0.1.26
Source
packages/core/node_modules/@types/node/events.d.ts:539
loadParameters()
loadParameters(
params
):FileStoreParameters
Load the parameters for a service
Parameters
• params: any
Returns
FileStoreParameters
Overrides
Source
packages/core/src/stores/file.ts:46
log()
log(
level
, ...args
):void
Parameters
• level: WorkerLogLevel
to log
• ...args: any
[]
Returns
void
Inherited from
Source
packages/core/src/services/service.ts:662
logSlowQuery()
logSlowQuery(
_query
,_reason
,_time
):void
Parameters
• _query: string
• _reason: string
• _time: number
Returns
void
Inherited from
Source
packages/core/src/stores/store.ts:660
migration()
migration(
name
,patcher
,batchSize
):Promise
<void
>
Add a migration mechanism to store
Parameters
• name: string
• patcher: (object
) => Promise
<() => Promise
<void
> | Partial
<T
>>
• batchSize: number
= 500
Returns
Promise
<void
>
Inherited from
Source
packages/core/src/stores/store.ts:1772
newModel()
newModel(
object
):T
Get a new model with this data preloaded
Parameters
• object: any
= {}
Returns
T
Inherited from
Source
packages/core/src/stores/store.ts:970
off()
off(
eventName
,listener
):this
Alias for emitter.removeListener()
.
Parameters
• eventName: string
| symbol
• listener: (...args
) => void
Returns
this
Inherited from
Since
v10.0.0
Source
packages/core/node_modules/@types/node/events.d.ts:499
on()
on<
Key
>(event
,listener
):this
Type the listener part
Type parameters
• Key extends keyof StoreEvents
Parameters
• event: symbol
| Key
• listener: (evt
) => void
Returns
this
Inherited from
Source
packages/core/src/services/service.ts:607
onAsync()
onAsync<
Key
>(event
,listener
,queue
):void
Listen to an event as on(...) would do except that it will be asynchronous
Type parameters
• Key extends keyof StoreEvents
Parameters
• event: Key
• listener: (evt
) => void
• queue: string
= undefined
Name of queue to use, can be undefined, queue name are used to define differents priorities
Returns
void
Inherited from
Source
packages/core/src/services/service.ts:618
once()
once(
eventName
,listener
):this
Adds a one-timelistener
function for the event named eventName
. The
next time eventName
is triggered, this listener is removed and then invoked.
server.once('connection', (stream) => {
console.log('Ah, we have our first user!');
});
Returns a reference to the EventEmitter
, so that calls can be chained.
By default, event listeners are invoked in the order they are added. Theemitter.prependOnceListener()
method can be used as an alternative to add the
event listener to the beginning of the listeners array.
const myEE = new EventEmitter();
myEE.once('foo', () => console.log('a'));
myEE.prependOnceListener('foo', () => console.log('b'));
myEE.emit('foo');
// Prints:
// b
// a
Parameters
• eventName: string
| symbol
The name of the event.
• listener: (...args
) => void
The callback function
Returns
this
Inherited from
Since
v0.3.0
Source
packages/core/node_modules/@types/node/events.d.ts:414
operationCreate()
operationCreate(
ctx
,model
):Promise
<void
>
Create a new object based on the context
Parameters
• ctx: OperationContext
<any
, any
>
• model: string
Returns
Promise
<void
>
Inherited from
Source
packages/core/src/stores/store.ts:2155
patch()
patch<
FK
>(object
,reverseMap
,conditionField
?,conditionValue
?):Promise
<T
>
Patch an object
Type parameters
• FK extends string
| number
| symbol
Parameters
• object: Partial
<T
>
• reverseMap: boolean
= true
• conditionField?: FK
• conditionValue?: any
Returns
Promise
<T
>
Inherited from
Source
packages/core/src/stores/store.ts:1432
prependListener()
prependListener(
eventName
,listener
):this
Adds the listener
function to the beginning of the listeners array for the
event named eventName
. No checks are made to see if the listener
has
already been added. Multiple calls passing the same combination of eventName
and listener
will result in the listener
being added, and called, multiple
times.
server.prependListener('connection', (stream) => {
console.log('someone connected!');
});
Returns a reference to the EventEmitter
, so that calls can be chained.
Parameters
• eventName: string
| symbol
The name of the event.
• listener: (...args
) => void
The callback function
Returns
this
Inherited from
Since
v6.0.0
Source
packages/core/node_modules/@types/node/events.d.ts:634
prependOnceListener()
prependOnceListener(
eventName
,listener
):this
Adds a one-timelistener
function for the event named eventName
to the beginning of the listeners array. The next time eventName
is triggered, this
listener is removed, and then invoked.
server.prependOnceListener('connection', (stream) => {
console.log('Ah, we have our first user!');
});
Returns a reference to the EventEmitter
, so that calls can be chained.
Parameters
• eventName: string
| symbol
The name of the event.
• listener: (...args
) => void
The callback function
Returns
this
Inherited from
Since
v6.0.0
Source
packages/core/node_modules/@types/node/events.d.ts:650
put()
put(
uuid
,data
):Promise
<T
>
Upsert the uuid object
Parameters
• uuid: string
• data: Partial
<T
>
Returns
Promise
<T
>
Inherited from
Source
packages/core/src/stores/store.ts:1979
query()
query(
query
,context
?):Promise
<Object
>
Query store with WebdaQL
Parameters
• query: string
• context?: OperationContext
<any
, any
>
to apply permission
Returns
Promise
<Object
>
continuationToken?
continuationToken?:
string
results
results:
T
[]
Inherited from
Source
packages/core/src/stores/store.ts:1172
queryAll()
queryAll(
query
,context
?):Promise
<T
[]>
Query all the results
Parameters
• query: string
• context?: OperationContext
<any
, any
>
Returns
Promise
<T
[]>
Inherited from
Deprecated
use iterate instead
Source
packages/core/src/stores/store.ts:1150
queryTypeUpdater()
queryTypeUpdater(
query
):Query
Check that __type Comparison is only used with = and CONTAINS If CONTAINS is used, move __type to __types If __type = store._model, remove it
Parameters
• query: Query
Returns
Inherited from
Source
packages/core/src/stores/store.ts:1164
rawListeners()
rawListeners(
eventName
):Function
[]
Returns a copy of the array of listeners for the event named eventName
,
including any wrappers (such as those created by .once()
).
const emitter = new EventEmitter();
emitter.once('log', () => console.log('log once'));
// Returns a new Array with a function `onceWrapper` which has a property
// `listener` which contains the original listener bound above
const listeners = emitter.rawListeners('log');
const logFnWrapper = listeners[0];
// Logs "log once" to the console and does not unbind the `once` event
logFnWrapper.listener();
// Logs "log once" to the console and removes the listener
logFnWrapper();
emitter.on('log', () => console.log('log persistently'));
// Will return a new Array with a single function bound by `.on()` above
const newListeners = emitter.rawListeners('log');
// Logs "log persistently" twice
newListeners[0]();
emitter.emit('log');
Parameters
• eventName: string
| symbol
Returns
Function
[]
Inherited from
Since
v9.4.0
Source
packages/core/node_modules/@types/node/events.d.ts:569
recomputeTypeCase()
recomputeTypeCase():
Promise
<void
>
Recompute type case
Returns
Promise
<void
>
Inherited from
Source
packages/core/src/stores/store.ts:1703
recomputeTypeShortId()
recomputeTypeShortId():
Promise
<void
>
Returns
Promise
<void
>
Inherited from
Source
packages/core/src/stores/store.ts:1662
recomputeTypes()
recomputeTypes():
Promise
<void
>
Recompute the __types for all objects (storeMigration.Registry.typesCompute)
Returns
Promise
<void
>
Inherited from
Source
packages/core/src/stores/store.ts:1727
reinit()
reinit(
config
):Promise
<FileStore
<T
,K
>>
Parameters
• config: DeepPartial
<K
>
new parameters for the service
Returns
Promise
<FileStore
<T
, K
>>
Inherited from
Source
packages/core/src/services/service.ts:579
removeAllListeners()
removeAllListeners(
event
?):this
Removes all listeners, or those of the specified eventName
.
It is bad practice to remove listeners added elsewhere in the code,
particularly when the EventEmitter
instance was created by some other
component or module (e.g. sockets or file streams).
Returns a reference to the EventEmitter
, so that calls can be chained.
Parameters
• event?: string
| symbol
Returns
this
Inherited from
Since
v0.1.26
Source
packages/core/node_modules/@types/node/events.d.ts:510
removeAttribute()
removeAttribute<
CK
>(uuid
,attribute
,itemWriteCondition
?,itemWriteConditionField
?):Promise
<void
>
Remove an attribute from an object
Type parameters
• CK extends string
| number
| symbol
Parameters
• uuid: string
• attribute: CK
• itemWriteCondition?: any
• itemWriteConditionField?: CK
Returns
Promise
<void
>
Inherited from
Source
packages/core/src/stores/store.ts:1821
removeListener()
removeListener(
eventName
,listener
):this
Removes the specified listener
from the listener array for the event namedeventName
.
const callback = (stream) => {
console.log('someone connected!');
};
server.on('connection', callback);
// ...
server.removeListener('connection', callback);
removeListener()
will remove, at most, one instance of a listener from the
listener array. If any single listener has been added multiple times to the
listener array for the specified eventName
, then removeListener()
must be
called multiple times to remove each instance.
Once an event is emitted, all listeners attached to it at the
time of emitting are called in order. This implies that anyremoveListener()
or removeAllListeners()
calls after emitting and before the last listener finishes execution
will not remove them fromemit()
in progress. Subsequent events behave as expected.
const myEmitter = new MyEmitter();
const callbackA = () => {
console.log('A');
myEmitter.removeListener('event', callbackB);
};
const callbackB = () => {
console.log('B');
};
myEmitter.on('event', callbackA);
myEmitter.on('event', callbackB);
// callbackA removes listener callbackB but it will still be called.
// Internal listener array at time of emit [callbackA, callbackB]
myEmitter.emit('event');
// Prints:
// A
// B
// callbackB is now removed.
// Internal listener array [callbackA]
myEmitter.emit('event');
// Prints:
// A
Because listeners are managed using an internal array, calling this will
change the position indices of any listener registered after the listener
being removed. This will not impact the order in which listeners are called,
but it means that any copies of the listener array as returned by
the emitter.listeners()
method will need to be recreated.
When a single function has been added as a handler multiple times for a single
event (as in the example below), removeListener()
will remove the most
recently added instance. In the example the once('ping')
listener is removed:
const ee = new EventEmitter();
function pong() {
console.log('pong');
}
ee.on('ping', pong);
ee.once('ping', pong);
ee.removeListener('ping', pong);
ee.emit('ping');
ee.emit('ping');
Returns a reference to the EventEmitter
, so that calls can be chained.
Parameters
• eventName: string
| symbol
• listener: (...args
) => void
Returns
this
Inherited from
Since
v0.1.26
Source
packages/core/node_modules/@types/node/events.d.ts:494
resolve()
resolve():
this
Resolve parameters Call initRoutes and initBeanRoutes
Returns
this
Inherited from
Source
packages/core/src/services/service.ts:388
save()
save(
object
,ctx
):Promise
<T
>
Save an object
Parameters
• object: any
• ctx: OperationContext
<any
, any
>= undefined
Returns
Promise
<T
>
with saved object
Might want to rename to create
Inherited from
Source
packages/core/src/stores/store.ts:1362
setAttribute()
setAttribute<
CK
>(uid
,property
,value
):Promise
<void
>
Set one attribute in an object
this is an helper function that calls patch
Type parameters
• CK extends string
| number
| symbol
Parameters
• uid: string
of the object
• property: CK
to update1
• value: any
new value
Returns
Promise
<void
>
Inherited from
Source
packages/core/src/stores/store.ts:2028
setMaxListeners()
setMaxListeners(
n
):this
By default EventEmitter
s will print a warning if more than 10
listeners are
added for a particular event. This is a useful default that helps finding
memory leaks. The emitter.setMaxListeners()
method allows the limit to be
modified for this specific EventEmitter
instance. The value can be set toInfinity
(or 0
) to indicate an unlimited number of listeners.
Returns a reference to the EventEmitter
, so that calls can be chained.
Parameters
• n: number
Returns
this
Inherited from
Since
v0.3.5
Source
packages/core/node_modules/@types/node/events.d.ts:520
setModel()
setModel(
model
):void
OVerwrite the model Used mainly in test
Parameters
• model: CoreModelDefinition
<T
>
Returns
void
Inherited from
Source
packages/core/src/stores/store.ts:882
simulateFind()
protected
simulateFind(query
,uuids
):Promise
<StoreFindResult
<T
>>
Parameters
• query: Query
• uuids: string
[]
Returns
Promise
<StoreFindResult
<T
>>
Inherited from
Source
packages/core/src/stores/store.ts:2038
simulateUpsertItemToCollection()
simulateUpsertItemToCollection<
FK
>(model
,prop
,item
,updateDate
,index
?,itemWriteCondition
?,itemWriteConditionField
?):Promise
<void
>
Type parameters
• FK extends string
| number
| symbol
Parameters
• model: T
• prop: FK
• item: any
• updateDate: Date
• index?: number
• itemWriteCondition?: any
• itemWriteConditionField?: string
Returns
Promise
<void
>
Inherited from
Store
.simulateUpsertItemToCollection
Source
packages/core/src/stores/store.ts:1528
stop()
stop():
Promise
<void
>
Shutdown the current service if action need to be taken
Returns
Promise
<void
>