nats - npm Package Compare versions

Comparing version 2.0.0-211 to 2.0.0-212

lib/nats-base-client/internal_mod.d.ts

@@ -5,13 +5,13 @@ export { NatsConnectionImpl } from "./nats";
 export type { ConnectionOptions, Msg, NatsConnection, PublishOptions, RequestOptions, Server, ServerInfo, ServersChanged, Status, Subscription, SubscriptionOptions, } from "./types";
-export { Events, DebugEvents, Empty, } from "./types";
-export { MsgImpl, } from "./msg";
-export { SubscriptionImpl, } from "./subscription";
-export { Subscriptions, } from "./subscriptions";
-export { setTransportFactory, setUrlParseFn, } from "./transport";
-export type { Transport, } from "./transport";
-export { Connect, ProtocolHandler, INFO, createInbox, } from "./protocol";
-export type { Timeout, Deferred, } from "./util";
-export { render, extractProtocolMessage, delay, deferred, timeout, } from "./util";
-export type { MsgHdrs, } from "./headers";
-export { MsgHdrsImpl, headers, } from "./headers";
+export { DebugEvents, Empty, Events } from "./types";
+export { MsgImpl } from "./msg";
+export { SubscriptionImpl } from "./subscription";
+export { Subscriptions } from "./subscriptions";
+export { setTransportFactory, setUrlParseFn } from "./transport";
+export type { Transport } from "./transport";
+export { Connect, createInbox, INFO, ProtocolHandler } from "./protocol";
+export type { Deferred, Timeout } from "./util";
+export { deferred, delay, extractProtocolMessage, render, timeout, } from "./util";
+export type { MsgHdrs } from "./headers";
+export { headers, MsgHdrsImpl } from "./headers";
 export { Heartbeat } from "./heartbeats";
@@ -23,15 +23,15 @@ export type { PH } from "./heartbeats";
 export { Request } from "./request";
-export type { Authenticator, } from "./authenticator";
-export { nkeyAuthenticator, jwtAuthenticator, credsAuthenticator, } from "./authenticator";
-export type { Codec, } from "./codec";
-export { JSONCodec, StringCodec, } from "./codec";
+export type { Authenticator } from "./authenticator";
+export { credsAuthenticator, jwtAuthenticator, nkeyAuthenticator, } from "./authenticator";
+export type { Codec } from "./codec";
+export { JSONCodec, StringCodec } from "./codec";
 export * from "./nkeys";
-export type { Dispatcher, } from "./queued_iterator";
-export { QueuedIterator, } from "./queued_iterator";
+export type { Dispatcher } from "./queued_iterator";
+export { QueuedIterator } from "./queued_iterator";
 export type { ParserEvent } from "./parser";
-export { Parser, State, Kind } from "./parser";
+export { Kind, Parser, State } from "./parser";
 export { DenoBuffer, MAX_SIZE, readAll, writeAll } from "./denobuffer";
 export { Bench, Metric } from "./bench";
 export type { BenchOpts } from "./bench";
-export { TE, TD } from "./encoders";
-export { parseIP, isIP } from "./ipparser";
+export { TD, TE } from "./encoders";
+export { isIP, parseIP } from "./ipparser";

lib/nats-base-client/internal_mod.js

@@ -13,3 +13,3 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.isIP = exports.parseIP = exports.TD = exports.TE = exports.Metric = exports.Bench = exports.writeAll = exports.readAll = exports.MAX_SIZE = exports.DenoBuffer = exports.Kind = exports.State = exports.Parser = exports.QueuedIterator = exports.StringCodec = exports.JSONCodec = exports.credsAuthenticator = exports.jwtAuthenticator = exports.nkeyAuthenticator = exports.Request = exports.checkOptions = exports.DataBuffer = exports.MuxSubscription = exports.Heartbeat = exports.headers = exports.MsgHdrsImpl = exports.timeout = exports.deferred = exports.delay = exports.extractProtocolMessage = exports.render = exports.createInbox = exports.INFO = exports.ProtocolHandler = exports.Connect = exports.setUrlParseFn = exports.setTransportFactory = exports.Subscriptions = exports.SubscriptionImpl = exports.MsgImpl = exports.Empty = exports.DebugEvents = exports.Events = exports.NatsError = exports.ErrorCode = exports.nuid = exports.Nuid = exports.NatsConnectionImpl = void 0;
+exports.parseIP = exports.isIP = exports.TE = exports.TD = exports.Metric = exports.Bench = exports.writeAll = exports.readAll = exports.MAX_SIZE = exports.DenoBuffer = exports.State = exports.Parser = exports.Kind = exports.QueuedIterator = exports.StringCodec = exports.JSONCodec = exports.nkeyAuthenticator = exports.jwtAuthenticator = exports.credsAuthenticator = exports.Request = exports.checkOptions = exports.DataBuffer = exports.MuxSubscription = exports.Heartbeat = exports.MsgHdrsImpl = exports.headers = exports.timeout = exports.render = exports.extractProtocolMessage = exports.delay = exports.deferred = exports.ProtocolHandler = exports.INFO = exports.createInbox = exports.Connect = exports.setUrlParseFn = exports.setTransportFactory = exports.Subscriptions = exports.SubscriptionImpl = exports.MsgImpl = exports.Events = exports.Empty = exports.DebugEvents = exports.NatsError = exports.ErrorCode = exports.nuid = exports.Nuid = exports.NatsConnectionImpl = void 0;
 var nats_1 = require("./nats");
