Take out shared code that works with YDB sessions

CHANGELOG.md

@@ -286,7 +286,7 @@ All notable changes to this project will be documented in this file. See [standa
     - decimal value is present as string instead of bigint
       (it wasn't working for float values before)
     - fix uuid and tz-date types conversion (it wasn't working before)
-* signatures of most methods in Session are changed:
+* signatures of most methods in TableSession are changed:
     - executeQuery
       Before: `(query, params, txControl, operationParams?, settings?, collectStats?)`
       After: `(query, params, txControl, settings?)`
@@ -336,7 +336,7 @@ All notable changes to this project will be documented in this file. See [standa
 
 * drop support of old environment variables ([963819a](https://www.github.com/ydb-platform/ydb-nodejs-sdk/commit/963819af9209a45749f5118077f1da4bdb390fa6))
 * reorganize signature of SchemeClient's methods ([734d57a](https://www.github.com/ydb-platform/ydb-nodejs-sdk/commit/734d57a2dd7c655cf727b96df415212504339cf8))
-* reorganize signatures of Session's methods ([431f149](https://www.github.com/ydb-platform/ydb-nodejs-sdk/commit/431f1491bf880f3ba9541d9455d8dd2f2b7849e6))
+* reorganize signatures of TableSession's methods ([431f149](https://www.github.com/ydb-platform/ydb-nodejs-sdk/commit/431f1491bf880f3ba9541d9455d8dd2f2b7849e6))
 * use identity names conversion in TypedData ([275598a](https://www.github.com/ydb-platform/ydb-nodejs-sdk/commit/275598aa444e1e977386a3dadd02bbc9ba01f38e))
 
 ### [2.9.2](https://www.github.com/ydb-platform/ydb-nodejs-sdk/compare/v2.9.1...v2.9.2) (2022-02-09)
@@ -431,7 +431,7 @@ All notable changes to this project will be documented in this file. See [standa
 * and many other changes in protobufs.
 
 ### 1.10.0
-* Add `alterTable` method to Session class
+* Add `alterTable` method to TableSession class
 * Put compiled protobufs to a separate 'ydb-sdk' namespace
 
 ### 1.9.0

src/__tests__/alter-table.test.ts

@@ -4,11 +4,11 @@ import {
     AlterTableDescription,
     AlterTableSettings,
     Column,
-    OperationParams,
     TableDescription,
     TableIndex,
-} from '../table';
+} from '../table/table-client';
 import { Types } from '../types';
+import {OperationParams} from "../table/session";
 
 const getTableName = () => `table_alter_${Math.trunc(1000 * Math.random())}`;
 

src/__tests__/bulk-upsert.test.ts

@@ -7,10 +7,10 @@ import {
     Row,
     TABLE
 } from '../test-utils';
-import {Session} from '../table';
+import {TableSession} from '../table/table-client';
 import {Ydb} from 'ydb-sdk-proto';
 
-async function readTable(session: Session): Promise<Row[]> {
+async function readTable(session: TableSession): Promise<Row[]> {
     const rows: Row[] = [];
 
     await session.streamReadTable(TABLE, (result) => {

src/__tests__/bytestring-identity.test.ts

@@ -1,10 +1,10 @@
 import Driver from '../driver';
 import {destroyDriver, initDriver, TABLE} from '../test-utils';
-import {Column, Session, TableDescription} from '../table';
+import {Column, TableSession, TableDescription} from '../table/table-client';
 import {declareType, TypedData, Types} from '../types';
 import {withRetries} from '../retries';
 
-async function createTable(session: Session) {
+async function createTable(session: TableSession) {
     await session.dropTable(TABLE);
     await session.createTable(
         TABLE,
@@ -46,7 +46,7 @@ class Row extends TypedData {
     }
 }
 
-export async function fillTableWithData(session: Session, rows: Row[]) {
+export async function fillTableWithData(session: TableSession, rows: Row[]) {
     const query = `
 DECLARE $data AS List<Struct<id: Uint64, field1: Text, field2: String, field3: Yson>>;
 

src/__tests__/create-table.test.ts

@@ -1,6 +1,6 @@
 import Driver from '../driver';
 import {destroyDriver, initDriver} from '../test-utils';
-import {Column, DescribeTableSettings, TableDescription} from '../table';
+import {Column, DescribeTableSettings, TableDescription} from '../table/table-client';
 import {TypedValues, Types} from '../types';
 import Long from 'long';
 import {Ydb} from 'ydb-sdk-proto';

src/__tests__/read-table.test.ts

@@ -7,10 +7,10 @@ import {
     Row,
     TABLE
 } from '../test-utils';
-import {ReadTableSettings, Session} from '../table';
+import {ReadTableSettings, TableSession} from '../table/table-client';
 import {TypedValues, TypedData} from '../types';
 
-async function readTable(session: Session, settings: ReadTableSettings): Promise<TypedData[]> {
+async function readTable(session: TableSession, settings: ReadTableSettings): Promise<TypedData[]> {
     const rows: TypedData[] = [];
 
     await session.streamReadTable(TABLE, (result) => {

src/__tests__/scan-query.test.ts

@@ -7,10 +7,10 @@ import {
     initDriver,
     Row,
 } from '../test-utils';
-import {Session} from '../table';
+import {TableSession} from '../table/table-client';
 import {TypedData} from '../types';
 
-async function executeScanQuery(session: Session): Promise<TypedData[]> {
+async function executeScanQuery(session: TableSession): Promise<TypedData[]> {
     const query = `SELECT * FROM ${TABLE};`;
 
     const rows: TypedData[] = [];

src/driver.ts

@@ -1,5 +1,5 @@
 import DiscoveryService from './discovery';
-import {TableClient} from './table';
+import {TableClient} from './table/table-client';
 import SchemeService from './scheme';
 import {ENDPOINT_DISCOVERY_PERIOD} from './constants';
 import {IAuthService} from './credentials';

src/index.ts

@@ -26,14 +26,10 @@ export {
     StringFunction,
 } from './types';
 export {
-    SessionPool,
-    Session,
+    TableSession,
     CreateTableSettings,
     AlterTableSettings,
     DropTableSettings,
-    BeginTransactionSettings,
-    CommitTransactionSettings,
-    RollbackTransactionSettings,
     DescribeTableSettings,
     PrepareQuerySettings,
     ExecuteQuerySettings,
@@ -54,9 +50,8 @@ export {
     CompactionPolicy,
     ExecutionPolicy,
     CachingPolicy,
-    OperationParams,
-    AUTO_TX,
-} from './table';
+
+} from './table/table-client';
 export {
     MakeDirectorySettings,
     RemoveDirectorySettings,
@@ -78,3 +73,9 @@ export {
 export {ISslCredentials} from './ssl-credentials';
 export {withRetries, RetryParameters} from './retries';
 export {YdbError, StatusCode} from './errors';
+export {SessionPool} from "./table/session-pool";
+export {RollbackTransactionSettings} from "./table/session";
+export {CommitTransactionSettings} from "./table/session";
+export {BeginTransactionSettings} from "./table/session";
+export {OperationParams} from "./table/session";
+export {AUTO_TX} from "./table/session";

src/scheme.ts

@@ -12,7 +12,6 @@ import {Logger} from './logging';
 import DiscoveryService, {Endpoint} from './discovery';
 import {retryable} from "./retries";
 import {ISslCredentials} from './ssl-credentials';
-import {OperationParamsSettings} from './table';
 
 import SchemeServiceAPI = Ydb.Scheme.V1.SchemeService;
 import ListDirectoryResult = Ydb.Scheme.ListDirectoryResult;
@@ -22,6 +21,7 @@ import IMakeDirectoryRequest = Ydb.Scheme.IMakeDirectoryRequest;
 import IPermissions = Ydb.Scheme.IPermissions;
 import {util} from "protobufjs";
 import EventEmitter = util.EventEmitter;
+import {OperationParamsSettings} from "./table/session";
 
 
 function preparePermissions(action?: IPermissions | null) {

src/table/index.ts

@@ -0,0 +1,3 @@
+export * from './session-pool';
+export * from './session';
+export * from './table-client';