ydb-sdk - npm Package Compare versions

Comparing version 3.4.4 to 3.5.0

build/cjs/package.json

 {
-    "version": "3.4.3"
+    "version": "3.4.4"
 }

build/cjs/src/discovery.d.ts

@@ -1,2 +0,1 @@
-/// <reference types="pino" />
 import { Ydb } from "ydb-sdk-proto";
@@ -3,0 +2,0 @@ import { AuthenticatedService } from "./utils";

build/cjs/src/driver.d.ts

@@ -1,2 +0,1 @@
-/// <reference types="pino" />
 import { TableClient } from "./table";
@@ -3,0 +2,0 @@ import SchemeService from "./scheme";

build/cjs/src/index.d.ts

 export { Ydb } from 'ydb-sdk-proto';
-export { default as getLogger, Logger } from './logging';
+export { default as getLogger, setDefaultLogger, Logger, LogFn } from './logging';
 export { default as Driver, IDriverSettings, IPoolSettings } from './driver';
@@ -4,0 +4,0 @@ export { declareType, StructFields, Types, TypedValues, TypedData, TypedDataOptions, withTypeOptions, NamesConversion, snakeToCamelCaseConversion, identityConversion, primitiveTypeToValue, typeMetadataKey, getNameConverter, StringFunction } from './types';

build/cjs/src/index.js

@@ -6,4 +6,4 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.getSACredentialsFromJson = exports.getCredentialsFromEnv = exports.ModifyPermissionsSettings = exports.DescribePathSettings = exports.ListDirectorySettings = exports.RemoveDirectorySettings = exports.MakeDirectorySettings = exports.AUTO_TX = exports.OperationParams = exports.CachingPolicy = exports.ExecutionPolicy = exports.CompactionPolicy = exports.ReplicationPolicy = exports.PartitioningPolicy = exports.ExplicitPartitions = exports.StoragePolicy = exports.ColumnFamilyPolicy = exports.StorageSettings = exports.TableIndex = exports.TableProfile = exports.Column = exports.AlterTableDescription = exports.TableDescription = exports.BulkUpsertSettings = exports.ReadTableSettings = exports.ExecuteScanQuerySettings = exports.ExecuteQuerySettings = exports.PrepareQuerySettings = exports.DescribeTableSettings = exports.RollbackTransactionSettings = exports.CommitTransactionSettings = exports.BeginTransactionSettings = exports.DropTableSettings = exports.AlterTableSettings = exports.CreateTableSettings = exports.Session = exports.SessionPool = exports.getNameConverter = exports.typeMetadataKey = exports.primitiveTypeToValue = exports.identityConversion = exports.snakeToCamelCaseConversion = exports.withTypeOptions = exports.TypedData = exports.TypedValues = exports.Types = exports.declareType = exports.Driver = exports.getLogger = exports.Ydb = void 0;
-exports.StatusCode = exports.YdbError = exports.RetryParameters = exports.withRetries = exports.MetadataAuthService = exports.TokenAuthService = exports.IamAuthService = exports.AnonymousAuthService = exports.parseConnectionString = void 0;
+exports.getCredentialsFromEnv = exports.ModifyPermissionsSettings = exports.DescribePathSettings = exports.ListDirectorySettings = exports.RemoveDirectorySettings = exports.MakeDirectorySettings = exports.AUTO_TX = exports.OperationParams = exports.CachingPolicy = exports.ExecutionPolicy = exports.CompactionPolicy = exports.ReplicationPolicy = exports.PartitioningPolicy = exports.ExplicitPartitions = exports.StoragePolicy = exports.ColumnFamilyPolicy = exports.StorageSettings = exports.TableIndex = exports.TableProfile = exports.Column = exports.AlterTableDescription = exports.TableDescription = exports.BulkUpsertSettings = exports.ReadTableSettings = exports.ExecuteScanQuerySettings = exports.ExecuteQuerySettings = exports.PrepareQuerySettings = exports.DescribeTableSettings = exports.RollbackTransactionSettings = exports.CommitTransactionSettings = exports.BeginTransactionSettings = exports.DropTableSettings = exports.AlterTableSettings = exports.CreateTableSettings = exports.Session = exports.SessionPool = exports.getNameConverter = exports.typeMetadataKey = exports.primitiveTypeToValue = exports.identityConversion = exports.snakeToCamelCaseConversion = exports.withTypeOptions = exports.TypedData = exports.TypedValues = exports.Types = exports.declareType = exports.Driver = exports.setDefaultLogger = exports.getLogger = exports.Ydb = void 0;
+exports.StatusCode = exports.YdbError = exports.RetryParameters = exports.withRetries = exports.MetadataAuthService = exports.TokenAuthService = exports.IamAuthService = exports.AnonymousAuthService = exports.parseConnectionString = exports.getSACredentialsFromJson = void 0;
 var ydb_sdk_proto_1 = require("ydb-sdk-proto");
