upodated rep file upload

2024-12-18 12:39:17 +00:00
parent 54728d9565
commit 97cfeb562a
13 changed files with 433 additions and 108 deletions
@@ -1321,6 +1321,92 @@ export const getRepsBlobs = async (containerName) => {
    return blobObj;
 };

+export const getRepsFilesBlobs = async (
+    containerName,
+    casefolderID,
+    filenamePrefix
+) => {
+    const containerToken = await createContainerSas(containerName);
+    const sasUrl = `${STORAGE_PATH}/${containerName}?${containerToken}`;
+    const containerClient = new ContainerClient(sasUrl);
+
+    //conLog"getBlobs " + sasUrl);
+
+    //console.log(containerClient.listBlobsFlat());
+
+    const blobObj = [];
+    for await (const blob of containerClient.listBlobsFlat({
+        prefix: casefolderID + "/" + filenamePrefix + "/files/",
+    })) {
+        let blobDocumentType = blob.name
+            .split("/")[2]
+            .slice(0, blob.name.split("/")[2].indexOf("_"));
+
+        console.log(blob.name);
+
+        blobObj.push({
+            "name": blob.name.split("/")[3],
+            "path": blob.name,
+            "documentType": getDocumentTypeFromFilename(
+                blob.name.split("/")[3]
+            ),
+            "versionId": blob.versionId,
+            "isCurrentVersion": blob.isCurrentVersion,
+            "contentLength": blob.properties.contentLength,
+            "filenameprefix": filenamePrefix,
+            "filepath":
+                "/api/file/downloadblob?container=" +
+                containerName +
+                "&casefolderID=" +
+                blob.name.split("/")[0] +
+                "/" +
+                blob.name.split("/")[1] +
+                "&blobname=" +
+                blob.name.split("/")[3],
+            "hashedfilepath": hashAPIPath(
+                "/api/file/downloadblob?container=" +
+                    containerName +
+                    "&casefolderID=" +
+                    blob.name.split("/")[0] +
+                    "/" +
+                    blob.name.split("/")[1] +
+                    "&blobname=" +
+                    blob.name
+            ),
+            "deletepath":
+                "/api/file/deleteblob?container=" +
+                containerName +
+                "&casefolderID=" +
+                blob.name.split("/")[0] +
+                "/" +
+                blob.name.split("/")[1] +
+                "&blobname=" +
+                blob.name.split("/")[3],
+            "hasheddeletepath": hashAPIPath(
+                "/api/file/deleteblob?container=" +
+                    containerName +
+                    "&casefolderID=" +
+                    blob.name.split("/")[0] +
+                    "/" +
+                    blob.name.split("/")[1] +
+                    "&blobname=" +
+                    blob.name.split("/")[3]
+            ),
+            "hashgetblobs": hashAPIPath(
+                "/api/file/getbloblist?container=" +
+                    containerName +
+                    "&casefolderID=" +
+                    blob.name.split("/")[0] +
+                    "/" +
+                    blob.name.split("/")[1]
+            ),
+        });
+    }
+    //console.log("blobObj:", blobObj);
+
+    return blobObj;
+};
+
 export const createQueueSas = async (queueName) => {
    // Get environment variables
    const account = process.env.AZURE_STORAGE_ACCOUNT_NAME;