Class FetcherMs

A wrapper of the Molueculer service to expose the main fetcher service through the broker.

Hierarchy

Service
- FetcherMs

Constructors

constructor

new FetcherMs(broker: ServiceBroker): FetcherMs
Parameters
- broker: ServiceBroker
Returns FetcherMs
Overrides Service.constructor
- Defined in packages/framework/src/services/fetcher/ms.ts:24

Properties

Promise

Promise: PromiseConstructorLike

actions

actions: ServiceActions

broker

broker: ServiceBroker

dependencies

dependencies: string | ServiceDependency | (string | ServiceDependency)[]

fullName

fullName: string

logger

logger: LoggerInstance

`Protected` main

main: FetcherMsMain

metadata

metadata: GenericObject

name

name: string

originalSchema

originalSchema: ServiceSchema<ServiceSettingSchema>

schema

schema: ServiceSchema<ServiceSettingSchema>

settings

settings: ServiceSettingSchema

`Optional` version

version?: string | number

`Static` mainFactory

mainFactory: MainFactory<FetcherMsMain>

Methods

_init

_init(): void
Returns void
Inherited from Service._init
- Defined in node_modules/moleculer/index.d.ts:776

_start

_start(): Promise<void>
Returns Promise<void>
Inherited from Service._start
- Defined in node_modules/moleculer/index.d.ts:777

_stop

_stop(): Promise<void>
Returns Promise<void>
Inherited from Service._stop
- Defined in node_modules/moleculer/index.d.ts:778

addAccountEntityFetcher

addAccountEntityFetcher(ctx: Context<AddAccountEntityRequestArgs, {}, GenericObject>): Promise<void>
Parameters
- ctx: Context<AddAccountEntityRequestArgs, {}, GenericObject>
Returns Promise<void>
- Defined in packages/framework/src/services/fetcher/ms.ts:74

applyMixins

applyMixins(schema: ServiceSchema<ServiceSettingSchema>): ServiceSchema<ServiceSettingSchema>
Apply mixins list in schema. Merge the schema with mixins schemas. Returns with the mixed schema
Parameters
- schema: ServiceSchema<ServiceSettingSchema>
  
  Schema containing the mixins to merge
Returns ServiceSchema<ServiceSettingSchema>
Inherited from Service.applyMixins
- Defined in node_modules/moleculer/index.d.ts:810

delAccountEntityFetcher

delAccountEntityFetcher(ctx: Context<DelAccountEntityRequestArgs, {}, GenericObject>): Promise<void>
Parameters
- ctx: Context<DelAccountEntityRequestArgs, {}, GenericObject>
Returns Promise<void>
- Defined in packages/framework/src/services/fetcher/ms.ts:80

emitLocalEventHandler

emitLocalEventHandler(eventName: string, params?: any, opts?: any): any
Call a local event handler. Useful for unit tests.
Parameters
- eventName: string
  
  The event name
- Optional params: any
  
  The event parameters
- Optional opts: any
  
  The event options
Returns any
Inherited from Service.emitLocalEventHandler
- Defined in node_modules/moleculer/index.d.ts:787

fetchAccountEntitiesByDate

fetchAccountEntitiesByDate(ctx: Context<FetchAccountEntitiesByDateRequestArgs, {}, GenericObject>): Promise<void | AsyncIterable<string[]>>
Parameters
- ctx: Context<FetchAccountEntitiesByDateRequestArgs, {}, GenericObject>
Returns Promise<void | AsyncIterable<string[]>>
- Defined in packages/framework/src/services/fetcher/ms.ts:92

fetchEntitiesById

fetchEntitiesById(ctx: Context<FetchEntitiesByIdRequestArgs, {}, GenericObject>): Promise<void>
Parameters
- ctx: Context<FetchEntitiesByIdRequestArgs, {}, GenericObject>
Returns Promise<void>
- Defined in packages/framework/src/services/fetcher/ms.ts:98

getAccountEntityFetcherState

getAccountEntityFetcherState(ctx: Context<GetAccountEntityStateRequestArgs, {}, GenericObject>): Promise<undefined | AccountEntityHistoryState<unknown>>
Parameters
- ctx: Context<GetAccountEntityStateRequestArgs, {}, GenericObject>
Returns Promise<undefined | AccountEntityHistoryState<unknown>>
- Defined in packages/framework/src/services/fetcher/ms.ts:86

getFetcherState