@@ -13,2 +13,3 @@ Object.defineProperty(exports, "Ydb", { enumerable: true, get: function () { return ydb_sdk_proto_1.Ydb; } });
 Object.defineProperty(exports, "getLogger", { enumerable: true, get: function () { return __importDefault(logging_1).default; } });
+Object.defineProperty(exports, "setDefaultLogger", { enumerable: true, get: function () { return logging_1.setDefaultLogger; } });
 var driver_1 = require("./driver");
@@ -15,0 +16,0 @@ Object.defineProperty(exports, "Driver", { enumerable: true, get: function () { return __importDefault(driver_1).default; } });

build/cjs/src/logging.d.ts

@@ -1,3 +0,15 @@
-import pino, { LoggerOptions } from 'pino';
-export default function getLogger(options?: LoggerOptions): pino.Logger;
-export { Logger } from 'pino';
+import { LogFn, LoggerOptions } from 'pino';
+interface Logger {
+    fatal: LogFn;
+    error: LogFn;
+    warn: LogFn;
+    info: LogFn;
+    debug: LogFn;
+    trace: LogFn;
+}
+/**
+ * Sets the default logger
+ */
+export declare function setDefaultLogger(newLogger: Logger): void;
+export default function getLogger(options?: LoggerOptions): Logger;
+export { Logger, LogFn };

build/cjs/src/logging.js

@@ -6,6 +6,6 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.setDefaultLogger = void 0;
 const pino_1 = __importDefault(require("pino"));
 const LOGLEVEL = process.env.YDB_SDK_LOGLEVEL || 'info';
 const PRETTY_LOGS = Boolean(process.env.YDB_SDK_PRETTY_LOGS);
-let logger = null;
 const defaultLoggerOptions = {
@@ -15,2 +15,11 @@ level: LOGLEVEL,
 };
