@jwalab/nats-runner - npm Package Compare versions

Comparing version 0.0.3 to 0.0.4

dist/ConsumerHandlers.d.ts

+import { Logger } from "@jwalab/logger";
+import { ConsumerOpts, ConsumerOptsBuilder, JetStreamClient, JetStreamPullSubscription, JetStreamSubscription, PullOptions } from "nats";
+import { JetStreamMessage } from "./Messages";
+export declare abstract class JetStreamConsumerHandler {
+    protected readonly logger: Logger;
+    abstract readonly subject: string;
+    constructor(logger: Logger);
+    getConsumerOptions(): ConsumerOptsBuilder | Partial<ConsumerOpts>;
+    abstract handle(msg: JetStreamMessage<unknown>): Promise<void>;
+    onReady(): void;
+}
+export declare abstract class JetStreamPushConsumerHandler extends JetStreamConsumerHandler {
+    protected readonly jetStreamClient: JetStreamClient;
+    protected subscription?: JetStreamSubscription;
+    constructor(logger: Logger, jetStreamClient: JetStreamClient);
+    subscribe(): Promise<void>;
+    getSubscription(): JetStreamSubscription;
+}
+export declare abstract class JetStreamPullConsumerHandler extends JetStreamConsumerHandler {
+    protected readonly jetStreamClient: JetStreamClient;
+    pullOptions: Partial<PullOptions>;
+    protected subscription?: JetStreamPullSubscription;
+    constructor(logger: Logger, jetStreamClient: JetStreamClient);
+    subscribe(): Promise<void>;
+    getSubscription(): JetStreamPullSubscription;
+}

dist/ConsumerHandlers.js

+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+exports.JetStreamPullConsumerHandler = exports.JetStreamPushConsumerHandler = exports.JetStreamConsumerHandler = void 0;
+class JetStreamConsumerHandler {
+    constructor(logger) {
+        this.logger = logger;
+    }
+    getConsumerOptions() {
+        return {};
+    }
+    onReady() {
+    }
+}
+exports.JetStreamConsumerHandler = JetStreamConsumerHandler;
+class JetStreamPushConsumerHandler extends JetStreamConsumerHandler {
+    constructor(logger, jetStreamClient) {
+        super(logger);
+        this.jetStreamClient = jetStreamClient;
+    }
+    async subscribe() {
+        this.logger.debug(`Registering consumer handler for ${this.subject}`);
+        this.subscription = await this.jetStreamClient.subscribe(this.subject, this.getConsumerOptions());
+    }
+    getSubscription() {
+        if (!this.subscription) {
+            throw new Error("Consumer handler doesn't have a subscription yet");
+        }
+        return this.subscription;
+    }
+}
+exports.JetStreamPushConsumerHandler = JetStreamPushConsumerHandler;
+class JetStreamPullConsumerHandler extends JetStreamConsumerHandler {
+    constructor(logger, jetStreamClient) {
+        super(logger);
+        this.jetStreamClient = jetStreamClient;
+        this.pullOptions = {};
+    }
+    async subscribe() {
+        this.logger.debug(`Registering consumer handler for ${this.subject}`);
+        this.subscription = await this.jetStreamClient.pullSubscribe(this.subject, this.getConsumerOptions());
+    }
+    getSubscription() {
+        if (!this.subscription) {
+            throw new Error("Consumer handler doesn't have a subscription yet");
+        }
+        return this.subscription;
+    }
+}
+exports.JetStreamPullConsumerHandler = JetStreamPullConsumerHandler;
+//# sourceMappingURL=ConsumerHandlers.js.map

dist/ConsumerHandlers.js.map

+{"version":3,"file":"ConsumerHandlers.js","sourceRoot":"","sources":["../src/ConsumerHandlers.ts"],"names":[],"mappings":";;;AAWA,MAAsB,wBAAwB;IAG1C,YAA+B,MAAc;QAAd,WAAM,GAAN,MAAM,CAAQ;IAAG,CAAC;IAEjD,kBAAkB;QACd,OAAO,EAAE,CAAC;IACd,CAAC;IAID,OAAO;IAEP,CAAC;CACJ;AAdD,4DAcC;AAED,MAAsB,4BAA6B,SAAQ,wBAAwB;IAG/E,YAAY,MAAc,EAAqB,eAAgC;QAC3E,KAAK,CAAC,MAAM,CAAC,CAAC;QAD6B,oBAAe,GAAf,eAAe,CAAiB;IAE/E,CAAC;IAED,KAAK,CAAC,SAAS;QACX,IAAI,CAAC,MAAM,CAAC,KAAK,CAAC,oCAAoC,IAAI,CAAC,OAAO,EAAE,CAAC,CAAC;QACtE,IAAI,CAAC,YAAY,GAAG,MAAM,IAAI,CAAC,eAAe,CAAC,SAAS,CAAC,IAAI,CAAC,OAAO,EAAE,IAAI,CAAC,kBAAkB,EAAE,CAAC,CAAC;IACtG,CAAC;IAED,eAAe;QACX,IAAI,CAAC,IAAI,CAAC,YAAY,EAAE;YACpB,MAAM,IAAI,KAAK,CAAC,kDAAkD,CAAC,CAAC;SACvE;QACD,OAAO,IAAI,CAAC,YAAY,CAAC;IAC7B,CAAC;CACJ;AAlBD,oEAkBC;AAED,MAAsB,4BAA6B,SAAQ,wBAAwB;IAI/E,YAAY,MAAc,EAAqB,eAAgC;QAC3E,KAAK,CAAC,MAAM,CAAC,CAAC;QAD6B,oBAAe,GAAf,eAAe,CAAiB;QAHxE,gBAAW,GAAyB,EAAE,CAAC;IAK9C,CAAC;IAED,KAAK,CAAC,SAAS;QACX,IAAI,CAAC,MAAM,CAAC,KAAK,CAAC,oCAAoC,IAAI,CAAC,OAAO,EAAE,CAAC,CAAC;QACtE,IAAI,CAAC,YAAY,GAAG,MAAM,IAAI,CAAC,eAAe,CAAC,aAAa,CAAC,IAAI,CAAC,OAAO,EAAE,IAAI,CAAC,kBAAkB,EAAE,CAAC,CAAC;IAC1G,CAAC;IAED,eAAe;QACX,IAAI,CAAC,IAAI,CAAC,YAAY,EAAE;YACpB,MAAM,IAAI,KAAK,CAAC,kDAAkD,CAAC,CAAC;SACvE;QACD,OAAO,IAAI,CAAC,YAAY,CAAC;IAC7B,CAAC;CACJ;AAnBD,oEAmBC"}

dist/Consumers.d.ts

