Merge pull request #8 from noxify/updates

Updates

Author: noxify

.changeset/core-changes.md

@@ -0,0 +1,8 @@
+---
+"@vorsteh-queue/core": minor
+---
+
+- Updated `BaseQueueAdapter` to use `setQueueName()` method
+- Updated `Queue` class to automatically set queue name on adapter
+- Updated `QueueAdapter` interface with optional `setQueueName()` method
+- Updated all core tests

.changeset/cruel-eggs-call.md

@@ -0,0 +1,36 @@
+---
+"@vorsteh-queue/adapter-prisma": minor
+---
+
+Initial Prisma adapter release with UTC-first timezone support
+
+**Features:**
+- `PostgresPrismaQueueAdapter`: PostgreSQL support using Prisma ORM
+- Raw SQL with `SKIP LOCKED` for race condition prevention
+- UTC-first design with proper timezone handling
+- Database schema uses UTC defaults: `timezone('utc', now())` for PostgreSQL
+- All timestamps explicitly stored as UTC for consistent behavior
+
+**Usage:**
+
+```typescript
+import { PrismaClient } from '@prisma/client'
+import { PostgresPrismaQueueAdapter } from '@vorsteh-queue/adapter-prisma'
+import { Queue } from '@vorsteh-queue/core'
+
+const prisma = new PrismaClient()
+const adapter = new PostgresPrismaQueueAdapter(prisma)
+const queue = new Queue(adapter, { name: 'my-queue' })
+
+// Register job handlers
+queue.register('send-email', async (payload: { to: string }) => {
+  // Send email logic
+  return { sent: true }
+})
+
+// Add jobs
+await queue.add('send-email', { to: '[email protected]' })
+
+// Start processing
+queue.start()
+```

.changeset/drizzle-changes.md

@@ -0,0 +1,28 @@
+---
+"@vorsteh-queue/drizzle-adapter": minor
+---
+
+- `PostgresQueueAdapter`: Constructor simplified
+- **BREAKING**: Removed MariaDB/MySQL support due to timezone handling complexities
+  - I tried my best to make it work, but failed successfully
+- **BREAKING**: Fixed UTC-first timezone handling - all timestamps now stored as UTC
+
+**Before (duplicate queue name)**
+
+```ts
+const adapter = new PostgresQueueAdapter(db, "my-queue")
+const queue = new Queue(adapter, { name: "my-queue" })
+```
+
+**After (single queue name):**
+
+```ts
+const adapter = new PostgresQueueAdapter(db)
+const queue = new Queue(adapter, { name: "my-queue" })
+```
+
+**Timezone Changes:**
+
+- Database schema now uses UTC defaults: `timezone('utc', now())` for PostgreSQL
+- Application timestamps stored as UTC using `toISOString()::timestamptz`
+- Consistent UTC-first behavior for reliable timezone handling

.github/workflows/ci.yml

@@ -37,6 +37,9 @@ jobs:
       - name: Setup
         uses: ./.github/setup
 
+      - name: Generate prisma client
+        run: pnpm -F adapter-prisma prisma:generate
+
       - name: Lint
         run: pnpm lint
 
@@ -59,6 +62,9 @@ jobs:
       - name: Setup
         uses: ./.github/setup
 
+      - name: Generate prisma client
+        run: pnpm -F adapter-prisma prisma:generate
+
       - name: Typecheck
         run: pnpm typecheck
 
@@ -86,16 +92,20 @@ jobs:
         run: pnpm install
 
       - name: Build packages
-        run: pnpm --filter "./packages/*" build
+        run: |
+          pnpm -F adapter-prisma prisma:generate
+          pnpm --filter "./packages/*" build
 
       - name: Test Core Package
         run: pnpm test:core
 
       - name: Test Drizzle PostgreSQL (PGlite)
         run: pnpm test:drizzle-postgres
 
-      - name: Test Drizzle MariaDB (Testcontainers)
-        run: pnpm test:drizzle-mariadb
+      - name: Test Prisma (Testcontainers - Postgres)
+        run: |
+          pnpm -F adapter-prisma prisma:generate
+          pnpm test:prisma-postgres
         env:
           # Ensure Docker is available for Testcontainers
           TESTCONTAINERS_RYUK_DISABLED: true
@@ -110,7 +120,10 @@ jobs:
       - name: Setup
         uses: ./.github/setup
 
+      - name: Generate prisma client
+        run: pnpm -F adapter-prisma prisma:generate
+
       - name: Build