@@ -24,5 +24,5 @@ Object.defineProperty(exports, "NatsConnectionImpl", { enumerable: true, get: function () { return nats_1.NatsConnectionImpl; } });
 var types_1 = require("./types");
-Object.defineProperty(exports, "Events", { enumerable: true, get: function () { return types_1.Events; } });
 Object.defineProperty(exports, "DebugEvents", { enumerable: true, get: function () { return types_1.DebugEvents; } });
 Object.defineProperty(exports, "Empty", { enumerable: true, get: function () { return types_1.Empty; } });
+Object.defineProperty(exports, "Events", { enumerable: true, get: function () { return types_1.Events; } });
 var msg_1 = require("./msg");
@@ -39,14 +39,14 @@ Object.defineProperty(exports, "MsgImpl", { enumerable: true, get: function () { return msg_1.MsgImpl; } });
 Object.defineProperty(exports, "Connect", { enumerable: true, get: function () { return protocol_1.Connect; } });
+Object.defineProperty(exports, "createInbox", { enumerable: true, get: function () { return protocol_1.createInbox; } });
+Object.defineProperty(exports, "INFO", { enumerable: true, get: function () { return protocol_1.INFO; } });
 Object.defineProperty(exports, "ProtocolHandler", { enumerable: true, get: function () { return protocol_1.ProtocolHandler; } });
-Object.defineProperty(exports, "INFO", { enumerable: true, get: function () { return protocol_1.INFO; } });
-Object.defineProperty(exports, "createInbox", { enumerable: true, get: function () { return protocol_1.createInbox; } });
 var util_1 = require("./util");
+Object.defineProperty(exports, "deferred", { enumerable: true, get: function () { return util_1.deferred; } });
+Object.defineProperty(exports, "delay", { enumerable: true, get: function () { return util_1.delay; } });
+Object.defineProperty(exports, "extractProtocolMessage", { enumerable: true, get: function () { return util_1.extractProtocolMessage; } });
 Object.defineProperty(exports, "render", { enumerable: true, get: function () { return util_1.render; } });
-Object.defineProperty(exports, "extractProtocolMessage", { enumerable: true, get: function () { return util_1.extractProtocolMessage; } });
-Object.defineProperty(exports, "delay", { enumerable: true, get: function () { return util_1.delay; } });
-Object.defineProperty(exports, "deferred", { enumerable: true, get: function () { return util_1.deferred; } });
 Object.defineProperty(exports, "timeout", { enumerable: true, get: function () { return util_1.timeout; } });
 var headers_1 = require("./headers");
+Object.defineProperty(exports, "headers", { enumerable: true, get: function () { return headers_1.headers; } });
 Object.defineProperty(exports, "MsgHdrsImpl", { enumerable: true, get: function () { return headers_1.MsgHdrsImpl; } });
-Object.defineProperty(exports, "headers", { enumerable: true, get: function () { return headers_1.headers; } });
 var heartbeats_1 = require("./heartbeats");
@@ -63,5 +63,5 @@ Object.defineProperty(exports, "Heartbeat", { enumerable: true, get: function () { return heartbeats_1.Heartbeat; } });
 var authenticator_1 = require("./authenticator");
+Object.defineProperty(exports, "credsAuthenticator", { enumerable: true, get: function () { return authenticator_1.credsAuthenticator; } });
+Object.defineProperty(exports, "jwtAuthenticator", { enumerable: true, get: function () { return authenticator_1.jwtAuthenticator; } });
 Object.defineProperty(exports, "nkeyAuthenticator", { enumerable: true, get: function () { return authenticator_1.nkeyAuthenticator; } });
