jcs224 / faktory_worker_deno Goto Github PK

import {
  FaktoryClient,
  FaktoryJob,
} from "https://deno.land/x/[email protected]/mod.ts";

function timeout(ms: number) {
  return new Promise((resolve) => setTimeout(resolve, ms));
}

async function randomIntFromInterval(min: number, max: number) {
  // min and max included
  await timeout(5000);
  return Math.floor(Math.random() * (max - min + 1) + min);
}

const client = new FaktoryClient("localhost", 7419);
await client.connect();

// Create job
const job = new FaktoryJob("adder", [
  randomIntFromInterval(1, 10),
  randomIntFromInterval(1, 10),
]);
// Push job
await client.push(job);

client.close();

# client.ts
# deno run -A client.ts

import { FaktoryClient, FaktoryWorker } from "./deps.ts";

const PORT = 7419;
const client = new FaktoryClient("localhost", PORT);
await client.connect();

console.log(`Listening on http://localhost:${PORT}`);

const worker = new FaktoryWorker(client);

worker.register("validate", (job: unknown) => {
  console.log(job);
});

await worker.run(true);

Listening on http://localhost:7419
[ {}, {} ]