Lint errors

Signed-off-by: Rodrigo Martins <rodrigo.sousa.577@gmail.com>
This commit is contained in:
rodrigo committed 2025-04-12 20:32:39 -03:00
1 parent 9742d62ba2
commit 5acec6b71e
196 files changed
+10885 -6655

No files matched your search

+50 -46
View File
@@ -1,55 +1,59 @@
import { Queue, Worker } from 'bullmq';
import { ProvaService } from '../services/ProvaService';
import { prisma } from '../config/database';
import { Queue, Worker } from "bullmq";
const provaQueue = new Queue('provas', {
import { prisma } from "../config/database";
import { ProvaService } from "../services/ProvaService";
const provaQueue = new Queue("provas", {
connection: {
host: process.env.REDIS_HOST || 'localhost',
port: Number(process.env.REDIS_PORT) || 6379
}
host: process.env.REDIS_HOST || "localhost",
port: Number(process.env.REDIS_PORT) || 6379,
},
});
const worker = new Worker('provas', async (job) => {
const { fileData, metadata } = job.data;
const provaService = new ProvaService();
const worker = new Worker(
"provas",
async (job) => {
const { fileData, metadata } = job.data;
const provaService = new ProvaService();
try {
// Atualizar status para PROCESSANDO
await prisma.prova.update({
where: { id: job.data.provaId },
data: { status: 'PROCESSANDO' }
});
try {
// Atualizar status para PROCESSANDO
await prisma.prova.update({
where: { id: job.data.provaId },
data: { status: "PROCESSANDO" },
});
// Processar o arquivo
const result = await provaService.processFile(
Buffer.from(fileData),
metadata
);
// Processar o arquivo
const result = await provaService.processFile(
Buffer.from(fileData),
metadata,
);
// Atualizar prova com resultado
await prisma.prova.update({
where: { id: job.data.provaId },
data: {
status: 'CONCLUIDO',
...result
}
});
} catch (error) {
console.error('Erro no processamento:', error);
await prisma.prova.update({
where: { id: job.data.provaId },
data: {
status: 'ERRO',
error: error.message
}
});
}
}, {
connection: {
host: process.env.REDIS_HOST || 'localhost',
port: Number(process.env.REDIS_PORT) || 6379
}
});
// Atualizar prova com resultado
await prisma.prova.update({
where: { id: job.data.provaId },
data: {
status: "CONCLUIDO",
...result,
},
});
} catch (error) {
console.error("Erro no processamento:", error);
await prisma.prova.update({
where: { id: job.data.provaId },
data: {
status: "ERRO",
error: error.message,
},
});
}
},
{
connection: {
host: process.env.REDIS_HOST || "localhost",
port: Number(process.env.REDIS_PORT) || 6379,
},
},
);
export { provaQueue, worker };
+4 -4
View File
@@ -1,11 +1,11 @@
import { worker } from './ProvaWorker';
import { worker } from "./ProvaWorker";
worker.on('completed', (job) => {
worker.on("completed", (job) => {
console.log(`Prova ${job.data.provaId} processada com sucesso`);
});
worker.on('failed', (job, error) => {
worker.on("failed", (job, error) => {
console.error(`Erro ao processar prova ${job.data.provaId}:`, error);
});
console.log('Worker de processamento de provas iniciado');
console.log("Worker de processamento de provas iniciado");