-        run: pnpm --filter "./packages/*" build
+        run: pnpm build:pkg
 
       - run: pnpx pkg-pr-new publish ./packages/*

README.md

@@ -1,13 +1,13 @@
 <div align="center">
   <img src="./assets/vorsteh-queue-logo-nobg.png" alt="Vorsteh Queue" height="200" />
   <h1>Vorsteh Queue</h1>
-  <p>A powerful, ORM-agnostic queue engine that works with any orm. Handle background jobs, scheduled tasks, and recurring processes with ease.</p>
+  <p>A powerful, ORM-agnostic queue engine for PostgreSQL 12+. Handle background jobs, scheduled tasks, and recurring processes with ease.</p>
 </div>
 
 ## Features
 
 - **Type-safe**: Full TypeScript support with generic job payloads
-- **Multiple adapters**: Drizzle ORM (PostgreSQL + MariaDB/MySQL) and in-memory implementations
+- **Multiple adapters**: Drizzle ORM (PostgreSQL), Prisma ORM (PostgreSQL), and in-memory implementations
 - **Priority queues**: Numeric priority system (lower = higher priority)
 - **Delayed jobs**: Schedule jobs for future execution
 - **Recurring jobs**: Cron expressions and interval-based repetition
@@ -22,8 +22,8 @@
 .
 ├── packages/
 │   ├── core/                # Core queue logic and interfaces
-│   ├── adapter-drizzle/     # Drizzle ORM adapter (PostgreSQL + MariaDB/MySQL)
-│   └── adapter-prisma/      # Prisma adapter (coming soon)
+│   ├── adapter-drizzle/     # Drizzle ORM adapter (PostgreSQL)
+│   └── adapter-prisma/      # Prisma ORM adapter (PostgreSQL)
 ├── examples/                # Standalone usage examples
 │   ├── drizzle-pg/         # Drizzle + node-postgres
 │   ├── drizzle-postgres/   # Drizzle + postgres.js
@@ -53,40 +53,53 @@ pnpm add @vorsteh-queue/core @vorsteh-queue/adapter-drizzle
 ### Basic Usage
 
 ```typescript
-// PostgreSQL
+// Drizzle ORM with PostgreSQL
 import { drizzle } from "drizzle-orm/node-postgres"
 import { Pool } from "pg"
 import { PostgresQueueAdapter } from "@vorsteh-queue/adapter-drizzle"
 import { Queue } from "@vorsteh-queue/core"
 
+interface EmailPayload {
+  to: string
+  subject: string
+  body: string
+}
+
+interface EmailResult {
+  messageId: string
+  sent: boolean
+}
+
 const pool = new Pool({ connectionString: "postgresql://..." })
 const db = drizzle(pool)
-const adapter = new PostgresQueueAdapter(db, "my-queue")
-const queue = new Queue(adapter, { name: "my-queue" })
-
-// MariaDB/MySQL
-import { drizzle } from "drizzle-orm/mysql2"
-import mysql from "mysql2/promise"
-import { MariaDBQueueAdapter } from "@vorsteh-queue/adapter-drizzle"
-
-const connection = await mysql.createConnection({
-  host: "localhost",
-  user: "root",
-  password: "password",
-  database: "queue_db",
-})
-const db = drizzle(connection, { mode: "default" })
-const adapter = new MariaDBQueueAdapter(db, "my-queue")
-const queue = new Queue(adapter, { name: "my-queue" })
+const queue = new Queue(new PostgresQueueAdapter(db), { name: "my-queue" })
+
+// Prisma ORM with PostgreSQL
+import { PrismaClient } from "@prisma/client"
+import { PostgresPrismaQueueAdapter } from "@vorsteh-queue/adapter-prisma"
+
+const prisma = new PrismaClient()
+const queue = new Queue(new PostgresPrismaQueueAdapter(prisma), { name: "my-queue" })
 
 // Register job handlers
-queue.register("send-email", async (payload: { to: string; subject: string }) => {
-  // Send email logic
-  return { sent: true }
+queue.register<EmailPayload, EmailResult>("send-email", async (job) => {
+  console.log(`Sending email to ${job.payload.to}`)
+  
+  // Send email logic here
+  await sendEmail(job.payload)
+  
+  return { 
+    messageId: "msg_123", 
+    sent: true 
+  }
 })
 
 // Add jobs
-await queue.add("send-email", { to: "[email protected]", subject: "Welcome!" })
+await queue.add("send-email", { 
+  to: "[email protected]", 
+  subject: "Welcome!", 
+  body: "Welcome to our service!" 
+})
 await queue.add(
   "send-email",
   { to: "[email protected]", subject: "Report" },

apps/docs/next.config.mjs

@@ -33,6 +33,13 @@ const nextConfig = {
   trailingSlash: true,
   poweredByHeader: false,
   pageExtensions: ["js", "jsx", "ts", "tsx", "md", "mdx"],
+  /** Enables hot reloading for local packages without a build step */
+  transpilePackages: [
+    "@vorsteh-queue/core",
+    "@vorsteh-queue/adapter-drizzle",
+    "@vorsteh-queue/adapter-prisma",
+    "create-vorsteh-queue",
+  ],
   eslint: {
     ignoreDuringBuilds: true,
   },

apps/docs/package.json

@@ -19,10 +19,12 @@
   "dependencies": {
     "@getcanary/web": "1.0.12",
     "@giscus/react": "3.1.0",
+    "@icons-pack/react-simple-icons": "13.5.0",
     "@mdx-js/loader": "3.1.0",
     "@mdx-js/node-loader": "3.1.0",
     "@mdx-js/react": "3.1.0",
     "@next/mdx": "15.4.2",
+    "@radix-ui/react-tabs": "1.1.12",
     "class-variance-authority": "0.7.1",
     "clsx": "2.1.1",
     "cmdk": "1.1.1",
@@ -39,14 +41,18 @@
     "remark-squeeze-paragraphs": "6.0.0",
     "remark-strip-badges": "7.0.0",
     "renoun": "8.14.0",
+    "tm-themes": "1.10.7",
     "ts-morph": "26.0.0",
     "zod": "4.0.5"
   },
   "devDependencies": {
     "@tailwindcss/postcss": "4.1.11",
+    "@types/mdx": "2.0.13",
     "@types/node": "22.16.5",
     "@types/react": "19.1.8",
     "@types/react-dom": "19.1.6",
+    "@vorsteh-queue/adapter-drizzle": "workspace:*",
+    "@vorsteh-queue/core": "workspace:*",
     "@vorsteh-queue/eslint-config": "workspace:*",
     "@vorsteh-queue/prettier-config": "workspace:*",
     "@vorsteh-queue/tsconfig": "workspace:*",

apps/docs/renoun.json

@@ -8,8 +8,8 @@
   "siteUrl": "https://vorsteh-queue.dev",
 
   "theme": {
-    "dark": "github-dark-default",
-    "light": "github-light-default"
+    "dark": "monokai",
+    "light": "monokai"
   },
   "languages": [
     "css",