chore: added processing of deleteSession into Query service

Author: Alexey Zorkaltsev

src/__tests__/e2e/query-service/query-service-client.ts

@@ -60,7 +60,7 @@ describe('Query client', () => {
                 expect(session.txId).toBeDefined();
 
                 // force new attempt
-                if (count < 3) throw new errors.Unavailable('test'); // an fast backoff error
+                if (count < 3) throw new errors.Aborted('test'); // an fast backoff error
 
                 res = await session.execute({
                     txControl: {commitTx: true},
@@ -117,7 +117,7 @@ describe('Query client', () => {
                 expect(session.txId).toBeDefined();
 
                 // force new attempt
-                if (count < 2) throw new errors.Unavailable('test'); // an fast backoff error
+                if (count < 2) throw new errors.Aborted('test'); // an fast backoff error
 
                 await expect(async () =>
                     await session.commitTransaction()

src/errors.ts

@@ -175,7 +175,8 @@ export class Aborted extends YdbError {
 
 export class Unavailable extends YdbError {
     static status = StatusCode.UNAVAILABLE;
-    public readonly [RetryPolicySymbol] =  retryPolicy(Backoff.Fast, false, true, true);
+    // TODO: Requires extra logic - see https://github.com/ydb-platform/ydb-go-sdk/blob/e1ba79620427a66c1564a52abe7e1ff10787d442/retry/errors_data_test.go#L197
+    public readonly [RetryPolicySymbol] =  retryPolicy(Backoff.Fast, false, true, false);
 }
 
 export class Overloaded extends YdbError {

src/query/query-client.ts

@@ -21,6 +21,7 @@ import {ensureContext} from "../context";
 import {Logger} from "../logger/simple-logger";
 import {RetryStrategy} from "../retries/retryStrategy";
 import {RetryParameters} from "../retries/retryParameters";
+import {RetryPolicySymbol} from "../retries/symbols";
 
 export interface IQueryClientSettings {
     database: string;
@@ -78,7 +79,7 @@ export class QueryClient extends EventEmitter {
                         session[isIdempotentDoLevelSymbol] = true;
                         session[isIdempotentSymbol] = opts.idempotent;
                     }
-                    let error;
+                    let error: Error;
                     try {
                         if (opts.txSettings) session[sessionTxSettingsSymbol] = opts.txSettings;
                         let res: T;
@@ -101,15 +102,16 @@ export class QueryClient extends EventEmitter {
                         }
                         return {result: res};
                     } catch (err) {
-                        error = err;
-                        return {err: err as Error, idempotent: session[isIdempotentSymbol]}
+                        error = err as Error;
+                        return {err: error, idempotent: session[isIdempotentSymbol]}
                     } finally {
                         delete session[ctxSymbol];
                         delete session[sessionTxSettingsSymbol];
                         delete session[sessionCurrentOperationSymbol];
                         delete session[isIdempotentDoLevelSymbol];
                         delete session[isIdempotentSymbol];
-                        if (error instanceof BadSession || error instanceof SessionBusy) {
+                        // @ts-ignore
+                        if (error && (error as any)[RetryPolicySymbol]?.deleteSession) {
                             this.logger.debug('Encountered bad or busy session, re-creating the session');
                             session.emit(SessionEvent.SESSION_BROKEN);
                         } else {