refactor: introduce TX type for transaction management and update imports across writer modules

Signed-off-by: Vladislav Polyakov <[email protected]>

Author: polRk

packages/topic/src/index.ts

@@ -1,8 +1,8 @@
 import { Driver } from "@ydbjs/core";
 
 import { TopicReader, type TopicReaderOptions } from "./reader.js";
+import type { TX } from "./tx.js";
 import { type TopicWriter, type TopicWriterOptions, createTopicTxWriter, createTopicWriter } from "./writer/index.js";
-import type { TX } from "./writer/tx.js";
 
 export interface TopicClient {
 	createReader(options: TopicReaderOptions): TopicReader;

packages/topic/src/writer/tx.ts renamed to packages/topic/src/tx.ts

@@ -1,10 +1,10 @@
 import type { StreamWriteMessage_FromClient, StreamWriteMessage_WriteRequest_MessageData } from "@ydbjs/api/topic";
 import type { CompressionCodec } from "../codec.js";
 import type { PQueue } from "../queue.js";
+import type { TX } from "../tx.js";
 import { _batch_messages } from "./_batch_messages.js";
 import { _emit_write_request } from "./_write_request.js";
 import { MAX_INFLIGHT_COUNT } from "./constants.js";
-import type { TX } from "./tx.js";
 
 export function _flush(ctx: {
 	readonly tx?: TX

packages/topic/src/writer/_flush.ts

@@ -1,8 +1,8 @@
 import type { StreamWriteMessage_FromClient, StreamWriteMessage_InitResponse, StreamWriteMessage_WriteRequest_MessageData } from "@ydbjs/api/topic";
 import type { CompressionCodec } from "../codec.js";
 import type { PQueue } from "../queue.js";
+import type { TX } from "../tx.js";
 import { _flush } from "./_flush.js";
-import type { TX } from "./tx.js";
 
 export function _on_init_response(ctx: {
 	readonly tx?: TX

packages/topic/src/writer/_init_reponse.ts

@@ -3,9 +3,9 @@ import { timestampFromDate } from "@bufbuild/protobuf/wkt";
 import { type StreamWriteMessage_FromClient, type StreamWriteMessage_WriteRequest_MessageData, StreamWriteMessage_WriteRequest_MessageDataSchema } from "@ydbjs/api/topic";
 import type { CompressionCodec } from "../codec.js";
 import type { PQueue } from "../queue.js";
+import type { TX } from "../tx.js";
 import { _flush } from "./_flush.js";
 import { MAX_PAYLOAD_SIZE } from "./constants.js";
-import type { TX } from "./tx.js";
 
 export function _write(ctx: {
 	readonly tx?: TX

packages/topic/src/writer/_write.ts

@@ -2,7 +2,7 @@ import { create } from "@bufbuild/protobuf";
 import { Codec, type StreamWriteMessage_FromClient, StreamWriteMessage_FromClientSchema, type StreamWriteMessage_WriteRequest_MessageData } from "@ydbjs/api/topic";
 import { type CompressionCodec } from "../codec.js";
 import type { PQueue } from "../queue.js";
-import type { TX } from "./tx.js";
+import type { TX } from "../tx.js";
 
 export function _emit_write_request(ctx: {
 	readonly tx?: TX

packages/topic/src/writer/_write_request.ts

@@ -1,8 +1,8 @@
 import type { StreamWriteMessage_FromClient, StreamWriteMessage_WriteRequest_MessageData, StreamWriteMessage_WriteResponse } from "@ydbjs/api/topic";
 import type { CompressionCodec } from "../codec.js";
 import type { PQueue } from "../queue.js";
+import type { TX } from "../tx.js";
 import { _flush } from "./_flush.js";
-import type { TX } from "./tx.js";
 
 export function _on_write_response(ctx: {
 	readonly tx?: TX

packages/topic/src/writer/_write_response.ts

@@ -10,6 +10,7 @@ import debug from "debug";
 
 import { type CompressionCodec, defaultCodecMap } from "../codec.js";
 import { PQueue } from "../queue.js";
+import type { TX } from "../tx.js";
 import { _flush } from "./_flush.js";
 import { _get_producer_id } from "./_gen_producer_id.js";
 import { _on_init_response } from "./_init_reponse.js";
@@ -18,7 +19,6 @@ import { _send_update_token_request } from "./_update_token.js";
 import { _write } from "./_write.js";
 import { _on_write_response } from "./_write_response.js";
 import { MAX_BUFFER_SIZE } from "./constants.js";
-import type { TX } from "./tx.js";
 
 export type TopicWriterOptions = {
 	// Transaction identity.