versia-pub/server
2
0
Fork 0
mirror of https://github.com/versia-pub/server.git synced 2026-03-13 05:49:16 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions

Try and fix some building issues

Browse source
This commit is contained in:
Jesse Wierzbinski 2024-03-12 08:27:50 -10:00
parent d29915456c
commit 986cc8a89c
No known key found for this signature in database
5 changed files with 84 additions and 82 deletions
Download patch file Download diff file Expand all files Collapse all files

8
database/datasource.ts
View file

@ -1,4 +1,4 @@
import { Queue } from "bullmq";
// import { Queue } from "bullmq";
import { PrismaClient } from "@prisma/client";
import { ConfigManager } from "config-manager";
@ -8,13 +8,13 @@ const client = new PrismaClient({
datasourceUrl: `postgresql://${config.database.username}:${config.database.password}@${config.database.host}:${config.database.port}/${config.database.database}`,
});
const federationQueue = new Queue("federation", {
/* const federationQueue = new Queue("federation", {
connection: {
host: config.redis.queue.host,
port: Number(config.redis.queue.port),
password: config.redis.queue.password || undefined,
db: config.redis.queue.database || undefined,
},
});
}); */
export { client, federationQueue };
export { client /* federationQueue */ };

12
database/entities/Queue.ts
View file

@ -1,5 +1,5 @@
import { Worker } from "bullmq";
import { client, federationQueue } from "~database/datasource";
// import { Worker } from "bullmq";
import { client /* federationQueue */ } from "~database/datasource";
import {
statusAndUserRelations,
statusToLysand,
@ -10,7 +10,7 @@ import { ConfigManager } from "config-manager";
const config = await new ConfigManager({}).getConfig();
export const federationWorker = new Worker(
/* export const federationWorker = new Worker(
"federation",
async job => {
await job.updateProgress(0);
@ -123,7 +123,7 @@ export const federationWorker = new Worker(
count: 3000,
},
}
);
); */
/**
* Convert a string into an ArrayBuffer
@ -191,7 +191,7 @@ export const federateStatusTo = async (
};
export const addStatusFederationJob = async (statusId: string) => {
await federationQueue.add("federation", {
/* await federationQueue.add("federation", {
id: statusId,
});
}); */
};