Skip to content

Commit 4dabd12

Browse files
Version Packages
1 parent 7e75656 commit 4dabd12

File tree

9 files changed

+89
-75
lines changed

9 files changed

+89
-75
lines changed

.changeset/core-changes.md

Lines changed: 0 additions & 8 deletions
This file was deleted.

.changeset/cruel-eggs-call.md

Lines changed: 0 additions & 36 deletions
This file was deleted.

.changeset/drizzle-changes.md

Lines changed: 0 additions & 28 deletions
This file was deleted.

packages/adapter-drizzle/CHANGELOG.md

Lines changed: 33 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,38 @@
11
# @vorsteh-queue/adapter-drizzle
22

3+
## 0.2.0
4+
5+
### Minor Changes
6+
7+
- 51f5968: - `PostgresQueueAdapter`: Constructor simplified
8+
- **BREAKING**: Removed MariaDB/MySQL support due to timezone handling complexities
9+
- I tried my best to make it work, but failed successfully
10+
- **BREAKING**: Fixed UTC-first timezone handling - all timestamps now stored as UTC
11+
12+
**Before (duplicate queue name)**
13+
14+
```ts
15+
const adapter = new PostgresQueueAdapter(db, "my-queue")
16+
const queue = new Queue(adapter, { name: "my-queue" })
17+
```
18+
19+
**After (single queue name):**
20+
21+
```ts
22+
const adapter = new PostgresQueueAdapter(db)
23+
const queue = new Queue(adapter, { name: "my-queue" })
24+
```
25+
26+
**Timezone Changes:**
27+
- Database schema now uses UTC defaults: `timezone('utc', now())` for PostgreSQL
28+
- Application timestamps stored as UTC using `toISOString()::timestamptz`
29+
- Consistent UTC-first behavior for reliable timezone handling
30+
31+
### Patch Changes
32+
33+
- Updated dependencies [51f5968]
34+
- @vorsteh-queue/core@0.2.0
35+
336
## 0.1.0
437

538
### Minor Changes

packages/adapter-drizzle/package.json

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
{
22
"name": "@vorsteh-queue/adapter-drizzle",
3-
"version": "0.1.0",
3+
"version": "0.2.0",
44
"keywords": [
55
"queue",
66
"job-queue",
Lines changed: 44 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,44 @@
1+
# @vorsteh-queue/adapter-prisma
2+
3+
## 0.1.0
4+
5+
### Minor Changes
6+
7+
- 61c0f7b: Initial Prisma adapter release with UTC-first timezone support
8+
9+
**Features:**
10+
- `PostgresPrismaQueueAdapter`: PostgreSQL support using Prisma ORM
11+
- Raw SQL with `SKIP LOCKED` for race condition prevention
12+
- UTC-first design with proper timezone handling
13+
- Database schema uses UTC defaults: `timezone('utc', now())` for PostgreSQL
14+
- All timestamps explicitly stored as UTC for consistent behavior
15+
16+
**Usage:**
17+
18+
```typescript
19+
import { PrismaClient } from "@prisma/client"
20+
21+
import { PostgresPrismaQueueAdapter } from "@vorsteh-queue/adapter-prisma"
22+
import { Queue } from "@vorsteh-queue/core"
23+
24+
const prisma = new PrismaClient()
25+
const adapter = new PostgresPrismaQueueAdapter(prisma)
26+
const queue = new Queue(adapter, { name: "my-queue" })
27+
28+
// Register job handlers
29+
queue.register("send-email", async (payload: { to: string }) => {
30+
// Send email logic
31+
return { sent: true }
32+
})
33+
34+
// Add jobs
35+
await queue.add("send-email", { to: "[email protected]" })
36+
37+
// Start processing
38+
queue.start()
39+
```
40+
41+
### Patch Changes
42+
43+
- Updated dependencies [51f5968]
44+
- @vorsteh-queue/core@0.2.0

packages/adapter-prisma/package.json

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
{
22
"name": "@vorsteh-queue/adapter-prisma",
3-
"version": "0.0.0",
3+
"version": "0.1.0",
44
"keywords": [
55
"queue",
66
"job-queue",

packages/core/CHANGELOG.md

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,14 @@
11
# @vorsteh-queue/core
22

3+
## 0.2.0
4+
5+
### Minor Changes
6+
7+
- 51f5968: - Updated `BaseQueueAdapter` to use `setQueueName()` method
8+
- Updated `Queue` class to automatically set queue name on adapter
9+
- Updated `QueueAdapter` interface with optional `setQueueName()` method
10+
- Updated all core tests
11+
312
## 0.1.0
413

514
### Minor Changes

packages/core/package.json

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
{
22
"name": "@vorsteh-queue/core",
3-
"version": "0.1.0",
3+
"version": "0.2.0",
44
"keywords": [
55
"queue",
66
"job-queue",

0 commit comments

Comments
 (0)