From fc469be61b6678ffa9a090fa290ec66856597550 Mon Sep 17 00:00:00 2001
From: tdurieux <durieuxthomas@hotmail.com>
Date: Wed, 3 Apr 2024 11:47:32 +0100
Subject: [PATCH] fix: fix queue

---
 src/queue/processes/downloadRepository.ts | 2 +-
 src/queue/processes/removeCache.ts        | 2 +-
 src/queue/processes/removeRepository.ts   | 2 +-
 3 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/src/queue/processes/downloadRepository.ts b/src/queue/processes/downloadRepository.ts
index 1a70bd6..d31f7be 100644
--- a/src/queue/processes/downloadRepository.ts
+++ b/src/queue/processes/downloadRepository.ts
@@ -13,7 +13,7 @@ export default async function (job: SandboxedJob<Repository, void>) {
   }: {
     connect: () => Promise<void>;
     getRepository: typeof getRepositoryImport;
-  } = require("../database/database");
+  } = require("../../server/database");
   const span = trace.getTracer("ano-file").startSpan("proc.downloadRepository");
   span.setAttribute("repoId", job.data.repoId);
   console.log(`[QUEUE] ${job.data.repoId} is going to be downloaded`);
diff --git a/src/queue/processes/removeCache.ts b/src/queue/processes/removeCache.ts
index 996004a..3cebf75 100644
--- a/src/queue/processes/removeCache.ts
+++ b/src/queue/processes/removeCache.ts
@@ -10,7 +10,7 @@ export default async function (job: SandboxedJob<Repository, void>) {
   }: {
     connect: () => Promise<void>;
     getRepository: typeof getRepositoryImport;
-  } = require("../database/database");
+  } = require("../../server/database");
   const span = trace.getTracer("ano-file").startSpan("proc.removeCache");
   span.setAttribute("repoId", job.data.repoId);
   try {
diff --git a/src/queue/processes/removeRepository.ts b/src/queue/processes/removeRepository.ts
index 03b36c1..7041167 100644
--- a/src/queue/processes/removeRepository.ts
+++ b/src/queue/processes/removeRepository.ts
@@ -11,7 +11,7 @@ export default async function (job: SandboxedJob<Repository, void>) {
   }: {
     connect: () => Promise<void>;
     getRepository: typeof getRepositoryImport;
-  } = require("../database/database");
+  } = require("../../server/database");
   const span = trace.getTracer("ano-file").startSpan("proc.removeRepository");
   span.setAttribute("repoId", job.data.repoId);
   try {