From 544a9ee5ee822ed23e35b98bfbb2ed253c7fd374 Mon Sep 17 00:00:00 2001
From: Alexey Zorkaltsev <azorkaltsev@yandex-team.com>
Date: Wed, 25 Sep 2024 19:55:50 +0300
Subject: [PATCH] chore: fix tests

---
 src/errors.ts                      | 7 +++----
 src/query/query-session-attach.ts  | 1 -
 src/query/query-session-execute.ts | 1 -
 src/retries_obsoleted.ts           | 1 -
 4 files changed, 3 insertions(+), 7 deletions(-)

diff --git a/src/errors.ts b/src/errors.ts
index b2f0e08c..501c53a0 100644
--- a/src/errors.ts
+++ b/src/errors.ts
@@ -98,7 +98,7 @@ export class YdbError extends Error {
             throw new MissingStatus('Missing status!');
         }
 
-        if (operation.issues) operation.issues = YdbError.flatIssues(operation.issues);
+        // if (operation.issues) operation.issues = YdbError.flatIssues(operation.issues);
 
         const status = operation.status as unknown as StatusCode;
         if (operation.status && !SUCCESS_CODES.has(status)) {
@@ -107,7 +107,8 @@ export class YdbError extends Error {
             if (!ErrCls) {
                 throw new Error(`Unexpected status code ${status}!`);
             } else {
-                throw new ErrCls(`${ErrCls.name} (code ${status}): ${YdbError.formatIssues(operation.issues)}`, operation.issues);
+                console.info(1000, JSON.stringify(operation, null, 2));
+                throw new ErrCls(`${ErrCls.name} (code ${status}): ${operation.issues}`, operation.issues);
             }
         }
     }
@@ -284,8 +285,6 @@ export class TransportError extends YdbError {
 
     static convertToYdbError(e: Error & GrpcStatusObject): Error {
 
-        console.info(1000, JSON.stringify(e, null, 2));
-
         const ErrCls = TRANSPORT_ERROR_CODES.get(e.code);
 
         if (!ErrCls) {
diff --git a/src/query/query-session-attach.ts b/src/query/query-session-attach.ts
index 9605c21b..2deaf0c7 100644
--- a/src/query/query-session-attach.ts
+++ b/src/query/query-session-attach.ts
@@ -40,7 +40,6 @@ export async function attach(this:QuerySession, onStreamClosed: () => void) {
                 // delete this[attachStream]; // uncomment when reattach policy will be implemented
                 onStreamClosed();
             } else {
-                console.info(2000, JSON.stringify(err, null, 2));
                 reject(TransportError.convertToYdbError(err));
             }
         });
diff --git a/src/query/query-session-execute.ts b/src/query/query-session-execute.ts
index cd4cd144..f8a8191f 100644
--- a/src/query/query-session-execute.ts
+++ b/src/query/query-session-execute.ts
@@ -262,7 +262,6 @@ export function execute(this: QuerySession, opts: {
     responseStream.on('error', (err: Error & GrpcStatusObject) => {
         this.logger.trace('execute(): error: %o', err);
         if (err.code === 1) return; // skip "cancelled" error
-        console.info(3000, JSON.stringify(err, null, 2));
         cancel(TransportError.convertToYdbError(err), true);
     });
 
diff --git a/src/retries_obsoleted.ts b/src/retries_obsoleted.ts
index d57418e9..d27de982 100644
--- a/src/retries_obsoleted.ts
+++ b/src/retries_obsoleted.ts
@@ -77,7 +77,6 @@ class RetryStrategy {
             try {
                 return await asyncMethod();
             } catch (e) {
-                console.info(4000, JSON.stringify(e, null, 2));
                 if(TransportError.isMember(e)) e = TransportError.convertToYdbError(e)
                 error = e;
                 if (e instanceof YdbError) {