Class TypeormAssetProvider

Hierarchy

TypeormProvider
- TypeormAssetProvider

Implements

AssetProvider

Constructors

constructor

new TypeormAssetProvider(__namedParameters: TypeormAssetProviderProps, dependencies: TypeormAssetProviderDependencies): TypeormAssetProvider
Parameters
- __namedParameters: TypeormAssetProviderProps
- dependencies: TypeormAssetProviderDependencies
Returns TypeormAssetProvider
Overrides TypeormProvider.constructor
- Defined in packages/cardano-services/src/Asset/TypeormAssetProvider/TypeormAssetProvider.ts:30

Properties

`Private` #connectionConfig$

#connectionConfig$: Observable<PgConnectionConfig>

`Private` #connectionTimeout

#connectionTimeout: Milliseconds

`Private` #dependencies

#dependencies: TypeormAssetProviderDependencies

`Private` #entities

#entities: Function[]

`Private` #nftMetadataService

#nftMetadataService: TypeOrmNftMetadataService

`Private` #paginationPageSizeLimit

#paginationPageSizeLimit: number

`Private` #subscription

#subscription: undefined | Subscription

`Protected` dataSource$

dataSource$: BehaviorSubject<null | DataSource> = ...

health

health: HealthCheckResponse = ...

healthCheckCache

healthCheckCache: InMemoryCache

logger

logger: Logger

name

name: string

state

state: RunnableModuleState

Methods

`Private` #fetchTokenMetadataList

#fetchTokenMetadataList(assetIds: AssetId[]): Promise<(undefined | null | TokenMetadata)[]>
Parameters
- assetIds: AssetId[]
Returns Promise<(undefined | null | TokenMetadata)[]>
- Defined in packages/cardano-services/src/Asset/TypeormAssetProvider/TypeormAssetProvider.ts:89

`Private` #getAssetInfo

#getAssetInfo(assetId: AssetId, queryRunner: QueryRunner): Promise<AssetInfo>
Parameters
- assetId: AssetId
- queryRunner: QueryRunner
Returns Promise<AssetInfo>
- Defined in packages/cardano-services/src/Asset/TypeormAssetProvider/TypeormAssetProvider.ts:123

`Private` #getAssetsInfo

#getAssetsInfo(assetIds: AssetId[], dataSource: DataSource): Promise<Map<AssetId, AssetInfo>>
Parameters
- assetIds: AssetId[]
- dataSource: DataSource
Returns Promise<Map<AssetId, AssetInfo>>
- Defined in packages/cardano-services/src/Asset/TypeormAssetProvider/TypeormAssetProvider.ts:143

`Private` #getMultiNftMetadata

#getMultiNftMetadata(assetIds: AssetId[], dataSource: DataSource): Promise<Map<AssetId, NftMetadata>>
Parameters
- assetIds: AssetId[]
- dataSource: DataSource
Returns Promise<Map<AssetId, NftMetadata>>
- Defined in packages/cardano-services/src/Asset/TypeormAssetProvider/TypeormAssetProvider.ts:172

`Private` #getNftMetadata

#getNftMetadata(asset: AssetInfo, queryRunner: QueryRunner): Promise<undefined | null | NftMetadata>
Parameters
- asset: AssetInfo
- queryRunner: QueryRunner
Returns Promise<undefined | null | NftMetadata>
- Defined in packages/cardano-services/src/Asset/TypeormAssetProvider/TypeormAssetProvider.ts:106

`Private` #reset

#reset(): void
Returns void
Inherited from TypeormProvider.#reset
- Defined in packages/cardano-services/src/util/TypeormService/TypeormService.ts:47

`Private` #subscribeToDataSource

#subscribeToDataSource(): Promise<unknown>
Returns Promise<unknown>
Inherited from TypeormProvider.#subscribeToDataSource
- Defined in packages/cardano-services/src/util/TypeormService/TypeormService.ts:30

getAsset

getAsset(__namedParameters: GetAssetArgs): Promise<AssetInfo>
Parameters
- __namedParameters: GetAssetArgs
Returns Promise<AssetInfo>
Implementation of AssetProvider.getAsset
- Defined in packages/cardano-services/src/Asset/TypeormAssetProvider/TypeormAssetProvider.ts:39

getAssets

getAssets(__namedParameters: GetAssetsArgs): Promise<AssetInfo[]>
Parameters
- __namedParameters: GetAssetsArgs
Returns Promise<AssetInfo[]>
Implementation of AssetProvider.getAssets
- Defined in packages/cardano-services/src/Asset/TypeormAssetProvider/TypeormAssetProvider.ts:52

healthCheck

healthCheck(): Promise<HealthCheckResponse>
Returns Promise<HealthCheckResponse>
Implementation of AssetProvider.healthCheck

Inherited from TypeormProvider.healthCheck
- Defined in packages/cardano-services/src/util/TypeormProvider/TypeormProvider.ts:26

initialize

initialize(): Promise<void>
Returns Promise<void>
Inherited from TypeormProvider.initialize
- Defined in packages/util/dist/cjs/RunnableModule.d.ts:15

initializeAfter

initializeAfter(): void
Returns void
Inherited from TypeormProvider.initializeAfter
- Defined in packages/util/dist/cjs/RunnableModule.d.ts:19

initializeBefore

initializeBefore(): void
Returns void
Inherited from TypeormProvider.initializeBefore
- Defined in packages/util/dist/cjs/RunnableModule.d.ts:18

