Version Packages

github-actions[bot] · github-actions[bot] · commit 6bd2f98d1ae6 · 2025-10-27T20:45:01.000Z
diff --git a/.changeset/fine-taxes-drive.md b/.changeset/fine-taxes-drive.md
diff --git a/.changeset/neat-moose-juggle.md b/.changeset/neat-moose-juggle.md
diff --git a/.changeset/sweet-oranges-cut.md b/.changeset/sweet-oranges-cut.md
diff --git a/.changeset/wet-sites-juggle.md b/.changeset/wet-sites-juggle.md
diff --git a/packages/adapter-drizzle/CHANGELOG.md b/packages/adapter-drizzle/CHANGELOG.md
@@ -1,5 +1,20 @@
 # @vorsteh-queue/adapter-drizzle
 
+## 0.4.0
+
+### Minor Changes
+
+- b18ec50: Added support for batch processing
+
+### Patch Changes
+
+- 6e5b82c: update dependencies
+- 35f7171: updated versions
+- Updated dependencies [6e5b82c]
+- Updated dependencies [66c4848]
+- Updated dependencies [35f7171]
+  - @vorsteh-queue/core@0.4.0
+
 ## 0.3.3
 
 ### Patch Changes
diff --git a/packages/adapter-drizzle/package.json b/packages/adapter-drizzle/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@vorsteh-queue/adapter-drizzle",
-  "version": "0.3.3",
+  "version": "0.4.0",
   "description": "Drizzle ORM adapter for Vorsteh Queue with PostgreSQL support",
   "keywords": [
     "queue",
diff --git a/packages/adapter-kysely/CHANGELOG.md b/packages/adapter-kysely/CHANGELOG.md
@@ -1,5 +1,20 @@
 # @vorsteh-queue/adapter-kysely
 
+## 0.2.0
+
+### Minor Changes
+
+- b18ec50: Added support for batch processing
+
+### Patch Changes
+
+- 6e5b82c: update dependencies
+- 35f7171: updated versions
+- Updated dependencies [6e5b82c]
+- Updated dependencies [66c4848]
+- Updated dependencies [35f7171]
+  - @vorsteh-queue/core@0.4.0
+
 ## 0.1.1
 
 ### Patch Changes
diff --git a/packages/adapter-kysely/package.json b/packages/adapter-kysely/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@vorsteh-queue/adapter-kysely",
-  "version": "0.1.1",
+  "version": "0.2.0",
   "description": "Kysely adapter for Vorsteh Queue with PostgreSQL support",
   "keywords": [
     "queue",
diff --git a/packages/adapter-prisma/CHANGELOG.md b/packages/adapter-prisma/CHANGELOG.md
@@ -1,5 +1,20 @@
 # @vorsteh-queue/adapter-prisma
 
+## 0.3.0
+
+### Minor Changes
+
+- b18ec50: Added support for batch processing
+
+### Patch Changes
+
+- 6e5b82c: update dependencies
+- 35f7171: updated versions
+- Updated dependencies [6e5b82c]
+- Updated dependencies [66c4848]
+- Updated dependencies [35f7171]
+  - @vorsteh-queue/core@0.4.0
+
 ## 0.2.3
 
 ### Patch Changes
diff --git a/packages/adapter-prisma/package.json b/packages/adapter-prisma/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@vorsteh-queue/adapter-prisma",
-  "version": "0.2.3",
+  "version": "0.3.0",
   "description": "Prisma ORM adapter for Vorsteh Queue with PostgreSQL support",
   "keywords": [
     "queue",
diff --git a/packages/core/CHANGELOG.md b/packages/core/CHANGELOG.md
@@ -1,5 +1,53 @@
 # @vorsteh-queue/core
 
+## 0.4.0
+
+### Minor Changes
+
+- 66c4848: ### Added
+  - Batch processing support: You can now register batch handlers via `queue.registerBatch`, allowing the queue to process multiple jobs at once according to configurable batch sizes and timing.
+  - New `batch` configuration options: `minSize`, `maxSize`, and `waitFor` allow fine-grained control over when and how batches are processed.
+  - Type-safe batch jobs: Batch jobs are strictly separated from scheduled/single jobs and **do not support** cron, delay, or repeat options.
+  - Adapter API extended: All core adapters now support efficient batch operations.
+  - Events for batch lifecycle: The queue emits `batch:processing`, `batch:completed`, and `batch:failed` events for batch jobs.
+
+  **Handler exclusivity:** A queue can handle only batch jobs or single jobs — not both. Attempting to register both handler types in the same queue will throw an error. This ensures clear and predictable processing.
+
+  #### Example
+
+  ```ts
+  import { MemoryQueueAdapter, Queue } from "@vorsteh-queue/core"
+
+  type EmailPayload = { to: string; body: string }
+  type EmailResult = { ok: boolean }
+
+  const adapter = new MemoryQueueAdapter()
+  const queue = new Queue<EmailPayload, EmailResult>(adapter, {
+    name: "batch-demo",
+    batch: { minSize: 5, maxSize: 20, waitFor: 1000 },
+  })
+
+  queue.registerBatch("send-emails", async (jobs) => {
+    // jobs is an array of up to 20 jobs
+    await sendBulkEmails(jobs.map((j) => j.payload))
+    return jobs.map(() => ({ ok: true }))
+  })
+
+  // Add jobs as usual
+  await queue.addJobs("send-emails", [
+    { to: "a@example.com", body: "Hi A" },
+    { to: "b@example.com", body: "Hi B" },
+    // ...
+  ])
+
+  queue.start()
+  ```
+
+### Patch Changes
+
+- 6e5b82c: update dependencies
+- 35f7171: updated versions
+
 ## 0.3.2
 
 ### Patch Changes
diff --git a/packages/core/package.json b/packages/core/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@vorsteh-queue/core",
-  "version": "0.3.2",
+  "version": "0.4.0",
   "description": "Core queue engine for Vorsteh Queue with TypeScript support, job scheduling, and event system",
   "keywords": [
     "queue",
diff --git a/packages/create-vorsteh-queue/CHANGELOG.md b/packages/create-vorsteh-queue/CHANGELOG.md
@@ -1,5 +1,12 @@
 # create-vorsteh-queue
 
+## 0.1.5
+
+### Patch Changes
+
+- 6e5b82c: update dependencies
+- 35f7171: updated versions
+
 ## 0.1.4
 
 ### Patch Changes
diff --git a/packages/create-vorsteh-queue/package.json b/packages/create-vorsteh-queue/package.json
@@ -1,6 +1,6 @@
 {
   "name": "create-vorsteh-queue",
-  "version": "0.1.4",
+  "version": "0.1.5",
   "description": "Create Vorsteh Queue applications with one command",
   "keywords": [
     "vorsteh-queue",

Original file line number	Diff line number	Diff line change
`@@ -1,6 +1,6 @@`
`1`	`1`	`{`
`2`	`2`	`"name": "@vorsteh-queue/adapter-drizzle",`
`3`		`- "version": "0.3.3",`
	`3`	`+ "version": "0.4.0",`
`4`	`4`	`"description": "Drizzle ORM adapter for Vorsteh Queue with PostgreSQL support",`
`5`	`5`	`"keywords": [`
`6`	`6`	`"queue",`
Original file line number	Diff line number	Diff line change
`@@ -1,6 +1,6 @@`
`1`	`1`	`{`
`2`	`2`	`"name": "@vorsteh-queue/adapter-kysely",`
`3`		`- "version": "0.1.1",`
	`3`	`+ "version": "0.2.0",`
`4`	`4`	`"description": "Kysely adapter for Vorsteh Queue with PostgreSQL support",`
`5`	`5`	`"keywords": [`
`6`	`6`	`"queue",`
Original file line number	Diff line number	Diff line change
`@@ -1,6 +1,6 @@`
`1`	`1`	`{`
`2`	`2`	`"name": "@vorsteh-queue/adapter-prisma",`
`3`		`- "version": "0.2.3",`
	`3`	`+ "version": "0.3.0",`
`4`	`4`	`"description": "Prisma ORM adapter for Vorsteh Queue with PostgreSQL support",`
`5`	`5`	`"keywords": [`
`6`	`6`	`"queue",`