Options
All
  • Public
  • Public/Protected
  • All
Menu

Class MemoryStore<T, K>

Store in Memory

Type parameters

Hierarchy

  • Store<T, K>
    • MemoryStore

Implements

Constructors

constructor

Properties

_cascade
_createException
_creationDateField
_exposeUrl
_initException
_initTime
_lastUpdateField
_model
_name
_reverseMap
_uuidField
_webda
logger
parameters
storage
defaultMaxListeners

Methods

__clean
_delete
_deleteItemFromCollection
_find
_get
_getSync
_handleCreatedMap
_handleDeletedMap
_handleMapFromPartial
_handleMapProperty
_handleUpdatedMap
_handleUpdatedMapMapper
_handleUpdatedMapTransferIn
_handleUpdatedMapTransferOut
_incrementAttribute
_patch
_removeAttribute
_save
_update
_upsertItemToCollection
addListener
addReverseMap
addRoute
canTriggerConfiguration
cascadeDelete
computeParameters
createIndex
delete
deleteItemFromCollection
emit
emitSync
eventNames
exists
find
generateUid
get
getAll
getConfiguration
getMapper
getMaxListeners
getModel
getName
getParameters
getService
getUrl
getUuidField
getWebda
handleIndex
handleMap
httpAction
httpCreate
httpGet
httpGlobalAction
httpRoute
httpUpdate
incrementAttribute
init
initMap
initModel
initRoutes
isMapped
listenerCount
listeners
loadParameters
log
off
on
onAsync
once
patch
prependListener
prependOnceListener
rawListeners
reinit
removeAllListeners
removeAttribute
removeListener
removeMapper
resolve
save
setMaxListeners
toPublicJSON
toString
update
upsertItemToCollection
getModda
listenerCount

Constructors

Properties

_cascade: any[] = []
_createException: string
_creationDateField: string
_exposeUrl: string
_initException: any = undefined
_initTime: number
_lastUpdateField: string
_model: CoreModelDefinition
_name: string

Service name

_reverseMap: any[] = []
_uuidField: string = "uuid"
_webda: Core

Webda Core object

logger: Logger

Logger with class context

parameters: K

Hold the parameters for your service

It will be bring from the webda.config.json

storage: StorageMap
defaultMaxListeners: number