getFetcherState(ctx: Context<FetcherStateRequestArgs, {}, GenericObject>): Promise<FetcherState<any>[]>
Parameters
- ctx: Context<FetcherStateRequestArgs, {}, GenericObject>
Returns Promise<FetcherState<any>[]>
- Defined in packages/framework/src/services/fetcher/ms.ts:102

invokeBlockchainMethod

invokeBlockchainMethod(ctx: Context<InvokeBlockchainMethodRequestArgs<unknown>, {}, GenericObject>): Promise<unknown>
Parameters
- ctx: Context<InvokeBlockchainMethodRequestArgs<unknown>, {}, GenericObject>
Returns Promise<unknown>
- Defined in packages/framework/src/services/fetcher/ms.ts:108

mergeSchemaActions

mergeSchemaActions(src: GenericObject, target: GenericObject): GenericObject
Merge actions property in schema
Parameters
- src: GenericObject
  
  Source schema property
- target: GenericObject
  
  Target schema property
Returns GenericObject
Inherited from Service.mergeSchemaActions
- Defined in node_modules/moleculer/index.d.ts:869

mergeSchemaDependencies

mergeSchemaDependencies(src: GenericObject, target: GenericObject): GenericObject
Merge dependencies property in schema
Parameters
- src: GenericObject
  
  Source schema property
- target: GenericObject
  
  Target schema property
Returns GenericObject
Inherited from Service.mergeSchemaDependencies
- Defined in node_modules/moleculer/index.d.ts:853

mergeSchemaEvents

mergeSchemaEvents(src: GenericObject, target: GenericObject): GenericObject
Merge events property in schema
Parameters
- src: GenericObject
  
  Source schema property
- target: GenericObject
  
  Target schema property
Returns GenericObject
Inherited from Service.mergeSchemaEvents
- Defined in node_modules/moleculer/index.d.ts:885

mergeSchemaHooks

mergeSchemaHooks(src: GenericObject, target: GenericObject): GenericObject
Merge hooks property in schema
Parameters
- src: GenericObject
  
  Source schema property
- target: GenericObject
  
  Target schema property
Returns GenericObject
Inherited from Service.mergeSchemaHooks
- Defined in node_modules/moleculer/index.d.ts:861

mergeSchemaLifecycleHandlers

mergeSchemaLifecycleHandlers(src: GenericObject, target: GenericObject): GenericObject
Merge started, stopped, created event handler properties in schema
Parameters
- src: GenericObject
  
  Source schema property
- target: GenericObject
  
  Target schema property
Returns GenericObject
Inherited from Service.mergeSchemaLifecycleHandlers
- Defined in node_modules/moleculer/index.d.ts:893

mergeSchemaMetadata

mergeSchemaMetadata(src: GenericObject, target: GenericObject): GenericObject
Merge metadata property in schema
Parameters
- src: GenericObject
  
  Source schema property
- target: GenericObject
  
  Target schema property
Returns GenericObject
Inherited from Service.mergeSchemaMetadata
- Defined in node_modules/moleculer/index.d.ts:837

mergeSchemaMethods

mergeSchemaMethods(src: GenericObject, target: GenericObject): GenericObject
Merge methods property in schema
Parameters
- src: GenericObject
  
  Source schema property
- target: GenericObject
  
  Target schema property
Returns GenericObject
Inherited from Service.mergeSchemaMethods
- Defined in node_modules/moleculer/index.d.ts:877

mergeSchemaSettings

mergeSchemaSettings(src: GenericObject, target: GenericObject): GenericObject
Merge settings property in schema
Parameters
- src: GenericObject
  
  Source schema property
- target: GenericObject
  
  Target schema property
Returns GenericObject
Inherited from Service.mergeSchemaSettings
- Defined in node_modules/moleculer/index.d.ts:829

mergeSchemaUniqArray

mergeSchemaUniqArray(src: GenericObject, target: GenericObject): GenericObject
Merge mixins property in schema
Parameters
- src: GenericObject
  
  Source schema property
- target: GenericObject
  
  Target schema property
Returns GenericObject
Inherited from Service.mergeSchemaUniqArray
- Defined in node_modules/moleculer/index.d.ts:845

mergeSchemaUnknown

mergeSchemaUnknown(src: GenericObject, target: GenericObject): GenericObject
Merge unknown properties in schema
Parameters
- src: GenericObject
  
  Source schema property
- target: GenericObject
  
  Target schema property
Returns GenericObject
Inherited from Service.mergeSchemaUnknown
- Defined in node_modules/moleculer/index.d.ts:901

mergeSchemas