-Object.defineProperty(exports, "jwtAuthenticator", { enumerable: true, get: function () { return authenticator_1.jwtAuthenticator; } });
-Object.defineProperty(exports, "credsAuthenticator", { enumerable: true, get: function () { return authenticator_1.credsAuthenticator; } });
 var codec_1 = require("./codec");
@@ -74,5 +74,5 @@ Object.defineProperty(exports, "JSONCodec", { enumerable: true, get: function () { return codec_1.JSONCodec; } });
 var parser_1 = require("./parser");
+Object.defineProperty(exports, "Kind", { enumerable: true, get: function () { return parser_1.Kind; } });
 Object.defineProperty(exports, "Parser", { enumerable: true, get: function () { return parser_1.Parser; } });
 Object.defineProperty(exports, "State", { enumerable: true, get: function () { return parser_1.State; } });
-Object.defineProperty(exports, "Kind", { enumerable: true, get: function () { return parser_1.Kind; } });
 var denobuffer_1 = require("./denobuffer");
@@ -87,7 +87,7 @@ Object.defineProperty(exports, "DenoBuffer", { enumerable: true, get: function () { return denobuffer_1.DenoBuffer; } });
 var encoders_1 = require("./encoders");
+Object.defineProperty(exports, "TD", { enumerable: true, get: function () { return encoders_1.TD; } });
 Object.defineProperty(exports, "TE", { enumerable: true, get: function () { return encoders_1.TE; } });
-Object.defineProperty(exports, "TD", { enumerable: true, get: function () { return encoders_1.TD; } });
 var ipparser_1 = require("./ipparser");
+Object.defineProperty(exports, "isIP", { enumerable: true, get: function () { return ipparser_1.isIP; } });
 Object.defineProperty(exports, "parseIP", { enumerable: true, get: function () { return ipparser_1.parseIP; } });
-Object.defineProperty(exports, "isIP", { enumerable: true, get: function () { return ipparser_1.isIP; } });
 //# sourceMappingURL=internal_mod.js.map

lib/nats-base-client/mod.d.ts

@@ -1,2 +0,2 @@
-export { Bench, ErrorCode, NatsError, Empty, Events, createInbox, credsAuthenticator, headers, JSONCodec, jwtAuthenticator, nkeyAuthenticator, Nuid, StringCodec, } from "./internal_mod";
+export { Bench, createInbox, credsAuthenticator, Empty, ErrorCode, Events, headers, JSONCodec, jwtAuthenticator, NatsError, nkeyAuthenticator, Nuid, StringCodec, } from "./internal_mod";
 export type { Authenticator, Codec, ConnectionOptions, Msg, MsgHdrs, NatsConnection, PublishOptions, RequestOptions, ServersChanged, Status, Subscription, SubscriptionOptions, } from "./internal_mod";

lib/nats-base-client/mod.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.StringCodec = exports.Nuid = exports.nkeyAuthenticator = exports.jwtAuthenticator = exports.JSONCodec = exports.headers = exports.credsAuthenticator = exports.createInbox = exports.Events = exports.Empty = exports.NatsError = exports.ErrorCode = exports.Bench = void 0;
+exports.StringCodec = exports.Nuid = exports.nkeyAuthenticator = exports.NatsError = exports.jwtAuthenticator = exports.JSONCodec = exports.headers = exports.Events = exports.ErrorCode = exports.Empty = exports.credsAuthenticator = exports.createInbox = exports.Bench = void 0;
 var internal_mod_1 = require("./internal_mod");
 Object.defineProperty(exports, "Bench", { enumerable: true, get: function () { return internal_mod_1.Bench; } });
+Object.defineProperty(exports, "createInbox", { enumerable: true, get: function () { return internal_mod_1.createInbox; } });
+Object.defineProperty(exports, "credsAuthenticator", { enumerable: true, get: function () { return internal_mod_1.credsAuthenticator; } });
+Object.defineProperty(exports, "Empty", { enumerable: true, get: function () { return internal_mod_1.Empty; } });
 Object.defineProperty(exports, "ErrorCode", { enumerable: true, get: function () { return internal_mod_1.ErrorCode; } });
