@nestjs-plugins/nestjs-nats-jetstream-transport - npm Package Compare versions

Comparing version 1.3.15 to 1.4.4

dist/client.js

@@ -37,3 +37,2 @@ "use strict";
         await this.nc.drain();
-        await this.nc.close();
         this.nc = undefined;
@@ -40,0 +39,0 @@ }

dist/index.d.ts

@@ -12,2 +12,1 @@ export * from './server';
 export * from './nats-jetstream.context';
-export * from './nats-jetstream-client';

dist/index.js

@@ -28,3 +28,2 @@ "use strict";
 __exportStar(require("./nats-jetstream.context"), exports);
-__exportStar(require("./nats-jetstream-client"), exports);
 //# sourceMappingURL=index.js.map

dist/interfaces/nats-stream-config.interface.d.ts

 import { StreamConfig } from 'nats';
-declare type $StreamConfig = Pick<StreamConfig, 'storage' | 'retention' | 'discard' | 'max_msgs' | 'max_msgs_per_subject' | 'max_msg_size' | 'max_age' | 'duplicate_window' | 'num_replicas'>;
+type $StreamConfig = Pick<StreamConfig, 'storage' | 'retention' | 'discard' | 'max_msgs' | 'max_msgs_per_subject' | 'max_msg_size' | 'max_age' | 'duplicate_window' | 'num_replicas'>;
 export interface NatsStreamConfig extends Partial<$StreamConfig> {
@@ -4,0 +4,0 @@ name: string;

dist/nats-jetstream-transport.module.d.ts

 import { DynamicModule } from '@nestjs/common';
-import { NatsJetStreamClientOptions } from './interfaces/nats-jetstream-client-options.interface';
+import { NatsJetStreamClientAsyncOptions, NatsJetStreamClientOptions } from './interfaces/nats-jetstream-client-options.interface';
 export declare class NatsJetStreamTransport {
     static register(options: NatsJetStreamClientOptions): DynamicModule;
-    static registerAsync(options: any): DynamicModule;
+    static registerAsync(options: NatsJetStreamClientAsyncOptions): DynamicModule;
 }

dist/nats-jetstream-transport.module.js

@@ -6,3 +6,2 @@ "use strict";
 const constants_1 = require("./constants");
-const nats_jetstream_client_1 = require("./nats-jetstream-client");
 class NatsJetStreamTransport {
@@ -34,5 +33,4 @@ static register(options) {
                 client_1.NatsJetStreamClientProxy,
-                nats_jetstream_client_1.NatsJetStreamClient,
             ],
-            exports: [client_1.NatsJetStreamClientProxy, nats_jetstream_client_1.NatsJetStreamClient],
+            exports: [client_1.NatsJetStreamClientProxy],
         };
@@ -39,0 +37,0 @@ }

dist/nats-jetstream.context.d.ts

 import { BaseRpcContext } from '@nestjs/microservices/ctx-host/base-rpc.context';
 import { JsMsg, Msg } from 'nats';
-export declare type NatsJetStreamContextArgs = [JsMsg];
-export declare type NatsContextArgs = [Msg];
+export type NatsJetStreamContextArgs = [JsMsg];
+export type NatsContextArgs = [Msg];
 export declare class NatsJetStreamContext extends BaseRpcContext<NatsJetStreamContextArgs> {
@@ -6,0 +6,0 @@ constructor(args: NatsJetStreamContextArgs);

dist/server.js

@@ -34,3 +34,2 @@ "use strict";
         await this.nc.drain();
-        await this.nc.close();
         this.nc = undefined;
@@ -105,3 +104,2 @@ }
             this.logger.log(`Stream ${streamInfo.config.name} created`);
-            console.log(streamInfo.config);
         }
@@ -108,0 +106,0 @@ }

package.json

 {
   "name": "@nestjs-plugins/nestjs-nats-jetstream-transport",
-  "version": "1.3.15",
+  "version": "1.4.4",
   "description": "Nats JetStream Transport for NestJS",
@@ -51,3 +51,3 @@ "main": "dist/index.js",
   },
-  "gitHead": "bffe2ffcccbf2bcec3b1f141f07b498d1741943b"
+  "gitHead": "a9a2ca123d6b5e4eb59af5a34897365b403c076a"
 }

README.md

@@ -175,3 +175,3 @@ # 🚀 Nats JetStream Transport Module for NestJS
   controllers: [AppController],
-  providers: [AppService, NatsJetStreamClient],
+  providers: [AppService],
 })
@@ -184,3 +184,3 @@ export class AppModule {}
 
-import { NatsJetStreamClient } from '@nestjs-plugins/nestjs-nats-jetstream-transport';
+import { NatsJetStreamClientProxy } from '@nestjs-plugins/nestjs-nats-jetstream-transport';
 import { Injectable } from '@nestjs/common';
@@ -209,3 +209,3 @@ import { PubAck } from 'nats';
 export class AppService {
-  constructor(private client: NatsJetStreamClient) {}
+  constructor(private client: NatsJetStreamClientProxy) {}
 
@@ -212,0 +212,0 @@ createOrder(): string {

No alert changes

Improved metrics

Total package byte prevSize

171977

increased by13.45%

Worsened metrics

Number of package files

40

decreased by-6.98%

Lines of code

435

decreased by-11.04%

No dependency changes