Skip to content

Commit ae2fbf9

Browse files
AngelCastilloBAngelCastilloB
authored
Merge pull request #1486 from input-output-hk/feat/lw-11568-hoist-buffer-chain-sync-event-to-projection-package
2 parents cc1fde1 + dd8b52f commit ae2fbf9

File tree

80 files changed

+265
-203
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

80 files changed

+265
-203
lines changed

‎packages/cardano-services/src/Projection/createTypeormProjection.ts

+8-2
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,13 @@
11
/* eslint-disable @typescript-eslint/no-explicit-any */
22
/* eslint-disable prefer-spread */
3-
import { Bootstrap, ProjectionEvent, logProjectionProgress, requestNext } from '@cardano-sdk/projection';
4-
import { Cardano, ObservableCardanoNode } from '@cardano-sdk/core';
3+
import {
4+
Bootstrap,
5+
ObservableCardanoNode,
6+
ProjectionEvent,
7+
logProjectionProgress,
8+
requestNext
9+
} from '@cardano-sdk/projection';
10+
import { Cardano } from '@cardano-sdk/core';
511
import { Logger } from 'ts-log';
612
import { Observable, concat, defer, groupBy, mergeMap, take, takeWhile } from 'rxjs';
713
import {

‎packages/cardano-services/src/Projection/prepareTypeormProjection.ts

+2-2
Original file line numberDiff line numberDiff line change
@@ -44,8 +44,8 @@ import {
4444
willStoreStakePools,
4545
willStoreUtxo
4646
} from '@cardano-sdk/projection-typeorm';
47-
import { Cardano, ChainSyncEventType } from '@cardano-sdk/core';
48-
import { Mappers as Mapper, ProjectionEvent } from '@cardano-sdk/projection';
47+
import { Cardano } from '@cardano-sdk/core';
48+
import { ChainSyncEventType, Mappers as Mapper, ProjectionEvent } from '@cardano-sdk/projection';
4949
import { ObservableType, passthrough } from '@cardano-sdk/util-rxjs';
5050
import { POOLS_METRICS_INTERVAL_DEFAULT, POOLS_METRICS_OUTDATED_INTERVAL_DEFAULT } from '../Program/programs/types';
5151
import { Sorter } from '@hapi/topo';

‎packages/cardano-services/src/TxSubmit/NodeTxSubmitProvider.ts

+1-1
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,6 @@ import {
55
HandleOwnerChangeError,
66
HandleProvider,
77
HealthCheckResponse,
8-
ObservableCardanoNode,
98
ProviderError,
109
ProviderFailure,
1110
SubmitTxArgs,
@@ -14,6 +13,7 @@ import {
1413
} from '@cardano-sdk/core';
1514
import { InMemoryCache } from '../InMemoryCache';
1615
import { Logger } from 'ts-log';
16+
import { ObservableCardanoNode } from '@cardano-sdk/projection';
1717
import { WithLogger } from '@cardano-sdk/util';
1818

1919
type ObservableTxSubmitter = Pick<ObservableCardanoNode, 'healthCheck$' | 'submitTx'>;

‎packages/cardano-services/test/Projection/createTypeormProjection.test.ts

+2-1
Original file line numberDiff line numberDiff line change
@@ -6,8 +6,9 @@ import {
66
TokensEntity,
77
createDataSource
88
} from '@cardano-sdk/projection-typeorm';
9-
import { Cardano, ChainSyncEventType } from '@cardano-sdk/core';
9+
import { Cardano } from '@cardano-sdk/core';
1010
import { ChainSyncDataSet, chainSyncData, logger } from '@cardano-sdk/util-dev';
11+
import { ChainSyncEventType } from '@cardano-sdk/projection';
1112
import { ProjectionName, createTypeormProjection, prepareTypeormProjection } from '../../src';
1213
import { lastValueFrom } from 'rxjs';
1314
import { projectorConnectionConfig, projectorConnectionConfig$ } from '../util';

‎packages/core/src/CardanoNode/types/CardanoNode.ts

+11-1
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
import type { HealthCheckResponse } from '../../Provider';
2-
import type { Lovelace, PoolId, VrfVkHex } from '../../Cardano';
2+
import type { Lovelace, PoolId, Tip, VrfVkHex } from '../../Cardano';
33
import type { Milliseconds } from '../../util';
44

55
export interface EraSummary {
@@ -48,3 +48,13 @@ export interface CardanoNode {
4848
*/
4949
healthCheck(): Promise<HealthCheckResponse>;
5050
}
51+
52+
// Similar to Ogmios.Point, but using Cardano.BlockId opaque string for hash
53+
export type Point = Pick<Tip, 'hash' | 'slot'>;
54+
export type Origin = 'origin';
55+
export type TipOrOrigin = Tip | Origin;
56+
export type PointOrOrigin = Point | Origin;
57+
export type Intersection = {
58+
point: PointOrOrigin;
59+
tip: TipOrOrigin;
60+
};

‎packages/core/src/CardanoNode/types/index.ts

-1
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,2 @@
11
export * from './CardanoNode';
22
export * from './CardanoNodeErrors';
3-
export * from './ObservableCardanoNode';

‎packages/e2e/test/projection/offline-fork.test.ts

+5-9
Original file line numberDiff line numberDiff line change
@@ -2,24 +2,20 @@ import * as Postgres from '@cardano-sdk/projection-typeorm';
22
import { BlockDataEntity, BlockEntity, StakeKeyEntity } from '@cardano-sdk/projection-typeorm';
33
import {
44
Bootstrap,
5+
ChainSyncEvent,
6+
ChainSyncEventType,
7+
ChainSyncRollForward,
58
InMemory,
69
Mappers,
10+
ObservableCardanoNode,
711
ProjectionEvent,
812
ProjectionOperator,
913
StabilityWindowBuffer,
1014
WithBlock,
1115
requestNext,
1216
withStaticContext
1317
} from '@cardano-sdk/projection';
14-
import {
15-
Cardano,
16-
ChainSyncEvent,
17-
ChainSyncEventType,
18-
ChainSyncRollForward,
19-
ObservableCardanoNode,
20-
Point,
21-
TipOrOrigin
22-
} from '@cardano-sdk/core';
18+
import { Cardano, Point, TipOrOrigin } from '@cardano-sdk/core';
2319
import { ChainSyncDataSet, chainSyncData, logger } from '@cardano-sdk/util-dev';
2420
import { ConnectionConfig } from '@cardano-ogmios/client';
2521
import { Observable, filter, firstValueFrom, lastValueFrom, map, of, take, takeWhile, throwError, toArray } from 'rxjs';

‎packages/e2e/test/projection/single-tenant-utxo.test.ts

+2-2
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
import * as Postgres from '@cardano-sdk/projection-typeorm';
2-
import { Bootstrap, Mappers, ProjectionEvent, requestNext } from '@cardano-sdk/projection';
3-
import { Cardano, ObservableCardanoNode } from '@cardano-sdk/core';
2+
import { Bootstrap, Mappers, ObservableCardanoNode, ProjectionEvent, requestNext } from '@cardano-sdk/projection';
3+
import { Cardano } from '@cardano-sdk/core';
44
import { ConnectionConfig } from '@cardano-ogmios/client';
55
import { DataSource, QueryRunner } from 'typeorm';
66
import { Observable, filter, firstValueFrom, lastValueFrom, of, scan, takeWhile } from 'rxjs';

‎packages/golden-test-generator/package.json

+1
Original file line numberDiff line numberDiff line change
@@ -45,6 +45,7 @@
4545
"dependencies": {
4646
"@cardano-sdk/core": "workspace:~",
4747
"@cardano-sdk/ogmios": "workspace:~",
48+
"@cardano-sdk/projection": "workspace:~",
4849
"@cardano-sdk/util": "workspace:~",
4950
"@cardano-sdk/util-dev": "workspace:~",
5051
"bunyan": "^1.8.15",

‎packages/golden-test-generator/src/ChainSyncEvents/chainSyncEvents.ts

+2-1
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,5 @@
1-
import { Cardano, ChainSyncEventType, Intersection } from '@cardano-sdk/core';
1+
import { Cardano, Intersection } from '@cardano-sdk/core';
2+
import { ChainSyncEventType } from '@cardano-sdk/projection';
23
import { GeneratorMetadata } from '../Content';
34
import { Logger } from 'ts-log';
45
import { Ogmios, ogmiosToCore } from '@cardano-sdk/ogmios';

‎packages/golden-test-generator/src/tsconfig.json

+3
Original file line numberDiff line numberDiff line change
@@ -12,6 +12,9 @@
1212
},
1313
{
1414
"path": "../../util/src"
15+
},
16+
{
17+
"path": "../../projection/src"
1518
}
1619
]
1720
}

‎packages/ogmios/package.json

+1
Original file line numberDiff line numberDiff line change
@@ -58,6 +58,7 @@
5858
"@cardano-ogmios/schema": "6.5.0",
5959
"@cardano-sdk/core": "workspace:~",
6060
"@cardano-sdk/crypto": "workspace:~",
61+
"@cardano-sdk/projection": "workspace:~",
6162
"@cardano-sdk/util": "workspace:~",
6263
"backoff-rxjs": "^7.0.0",
6364
"buffer": "5.7.1",

‎packages/ogmios/src/CardanoNode/OgmiosObservableCardanoNode/OgmiosObservableCardanoNode.ts

+1-2
Original file line numberDiff line numberDiff line change
@@ -8,8 +8,6 @@ import {
88
GeneralCardanoNodeErrorCode,
99
HealthCheckResponse,
1010
Milliseconds,
11-
ObservableCardanoNode,
12-
ObservableChainSync,
1311
PointOrOrigin,
1412
StakeDistribution,
1513
StateQueryErrorCode
@@ -49,6 +47,7 @@ import {
4947
withCoreCardanoNodeError
5048
} from '../queries';
5149
import isEqual from 'lodash/isEqual.js';
50+
import type { ObservableCardanoNode, ObservableChainSync } from '@cardano-sdk/projection';
5251
import type { Serialization } from '@cardano-sdk/core';
5352

5453
const ogmiosToCoreIntersection = (intersection: ChainSynchronization.Intersection) => ({

‎packages/ogmios/src/CardanoNode/OgmiosObservableCardanoNode/createObservableChainSyncClient.ts

+2-8
Original file line numberDiff line numberDiff line change
@@ -1,12 +1,6 @@
1-
import {
2-
ChainSyncEvent,
3-
ChainSyncEventType,
4-
GeneralCardanoNodeError,
5-
GeneralCardanoNodeErrorCode,
6-
PointOrOrigin,
7-
RequestNext
8-
} from '@cardano-sdk/core';
1+
import { ChainSyncEvent, ChainSyncEventType, RequestNext } from '@cardano-sdk/projection';
92
import { ChainSynchronization, InteractionContext, Schema, safeJSON } from '@cardano-ogmios/client';
3+
import { GeneralCardanoNodeError, GeneralCardanoNodeErrorCode, PointOrOrigin } from '@cardano-sdk/core';
104
import { Logger } from 'ts-log';
115
import { Observable, Subscriber, from, switchMap } from 'rxjs';
126
import { WithLogger, toSerializableObject } from '@cardano-sdk/util';

‎packages/ogmios/src/tsconfig.json

+3
Original file line numberDiff line numberDiff line change
@@ -10,6 +10,9 @@
1010
{
1111
"path": "../../util-rxjs/src"
1212
},
13+
{
14+
"path": "../../projection/src"
15+
},
1316
{
1417
"path": "../../crypto/src"
1518
}

‎packages/projection-typeorm/src/TypeormStabilityWindowBuffer.ts

+8-2
Original file line numberDiff line numberDiff line change
@@ -1,10 +1,16 @@
11
/* eslint-disable @typescript-eslint/no-explicit-any */
22
import { BlockDataEntity } from './entity';
3-
import { Cardano, ChainSyncEventType } from '@cardano-sdk/core';
3+
import { Cardano } from '@cardano-sdk/core';
4+
import {
5+
ChainSyncEventType,
6+
ProjectionEvent,
7+
RollForwardEvent,
8+
StabilityWindowBuffer,
9+
WithNetworkInfo
10+
} from '@cardano-sdk/projection';
411
import { LessThan, QueryRunner } from 'typeorm';
512
import { Logger } from 'ts-log';
613
import { Observable, catchError, concatMap, from, map, of, switchMap, take } from 'rxjs';
7-
import { ProjectionEvent, RollForwardEvent, StabilityWindowBuffer, WithNetworkInfo } from '@cardano-sdk/projection';
814
import { ReconnectionConfig } from '@cardano-sdk/util-rxjs';
915
import { RetryBackoffConfig, retryBackoff } from 'backoff-rxjs';
1016
import { TypeormConnection } from './createDataSource';

‎packages/projection-typeorm/src/createTypeormTipTracker.ts

+2-2
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,9 @@
1-
import { BaseProjectionEvent } from '@cardano-sdk/projection';
1+
import { BaseProjectionEvent, ChainSyncEventType } from '@cardano-sdk/projection';
22
import { BlockEntity } from './entity';
3-
import { ChainSyncEventType, TipOrOrigin } from '@cardano-sdk/core';
43
import { Observable, ReplaySubject, from, map, of, switchMap, take, tap } from 'rxjs';
54
import { ReconnectionConfig } from '@cardano-sdk/util-rxjs';
65
import { RetryBackoffConfig, retryBackoff } from 'backoff-rxjs';
6+
import { TipOrOrigin } from '@cardano-sdk/core';
77
import { TypeormConnection } from './createDataSource';
88
import { isRecoverableTypeormError } from './isRecoverableTypeormError';
99

‎packages/projection-typeorm/src/operators/storeAddresses.ts

+2-2
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
import { AddressEntity } from '../entity/Address.entity';
2-
import { Cardano, ChainSyncEventType } from '@cardano-sdk/core';
2+
import { Cardano } from '@cardano-sdk/core';
3+
import { ChainSyncEventType, Mappers } from '@cardano-sdk/projection';
34
import { Hash28ByteBase16 } from '@cardano-sdk/crypto';
4-
import { Mappers } from '@cardano-sdk/projection';
55
import { QueryRunner } from 'typeorm';
66
import { StakeKeyRegistrationEntity } from '../entity';
77
import { certificatePointerToId, typeormOperator } from './util';

‎packages/projection-typeorm/src/operators/storeAssets.ts

+2-2
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
import { AssetEntity } from '../entity';
2-
import { Cardano, ChainSyncEventType } from '@cardano-sdk/core';
3-
import { Mappers } from '@cardano-sdk/projection';
2+
import { Cardano } from '@cardano-sdk/core';
3+
import { ChainSyncEventType, Mappers } from '@cardano-sdk/projection';
44
import { QueryRunner } from 'typeorm';
55
import { typeormOperator } from './util';
66

‎packages/projection-typeorm/src/operators/storeBlock.ts

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
import { BlockEntity } from '../entity';
2-
import { ChainSyncEventType } from '@cardano-sdk/core';
2+
import { ChainSyncEventType } from '@cardano-sdk/projection';
33
import { typeormOperator } from './util';
44

55
export const storeBlock = typeormOperator(async (evt) => {

‎packages/projection-typeorm/src/operators/storeGovernanceAction.ts

+2-2
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
1-
import { Cardano, ChainSyncEventType } from '@cardano-sdk/core';
1+
import { Cardano } from '@cardano-sdk/core';
2+
import { ChainSyncEventType, Mappers, ProjectionEvent } from '@cardano-sdk/projection';
23
import { GovernanceActionEntity } from '../entity';
3-
import { Mappers, ProjectionEvent } from '@cardano-sdk/projection';
44
import { typeormOperator } from './util';
55

66
export const willStoreGovernanceAction = (evt: ProjectionEvent<Mappers.WithGovernanceActions>) =>

‎packages/projection-typeorm/src/operators/storeHandleMetadata.ts

+1-2
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,5 @@
1-
import { ChainSyncEventType } from '@cardano-sdk/core';
1+
import { ChainSyncEventType, Mappers } from '@cardano-sdk/projection';
22
import { HandleMetadataEntity } from '../entity';
3-
import { Mappers } from '@cardano-sdk/projection';
43
import { WithStoredProducedUtxo } from './storeUtxo';
54
import { typeormOperator } from './util';
65

‎packages/projection-typeorm/src/operators/storeHandles.ts

+2-2
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
import { AssetEntity, HandleEntity, HandleMetadataEntity } from '../entity';
2-
import { Cardano, ChainSyncEventType, Handle } from '@cardano-sdk/core';
2+
import { Cardano, Handle } from '@cardano-sdk/core';
3+
import { ChainSyncEventType, Mappers } from '@cardano-sdk/projection';
34
import { In, QueryRunner } from 'typeorm';
4-
import { Mappers } from '@cardano-sdk/projection';
55
import { WithMintedAssetSupplies } from './storeAssets';
66
import { typeormOperator } from './util';
77
import sortBy from 'lodash/sortBy.js';

‎packages/projection-typeorm/src/operators/storeNftMetadata.ts

+2-2
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
1-
import { Asset, Cardano, ChainSyncEventType } from '@cardano-sdk/core';
1+
import { Asset, Cardano } from '@cardano-sdk/core';
22
import { AssetEntity, NftMetadataEntity, NftMetadataType } from '../entity';
3-
import { Mappers, ProjectionEvent } from '@cardano-sdk/projection';
3+
import { ChainSyncEventType, Mappers, ProjectionEvent } from '@cardano-sdk/projection';
44
import { Repository } from 'typeorm';
55
import { typeormOperator } from './util';
66

‎packages/projection-typeorm/src/operators/storePoolMetricsUpdateJob.ts

+2-1
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,5 @@
1-
import { Cardano, ChainSyncEventType } from '@cardano-sdk/core';
1+
import { Cardano } from '@cardano-sdk/core';
2+
import { ChainSyncEventType } from '@cardano-sdk/projection';
23
import { STAKE_POOL_METRICS_UPDATE } from '../pgBoss';
34
import { WithPgBoss } from './withTypeormTransaction';
45
import { typeormOperator } from './util';

‎packages/projection-typeorm/src/operators/storeStakeKeyRegistrations.ts

+1-2
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,4 @@
1-
import { ChainSyncEventType } from '@cardano-sdk/core';
2-
import { Mappers } from '@cardano-sdk/projection';
1+
import { ChainSyncEventType, Mappers } from '@cardano-sdk/projection';
32
import { StakeKeyRegistrationEntity } from '../entity';
43
import { certificatePointerToId, typeormOperator } from './util';
54

‎packages/projection-typeorm/src/operators/storeStakePoolMetadataJob.ts

+1-2
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,4 @@
1-
import { ChainSyncEventType } from '@cardano-sdk/core';
2-
import { Mappers } from '@cardano-sdk/projection';
1+
import { ChainSyncEventType, Mappers } from '@cardano-sdk/projection';
32
import { STAKE_POOL_METADATA_QUEUE, StakePoolMetadataJob, defaultJobOptions } from '../pgBoss';
43
import { WithPgBoss } from './withTypeormTransaction';
54
import { certificatePointerToId, typeormOperator } from './util';

‎packages/projection-typeorm/src/operators/storeStakePoolRewardsJob.ts

+2-1
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,5 @@
1-
import { Cardano, ChainSyncEventType } from '@cardano-sdk/core';
1+
import { Cardano } from '@cardano-sdk/core';
2+
import { ChainSyncEventType } from '@cardano-sdk/projection';
23
import { STAKE_POOL_REWARDS, defaultJobOptions } from '../pgBoss';
34
import { WithPgBoss } from './withTypeormTransaction';
45
import { typeormOperator } from './util';

‎packages/projection-typeorm/src/operators/storeStakePools.ts

+2-2
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
1-
import { Cardano, ChainSyncEventType, EraSummary, epochSlotsCalc } from '@cardano-sdk/core';
1+
import { Cardano, EraSummary, epochSlotsCalc } from '@cardano-sdk/core';
2+
import { ChainSyncEventType, Mappers, ProjectionEvent } from '@cardano-sdk/projection';
23
import { In, Not, QueryRunner, Repository } from 'typeorm';
3-
import { Mappers, ProjectionEvent } from '@cardano-sdk/projection';
44
import {
55
MaxCertificatePointerIdCertificateIndex as MaxCertificatePointerIdCertIndex,
66
MaxCertificatePointerIdTxIndex,

‎packages/projection-typeorm/src/operators/storeUtxo.ts

+2-2
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
1-
import { Cardano, ChainSyncEventType, Serialization } from '@cardano-sdk/core';
2-
import { Mappers } from '@cardano-sdk/projection';
1+
import { Cardano, Serialization } from '@cardano-sdk/core';
2+
import { ChainSyncEventType, Mappers } from '@cardano-sdk/projection';
33
import { ObjectLiteral } from 'typeorm';
44
import { OutputEntity, TokensEntity } from '../entity';
55
import { typeormOperator } from './util';

‎packages/projection-typeorm/test/TypeormStabilityWindowBuffer.test.ts

+2-2
Original file line numberDiff line numberDiff line change
@@ -6,9 +6,9 @@ import {
66
createObservableConnection,
77
willStoreBlockData
88
} from '../src';
9-
import { Cardano, ChainSyncEventType } from '@cardano-sdk/core';
9+
import { Cardano } from '@cardano-sdk/core';
10+
import { ChainSyncEventType, ProjectionEvent } from '@cardano-sdk/projection';
1011
import { DataSource, NoConnectionForRepositoryError, QueryRunner, Repository } from 'typeorm';
11-
import { ProjectionEvent } from '@cardano-sdk/projection';
1212
import { connectionConfig$, createBlockEntity, createBlockHeader, initializeDataSource } from './util';
1313
import { createStubObservable, logger } from '@cardano-sdk/util-dev';
1414
import { firstValueFrom, of, throwError } from 'rxjs';

‎packages/projection-typeorm/test/createTypeormTipTracker.test.ts

+2-2
Original file line numberDiff line numberDiff line change
@@ -1,12 +1,12 @@
1-
import { BaseProjectionEvent } from '@cardano-sdk/projection';
1+
import { BaseProjectionEvent, ChainSyncEventType } from '@cardano-sdk/projection';
22
import {
33
BlockEntity,
44
TypeormConnection,
55
TypeormTipTracker,
66
createObservableConnection,
77
createTypeormTipTracker
88
} from '../src';
9-
import { Cardano, ChainSyncEventType } from '@cardano-sdk/core';
9+
import { Cardano } from '@cardano-sdk/core';
1010
import { DataSource, NoConnectionForRepositoryError, QueryRunner, Repository } from 'typeorm';
1111
import { Observable, firstValueFrom, of, throwError } from 'rxjs';
1212
import { RetryBackoffConfig } from 'backoff-rxjs';

‎packages/projection-typeorm/test/operators/storeAssets.test.ts

+2-2
Original file line numberDiff line numberDiff line change
@@ -12,8 +12,8 @@ import {
1212
willStoreAssets,
1313
withTypeormTransaction
1414
} from '../../src';
15-
import { Bootstrap, Mappers, requestNext } from '@cardano-sdk/projection';
16-
import { Cardano, ChainSyncEventType } from '@cardano-sdk/core';
15+
import { Bootstrap, ChainSyncEventType, Mappers, requestNext } from '@cardano-sdk/projection';
16+
import { Cardano } from '@cardano-sdk/core';
1717
import { ChainSyncDataSet, chainSyncData, logger } from '@cardano-sdk/util-dev';
1818
import { Mint } from '@cardano-sdk/projection/dist/cjs/operators/Mappers';
1919
import { QueryRunner } from 'typeorm';

‎packages/projection-typeorm/test/operators/storeGovernanceAction.test.ts

+2-2
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
import { BlockEntity, GovernanceActionEntity } from '../../src';
2-
import { Cardano, ChainSyncEventType } from '@cardano-sdk/core';
2+
import { Cardano } from '@cardano-sdk/core';
3+
import { ChainSyncEventType, Mappers, ProjectionEvent } from '@cardano-sdk/projection';
34
import { DataSource, QueryRunner } from 'typeorm';
4-
import { Mappers, ProjectionEvent } from '@cardano-sdk/projection';
55
import { WithTypeormContext, storeBlock, storeGovernanceAction } from '../../src/operators';
66
import { firstValueFrom, of } from 'rxjs';
77
import { initializeDataSource } from '../util';

‎packages/projection-typeorm/test/operators/storeHandleMetadata.test.ts

+2-2
Original file line numberDiff line numberDiff line change
@@ -17,8 +17,8 @@ import {
1717
willStoreHandleMetadata,
1818
withTypeormTransaction
1919
} from '../../src';
20-
import { Bootstrap, Mappers, ProjectionEvent, requestNext } from '@cardano-sdk/projection';
21-
import { Cardano, ObservableCardanoNode } from '@cardano-sdk/core';
20+
import { Bootstrap, Mappers, ObservableCardanoNode, ProjectionEvent, requestNext } from '@cardano-sdk/projection';
21+
import { Cardano } from '@cardano-sdk/core';
2222
import { ChainSyncDataSet, chainSyncData, logger } from '@cardano-sdk/util-dev';
2323
import { HandleMetadata } from '@cardano-sdk/projection/dist/cjs/operators/Mappers';
2424
import { Observable, firstValueFrom } from 'rxjs';

‎packages/projection-typeorm/test/operators/storeHandles/general.test.ts

+2-1
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,6 @@
1-
import { Asset, Cardano, ChainSyncEventType } from '@cardano-sdk/core';
1+
import { Asset, Cardano } from '@cardano-sdk/core';
22
import { AssetEntity, HandleEntity, OutputEntity, willStoreHandles } from '../../../src';
3+
import { ChainSyncEventType } from '@cardano-sdk/projection';
34
import { HandleOwnership } from '@cardano-sdk/projection/dist/cjs/operators/Mappers';
45
import { ProjectorContext, createProjectorContext } from '../util';
56
import { QueryRunner } from 'typeorm';

0 commit comments

Comments
 (0)