fix: update protobufjs to the latest version and add dependencies to …

…protobufjs in the proto file

examples/basic-example-v1-with-table-service/index.ts

@@ -224,7 +224,7 @@ async function selectPrepared(session: Session, data: ThreeIds[], logger: Logger
                 '$episodeId': episode.getTypedValue('episodeId')
             });
             const result = Series.createNativeObjects(resultSets[0]);
-            logger.info(`Select prepared query ${JSON.stringify(result, null, 2)}`);
+            logger.info(`Parametrized select query ${JSON.stringify(result, null, 2)}`);
         }
     }
     await withRetries(select);

examples/basic-example-v2-with-query-service/index.ts

@@ -165,7 +165,7 @@ async function selectWithParameters(driver: Driver, data: ThreeIds[], logger: Lo
                 const {value: resultSet} = await resultSets.next();
                 const {value: row} = await resultSet.rows.next();
                 await opFinished;
-                logger.info(`Select prepared query ${JSON.stringify(row, null, 2)}`);
+                logger.info(`Parametrized select query ${JSON.stringify(row, null, 2)}`);
             }
         }
     });

examples/url-shortener/database.ts

@@ -53,18 +53,17 @@ VALUES ($shortenUrl, $sourceUrl);`;
     return shortenUrl;
 }
 
-
 export async function selectSource(
     shortenUrl: string,
     session: Session,
     logger: Logger): Promise<string> {
     const query = `
     ${SYNTAX_V1}
-    DECLARE $shortenUrl as Utf8;
+DECLARE $shortenUrl as Utf8;
 
-    SELECT *
-    FROM ${URLS_TABLE}
-    WHERE shorten = $shortenUrl;`;
+SELECT *
+FROM ${URLS_TABLE}
+WHERE shorten = $shortenUrl;`;
 
     async function execute() : Promise<string> {
         logger.info('Preparing query...');
@@ -75,7 +74,7 @@ export async function selectSource(
             '$shortenUrl': requestSourceUrl.getTypedValue('shorten')
         });
         const result = UrlsMatch.createNativeObjects(resultSets[0]);
-        logger.info('Select prepared query', result);
+        logger.info('Parametrized select query', result);
         if (result.length == 0) {
             return '';
         } else {

package.json

@@ -43,7 +43,7 @@
     "reflect-metadata": "^0.1.13",
     "typed-emitter": "^2.1.0",
     "uuid": "^8.3.2",
-    "ydb-sdk-proto": "^1.1.0"
+    "ydb-sdk-proto": "^1.2.5"
   },
   "devDependencies": {
     "@commitlint/cli": "^17.6.1",

src/topic/topic-client.ts

@@ -26,7 +26,6 @@ export type ICreateReaderArgs = {
     }[];
     consumer?: (string|null);
     readerName?: (string|null);
-
 }
 export type ICommitOffsetArgs = {
     path: (string|null);