A sqlite-based job queue for Node.js
npm install liteque!GitHub Actions Workflow Status !NPM Version
A simple typesafe sqlite-based job queue for Node.js.
``bash`
$ npm install liteque
`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
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});[${job.id}] Completed successfully
},
onComplete: async (job) => {
console.log();[${job.id}] job failed: ${job.error}\n${job.error.stack}
},
onError: async (job) => {
logger.error(
,
);
},
},
{
concurrency: 1,
pollIntervalMs: 1000,
timeoutSecs: 60,
validator: requestSchema,
},
);
`
`base
$ pnpm install
$ pnpm typecheck
$ pnpm test
``