initializeImpl

initializeImpl(): Promise<void>
Returns Promise<void>
Overrides TypeormProvider.initializeImpl
- Defined in packages/cardano-services/src/Asset/TypeormAssetProvider/TypeormAssetProvider.ts:197

onError

onError(_: unknown): void
Parameters
- _: unknown
Returns void
Inherited from TypeormProvider.onError
- Defined in packages/cardano-services/src/util/TypeormService/TypeormService.ts:53

shutdown

shutdown(): Promise<void>
Returns Promise<void>
Inherited from TypeormProvider.shutdown
- Defined in packages/util/dist/cjs/RunnableModule.d.ts:17

shutdownAfter

shutdownAfter(): void
Returns void
Inherited from TypeormProvider.shutdownAfter
- Defined in packages/util/dist/cjs/RunnableModule.d.ts:23

shutdownBefore

shutdownBefore(): void
Returns void
Inherited from TypeormProvider.shutdownBefore
- Defined in packages/util/dist/cjs/RunnableModule.d.ts:22

shutdownImpl

shutdownImpl(): Promise<void>
Returns Promise<void>
Overrides TypeormProvider.shutdownImpl
- Defined in packages/cardano-services/src/Asset/TypeormAssetProvider/TypeormAssetProvider.ts:207

start

start(): Promise<void>
Returns Promise<void>
Inherited from TypeormProvider.start
- Defined in packages/util/dist/cjs/RunnableModule.d.ts:16

startAfter

startAfter(): void
Returns void
Inherited from TypeormProvider.startAfter
- Defined in packages/util/dist/cjs/RunnableModule.d.ts:21

startBefore

startBefore(): void
Returns void
Inherited from TypeormProvider.startBefore
- Defined in packages/util/dist/cjs/RunnableModule.d.ts:20

startImpl

startImpl(): Promise<void>
Returns Promise<void>
Overrides TypeormProvider.startImpl
- Defined in packages/cardano-services/src/Asset/TypeormAssetProvider/TypeormAssetProvider.ts:202

withDataSource

withDataSource<T>(callback: ((dataSource: DataSource) => Promise<T>)): Promise<T>
Type Parameters
- T
Parameters
- callback: ((dataSource: DataSource) => Promise<T>)
  - - (dataSource: DataSource): Promise<T>
    - Parameters
      
      dataSource: DataSource
      
      Returns Promise<T>
Returns Promise<T>
Inherited from TypeormProvider.withDataSource
- Defined in packages/cardano-services/src/util/TypeormService/TypeormService.ts:58

withQueryRunner

withQueryRunner<T>(callback: ((queryRunner: QueryRunner) => Promise<T>)): Promise<T>
Type Parameters
- T
Parameters
- callback: ((queryRunner: QueryRunner) => Promise<T>)
  - - (queryRunner: QueryRunner): Promise<T>
    - Parameters
      
      queryRunner: QueryRunner
      
      Returns Promise<T>
Returns Promise<T>
Inherited from TypeormProvider.withQueryRunner
- Defined in packages/cardano-services/src/util/TypeormService/TypeormService.ts:71

Class TypeormAssetProvider

Hierarchy

Implements

Index

Constructors

Properties

Methods

Constructors

constructor

Parameters

__namedParameters: TypeormAssetProviderProps

dependencies: TypeormAssetProviderDependencies

Returns TypeormAssetProvider

Properties

Private #connectionConfig$

Private #connectionTimeout

Private #dependencies

Private #entities

Private #nftMetadataService

Private #paginationPageSizeLimit

Private #subscription

Protected dataSource$

health

healthCheckCache

logger

name

state

Methods

Private #fetchTokenMetadataList

Parameters

assetIds: AssetId[]

Returns Promise<(undefined | null | TokenMetadata)[]>

Private #getAssetInfo

Parameters

assetId: AssetId

queryRunner: QueryRunner

Returns Promise<AssetInfo>

Private #getAssetsInfo

Parameters

assetIds: AssetId[]

dataSource: DataSource

Returns Promise<Map<AssetId, AssetInfo>>

Private #getMultiNftMetadata

Parameters

assetIds: AssetId[]

dataSource: DataSource

Returns Promise<Map<AssetId, NftMetadata>>

Private #getNftMetadata

Parameters

asset: AssetInfo

queryRunner: QueryRunner

Returns Promise<undefined | null | NftMetadata>

Private #reset

Returns void

Private #subscribeToDataSource

Returns Promise<unknown>

getAsset

Parameters

__namedParameters: GetAssetArgs

Returns Promise<AssetInfo>

getAssets

Parameters

__namedParameters: GetAssetsArgs

Returns Promise<AssetInfo[]>

healthCheck

Returns Promise<HealthCheckResponse>

initialize

Returns Promise<void>

initializeAfter

Returns void

initializeBefore

Returns void

initializeImpl

Returns Promise<void>

onError

Parameters

_: unknown

Returns void

shutdown

Returns Promise<void>

`Private` #connectionConfig$

`Private` #connectionTimeout

`Private` #dependencies

`Private` #entities

`Private` #nftMetadataService

`Private` #paginationPageSizeLimit

`Private` #subscription

`Protected` dataSource$

`Private` #fetchTokenMetadataList

`Private` #getAssetInfo

`Private` #getAssetsInfo

`Private` #getMultiNftMetadata

`Private` #getNftMetadata

`Private` #reset

`Private` #subscribeToDataSource