fix: imports

hirosystems · Jan 6, 2025 · 82600b6 · 82600b6
1 parent bdf5c91
commit 82600b6
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/src/event-replay/parquet-based/importers/attachment-new-importer.ts b/src/event-replay/parquet-based/importers/attachment-new-importer.ts
@@ -4,7 +4,7 @@
 import { Readable, Writable } from 'stream';
 import { pipeline } from 'stream/promises';
 import { PgWriteStore } from '../../../datastore/pg-write-store';
-import { parseAttachment } from '../../../event-stream/event-server';
+import { parseAttachment } from '../../../event-stream/event-message-handler';
 import { logger } from '../../../logger';
 import { CoreNodeAttachmentMessage } from '../../../event-stream/core-node-message';
 import { DataStoreAttachmentSubdomainData } from '../../../datastore/common';

diff --git a/src/event-replay/parquet-based/importers/new-block-importer.ts b/src/event-replay/parquet-based/importers/new-block-importer.ts
@@ -1,7 +1,6 @@
 import { Readable, Writable, Transform } from 'stream';
 import { pipeline } from 'stream/promises';
 import { PgWriteStore } from '../../../datastore/pg-write-store';
-import { parseNewBlockMessage } from '../../../event-stream/event-server';
 import {
   DbBlock,
   DbMicroblock,
@@ -21,6 +20,7 @@ import { getApiConfiguredChainID } from '../../../helpers';
 import { CoreNodeBlockMessage } from '../../../event-stream/core-node-message';
 import { DatasetStore } from '../dataset/store';
 import { batchIterate } from '@hirosystems/api-toolkit';
+import { parseNewBlockMessage } from '../../../event-stream/event-message-handler';
 
 const chainID = getApiConfiguredChainID();
 

diff --git a/tests/api/synthetic-stx-txs.test.ts b/tests/api/synthetic-stx-txs.test.ts
@@ -4,7 +4,7 @@ import * as path from 'path';
 import { DecodedTxResult, TxPayloadTypeID } from 'stacks-encoding-native-js';
 import { CoreNodeBlockMessage } from '../../src/event-stream/core-node-message';
 import { parseMessageTransaction } from '../../src/event-stream/reader';
-import { parseNewBlockMessage } from '../../src/event-stream/event-server';
+import { parseNewBlockMessage } from '../../src/event-stream/event-message-handler';
 
 // Test processing of the psuedo-Stacks transactions, i.e. the ones that
 // originate on the Bitcoin chain, and have a `raw_tx == '0x00'.