Merge pull request #22 from heryTz/feat/add-test-with-other-dir

feat: add test with other dir

.changeset/lucky-steaks-collect.md

@@ -0,0 +1,5 @@
+---
+"rcu-back-core": patch
+---
+
+add test with other dir

packages/back-core/.gitignore

@@ -1,2 +1,3 @@
 dist
-tmp
+tmp
+tmp-other

packages/back-core/.npmignore

@@ -1,2 +1,3 @@
 .turbo
 tmp
+tmp-other

packages/back-core/src/__tests__/rcu-service.test.ts

@@ -1,7 +1,7 @@
 import { writeFile } from "fs/promises";
 import { JsonStoreData, JsonStoreProvider } from "../json-store-provider";
 import { RCUService } from "../rcu-service";
-import { deleteFile, readOrCreateFile, sleep } from "../util";
+import { deleteDir, deleteFile, readOrCreateFile, sleep } from "../util";
 
 const fileBuffer = Buffer.from([0x62, 0x75, 0x66, 0x66, 0x65, 0x72]);
 
@@ -191,4 +191,41 @@ describe(RCUService.name, () => {
       })
     ).rejects.toThrow("File corrupted");
   });
+
+  it("upload chunk to other dir", async () => {
+    const otherDir = "./tmp-other";
+    await deleteDir(otherDir);
+    const file = "./tmp/test-service-7.json";
+    await deleteFile(file);
+    await readOrCreateFile(
+      file,
+      JSON.stringify({
+        rows: [
+          {
+            id: "test-chunk-uploaded-to-other-dir.txt",
+            chunkCount: 4,
+            chunkFilenames: [],
+            lastUploadedChunkNumber: 0,
+          },
+        ],
+      } as JsonStoreData)
+    );
+    const store = new JsonStoreProvider(file);
+    await sleep(100);
+    const service = new RCUService({
+      store,
+      tmpDir: otherDir,
+      outputDir: otherDir,
+    });
+    const response = await service.upload({
+      file: fileBuffer,
+      fileId: "test-chunk-uploaded-to-other-dir.txt",
+      chunkCount: 4,
+      chunkNumber: 1,
+      chunkSize: 1,
+      fileSize: 6,
+      originalFilename: "test-chunk-uploaded-to-other-dir.txt",
+    });
+    expect(response.message).toBe("Chunk uploaded");
+  });
 });

packages/back-core/src/util.ts

@@ -1,4 +1,4 @@
-import { readFile, access, mkdir, writeFile, unlink } from "fs/promises";
+import { readFile, access, mkdir, writeFile, unlink, rm } from "fs/promises";
 import path from "path";
 
 export async function readOrCreateFile(
@@ -34,3 +34,10 @@ export async function createDir(dirPath: string) {
     await mkdir(dirPath, { recursive: true });
   }
 }
+
+export async function deleteDir(dirPath: string) {
+  try {
+    await access(dirPath);
+    await rm(dirPath, { recursive: true });
+  } catch (error) {}
+}