change(jetstream): removed jsclient#fetch()/pullSubscribe()/subscribe…

…() and related configuration options such as ConsumerOpts, ConsumerOptsBuilder, and consumerOpts(), and related tests. bump(*): deps, and synchronized lib internal dependencies to match Signed-off-by: Alberto Ricart <[email protected]>
nats-io · Oct 18, 2024 · f1d61f8 · f1d61f8
1 parent d406ba1
commit f1d61f8
Show file tree

Hide file tree

Showing 30 changed files with 151 additions and 2,964 deletions.
diff --git a/TODO.md b/TODO.md
@@ -3,3 +3,9 @@
 ## BUGS
 
 - ObjectStore should report the number of entries in it.
+
+- no_wait for Consumer args.no_wait = opts.no_wait || false; if (args.no_wait &&
+  args.expires) { args.expires = 0; }
+- headers_only is needed in Consumer
+
+- add a test for next/fetch/consume where message size smaller than availablle
diff --git a/core/deno.json b/core/deno.json
@@ -1,6 +1,6 @@
 {
   "name": "@nats-io/nats-core",
-  "version": "3.0.0-27",
+  "version": "3.0.0-28",
   "exports": {
     ".": "./src/mod.ts",
     "./internal": "./src/internal_mod.ts"

diff --git a/core/package.json b/core/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@nats-io/nats-core",
-  "version": "3.0.0-27",
+  "version": "3.0.0-28",
   "files": [
     "lib/",
     "LICENSE",
@@ -24,7 +24,9 @@
     "build-cjs": "npm run pre-process && tsc",
     "build": "npm run build-cjs",
     "doc": "npm run build && node_modules/.bin/typedoc --out ../docs/core && touch ../docs/core/.nojekyll",
-    "prepack": "npm run build"
+    "prepack": "npm run build",
+    "bump-qualifier": "npm version prerelease --no-commit-hooks --no-git-tag-version",
+    "bump-release": "npm version patch --no-commit-hooks --no-git-tag-version"
   },
   "keywords": [],
   "author": {
@@ -36,9 +38,9 @@
     "@nats-io/nuid": "2.0.1-2"
   },
   "devDependencies": {
-    "@types/node": "^22.0.0",
+    "@types/node": "^22.7.6",
     "shx": "^0.3.4",
-    "typedoc": "^0.26.5",
+    "typedoc": "^0.26.10",
     "typescript": "^5.5.4"
   }
 }
diff --git a/core/src/version.ts b/core/src/version.ts
@@ -1,2 +1,2 @@
 // This file is generated - do not edit
-export const version = "3.0.0-27";
+export const version = "3.0.0-28";
diff --git a/jetstream/deno.json b/jetstream/deno.json
@@ -1,6 +1,6 @@
 {
   "name": "@nats-io/jetstream",
-  "version": "3.0.0-11",
+  "version": "3.0.0-13",
   "exports": {
     ".": "./src/mod.ts",
     "./internal": "./src/internal_mod.ts"
@@ -33,6 +33,6 @@
     "test": "deno test -A --parallel --reload --trace-leaks --quiet tests/ --import-map=import_map.json"
   },
   "imports": {
-    "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-27"
+    "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-28"
   }
 }
diff --git a/jetstream/import_map.json b/jetstream/import_map.json
@@ -2,8 +2,8 @@
   "imports": {
     "@nats-io/nkeys": "jsr:@nats-io/[email protected]",
     "@nats-io/nuid": "jsr:@nats-io/[email protected]",
-    "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-27",
-    "@nats-io/nats-core/internal": "jsr:@nats-io/nats-core@~3.0.0-27/internal",
+    "@nats-io/nats-core": "jsr:@nats-io/nats-core@~3.0.0-28",
+    "@nats-io/nats-core/internal": "jsr:@nats-io/nats-core@~3.0.0-28/internal",
     "test_helpers": "../test_helpers/mod.ts",
     "@std/io": "jsr:@std/[email protected]"
   }

diff --git a/jetstream/package.json b/jetstream/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@nats-io/jetstream",
-  "version": "3.0.0-11",
+  "version": "3.0.0-13",
   "files": [
     "lib/",
     "LICENSE",
@@ -24,20 +24,22 @@
     "build-cjs": "npm run pre-process && tsc",
     "build": "npm run build-cjs",
     "doc": "npm run build && node_modules/.bin/typedoc --out ../docs/jetstream && touch ../docs/jetstream/.nojekyll",
-    "prepack": "npm run build"
+    "prepack": "npm run build",
+    "bump-qualifier": "npm version prerelease --no-commit-hooks --no-git-tag-version",
+    "bump-release": "npm version patch --no-commit-hooks --no-git-tag-version"
   },
   "keywords": [],
   "author": {
     "name": "The NATS Authors"
   },
   "description": "jetstream library - this library implements all the base functionality for NATS JetStream for javascript clients",
   "dependencies": {
-    "@nats-io/nats-core": "~3.0.0-27"
+    "@nats-io/nats-core": "~3.0.0-28"
   },
   "devDependencies": {
-    "@types/node": "^22.0.0",
+    "@types/node": "^22.7.6",
     "shx": "^0.3.4",
-    "typedoc": "^0.26.5",
-    "typescript": "^5.5.4"
+    "typedoc": "^0.26.10",
+    "typescript": "^5.6.3"
   }
 }
diff --git a/jetstream/src/internal_mod.ts b/jetstream/src/internal_mod.ts
@@ -18,10 +18,8 @@ export {
   AdvisoryKind,
   ConsumerDebugEvents,
   ConsumerEvents,
-  consumerOpts,
   DirectMsgHeaders,
   isBoundPushConsumerOptions,
-  isConsumerOptsBuilder,
   isOrderedPushConsumerOptions,
   isPullConsumer,
   isPushConsumer,
@@ -49,11 +47,8 @@ export type {
   Consumer,
   ConsumerAPI,
   ConsumerCallbackFn,
-  ConsumerInfoable,
   ConsumerKind,
   ConsumerMessages,
-  ConsumerOpts,
-  ConsumerOptsBuilder,
   Consumers,
   ConsumerStatus,
   DeleteableConsumer,
@@ -70,11 +65,6 @@ export type {
   JetStreamManagerOptions,
   JetStreamOptions,
   JetStreamPublishOptions,
-  JetStreamPullSubscription,
-  JetStreamSubscription,
-  JetStreamSubscriptionInfoable,
-  JetStreamSubscriptionOptions,
-  JsMsgCallback,
   Lister,
   ListerFieldFilter,
   MaxBytes,
@@ -83,7 +73,6 @@ export type {
   OrderedConsumerOptions,
   OrderedPushConsumerOptions,
   PubAck,
-  Pullable,
   PushConsumer,
   PushConsumerOptions,
   StoredMsg,