Liteque

!GitHub Actions Workflow Status !NPM Version

A simple typesafe sqlite-based job queue for Node.js.

Installation

``bash
$ npm install liteque
`

Usage

`ts
import { buildDBClient, Runner, SqliteQueue } from "liteque";
import { z } from "zod";

const db = buildDBClient(":memory:", {
runMigrations: true,
});

const requestSchema = z.object({
message: z.string(),
});
const ZRequest = z.infer;

// Init the queue
const queue = new SqliteQueue("requests", db, {
defaultJobArgs: {
numRetries: 2,
},
keepFailedJobs: false,
});

// Enqueue a job
await queue.enqueue({
message: "Hello world",
});

// Start the runner
const worker = new Runner(
queue,
{
run: async (job) => {
logger.info([${job.id}] ${job.data.message});
},
onComplete: async (job) => {
console.log([${job.id}] Completed successfully);
},
onError: async (job) => {
logger.error(
[${job.id}] job failed: ${job.error}\n${job.error.stack},
);
},
},
{
concurrency: 1,
pollIntervalMs: 1000,
timeoutSecs: 60,
validator: requestSchema,
},
);

`

Development

`base
$ pnpm install

And before submitting a PR

$ pnpm typecheck
$ pnpm test
``