+let logger = null;
+/**
+ * Sets the default logger
+ */
+function setDefaultLogger(newLogger) {
+    logger = newLogger;
+    logger.debug(`Default logger changed to ${newLogger.constructor.name}`);
+}
+exports.setDefaultLogger = setDefaultLogger;
 function getLogger(options = defaultLoggerOptions) {
@@ -17,0 +26,0 @@ if (!logger) {

build/cjs/src/parse-env-vars.d.ts

@@ -1,2 +0,1 @@
-/// <reference types="pino" />
 import { IAuthService, IIamCredentials } from './credentials';
@@ -3,0 +2,0 @@ import { Logger } from './logging';

build/cjs/src/retries.js

@@ -114,7 +114,9 @@ "use strict";
         const wrappedMethodName = `${target.constructor.name}::${propertyKey}`;
-        if (!strategyParams) {
-            strategyParams = new RetryParameters();
-        }
-        const strategy = new RetryStrategy(wrappedMethodName, strategyParams);
+        let strategy;
         descriptor.value = async function (...args) {
+            if (!strategy) {
+                if (!strategyParams)
+                    strategyParams = new RetryParameters();
+                strategy = new RetryStrategy(wrappedMethodName, strategyParams);
+            }
             return await strategy.retry(async () => await originalMethod.call(this, ...args));
@@ -121,0 +123,0 @@ };

build/cjs/src/scheme.d.ts

@@ -1,2 +0,1 @@
-/// <reference types="pino" />
 import { Ydb } from "ydb-sdk-proto";
@@ -3,0 +2,0 @@ import { ClientOptions } from "./utils";

build/cjs/src/ssl-credentials.d.ts

@@ -1,2 +0,1 @@
-/// <reference types="pino" />
 /// <reference types="node" />
@@ -3,0 +2,0 @@ import { Logger } from './logging';

build/cjs/src/table.d.ts

@@ -1,2 +0,1 @@
-/// <reference types="pino" />
 /// <reference types="node" />
@@ -3,0 +2,0 @@ import EventEmitter from 'events';

build/esm/package.json

 {
-    "version": "3.4.3"
+    "version": "3.4.4"
 }

build/esm/src/discovery.d.ts

@@ -1,2 +0,1 @@
-/// <reference types="pino" />
 import { Ydb } from "ydb-sdk-proto";
@@ -3,0 +2,0 @@ import { AuthenticatedService } from "./utils";

build/esm/src/driver.d.ts

@@ -1,2 +0,1 @@
-/// <reference types="pino" />
 import { TableClient } from "./table";
@@ -3,0 +2,0 @@ import SchemeService from "./scheme";

build/esm/src/index.d.ts

 export { Ydb } from 'ydb-sdk-proto';
-export { default as getLogger, Logger } from './logging';
+export { default as getLogger, setDefaultLogger, Logger, LogFn } from './logging';
 export { default as Driver, IDriverSettings, IPoolSettings } from './driver';
@@ -4,0 +4,0 @@ export { declareType, StructFields, Types, TypedValues, TypedData, TypedDataOptions, withTypeOptions, NamesConversion, snakeToCamelCaseConversion, identityConversion, primitiveTypeToValue, typeMetadataKey, getNameConverter, StringFunction } from './types';

build/esm/src/index.js

@@ -6,4 +6,4 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.getSACredentialsFromJson = exports.getCredentialsFromEnv = exports.ModifyPermissionsSettings = exports.DescribePathSettings = exports.ListDirectorySettings = exports.RemoveDirectorySettings = exports.MakeDirectorySettings = exports.AUTO_TX = exports.OperationParams = exports.CachingPolicy = exports.ExecutionPolicy = exports.CompactionPolicy = exports.ReplicationPolicy = exports.PartitioningPolicy = exports.ExplicitPartitions = exports.StoragePolicy = exports.ColumnFamilyPolicy = exports.StorageSettings = exports.TableIndex = exports.TableProfile = exports.Column = exports.AlterTableDescription = exports.TableDescription = exports.BulkUpsertSettings = exports.ReadTableSettings = exports.ExecuteScanQuerySettings = exports.ExecuteQuerySettings = exports.PrepareQuerySettings = exports.DescribeTableSettings = exports.RollbackTransactionSettings = exports.CommitTransactionSettings = exports.BeginTransactionSettings = exports.DropTableSettings = exports.AlterTableSettings = exports.CreateTableSettings = exports.Session = exports.SessionPool = exports.getNameConverter = exports.typeMetadataKey = exports.primitiveTypeToValue = exports.identityConversion = exports.snakeToCamelCaseConversion = exports.withTypeOptions = exports.TypedData = exports.TypedValues = exports.Types = exports.declareType = exports.Driver = exports.getLogger = exports.Ydb = void 0;
-exports.StatusCode = exports.YdbError = exports.RetryParameters = exports.withRetries = exports.MetadataAuthService = exports.TokenAuthService = exports.IamAuthService = exports.AnonymousAuthService = exports.parseConnectionString = void 0;
+exports.getCredentialsFromEnv = exports.ModifyPermissionsSettings = exports.DescribePathSettings = exports.ListDirectorySettings = exports.RemoveDirectorySettings = exports.MakeDirectorySettings = exports.AUTO_TX = exports.OperationParams = exports.CachingPolicy = exports.ExecutionPolicy = exports.CompactionPolicy = exports.ReplicationPolicy = exports.PartitioningPolicy = exports.ExplicitPartitions = exports.StoragePolicy = exports.ColumnFamilyPolicy = exports.StorageSettings = exports.TableIndex = exports.TableProfile = exports.Column = exports.AlterTableDescription = exports.TableDescription = exports.BulkUpsertSettings = exports.ReadTableSettings = exports.ExecuteScanQuerySettings = exports.ExecuteQuerySettings = exports.PrepareQuerySettings = exports.DescribeTableSettings = exports.RollbackTransactionSettings = exports.CommitTransactionSettings = exports.BeginTransactionSettings = exports.DropTableSettings = exports.AlterTableSettings = exports.CreateTableSettings = exports.Session = exports.SessionPool = exports.getNameConverter = exports.typeMetadataKey = exports.primitiveTypeToValue = exports.identityConversion = exports.snakeToCamelCaseConversion = exports.withTypeOptions = exports.TypedData = exports.TypedValues = exports.Types = exports.declareType = exports.Driver = exports.setDefaultLogger = exports.getLogger = exports.Ydb = void 0;
+exports.StatusCode = exports.YdbError = exports.RetryParameters = exports.withRetries = exports.MetadataAuthService = exports.TokenAuthService = exports.IamAuthService = exports.AnonymousAuthService = exports.parseConnectionString = exports.getSACredentialsFromJson = void 0;
 var ydb_sdk_proto_1 = require("ydb-sdk-proto");
@@ -13,2 +13,3 @@ Object.defineProperty(exports, "Ydb", { enumerable: true, get: function () { return ydb_sdk_proto_1.Ydb; } });
 Object.defineProperty(exports, "getLogger", { enumerable: true, get: function () { return __importDefault(logging_1).default; } });
+Object.defineProperty(exports, "setDefaultLogger", { enumerable: true, get: function () { return logging_1.setDefaultLogger; } });
 var driver_1 = require("./driver");
@@ -15,0 +16,0 @@ Object.defineProperty(exports, "Driver", { enumerable: true, get: function () { return __importDefault(driver_1).default; } });

build/esm/src/logging.d.ts

@@ -1,3 +0,15 @@
-import pino, { LoggerOptions } from 'pino';
-export default function getLogger(options?: LoggerOptions): pino.Logger;
-export { Logger } from 'pino';
+import { LogFn, LoggerOptions } from 'pino';
+interface Logger {
+    fatal: LogFn;
+    error: LogFn;
+    warn: LogFn;
+    info: LogFn;
+    debug: LogFn;
+    trace: LogFn;
+}
+/**
+ * Sets the default logger
+ */
+export declare function setDefaultLogger(newLogger: Logger): void;
+export default function getLogger(options?: LoggerOptions): Logger;
+export { Logger, LogFn };

build/esm/src/logging.js

@@ -6,6 +6,6 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.setDefaultLogger = void 0;
 const pino_1 = __importDefault(require("pino"));
 const LOGLEVEL = process.env.YDB_SDK_LOGLEVEL || 'info';
 const PRETTY_LOGS = Boolean(process.env.YDB_SDK_PRETTY_LOGS);
-let logger = null;
 const defaultLoggerOptions = {
@@ -15,2 +15,11 @@ level: LOGLEVEL,
 };
+let logger = null;
+/**
+ * Sets the default logger
+ */
+function setDefaultLogger(newLogger) {
+    logger = newLogger;
+    logger.debug(`Default logger changed to ${newLogger.constructor.name}`);
+}
+exports.setDefaultLogger = setDefaultLogger;
 function getLogger(options = defaultLoggerOptions) {
@@ -17,0 +26,0 @@ if (!logger) {

build/esm/src/parse-env-vars.d.ts

@@ -1,2 +0,1 @@
-/// <reference types="pino" />
 import { IAuthService, IIamCredentials } from './credentials';
@@ -3,0 +2,0 @@ import { Logger } from './logging';

build/esm/src/retries.js

@@ -126,7 +126,9 @@ "use strict";
         const wrappedMethodName = `${target.constructor.name}::${propertyKey}`;
-        if (!strategyParams) {
-            strategyParams = new RetryParameters();
-        }
-        const strategy = new RetryStrategy(wrappedMethodName, strategyParams);
+        let strategy;
         descriptor.value = async function (...args) {
+            if (!strategy) {
+                if (!strategyParams)
+                    strategyParams = new RetryParameters();
+                strategy = new RetryStrategy(wrappedMethodName, strategyParams);
+            }
             return await strategy.retry(async () => await originalMethod.call(this, ...args));
@@ -133,0 +135,0 @@ };

build/esm/src/scheme.d.ts

@@ -1,2 +0,1 @@
-/// <reference types="pino" />
 import { Ydb } from "ydb-sdk-proto";
@@ -3,0 +2,0 @@ import { ClientOptions } from "./utils";

build/esm/src/ssl-credentials.d.ts

@@ -1,2 +0,1 @@
-/// <reference types="pino" />
 /// <reference types="node" />
@@ -3,0 +2,0 @@ import { Logger } from './logging';

build/esm/src/table.d.ts

@@ -1,2 +0,1 @@
-/// <reference types="pino" />
 /// <reference types="node" />
@@ -3,0 +2,0 @@ import EventEmitter from 'events';

CHANGELOG.md

@@ -5,2 +5,14 @@ # Changelog
 
+## [3.5.0](https://github.com/ydb-platform/ydb-nodejs-sdk/compare/v3.4.4...v3.5.0) (2022-11-15)
+
+
+### Features
+
+* add custom logger ([2d411cd](https://github.com/ydb-platform/ydb-nodejs-sdk/commit/2d411cd5e613d07ebefdde8f34d582981fc0fedf)), closes [#191](https://github.com/ydb-platform/ydb-nodejs-sdk/issues/191)
+
+
+### Bug Fixes
+
+* **deps:** update logging packages to latest ([ad8dbd2](https://github.com/ydb-platform/ydb-nodejs-sdk/commit/ad8dbd25ddfe8eb9a4617cb9f34a85ddb83d9aae))
+
 ## [3.4.4](https://github.com/ydb-platform/ydb-nodejs-sdk/compare/v3.4.3...v3.4.4) (2022-10-20)
@@ -7,0 +19,0 @@

package.json

 {
   "name": "ydb-sdk",
-  "version": "3.4.4",
+  "version": "3.5.0",
   "description": "Node.js bindings for working with YDB API over gRPC",
@@ -5,0 +5,0 @@ "main": "build/cjs/src/index.js",

No alert changes

Improved metrics

Total package byte prevSize

1027076

increased by0.15%

Lines of code

12459

increased by0.29%

No dependency changes