29 lines
846 B
TypeScript
29 lines
846 B
TypeScript
import { createBullBoard } from "@bull-board/api";
|
|
import { BullMQAdapter } from "@bull-board/api/bullMQAdapter.js";
|
|
import { ExpressAdapter } from "@bull-board/express";
|
|
import express from "express";
|
|
import { ClassifyVideoQueue, LatestVideosQueue, MiscQueue, SnapshotQueue } from "mq/index";
|
|
|
|
const serverAdapter = new ExpressAdapter();
|
|
serverAdapter.setBasePath("/");
|
|
|
|
createBullBoard({
|
|
queues: [
|
|
new BullMQAdapter(LatestVideosQueue),
|
|
new BullMQAdapter(ClassifyVideoQueue),
|
|
new BullMQAdapter(SnapshotQueue),
|
|
new BullMQAdapter(MiscQueue),
|
|
],
|
|
serverAdapter: serverAdapter,
|
|
});
|
|
|
|
const app = express();
|
|
|
|
app.use("/", serverAdapter.getRouter());
|
|
|
|
app.listen(5086, () => {
|
|
console.log("Running on 5086...");
|
|
console.log("For the UI, open http://localhost:5086/");
|
|
console.log("Make sure Redis is running on port 6379 by default");
|
|
});
|