@@ -1,2 +0,3 @@
-import { ConsumerOpts, ConsumerOptsBuilder } from "nats";
+import { Logger } from "@jwalab/logger";
+import { ConsumerOpts, ConsumerOptsBuilder, JetStreamClient, JetStreamPullSubscription, JetStreamSubscription, PullOptions } from "nats";
 import { JetStreamMessage } from "./Messages";
@@ -7,2 +8,20 @@ export declare abstract class JetStreamConsumer {
     abstract handle(msg: JetStreamMessage<unknown>): Promise<void>;
+    onReady(): void;
 }
+export declare abstract class JetStreamPushConsumer extends JetStreamConsumer {
+    protected readonly logger: Logger;
+    protected readonly jetStreamClient: JetStreamClient;
+    protected subscription?: JetStreamSubscription;
+    constructor(logger: Logger, jetStreamClient: JetStreamClient);
+    subscribe(): Promise<void>;
+    getSubscription(): JetStreamSubscription;
+}
+export declare abstract class JetStreamPullConsumer extends JetStreamConsumer {
+    protected readonly logger: Logger;
+    protected readonly jetStreamClient: JetStreamClient;
+    pullOptions: Partial<PullOptions>;
+    protected subscription?: JetStreamPullSubscription;
+    constructor(logger: Logger, jetStreamClient: JetStreamClient);
+    subscribe(): Promise<void>;
+    getSubscription(): JetStreamPullSubscription;
+}

dist/Consumers.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.JetStreamConsumer = void 0;
+exports.JetStreamPullConsumer = exports.JetStreamPushConsumer = exports.JetStreamConsumer = void 0;
 class JetStreamConsumer {
@@ -8,4 +8,43 @@ getConsumerOptions() {
     }
+    onReady() {
+    }
 }
 exports.JetStreamConsumer = JetStreamConsumer;
+class JetStreamPushConsumer extends JetStreamConsumer {
+    constructor(logger, jetStreamClient) {
+        super();
+        this.logger = logger;
+        this.jetStreamClient = jetStreamClient;
+    }
+    async subscribe() {
+        this.logger.debug(`Registering consumer for ${this.subject}`);
+        this.subscription = await this.jetStreamClient.subscribe(this.subject, this.getConsumerOptions());
+    }
+    getSubscription() {
+        if (!this.subscription) {
+            throw new Error("Consumer doesn't have a subscription yet");
+        }
+        return this.subscription;
+    }
+}
+exports.JetStreamPushConsumer = JetStreamPushConsumer;
+class JetStreamPullConsumer extends JetStreamConsumer {
+    constructor(logger, jetStreamClient) {
+        super();
+        this.logger = logger;
+        this.jetStreamClient = jetStreamClient;
+        this.pullOptions = {};
+    }
+    async subscribe() {
+        this.logger.debug(`Registering consumer for ${this.subject}`);
+        this.subscription = await this.jetStreamClient.pullSubscribe(this.subject, this.getConsumerOptions());
+    }
+    getSubscription() {
+        if (!this.subscription) {
+            throw new Error("Consumer doesn't have a subscription yet");
+        }
+        return this.subscription;
+    }
+}
+exports.JetStreamPullConsumer = JetStreamPullConsumer;
 //# sourceMappingURL=Consumers.js.map

dist/Consumers.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"Consumers.js","sourceRoot":"","sources":["../src/Consumers.ts"],"names":[],"mappings":";;;AAGA,MAAsB,iBAAiB;IAGnC,kBAAkB;QACd,OAAO,EAAE,CAAC;IACd,CAAC;CAGJ;AARD,8CAQC"}
+{"version":3,"file":"Consumers.js","sourceRoot":"","sources":["../src/Consumers.ts"],"names":[],"mappings":";;;AAWA,MAAsB,iBAAiB;IAGnC,kBAAkB;QACd,OAAO,EAAE,CAAC;IACd,CAAC;IAID,OAAO;IAEP,CAAC;CACJ;AAZD,8CAYC;AAED,MAAsB,qBAAsB,SAAQ,iBAAiB;IAGjE,YAA+B,MAAc,EAAqB,eAAgC;QAC9F,KAAK,EAAE,CAAC;QADmB,WAAM,GAAN,MAAM,CAAQ;QAAqB,oBAAe,GAAf,eAAe,CAAiB;IAElG,CAAC;IAED,KAAK,CAAC,SAAS;QACX,IAAI,CAAC,MAAM,CAAC,KAAK,CAAC,4BAA4B,IAAI,CAAC,OAAO,EAAE,CAAC,CAAC;QAC9D,IAAI,CAAC,YAAY,GAAG,MAAM,IAAI,CAAC,eAAe,CAAC,SAAS,CAAC,IAAI,CAAC,OAAO,EAAE,IAAI,CAAC,kBAAkB,EAAE,CAAC,CAAC;IACtG,CAAC;IAED,eAAe;QACX,IAAI,CAAC,IAAI,CAAC,YAAY,EAAE;YACpB,MAAM,IAAI,KAAK,CAAC,0CAA0C,CAAC,CAAC;SAC/D;QACD,OAAO,IAAI,CAAC,YAAY,CAAC;IAC7B,CAAC;CACJ;AAlBD,sDAkBC;AAED,MAAsB,qBAAsB,SAAQ,iBAAiB;IAIjE,YAA+B,MAAc,EAAqB,eAAgC;QAC9F,KAAK,EAAE,CAAC;QADmB,WAAM,GAAN,MAAM,CAAQ;QAAqB,oBAAe,GAAf,eAAe,CAAiB;QAH3F,gBAAW,GAAyB,EAAE,CAAC;IAK9C,CAAC;IAED,KAAK,CAAC,SAAS;QACX,IAAI,CAAC,MAAM,CAAC,KAAK,CAAC,4BAA4B,IAAI,CAAC,OAAO,EAAE,CAAC,CAAC;QAC9D,IAAI,CAAC,YAAY,GAAG,MAAM,IAAI,CAAC,eAAe,CAAC,aAAa,CAAC,IAAI,CAAC,OAAO,EAAE,IAAI,CAAC,kBAAkB,EAAE,CAAC,CAAC;IAC1G,CAAC;IAED,eAAe;QACX,IAAI,CAAC,IAAI,CAAC,YAAY,EAAE;YACpB,MAAM,IAAI,KAAK,CAAC,0CAA0C,CAAC,CAAC;SAC/D;QACD,OAAO,IAAI,CAAC,YAAY,CAAC;IAC7B,CAAC;CACJ;AAnBD,sDAmBC"}

dist/NatsRunner.d.ts

@@ -1,8 +0,8 @@
-import { Subscription, JetStreamSubscription } from "nats";
+import { Subscription } from "nats";
 import { Logger } from "@jwalab/logger";
