upload fies to storage account for appeal

actions/azurestorage.js

@@ -0,0 +1,196 @@
+import { v4 as uuidv4 } from "uuid";
+import { BlobServiceClient, ContainerClient } from "@azure/storage-blob";
+import {
+    DefaultAzureCredential,
+    InteractiveBrowserCredential,
+    EnvironmentCredential,
+    ClientSecretCredential,
+} from "@azure/identity";
+import { hashAPIPath } from ".";
+
+const STORAGE_PATH = process.env.AZURE_PEDW_STORAGE_ENDPOINT;
+const STORAGE_CONTAINER = process.env.AZURE_PEDW_CONTAINER;
+
+export const createContainer = async (containerName) => {
+    const creds = new DefaultAzureCredential();
+
+    containerName = containerName.toLowerCase();
+
+    // console.log(
+    //     "container name:",
+    //     containerName,
+    //     STORAGE_PATH + "/" + containerName
+    // );
+
+    const containerClient = new ContainerClient(
+        `${STORAGE_PATH}/${containerName}`,
+        creds
+    );
+
+    const blobServiceClient = new BlobServiceClient(`${STORAGE_PATH}`, creds);
+
+    const createContainerResponse = await containerClient.createIfNotExists();
+    // console.log(
+    //     `Created container ${containerName} successfully`,
+    //     createContainerResponse.requestId
+    // );
+
+    // console.log("Containers:");
+    // for await (const container of blobServiceClient.listContainers()) {
+    //     console.log(`- ${container.name}`);
+    // }
+
+    return containerName;
+};
+
+export const getContainers = async () => {
+    const creds = new DefaultAzureCredential();
+    const blobServiceClient = new BlobServiceClient(`${STORAGE_PATH}`, creds);
+
+    console.log("Containers:");
+    for await (const container of blobServiceClient.listContainers()) {
+        console.log(`- ${container.name}`);
+    }
+};
+
+export const getBlobs = async (containerName) => {
+    const creds = new DefaultAzureCredential();
+
+    const containerClient = new ContainerClient(
+        `${STORAGE_PATH}/${containerName}`,
+        creds
+    );
+
+    containerClient.createIfNotExists();
+
+    const blobObj = [];
+    for await (const blob of containerClient.listBlobsFlat({
+        prefix: "files/",
+    })) {
+        let blobDocumentType = blob.name
+            .split("/")[1]
+            .slice(0, blob.name.split("/")[1].indexOf("_"));
+
+        blobObj.push({
+            "name": blob.name.split("/")[1],
+            "path": blob.name,
+            "documentType": blobDocumentType,
+            "versionId": blob.versionId,
+            "isCurrentVersion": blob.isCurrentVersion,
+            "contentLength": blob.properties.contentLength,
+            "contentType": blob.contentType,
+            "hashedfilepath": hashAPIPath(
+                "/api/file/downloadblob?container=" +
+                    containerName.toLowerCase() +
+                    "&blobname=" +
+                    blob.name.split("/")[1]
+            ),
+        });
+    }
+
+    return blobObj;
+};
+
+export const createBlob = async (formContent, containerName) => {
+    const creds = new DefaultAzureCredential();
+
+    const containerClient = new ContainerClient(
+        `${STORAGE_PATH}/${containerName}`,
+        creds
+    );
+
+    const content = JSON.stringify(formContent);
+    const blobName =
+        formContent.pinswg_name + "_" + new Date().getTime() + ".json";
+    const blockBlobClient = containerClient.getBlockBlobClient(blobName);
+
+    const uploadBlobResponse = await blockBlobClient.upload(
+        content,
+        Buffer.byteLength(content)
+    );
+
+    // console.log("Blobs:");
+    // for await (const blob of containerClient.listBlobsByHierarchy("/")) {
+    //     console.log(`- ${blob.name}`);
+    // }
+
+    return formContent.pinswg_name;
+};
+
+export const deleteBlob = async (containerName, blobName) => {
+    const creds = new DefaultAzureCredential();
+
+    const options = {
+        deleteSnapshots: "include", // or 'only'
+    };
+
+    const containerClient = new ContainerClient(
+        `${STORAGE_PATH}/${containerName.toLowerCase()}`,
+        creds
+    );
+
+    const blockBlobClient = containerClient.getBlockBlobClient(blobName);
+
+    await blockBlobClient.deleteIfExists(options);
+
+    console.log(`deleted blob ${blobName}`);
+
+    return { "deleted": blobName };
+};
+
+export const uploadFile = async (formContent, containerName, foldername) => {
+    const creds = new DefaultAzureCredential();
+
+    const containerClient = new ContainerClient(
+        `${STORAGE_PATH}/${containerName}`,
+        creds
+    );
+
+    const files = formContent;
+
+    //console.log(...formContent);
+    //console.log("files...", files, files.length);
+
+    for (const prop in files) {
+        //console.log(`files[${prop}] = ${files[prop][0].size}`);
+        const blobName = "files/" + files[prop][0].fieldName;
+        const blockBlobClient = containerClient.getBlockBlobClient(blobName);
+        const uploadBlobResponse = await blockBlobClient.uploadFile(
+            files[prop][0].path,
+            files[prop].size
+        );
+        console.log(
+            `Uploaded block blob ${files[prop][0].fieldName} successfully`,
+            uploadBlobResponse.requestId
+        );
+    }
+};
+
+export const downloadFile = async (containerName, blobName) => {
+    //console.log.apply(containerName, blobName);
+    const creds = new DefaultAzureCredential();
+
+    const containerClient = new ContainerClient(
+        `${STORAGE_PATH}/${containerName}`,
+        creds
+    );
+
+    const blobClient = containerClient.getBlobClient("files/" + blobName);
+    const downloadedBlob = await blobClient.download(0);
+
+    const downloaded = await streamToBuffer(downloadedBlob.readableStreamBody);
+    return downloaded;
+};
+
+const streamToBuffer = async (readableStream) => {
+    return new Promise((resolve, reject) => {
+        const chunks = [];
+        readableStream.on("data", (data) => {
+            chunks.push(data instanceof Buffer ? data : Buffer.from(data));
+        });
+        readableStream.on("end", () => {
+            resolve(Buffer.concat(chunks));
+        });
+        readableStream.on("error", reject);
+    });
+};