-Object.defineProperty(exports, "NatsError", { enumerable: true, get: function () { return internal_mod_1.NatsError; } });
-Object.defineProperty(exports, "Empty", { enumerable: true, get: function () { return internal_mod_1.Empty; } });
 Object.defineProperty(exports, "Events", { enumerable: true, get: function () { return internal_mod_1.Events; } });
-Object.defineProperty(exports, "createInbox", { enumerable: true, get: function () { return internal_mod_1.createInbox; } });
-Object.defineProperty(exports, "credsAuthenticator", { enumerable: true, get: function () { return internal_mod_1.credsAuthenticator; } });
 Object.defineProperty(exports, "headers", { enumerable: true, get: function () { return internal_mod_1.headers; } });
 Object.defineProperty(exports, "JSONCodec", { enumerable: true, get: function () { return internal_mod_1.JSONCodec; } });
 Object.defineProperty(exports, "jwtAuthenticator", { enumerable: true, get: function () { return internal_mod_1.jwtAuthenticator; } });
+Object.defineProperty(exports, "NatsError", { enumerable: true, get: function () { return internal_mod_1.NatsError; } });
 Object.defineProperty(exports, "nkeyAuthenticator", { enumerable: true, get: function () { return internal_mod_1.nkeyAuthenticator; } });
@@ -16,0 +16,0 @@ Object.defineProperty(exports, "Nuid", { enumerable: true, get: function () { return internal_mod_1.Nuid; } });

lib/nats-base-client/nats.d.ts

 import { ProtocolHandler } from "./protocol";
-import { ConnectionOptions, Subscription, RequestOptions, PublishOptions, Msg, SubscriptionOptions, Status, NatsConnection, Stats, ServerInfo } from "./types";
+import { ConnectionOptions, Msg, NatsConnection, PublishOptions, RequestOptions, ServerInfo, Stats, Status, Subscription, SubscriptionOptions } from "./types";
 import { QueuedIterator } from "./queued_iterator";
@@ -4,0 +4,0 @@ export declare class NatsConnectionImpl implements NatsConnection {

lib/nats-base-client/protocol.d.ts

@@ -1,2 +0,2 @@
-import { ConnectionOptions, Status, Subscription, PublishOptions } from "./types";
+import { ConnectionOptions, PublishOptions, Status, Subscription } from "./types";
 import { Transport } from "./transport";
@@ -3,0 +3,0 @@ import { NatsError } from "./error";

lib/nats-base-client/servers.d.ts

@@ -1,2 +0,2 @@
-import { ServerInfo, ServersChanged, Server, URLParseFn } from "./types";
+import { Server, ServerInfo, ServersChanged, URLParseFn } from "./types";
 /**
@@ -3,0 +3,0 @@ * @hidden

lib/src/connect.d.ts

@@ -1,2 +0,2 @@
-import { NatsConnection, ConnectionOptions } from "./nats-base-client";
+import { ConnectionOptions, NatsConnection } from "./nats-base-client";
 export declare function connect(opts?: ConnectionOptions): Promise<NatsConnection>;

lib/src/node_transport.d.ts

 /// <reference types="node" />
-import { Transport, Deferred } from "./nats-base-client";
+import { Deferred, Transport } from "./nats-base-client";
 import { ConnectionOptions } from "./nats-base-client";
@@ -4,0 +4,0 @@ import { Socket } from "net";

lib/src/node_transport.js

@@ -45,3 +45,3 @@ "use strict";
 const { readFile, existsSync } = require("fs");
-const VERSION = "2.0.0-211";
+const VERSION = "2.0.0-212";
 const LANG = "nats.js";
@@ -48,0 +48,0 @@ class NodeTransport {

package.json

 {
   "name": "nats",
-  "version": "2.0.0-211",
+  "version": "2.0.0-212",
   "description": "Node.js client for NATS, a lightweight, high-performance cloud native messaging system",
@@ -44,3 +44,3 @@ "keywords": [
     "clean": "rm -Rf ./lib/* ./nats-base-client ./.deps",
-    "clone-nbc": "mkdir -p ./.deps && cd ./.deps && git clone --branch=v1.0.0-10 https://github.com/nats-io/nats.deno.git",
+    "clone-nbc": "mkdir -p ./.deps && cd ./.deps && git clone --branch=v1.0.0-11 https://github.com/nats-io/nats.deno.git",
     "fmt": "deno fmt ./src/ ./examples/ ./test/",
@@ -47,0 +47,0 @@ "prepack": "npm run clone-nbc && npm run cjs && npm run build",

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Worsened metrics

Total package byte prevSize

372626

No dependency changes