-import { JetStreamConsumer } from "./Consumers";
+import { JetStreamPullConsumerHandler, JetStreamPushConsumerHandler } from "./ConsumerHandlers";
 import { AirlockHandler, PrivateHandler } from "./Handlers";
 export * from "./Messages";
 export * from "./Handlers";
-export * from "./Consumers";
+export * from "./ConsumerHandlers";
 export * from "./Plugin";
@@ -42,4 +42,4 @@ export * from "./tokenParser";
     private registerJetStreamConsumer;
-    handleJetStreamMessage(subscription: JetStreamSubscription, consumer: JetStreamConsumer): Promise<void>;
+    handleJetStreamMessage(consumer: JetStreamPullConsumerHandler | JetStreamPushConsumerHandler): Promise<void>;
     private registerSignalHandlers;
 }

dist/NatsRunner.js

@@ -29,3 +29,3 @@ "use strict";
 const errors_1 = require("@jwalab/errors");
-const Consumers_1 = require("./Consumers");
+const ConsumerHandlers_1 = require("./ConsumerHandlers");
 const Handlers_1 = require("./Handlers");
@@ -35,3 +35,3 @@ const Messages_1 = require("./Messages");
 __exportStar(require("./Handlers"), exports);
-__exportStar(require("./Consumers"), exports);
+__exportStar(require("./ConsumerHandlers"), exports);
 __exportStar(require("./Plugin"), exports);
@@ -128,7 +128,7 @@ __exportStar(require("./tokenParser"), exports);
             const consumer = this.container.get(id);
-            if (consumer instanceof Consumers_1.JetStreamConsumer) {
+            if (consumer instanceof ConsumerHandlers_1.JetStreamPushConsumerHandler || consumer instanceof ConsumerHandlers_1.JetStreamPullConsumerHandler) {
                 this.registerJetStreamConsumer(consumer);
             }
             else {
-                throw new Error("Nats Consumer must extend type JetStreamConsumer");
+                throw new Error("Nats Consumer must be of type JetStreamPushConsumer or JetStreamPullConsumer");
             }
@@ -190,9 +190,8 @@ });
     async registerJetStreamConsumer(consumer) {
-        const subject = consumer.subject;
-        this.logger.debug(`Registering consumer for ${subject}`);
-        const consumerOptions = consumer.getConsumerOptions();
-        const subscription = await this.jetStreamClient.subscribe(subject, consumerOptions);
-        this.handleJetStreamMessage(subscription, consumer);
+        await consumer.subscribe();
+        this.handleJetStreamMessage(consumer);
+        consumer.onReady();
     }