Methods

  • __clean(): Promise<void>
  • _delete(uid: any): Promise<void>
  • _deleteItemFromCollection(uid: any, prop: any, index: any, itemWriteCondition: any, itemWriteConditionField: any, updateDate: Date): Promise<T>
  • _find(request: any, offset: any, limit: any): Promise<any>
  • _get(uid: any): Promise<T>
  • _getSync(uid: any): T
  • _handleCreatedMap(object: any, map: any, mapped: any, store: any): any
  • _handleDeletedMap(object: any, map: any, mapped: any, store: any): any
  • _handleMapFromPartial(uid: string, updateDate: Date, prop?: string): Promise<void>
  • _handleMapProperty(store: any, object: any, property: any, updates: any): Promise<any>
  • _handleUpdatedMap(object: any, map: any, mapped: any, store: any, updates: any): Promise<any>
  • _handleUpdatedMapMapper(object: any, map: any, mapped: any, store: any, updates: any): any
  • _handleUpdatedMapTransferIn(object: any, map: any, store: any, updates: any): any
  • _handleUpdatedMapTransferOut(object: any, map: any, mapped: any, store: any, updates: any): any
  • _incrementAttribute(uid: any, prop: any, value: any, updateDate: Date): Promise<T>
  • _patch(object: any, uuid: any): Promise<T>
  • _removeAttribute(uuid: string, attribute: string): Promise<void>
  • _save(object: any): Promise<T>
  • _update(object: any, uuid: any): Promise<T>
  • _upsertItemToCollection(uid: any, prop: any, item: any, index: any, itemWriteCondition: any, itemWriteConditionField: any, updateDate: Date): Promise<void>
  • addListener(event: string | symbol, listener: function): this
  • addReverseMap(prop: any, cascade: any, store: any): void
  • addRoute(url: string, methods: HttpMethodType[], executer: Function, openapi?: object, allowPath?: boolean): void
  • canTriggerConfiguration(id: string, callback: function): boolean
  • cascadeDelete(obj: any, uuid: string): Promise<any>
  • computeParameters(): void
  • createIndex(): Promise<void>
  • delete(uid: any, sync?: boolean): Promise<void>
  • deleteItemFromCollection(uid: any, prop: any, index: any, itemWriteCondition: any, itemWriteConditionField: any): Promise<void>
  • emit(event: string | symbol, ...args: any[]): boolean
  • emitSync(event: any, data: any): Promise<any[]>
  • eventNames(): Array<string | symbol>
  • exists(uid: any): Promise<boolean>
  • find(request?: any, offset?: number, limit?: number): Promise<any>
  • generateUid(): any
  • get(uid: string, ctx?: Context): Promise<T>
  • getAll(uids: any): Promise<any>
  • getConfiguration(id: string): Promise<Map<string, any>>
  • getMapper(map: any, uuid: any): number
  • getMaxListeners(): number
  • getName(): string
  • getParameters(): K
  • getService<T>(service: string): T
  • getUrl(): string
  • getUuidField(): string
  • handleIndex(object: CoreModel, updates: object | string): Promise<void>
  • handleMap(object: any, map: any, updates: any): Promise<any[]>
  • httpAction(ctx: Context): Promise<void>
  • httpCreate(ctx: Context): Promise<void>
  • httpGet(ctx: Context): Promise<void>
  • httpGlobalAction(ctx: Context): Promise<void>
  • httpRoute(ctx: Context): Promise<void>
  • httpUpdate(ctx: Context): Promise<void>
  • incrementAttribute(uid: any, prop: any, value: any): Promise<void | any[]>
  • init(): Promise<void>
  • initMap(map: any): void
  • initModel(object: any): T
  • initRoutes(): void
  • isMapped(property: string): boolean
  • listenerCount(type: string | symbol): number
  • listeners(event: string | symbol): Function[]
  • off(event: string | symbol, listener: function): this
  • on(event: string | symbol, listener: function): this
  • onAsync(event: any, callback: any, queue?: string): void

  • Listen to an event as on(...) would do except that it will be asynchronous

    Parameters

    • event: any
    • callback: any
    • Default value queue: string = undefined

      Name of queue to use, can be undefined, queue name are used to define differents priorities

    Returns void

  • once(event: string | symbol, listener: function): this
  • patch(object: any, reverseMap?: boolean): Promise<any>
  • prependListener(event: string | symbol, listener: function): this
  • prependOnceListener(event: string | symbol, listener: function): this
  • rawListeners(event: string | symbol): Function[]
  • reinit(config: any): Promise<void>
  • removeAllListeners(event?: string | symbol): this
  • removeAttribute(uuid: string, attribute: string): Promise<void>
  • removeListener(event: string | symbol, listener: function): this
  • removeMapper(map: any, uuid: any): boolean
  • resolve(): void
  • save(object: any, ctx?: Context): Promise<any>
  • setMaxListeners(n: number): this
  • toPublicJSON(object: any): string
  • toString(): string
  • update(object: any, reverseMap?: boolean, partial?: boolean): Promise<any>

  • Update an object

    Parameters

    • object: any
    • Default value reverseMap: boolean = true

      internal use only, for disable map resolution

    • Default value partial: boolean = false

    Returns Promise<any>

    with saved object

  • upsertItemToCollection(uid: any, prop: any, item: any, index?: any, itemWriteCondition?: any, itemWriteConditionField?: any): Promise<void>
  • listenerCount(emitter: EventEmitter, event: string | symbol): number

Generated using TypeDoc