mergeSchemas(mixinSchema: Partial<ServiceSchema<ServiceSettingSchema>>, svcSchema: Partial<ServiceSchema<ServiceSettingSchema>>): Partial<ServiceSchema<ServiceSettingSchema>>
Merge two Service schema
Parameters
- mixinSchema: Partial<ServiceSchema<ServiceSettingSchema>>
  
  Mixin schema
- svcSchema: Partial<ServiceSchema<ServiceSettingSchema>>
  
  Service schema
Returns Partial<ServiceSchema<ServiceSettingSchema>>
Inherited from Service.mergeSchemas
- Defined in node_modules/moleculer/index.d.ts:818

`Protected` parseServiceSchema

parseServiceSchema(schema: ServiceSchema<ServiceSettingSchema>): void
Parameters
- schema: ServiceSchema<ServiceSettingSchema>
Returns void
Inherited from Service.parseServiceSchema
- Defined in node_modules/moleculer/index.d.ts:761

start

start(): Promise<void>
Returns Promise<void>
- Defined in packages/framework/src/services/fetcher/ms.ts:66

stop

stop(): Promise<void>
Returns Promise<void>
- Defined in packages/framework/src/services/fetcher/ms.ts:70

waitForServices

waitForServices(serviceNames: string | string[] | ServiceDependency[], timeout?: number, interval?: number): Promise<WaitForServicesResult>
Wait for the specified services to become available/registered with this broker.
Parameters
- serviceNames: string | string[] | ServiceDependency[]
  
  The service, or services, we are waiting for.
- Optional timeout: number
  
  The total time this call may take. If this time has passed and the service(s) are not available an error will be thrown. (In milliseconds)
- Optional interval: number
  
  The time we will wait before once again checking if the service(s) are available (In milliseconds)
Returns Promise<WaitForServicesResult>
Inherited from Service.waitForServices
- Defined in node_modules/moleculer/index.d.ts:797

`Static` getVersionedFullName

getVersionedFullName(name: string, version?: string | number): string
Return a versioned full service name.
Parameters
- name: string
  
  The name
- Optional version: string | number
  
  The version
Returns string
Inherited from Service.getVersionedFullName
- Defined in node_modules/moleculer/index.d.ts:909

Class FetcherMs

Hierarchy

Index

Constructors

Properties

Methods

Constructors

constructor

Parameters

broker: ServiceBroker

Returns FetcherMs

Properties

Promise

actions

broker

dependencies

fullName

logger

Protected main

metadata

name

originalSchema

schema

settings

Optional version

Static mainFactory

Methods

_init

Returns void

_start

Returns Promise<void>

_stop

Returns Promise<void>

addAccountEntityFetcher

Parameters

ctx: Context<AddAccountEntityRequestArgs, {}, GenericObject>

Returns Promise<void>

applyMixins

Parameters

schema: ServiceSchema<ServiceSettingSchema>

Returns ServiceSchema<ServiceSettingSchema>

delAccountEntityFetcher

Parameters

ctx: Context<DelAccountEntityRequestArgs, {}, GenericObject>

Returns Promise<void>

emitLocalEventHandler

Parameters

eventName: string

Optional params: any

Optional opts: any

Returns any

fetchAccountEntitiesByDate

Parameters

ctx: Context<FetchAccountEntitiesByDateRequestArgs, {}, GenericObject>

Returns Promise<void | AsyncIterable<string[]>>

fetchEntitiesById

Parameters

ctx: Context<FetchEntitiesByIdRequestArgs, {}, GenericObject>

Returns Promise<void>

getAccountEntityFetcherState

Parameters

ctx: Context<GetAccountEntityStateRequestArgs, {}, GenericObject>

Returns Promise<undefined | AccountEntityHistoryState<unknown>>

getFetcherState

Parameters

ctx: Context<FetcherStateRequestArgs, {}, GenericObject>

Returns Promise<FetcherState<any>[]>

invokeBlockchainMethod

Parameters

ctx: Context<InvokeBlockchainMethodRequestArgs<unknown>, {}, GenericObject>

Returns Promise<unknown>

mergeSchemaActions

Parameters

src: GenericObject

target: GenericObject

Returns GenericObject

mergeSchemaDependencies

Parameters

src: GenericObject

target: GenericObject

`Protected` main

`Optional` version

`Static` mainFactory

`Optional` params: any

`Optional` opts: any

`Protected` parseServiceSchema

`Optional` timeout: number

`Optional` interval: number

`Static` getVersionedFullName

`Optional` version: string | number