-    async handleJetStreamMessage(subscription, consumer) {
+    async handleJetStreamMessage(consumer) {
+        const subscription = consumer.getSubscription();
         for await (const message of subscription) {
@@ -203,3 +202,3 @@ try {
             catch (err) {
-                this.logger.error(err.message);
+                this.logger.error(`Error handling JetStream message with sequence id (${message.seq}). ${JSON.stringify(err)}. Message won't be redelivered`);
                 message.term();
@@ -206,0 +205,0 @@ }

dist/NatsRunner.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"NatsRunner.js","sourceRoot":"","sources":["../src/NatsRunner.ts"],"names":[],"mappings":";;;;;;;;;;;;;;;;;;;;;;;;;AAAA,+BAAuH;AACvH,yEAAsF;AACtF,2CAAwC;AAExC,2CAAgD;AAEhD,yCAA4D;AAC5D,yCAAuE;AAEvE,6CAA2B;AAC3B,6CAA2B;AAC3B,8CAA4B;AAC5B,2CAAyB;AACzB,gDAA8B;AAE9B,IAAY,aAMX;AAND,WAAY,aAAa;IACrB,4BAAa,CAAA;IACb,8BAAe,CAAA;IACf,4BAAa,CAAA;IACb,gCAAiB,CAAA;IACjB,kCAAmB,CAAA;AACvB,CAAC,EANW,aAAa,GAAb,qBAAa,KAAb,qBAAa,QAMxB;AAOD,MAAa,UAAU;IAUnB,YAAY,GAAW;QACnB,IAAI,CAAC,SAAS,GAAG,IAAA,gBAAS,GAAE,CAAC;QAC7B,IAAI,CAAC,GAAG,GAAG,GAAG,CAAC;QACf,IAAI,CAAC,SAAS,GAAG,IAAI,4CAAgB,EAAE,CAAC;IAC5C,CAAC;IAED,KAAK,CAAC,KAAK;QACP,IAAI;YACA,MAAM,IAAI,CAAC,SAAS,EAAE,CAAC;YACvB,IAAI,CAAC,aAAa,EAAE,CAAC;YACrB,MAAM,IAAI,CAAC,QAAQ,EAAE,CAAC;YACtB,MAAM,IAAI,CAAC,YAAY,EAAE,CAAC;YAC1B,MAAM,IAAI,CAAC,oBAAoB,EAAE,CAAC;YAClC,MAAM,IAAI,CAAC,0BAA0B,EAAE,CAAC;YAExC,IAAI,CAAC,sBAAsB,EAAE,CAAC;SACjC;QAAC,OAAO,CAAC,EAAE;YACR,OAAO,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC;YACjB,OAAO,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC;SACnB;IACL,CAAC;IAEO,KAAK,CAAC,SAAS;QACnB,IAAI;YACA,MAAM,MAAM,GAAG,wDAAa,GAAG,IAAI,CAAC,GAAG,SAAS,GAAC,CAAC;YAClD,IAAI,CAAC,MAAM,GAAG,MAAM,CAAC,OAAO,CAAC;SAChC;QAAC,OAAO,GAAG,EAAE;YACV,IAAI,CAAC,MAAM,CAAC,KAAK,CAAC,0CAA0C,GAAG,EAAE,CAAC,CAAC;YACnE,OAAO,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC;SACnB;IACL,CAAC;IAEO,aAAa;QACjB,MAAM,CAAC,IAAI,CAAC,IAAI,CAAC,MAAM,CAAC,CAAC,OAAO,CAAC,CAAC,UAAU,EAAE,EAAE;YAC5C,IAAI,CAAC,MAAM,CAAC,UAAU,CAAC;gBACnB,IAAI,CAAC,SAAS,CAAC,YAAY,CAAC,UAAU,UAAU,EAAE,EAAE,IAAI,CAAC,MAAM,CAAC,UAAU,CAAc,CAAC,CAAC;QAClG,CAAC,CAAC,CAAC;QAEH,IAAI,CAAC,SAAS,CAAC,YAAY,CAAC,KAAK,EAAE,IAAI,CAAC,GAAG,CAAC,CAAC;QAC7C,MAAM,MAAM,GAAG,IAAI,wCAAY,CAAC,IAAI,CAAC,SAAS,CAAC,CAAC;QAEhD,MAAM,CAAC,IAAI,CAAC,GAAG,SAAS,KAAK,CAAC,CAAC;QAC/B,MAAM,CAAC,IAAI,CAAC,GAAG,IAAI,CAAC,GAAG,KAAK,CAAC,CAAC;QAE9B,IAAI,CAAC,MAAM,GAAG,IAAI,CAAC,SAAS,CAAC,GAAG,CAAS,QAAQ,CAAC,CAAC;QAEnD,IAAI,CAAC,SAAS,CAAC,MAAM,GAAG,EAAE,IAAI,EAAE,CAAC,GAAG,EAAE,EAAE,CAAC,IAAI,CAAC,MAAM,CAAC,OAAO,CAAC,GAAG,CAAC,EAAE,CAAC;QAEpE,IAAI,CAAC,MAAM,CAAC,KAAK,CAAC,kCAAkC,CAAC,CAAC;IAC1D,CAAC;IAEO,KAAK,CAAC,QAAQ;QAClB,IAAI,CAAC,cAAc,GAAG,MAAM,IAAA,cAAO,EAAC;YAChC,OAAO,EAAE,IAAI,CAAC,MAAM,CAAC,QAAkB;SAC1C,CAAC,CAAC;QAEH,IAAI,CAAC,SAAS,CAAC,QAAQ,CAAC,gBAAgB,CAAC,CAAC;QAC1C,IAAI,CAAC,SAAS,CAAC,GAAG,CAAC,gBAAgB,EAAE,IAAI,CAAC,cAAc,CAAC,CAAC;QAE1D,IAAI,CAAC,eAAe,GAAG,IAAI,CAAC,cAAc,CAAC,SAAS,EAAE,CAAC;QAEvD,IAAI,CAAC,SAAS,CAAC,QAAQ,CAAC,iBAAiB,CAAC,CAAC;QAC3C,IAAI,CAAC,SAAS,CAAC,GAAG,CAAC,iBAAiB,EAAE,IAAI,CAAC,eAAe,CAAC,CAAC;QAE5D,IAAI,CAAC,MAAM,CAAC,KAAK,CAAC,gCAAgC,IAAI,CAAC,MAAM,CAAC,QAAQ,mCAAmC,CAAC,CAAC;IAC/G,CAAC;IAEO,KAAK,CAAC,YAAY;QACtB,MAAM,GAAG,GAAG,KAAK,CAAC,IAAI,CAAC,IAAI,CAAC,SAAS,CAAC,oBAAoB,CAAC,eAAe,CAAC,CAAC,IAAI,EAAE,CAAC,CAAC;QAEpF,MAAM,OAAO,CAAC,GAAG,CACb,GAAG,CAAC,GAAG,CAAC,KAAK,EAAE,EAAE,EAAE,EAAE;YACjB,MAAM,MAAM,GAAG,IAAI,CAAC,SAAS,CAAC,GAAG,CAAC,EAAE,CAAC,CAAC;YAEtC,MAAM,MAAM,CAAC,KAAK,EAAE,CAAC;QACzB,CAAC,CAAC,CACL,CAAC;IACN,CAAC;IAEO,KAAK,CAAC,oBAAoB;QAC9B,MAAM,GAAG,GAAG,KAAK,CAAC,IAAI,CAAC,IAAI,CAAC,SAAS,CAAC,oBAAoB,CAAC,cAAc,CAAC,CAAC,IAAI,EAAE,CAAC,CAAC;QAEnF,GAAG,CAAC,OAAO,CAAC,CAAC,EAAE,EAAE,EAAE;YACf,MAAM,OAAO,GAAG,IAAI,CAAC,SAAS,CAAC,GAAG,CAAC,EAAE,CAAC,CAAC;YAEvC,IAAI,OAAO,YAAY,yBAAc,EAAE;gBACnC,IAAI,CAAC,sBAAsB,CAAC,OAAO,CAAC,CAAC;aACxC;iBAAM,IAAI,OAAO,YAAY,yBAAc,EAAE;gBAC1C,IAAI,CAAC,sBAAsB,CAAC,OAAO,CAAC,CAAC;aACxC;iBAAM;gBACH,MAAM,IAAI,KAAK,CAAC,yDAAyD,CAAC,CAAC;aAC9E;QACL,CAAC,CAAC,CAAC;IACP,CAAC;IAEO,KAAK,CAAC,0BAA0B;QACpC,MAAM,GAAG,GAAG,KAAK,CAAC,IAAI,CAAC,IAAI,CAAC,SAAS,CAAC,oBAAoB,CAAC,eAAe,CAAC,CAAC,IAAI,EAAE,CAAC,CAAC;QAEpF,GAAG,CAAC,OAAO,CAAC,CAAC,EAAE,EAAE,EAAE;YACf,MAAM,QAAQ,GAAG,IAAI,CAAC,SAAS,CAAC,GAAG,CAAC,EAAE,CAAC,CAAC;YAExC,IAAI,QAAQ,YAAY,6BAAiB,EAAE;gBACvC,IAAI,CAAC,yBAAyB,CAAC,QAAQ,CAAC,CAAC;aAC5C;iBAAM;gBACH,MAAM,IAAI,KAAK,CAAC,kDAAkD,CAAC,CAAC;aACvE;QACL,CAAC,CAAC,CAAC;IACP,CAAC;IAEO,sBAAsB,CAAC,OAAuB;QAClD,IAAI,OAAO,CAAC;QAEZ,IAAI,OAAO,CAAC,oBAAoB,EAAE;YAC9B,OAAO,GAAG,GAAG,IAAI,CAAC,MAAM,CAAC,YAAY,IAAI,OAAO,CAAC,OAAO,EAAE,CAAC;SAC9D;aAAM;YACH,OAAO,GAAG,OAAO,CAAC,OAAO,CAAC;SAC7B;QAED,IAAI,CAAC,MAAM,CAAC,KAAK,CAAC,mCAAmC,OAAO,EAAE,CAAC,CAAC;QAChE,MAAM,mBAAmB,GAAG,OAAO,CAAC,sBAAsB,EAAE,CAAC;QAE7D,MAAM,YAAY,GAAG,IAAI,CAAC,cAAc,CAAC,SAAS,CAAC,OAAO,EAAE,mBAAmB,CAAC,CAAC;QAEjF,IAAI,CAAC,oBAAoB,CAAC,YAAY,EAAE,OAAO,CAAC,CAAC;IACrD,CAAC;IAEO,sBAAsB,CAAC,OAAuB;QAClD,MAAM,OAAO,GAAG,GAAG,OAAO,CAAC,IAAI,IAAI,IAAI,CAAC,MAAM,CAAC,YAAY,IAAI,OAAO,CAAC,OAAO,EAAE,CAAC;QACjF,IAAI,CAAC,MAAM,CAAC,KAAK,CAAC,mCAAmC,OAAO,EAAE,CAAC,CAAC;QAChE,MAAM,mBAAmB,GAAG,OAAO,CAAC,sBAAsB,EAAE,CAAC;QAE7D,MAAM,YAAY,GAAG,IAAI,CAAC,cAAc,CAAC,SAAS,CAAC,OAAO,EAAE,mBAAmB,CAAC,CAAC;QAEjF,IAAI,CAAC,oBAAoB,CAAC,YAAY,EAAE,OAAO,CAAC,CAAC;IACrD,CAAC;IAED,KAAK,CAAC,oBAAoB,CAAC,YAA0B,EAAE,OAAuB;QAC1E,IAAI,KAAK,EAAE,MAAM,OAAO,IAAI,YAAY,EAAE;YACtC,IAAI;gBACA,MAAM,QAAQ,GAAG,MAAM,OAAO,CAAC,MAAM,CAAC,IAAI,yBAAc,CAAC,OAAO,CAAC,CAAC,CAAC;gBAEnE,OAAO,CAAC,OAAO,CAAC,IAAI,CAAC,SAAS,CAAC,MAAM,CAAC,QAAQ,CAAC,CAAC,CAAC;aACpD;YAAC,OAAO,GAAG,EAAE;gBACV,IAAI,CAAC,MAAM,CAAC,KAAK,CAAE,GAAa,CAAC,OAAO,CAAC,CAAC;gBAC1C,OAAO,CAAC,OAAO,CACX,IAAI,CAAC,SAAS,CAAC,MAAM,CAAC;oBAClB,KAAK,EACD,GAAG,YAAY,iBAAQ;wBACnB,CAAC,CAAC,IAAI,CAAC,SAAS,CAAC,EAAE,GAAG,GAAG,EAAE,MAAM,EAAE,SAAS,EAAE,CAAC;wBAC/C,CAAC,CAAE,GAAa,CAAC,OAAO;iBACnC,CAAC,CACL,CAAC;aACL;SACJ;IACL,CAAC;IAED,KAAK,CAAC,oBAAoB,CAAC,YAA0B,EAAE,OAAuB;QAC1E,IAAI,KAAK,EAAE,MAAM,OAAO,IAAI,YAAY,EAAE;YACtC,IAAI;gBACA,MAAM,QAAQ,GAAG,MAAM,OAAO,CAAC,MAAM,CAAC,IAAI,kBAAO,CAAC,OAAO,CAAC,CAAC,CAAC;gBAE5D,OAAO,CAAC,OAAO,CAAC,IAAI,CAAC,SAAS,CAAC,MAAM,CAAC,QAAQ,CAAC,CAAC,CAAC;aACpD;YAAC,OAAO,GAAG,EAAE;gBACV,IAAI,CAAC,MAAM,CAAC,KAAK,CAAE,GAAa,CAAC,OAAO,CAAC,CAAC;gBAC1C,OAAO,CAAC,OAAO,CACX,IAAI,CAAC,SAAS,CAAC,MAAM,CAAC;oBAClB,KAAK,EACD,GAAG,YAAY,iBAAQ;wBACnB,CAAC,CAAC,IAAI,CAAC,SAAS,CAAC,EAAE,GAAG,GAAG,EAAE,MAAM,EAAE,SAAS,EAAE,CAAC;wBAC/C,CAAC,CAAE,GAAa,CAAC,OAAO;iBACnC,CAAC,CACL,CAAC;aACL;SACJ;IACL,CAAC;IAEO,KAAK,CAAC,yBAAyB,CAAC,QAA2B;QAC/D,MAAM,OAAO,GAAG,QAAQ,CAAC,OAAO,CAAC;QAEjC,IAAI,CAAC,MAAM,CAAC,KAAK,CAAC,4BAA4B,OAAO,EAAE,CAAC,CAAC;QAEzD,MAAM,eAAe,GAAG,QAAQ,CAAC,kBAAkB,EAAE,CAAC;QAEtD,MAAM,YAAY,GAAG,MAAM,IAAI,CAAC,eAAe,CAAC,SAAS,CAAC,OAAO,EAAE,eAAe,CAAC,CAAC;QAEpF,IAAI,CAAC,sBAAsB,CAAC,YAAY,EAAE,QAAQ,CAAC,CAAC;IACxD,CAAC;IAED,KAAK,CAAC,sBAAsB,CAAC,YAAmC,EAAE,QAA2B;QACzF,IAAI,KAAK,EAAE,MAAM,OAAO,IAAI,YAAY,EAAE;YACtC,IAAI;gBACA,MAAM,QAAQ,CAAC,MAAM,CAAC,IAAI,2BAAgB,CAAC,OAAO,CAAC,CAAC,CAAC;aACxD;YAAC,OAAO,GAAG,EAAE;gBACV,IAAI,CAAC,MAAM,CAAC,KAAK,CAAE,GAAa,CAAC,OAAO,CAAC,CAAC;gBAK1C,OAAO,CAAC,IAAI,EAAE,CAAC;aAClB;SACJ;IACL,CAAC;IAEO,sBAAsB;QAC1B,MAAM,kBAAkB,GAAG,KAAK,IAAI,EAAE;YAClC,IAAI,CAAC,MAAM,CAAC,KAAK,CAAC,wCAAwC,CAAC,CAAC;YAC5D,MAAM,IAAI,CAAC,cAAc,CAAC,KAAK,EAAE,CAAC;YAClC,IAAI,CAAC,MAAM,CAAC,KAAK,CAAC,wBAAwB,CAAC,CAAC;YAC5C,OAAO,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC;QACpB,CAAC,CAAC;QAEF,OAAO,CAAC,EAAE,CAAC,QAAQ,EAAE,kBAAkB,CAAC,CAAC;QACzC,OAAO,CAAC,EAAE,CAAC,SAAS,EAAE,kBAAkB,CAAC,CAAC;IAC9C,CAAC;CACJ;AAhOD,gCAgOC"}
+{"version":3,"file":"NatsRunner.js","sourceRoot":"","sources":["../src/NatsRunner.ts"],"names":[],"mappings":";;;;;;;;;;;;;;;;;;;;;;;;;AAAA,+BAAgG;AAChG,yEAAsF;AACtF,2CAA0C;AAG1C,yDAAgG;AAChG,yCAA4D;AAC5D,yCAAuE;AAEvE,6CAA2B;AAC3B,6CAA2B;AAC3B,qDAAmC;AACnC,2CAAyB;AACzB,gDAA8B;AAE9B,IAAY,aAMX;AAND,WAAY,aAAa;IACrB,4BAAa,CAAA;IACb,8BAAe,CAAA;IACf,4BAAa,CAAA;IACb,gCAAiB,CAAA;IACjB,kCAAmB,CAAA;AACvB,CAAC,EANW,aAAa,GAAb,qBAAa,KAAb,qBAAa,QAMxB;AAOD,MAAa,UAAU;IAUnB,YAAY,GAAW;QACnB,IAAI,CAAC,SAAS,GAAG,IAAA,gBAAS,GAAE,CAAC;QAC7B,IAAI,CAAC,GAAG,GAAG,GAAG,CAAC;QACf,IAAI,CAAC,SAAS,GAAG,IAAI,4CAAgB,EAAE,CAAC;IAC5C,CAAC;IAED,KAAK,CAAC,KAAK;QACP,IAAI;YACA,MAAM,IAAI,CAAC,SAAS,EAAE,CAAC;YACvB,IAAI,CAAC,aAAa,EAAE,CAAC;YACrB,MAAM,IAAI,CAAC,QAAQ,EAAE,CAAC;YACtB,MAAM,IAAI,CAAC,YAAY,EAAE,CAAC;YAC1B,MAAM,IAAI,CAAC,oBAAoB,EAAE,CAAC;YAClC,MAAM,IAAI,CAAC,0BAA0B,EAAE,CAAC;YAExC,IAAI,CAAC,sBAAsB,EAAE,CAAC;SACjC;QAAC,OAAO,CAAC,EAAE;YACR,OAAO,CAAC,KAAK,CAAC,CAAC,CAAC,CAAC;YACjB,OAAO,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC;SACnB;IACL,CAAC;IAEO,KAAK,CAAC,SAAS;QACnB,IAAI;YACA,MAAM,MAAM,GAAG,wDAAa,GAAG,IAAI,CAAC,GAAG,SAAS,GAAC,CAAC;YAClD,IAAI,CAAC,MAAM,GAAG,MAAM,CAAC,OAAO,CAAC;SAChC;QAAC,OAAO,GAAG,EAAE;YACV,IAAI,CAAC,MAAM,CAAC,KAAK,CAAC,0CAA0C,GAAG,EAAE,CAAC,CAAC;YACnE,OAAO,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC;SACnB;IACL,CAAC;IAEO,aAAa;QACjB,MAAM,CAAC,IAAI,CAAC,IAAI,CAAC,MAAM,CAAC,CAAC,OAAO,CAAC,CAAC,UAAU,EAAE,EAAE;YAC5C,IAAI,CAAC,MAAM,CAAC,UAAU,CAAC;gBACnB,IAAI,CAAC,SAAS,CAAC,YAAY,CAAC,UAAU,UAAU,EAAE,EAAE,IAAI,CAAC,MAAM,CAAC,UAAU,CAAc,CAAC,CAAC;QAClG,CAAC,CAAC,CAAC;QAEH,IAAI,CAAC,SAAS,CAAC,YAAY,CAAC,KAAK,EAAE,IAAI,CAAC,GAAG,CAAC,CAAC;QAC7C,MAAM,MAAM,GAAG,IAAI,wCAAY,CAAC,IAAI,CAAC,SAAS,CAAC,CAAC;QAEhD,MAAM,CAAC,IAAI,CAAC,GAAG,SAAS,KAAK,CAAC,CAAC;QAC/B,MAAM,CAAC,IAAI,CAAC,GAAG,IAAI,CAAC,GAAG,KAAK,CAAC,CAAC;QAE9B,IAAI,CAAC,MAAM,GAAG,IAAI,CAAC,SAAS,CAAC,GAAG,CAAC,QAAQ,CAAC,CAAC;QAE3C,IAAI,CAAC,SAAS,CAAC,MAAM,GAAG,EAAE,IAAI,EAAE,CAAC,GAAG,EAAE,EAAE,CAAC,IAAI,CAAC,MAAM,CAAC,OAAO,CAAC,GAAG,CAAC,EAAE,CAAC;QAEpE,IAAI,CAAC,MAAM,CAAC,KAAK,CAAC,kCAAkC,CAAC,CAAC;IAC1D,CAAC;IAEO,KAAK,CAAC,QAAQ;QAClB,IAAI,CAAC,cAAc,GAAG,MAAM,IAAA,cAAO,EAAC;YAChC,OAAO,EAAE,IAAI,CAAC,MAAM,CAAC,QAAkB;SAC1C,CAAC,CAAC;QAEH,IAAI,CAAC,SAAS,CAAC,QAAQ,CAAC,gBAAgB,CAAC,CAAC;QAC1C,IAAI,CAAC,SAAS,CAAC,GAAG,CAAC,gBAAgB,EAAE,IAAI,CAAC,cAAc,CAAC,CAAC;QAE1D,IAAI,CAAC,eAAe,GAAG,IAAI,CAAC,cAAc,CAAC,SAAS,EAAE,CAAC;QAEvD,IAAI,CAAC,SAAS,CAAC,QAAQ,CAAC,iBAAiB,CAAC,CAAC;QAC3C,IAAI,CAAC,SAAS,CAAC,GAAG,CAAC,iBAAiB,EAAE,IAAI,CAAC,eAAe,CAAC,CAAC;QAE5D,IAAI,CAAC,MAAM,CAAC,KAAK,CAAC,gCAAgC,IAAI,CAAC,MAAM,CAAC,QAAQ,mCAAmC,CAAC,CAAC;IAC/G,CAAC;IAEO,KAAK,CAAC,YAAY;QACtB,MAAM,GAAG,GAAG,KAAK,CAAC,IAAI,CAAC,IAAI,CAAC,SAAS,CAAC,oBAAoB,CAAC,eAAe,CAAC,CAAC,IAAI,EAAE,CAAC,CAAC;QAEpF,MAAM,OAAO,CAAC,GAAG,CACb,GAAG,CAAC,GAAG,CAAC,KAAK,EAAE,EAAE,EAAE,EAAE;YACjB,MAAM,MAAM,GAAG,IAAI,CAAC,SAAS,CAAC,GAAG,CAAC,EAAE,CAAC,CAAC;YAEtC,MAAM,MAAM,CAAC,KAAK,EAAE,CAAC;QACzB,CAAC,CAAC,CACL,CAAC;IACN,CAAC;IAEO,KAAK,CAAC,oBAAoB;QAC9B,MAAM,GAAG,GAAG,KAAK,CAAC,IAAI,CAAC,IAAI,CAAC,SAAS,CAAC,oBAAoB,CAAC,cAAc,CAAC,CAAC,IAAI,EAAE,CAAC,CAAC;QAEnF,GAAG,CAAC,OAAO,CAAC,CAAC,EAAE,EAAE,EAAE;YACf,MAAM,OAAO,GAAG,IAAI,CAAC,SAAS,CAAC,GAAG,CAAC,EAAE,CAAC,CAAC;YAEvC,IAAI,OAAO,YAAY,yBAAc,EAAE;gBACnC,IAAI,CAAC,sBAAsB,CAAC,OAAO,CAAC,CAAC;aACxC;iBAAM,IAAI,OAAO,YAAY,yBAAc,EAAE;gBAC1C,IAAI,CAAC,sBAAsB,CAAC,OAAO,CAAC,CAAC;aACxC;iBAAM;gBACH,MAAM,IAAI,KAAK,CAAC,yDAAyD,CAAC,CAAC;aAC9E;QACL,CAAC,CAAC,CAAC;IACP,CAAC;IAEO,KAAK,CAAC,0BAA0B;QACpC,MAAM,GAAG,GAAG,KAAK,CAAC,IAAI,CAAC,IAAI,CAAC,SAAS,CAAC,oBAAoB,CAAC,eAAe,CAAC,CAAC,IAAI,EAAE,CAAC,CAAC;QAEpF,GAAG,CAAC,OAAO,CAAC,CAAC,EAAE,EAAE,EAAE;YACf,MAAM,QAAQ,GAAG,IAAI,CAAC,SAAS,CAAC,GAAG,CAAC,EAAE,CAAC,CAAC;YAExC,IAAI,QAAQ,YAAY,+CAA4B,IAAI,QAAQ,YAAY,+CAA4B,EAAE;gBACtG,IAAI,CAAC,yBAAyB,CAAC,QAAQ,CAAC,CAAC;aAC5C;iBAAM;gBACH,MAAM,IAAI,KAAK,CAAC,8EAA8E,CAAC,CAAC;aACnG;QACL,CAAC,CAAC,CAAC;IACP,CAAC;IAEO,sBAAsB,CAAC,OAAuB;QAClD,IAAI,OAAO,CAAC;QAEZ,IAAI,OAAO,CAAC,oBAAoB,EAAE;YAC9B,OAAO,GAAG,GAAG,IAAI,CAAC,MAAM,CAAC,YAAY,IAAI,OAAO,CAAC,OAAO,EAAE,CAAC;SAC9D;aAAM;YACH,OAAO,GAAG,OAAO,CAAC,OAAO,CAAC;SAC7B;QAED,IAAI,CAAC,MAAM,CAAC,KAAK,CAAC,mCAAmC,OAAO,EAAE,CAAC,CAAC;QAChE,MAAM,mBAAmB,GAAG,OAAO,CAAC,sBAAsB,EAAE,CAAC;QAE7D,MAAM,YAAY,GAAG,IAAI,CAAC,cAAc,CAAC,SAAS,CAAC,OAAO,EAAE,mBAAmB,CAAC,CAAC;QAEjF,IAAI,CAAC,oBAAoB,CAAC,YAAY,EAAE,OAAO,CAAC,CAAC;IACrD,CAAC;IAEO,sBAAsB,CAAC,OAAuB;QAClD,MAAM,OAAO,GAAG,GAAG,OAAO,CAAC,IAAI,IAAI,IAAI,CAAC,MAAM,CAAC,YAAY,IAAI,OAAO,CAAC,OAAO,EAAE,CAAC;QACjF,IAAI,CAAC,MAAM,CAAC,KAAK,CAAC,mCAAmC,OAAO,EAAE,CAAC,CAAC;QAChE,MAAM,mBAAmB,GAAG,OAAO,CAAC,sBAAsB,EAAE,CAAC;QAE7D,MAAM,YAAY,GAAG,IAAI,CAAC,cAAc,CAAC,SAAS,CAAC,OAAO,EAAE,mBAAmB,CAAC,CAAC;QAEjF,IAAI,CAAC,oBAAoB,CAAC,YAAY,EAAE,OAAO,CAAC,CAAC;IACrD,CAAC;IAED,KAAK,CAAC,oBAAoB,CAAC,YAA0B,EAAE,OAAuB;QAC1E,IAAI,KAAK,EAAE,MAAM,OAAO,IAAI,YAAY,EAAE;YACtC,IAAI;gBACA,MAAM,QAAQ,GAAG,MAAM,OAAO,CAAC,MAAM,CAAC,IAAI,yBAAc,CAAC,OAAO,CAAC,CAAC,CAAC;gBAEnE,OAAO,CAAC,OAAO,CAAC,IAAI,CAAC,SAAS,CAAC,MAAM,CAAC,QAAQ,CAAC,CAAC,CAAC;aACpD;YAAC,OAAO,GAAG,EAAE;gBACV,IAAI,CAAC,MAAM,CAAC,KAAK,CAAE,GAAa,CAAC,OAAO,CAAC,CAAC;gBAC1C,OAAO,CAAC,OAAO,CACX,IAAI,CAAC,SAAS,CAAC,MAAM,CAAC;oBAClB,KAAK,EACD,GAAG,YAAY,iBAAQ;wBACnB,CAAC,CAAC,IAAI,CAAC,SAAS,CAAC,EAAE,GAAG,GAAG,EAAE,MAAM,EAAE,SAAS,EAAE,CAAC;wBAC/C,CAAC,CAAE,GAAa,CAAC,OAAO;iBACnC,CAAC,CACL,CAAC;aACL;SACJ;IACL,CAAC;IAED,KAAK,CAAC,oBAAoB,CAAC,YAA0B,EAAE,OAAuB;QAC1E,IAAI,KAAK,EAAE,MAAM,OAAO,IAAI,YAAY,EAAE;YACtC,IAAI;gBACA,MAAM,QAAQ,GAAG,MAAM,OAAO,CAAC,MAAM,CAAC,IAAI,kBAAO,CAAC,OAAO,CAAC,CAAC,CAAC;gBAE5D,OAAO,CAAC,OAAO,CAAC,IAAI,CAAC,SAAS,CAAC,MAAM,CAAC,QAAQ,CAAC,CAAC,CAAC;aACpD;YAAC,OAAO,GAAG,EAAE;gBACV,IAAI,CAAC,MAAM,CAAC,KAAK,CAAE,GAAa,CAAC,OAAO,CAAC,CAAC;gBAC1C,OAAO,CAAC,OAAO,CACX,IAAI,CAAC,SAAS,CAAC,MAAM,CAAC;oBAClB,KAAK,EACD,GAAG,YAAY,iBAAQ;wBACnB,CAAC,CAAC,IAAI,CAAC,SAAS,CAAC,EAAE,GAAG,GAAG,EAAE,MAAM,EAAE,SAAS,EAAE,CAAC;wBAC/C,CAAC,CAAE,GAAa,CAAC,OAAO;iBACnC,CAAC,CACL,CAAC;aACL;SACJ;IACL,CAAC;IAEO,KAAK,CAAC,yBAAyB,CAAC,QAAqE;QACzG,MAAM,QAAQ,CAAC,SAAS,EAAE,CAAC;QAE3B,IAAI,CAAC,sBAAsB,CAAC,QAAQ,CAAC,CAAC;QAEtC,QAAQ,CAAC,OAAO,EAAE,CAAC;IACvB,CAAC;IAED,KAAK,CAAC,sBAAsB,CAAC,QAAqE;QAC9F,MAAM,YAAY,GAAG,QAAQ,CAAC,eAAe,EAAE,CAAC;QAEhD,IAAI,KAAK,EAAE,MAAM,OAAO,IAAI,YAAY,EAAE;YACtC,IAAI;gBACA,MAAM,QAAQ,CAAC,MAAM,CAAC,IAAI,2BAAgB,CAAC,OAAO,CAAC,CAAC,CAAC;aACxD;YAAC,OAAO,GAAG,EAAE;gBACV,IAAI,CAAC,MAAM,CAAC,KAAK,CACb,sDAAsD,OAAO,CAAC,GAAG,MAAM,IAAI,CAAC,SAAS,CACjF,GAAG,CACN,gCAAgC,CACpC,CAAC;gBAKF,OAAO,CAAC,IAAI,EAAE,CAAC;aAClB;SACJ;IACL,CAAC;IAEO,sBAAsB;QAC1B,MAAM,kBAAkB,GAAG,KAAK,IAAI,EAAE;YAClC,IAAI,CAAC,MAAM,CAAC,KAAK,CAAC,wCAAwC,CAAC,CAAC;YAC5D,MAAM,IAAI,CAAC,cAAc,CAAC,KAAK,EAAE,CAAC;YAClC,IAAI,CAAC,MAAM,CAAC,KAAK,CAAC,wBAAwB,CAAC,CAAC;YAC5C,OAAO,CAAC,IAAI,CAAC,CAAC,CAAC,CAAC;QACpB,CAAC,CAAC;QAEF,OAAO,CAAC,EAAE,CAAC,QAAQ,EAAE,kBAAkB,CAAC,CAAC;QACzC,OAAO,CAAC,EAAE,CAAC,SAAS,EAAE,kBAAkB,CAAC,CAAC;IAC9C,CAAC;CACJ;AAlOD,gCAkOC"}

dist/openApi.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"openApi.js","sourceRoot":"","sources":["../src/openApi.ts"],"names":[],"mappings":";;;;;;AAAA,4CAAoB;AAKpB,yCAA0C;AAI1C,MAAa,cAAe,SAAQ,yBAAc;IAW9C,YAAoB,GAAW,EAAU,YAAoB,EAAU,MAAc;QACjF,KAAK,EAAE,CAAC;QADQ,QAAG,GAAH,GAAG,CAAQ;QAAU,iBAAY,GAAZ,YAAY,CAAQ;QAAU,WAAM,GAAN,MAAM,CAAQ;QAV5E,YAAO,GAAG,MAAM,CAAC;QACjB,yBAAoB,GAAG,KAAK,CAAC;QAYlC,IAAI,QAAQ,CAAC;QAEb,IAAI;YACA,MAAM,IAAI,GAAG,MAAM,CAAC,YAAE,CAAC,YAAY,CAAC,GAAG,IAAI,CAAC,GAAG,oBAAoB,CAAC,CAAC,CAAC;YACtE,QAAQ,GAAG,IAAI,CAAC,KAAK,CAAC,IAAI,CAAC,CAAC;SAC/B;QAAC,OAAO,GAAG,EAAE;YACV,IAAI,CAAC,MAAM,CAAC,OAAO,CAAC,8BAA8B,CAAC,CAAC;SACvD;QAED,IAAI,CAAC,QAAQ,GAAG,QAAQ,CAAC;IAC7B,CAAC;IAnBD,sBAAsB;QAClB,OAAO;YACH,KAAK,EAAE,IAAI,CAAC,YAAY;SAC3B,CAAC;IACN,CAAC;IAiBD,KAAK,CAAC,MAAM;QACR,OAAO,IAAI,CAAC,QAAQ,CAAC;IACzB,CAAC;CACJ;AA7BD,wCA6BC"}
+{"version":3,"file":"openApi.js","sourceRoot":"","sources":["../src/openApi.ts"],"names":[],"mappings":";;;;;;AAAA,4CAAoB;AAKpB,yCAA4C;AAI5C,MAAa,cAAe,SAAQ,yBAAc;IAW9C,YAAoB,GAAW,EAAU,YAAoB,EAAU,MAAc;QACjF,KAAK,EAAE,CAAC;QADQ,QAAG,GAAH,GAAG,CAAQ;QAAU,iBAAY,GAAZ,YAAY,CAAQ;QAAU,WAAM,GAAN,MAAM,CAAQ;QAV5E,YAAO,GAAG,MAAM,CAAC;QACjB,yBAAoB,GAAG,KAAK,CAAC;QAYlC,IAAI,QAAQ,CAAC;QAEb,IAAI;YACA,MAAM,IAAI,GAAG,MAAM,CAAC,YAAE,CAAC,YAAY,CAAC,GAAG,IAAI,CAAC,GAAG,oBAAoB,CAAC,CAAC,CAAC;YACtE,QAAQ,GAAG,IAAI,CAAC,KAAK,CAAC,IAAI,CAAC,CAAC;SAC/B;QAAC,OAAO,GAAG,EAAE;YACV,IAAI,CAAC,MAAM,CAAC,OAAO,CAAC,8BAA8B,CAAC,CAAC;SACvD;QAED,IAAI,CAAC,QAAQ,GAAG,QAAQ,CAAC;IAC7B,CAAC;IAnBD,sBAAsB;QAClB,OAAO;YACH,KAAK,EAAE,IAAI,CAAC,YAAY;SAC3B,CAAC;IACN,CAAC;IAiBD,KAAK,CAAC,MAAM;QACR,OAAO,IAAI,CAAC,QAAQ,CAAC;IACzB,CAAC;CACJ;AA7BD,wCA6BC"}

package.json

 {
     "name": "@jwalab/nats-runner",
-    "version": "0.0.3",
+    "version": "0.0.4",
     "description": "",
@@ -24,3 +24,3 @@ "main": "dist/index.js",
     "peerDependencies": {
-        "nats": "^2.1.0"
+        "nats": "^2.4.0"
     },
@@ -27,0 +27,0 @@ "scripts": {

New alerts

New author

Supply chain risk

A new npm collaborator published a version of the package for the first time. New collaborators are usually benign additions to a project, but do indicate a change to the security surface area of a package.

Found 1 instance in 1 package

Filesystem access

Supply chain risk

Accesses the file system, and could potentially read sensitive data.

Found 1 instance in 1 package

Fixed alerts

Filesystem access

Supply chain risk

Accesses the file system, and could potentially read sensitive data.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

39303

25.22%

Number of package files

31

10.71%

Lines of code

626

26.72%

Worsened metrics

Number of medium supply chain risk alerts

1

Infinity%

No dependency changes