(simatec) Download for Onedrive with local API added

Author: simatec

lib/list/onedrive.js

@@ -1,8 +1,8 @@
 'use strict';
 const fs = require('node:fs');
-const oneDriveAPI = require('onedrive-api');
+//const oneDriveAPI = require('onedrive-api');
 const Onedrive = require('../oneDriveLib');
-const got = require('@esm2cjs/got').default;
+//const got = require('@esm2cjs/got').default;
 
 let od_accessToken;
 
@@ -143,7 +143,7 @@ async function list(restoreSource, options, types, log, callback) {
         callback && callback();
     }
 }
-
+/*
 async function getFile(options, fileName, toStoreName, log, callback) {
     const db_onedriveAccessJson = options.onedriveAccessJson !== undefined ? options.onedriveAccessJson : options.onedrive?.onedriveAccessJson || '';
     const db_dir = options.dir !== undefined ? options.dir : options.onedrive?.dir || '/';
@@ -243,6 +243,40 @@ async function getFile(options, fileName, toStoreName, log, callback) {
         callback && callback('Not configured');
     }
 }
+*/
+
+async function getFile(options, fileName, toStoreName, log, callback) {
+    const db_onedriveAccessJson = options.onedriveAccessJson ?? options.onedrive?.onedriveAccessJson ?? '';
+    const db_dir = options.dir ?? options.onedrive?.dir ?? '/';
+    const db_ownDir = options.ownDir ?? options.onedrive?.ownDir ?? false;
+    const db_dirMinimal = options.dirMinimal ?? options.onedrive?.dirMinimal ?? '/';
+
+    const onedrive = new Onedrive();
+    const od_accessToken = await onedrive.getToken(db_onedriveAccessJson, log).catch(err => log.warn(`OneDrive Token: ${err}`));
+
+    if (!od_accessToken) {
+        callback?.('Not configured');
+        return;
+    }
+
+    try {
+        const dir = db_ownDir ? db_dirMinimal : db_dir;
+        const onlyFileName = fileName.split('/').pop();
+
+        await onedrive.downloadFileByName({
+            accessToken: od_accessToken,
+            dir,
+            fileName: onlyFileName,
+            targetPath: toStoreName,
+            log
+        });
+
+        callback?.();
+    } catch (err) {
+        log.error(`OneDrive: ${err.message}`);
+        callback?.(err);
+    }
+}
 
 module.exports = {
     list,

lib/oneDriveLib.js

@@ -355,6 +355,67 @@ class onedrive {
             throw error;
         }
     }
+
+    async downloadFileByName({ accessToken, dir, fileName, targetPath, log }) {
+        try {
+            // Normalize directory path
+            let normalizedDir = (dir || '').replace(/\\/g, '/');
+            if (!normalizedDir || normalizedDir === '/') {
+                normalizedDir = 'root';
+            } else if (normalizedDir.startsWith('/')) {
+                normalizedDir = normalizedDir.slice(1);
+            }
+
+            // Get metadata of the directory to find its ID
+            const metadata = await this.getMetadata({
+                accessToken,
+                itemPath: normalizedDir
+            });
+
+            if (!metadata?.id) {
+                throw new Error(`Could not retrieve metadata for path "${normalizedDir}"`);
+            }
+
+            // List all files inside the directory
+            const childrenRes = await this.listChildren({
+                accessToken,
+                itemId: metadata.id
+            });
+
+            const children = childrenRes?.value || [];
+            const file = children.find(f => f.name === fileName);
+
+            if (!file) {
+                throw new Error(`File "${fileName}" not found in OneDrive`);
+            }
+
+            const downloadUrl = file['@microsoft.graph.downloadUrl'];
+            if (!downloadUrl) {
+                throw new Error(`Download URL missing for "${fileName}"`);
+            }
+
+            log.debug(`OneDrive: Download of "${fileName}" started`);
+
+            // Stream download to local file
+            await new Promise((resolve, reject) => {
+                const writeStream = fs.createWriteStream(targetPath);
+                writeStream.on('finish', () => {
+                    log.debug(`OneDrive: Download of "${fileName}" finished`);
+                    resolve();
+                });
+                writeStream.on('error', reject);
+
+                got.stream(downloadUrl)
+                    .on('error', reject)
+                    .pipe(writeStream);
+            });
+
+        } catch (err) {
+            log.error(`downloadFileByName error: ${err.message}`);
+            throw err;
+        }
+    }
+
 }
 
 module.exports = onedrive;