sebclem/hassio-nextcloud-backup
1
0
Fork 0
mirror of https://github.com/Sebclem/hassio-nextcloud-backup.git synced 2024-11-22 17:22:58 +01:00
Code Issues Projects Releases Wiki Activity

Change some log levels

Browse Source
This commit is contained in:
SebClem 2024-09-05 17:00:29 +02:00
parent 3c6dcd9163
commit f54bcdfc58
Signed by: sebclem
GPG Key ID: 5A4308F6A359EA50
2 changed files with 13 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
nextcloud_backup/backend/src/services/orchestrator.ts
View File

@ -25,6 +25,8 @@ export function doBackupWorkflow(type: WorkflowType) {
const backupConfig = backupConfigService.getBackupConfig(); const backupConfig = backupConfigService.getBackupConfig();
const webdavConfig = getWebdavConfig(); const webdavConfig = getWebdavConfig();
logger.info(`Stating backup workflow, type: ${type}`);
return homeAssistantService return homeAssistantService
.getVersion() .getVersion()
.then((value) => { .then((value) => {

17
nextcloud_backup/backend/src/services/webdavService.ts
View File

@ -46,7 +46,7 @@ export function checkWebdavLogin(
config: WebdavConfig, config: WebdavConfig,
silent: boolean = false silent: boolean = false
) { ) {
logger.info("Checking webdab login"); logger.debug("Checking webdab login");
const endpoint = getEndpoint(config); const endpoint = getEndpoint(config);
return got(config.url + endpoint, { return got(config.url + endpoint, {
method: "OPTIONS", method: "OPTIONS",
@ -61,6 +61,7 @@ export function checkWebdavLogin(
const status = statusTools.getStatus(); const status = statusTools.getStatus();
status.webdav.logged_in = true; status.webdav.logged_in = true;
status.webdav.last_check = DateTime.now(); status.webdav.last_check = DateTime.now();
logger.debug("Webdab login OK");
return response; return response;
}, },
(reason: RequestError) => { (reason: RequestError) => {
@ -151,6 +152,7 @@ export function getBackups(
config: WebdavConfig, config: WebdavConfig,
nameTemplate: string nameTemplate: string
) { ) {
logger.info("Download backup form webdav");
const status = statusTools.getStatus(); const status = statusTools.getStatus();
if (!status.webdav.logged_in && !status.webdav.folder_created) { if (!status.webdav.logged_in && !status.webdav.folder_created) {
return Promise.reject(new Error("Not logged in")); return Promise.reject(new Error("Not logged in"));
@ -171,6 +173,7 @@ export function getBackups(
const data = parseXmlBackupData(value.body, config).sort( const data = parseXmlBackupData(value.body, config).sort(
(a, b) => b.lastEdit.toMillis() - a.lastEdit.toMillis() (a, b) => b.lastEdit.toMillis() - a.lastEdit.toMillis()
); );
logger.info("Download success");
return extractBackupInfo(data, nameTemplate); return extractBackupInfo(data, nameTemplate);
}, },
(reason: RequestError) => { (reason: RequestError) => {
@ -209,7 +212,7 @@ function extractBackupInfo(backups: WebdavBackup[], template: string) {
} }
export function deleteBackup(pathToDelete: string, config: WebdavConfig) { export function deleteBackup(pathToDelete: string, config: WebdavConfig) {
logger.debug(`Deleting Cloud backup ${pathToDelete}`); logger.info(`Deleting Cloud backup ${pathToDelete}`);
const endpoint = getEndpoint(config); const endpoint = getEndpoint(config);
return got return got
.delete(urlJoin(config.url, endpoint, pathToDelete), { .delete(urlJoin(config.url, endpoint, pathToDelete), {
@ -224,6 +227,7 @@ export function deleteBackup(pathToDelete: string, config: WebdavConfig) {
}) })
.then( .then(
(response) => { (response) => {
logger.info("Delete success");
return response; return response;
}, },
(reason: RequestError) => { (reason: RequestError) => {
@ -348,7 +352,7 @@ export async function chunkedUpload(
) { ) {
const uuid = randomUUID(); const uuid = randomUUID();
const fileSize = fs.statSync(localPath).size; const fileSize = fs.statSync(localPath).size;
logger.info("Uploading backup to webdav (Chunked)");
const chunkEndpoint = getChunkEndpoint(config); const chunkEndpoint = getChunkEndpoint(config);
const chunkedUrl = urlJoin(config.url, chunkEndpoint, uuid); const chunkedUrl = urlJoin(config.url, chunkEndpoint, uuid);
const finalDestination = urlJoin(config.url, getEndpoint(config), webdavPath); const finalDestination = urlJoin(config.url, getEndpoint(config), webdavPath);
@ -393,6 +397,7 @@ export async function chunkedUpload(
}; };
let i = 1; let i = 1;
logger.debug("Starting chunck upload");
while (start < fileSize - 1) { while (start < fileSize - 1) {
const chunk = fs.createReadStream(localPath, { start, end }); const chunk = fs.createReadStream(localPath, { start, end });
try { try {
@ -437,14 +442,14 @@ export async function chunkedUpload(
throw error; throw error;
} }
} }
logger.debug("Chunked upload funished, assembling chunks."); logger.debug("Chunks upload funished, assembling chunks.");
try { try {
await assembleChunkedUpload(chunkedUrl, finalDestination, fileSize, config); await assembleChunkedUpload(chunkedUrl, finalDestination, fileSize, config);
const status = statusTools.getStatus(); const status = statusTools.getStatus();
status.status = States.IDLE; status.status = States.IDLE;
status.progress = undefined; status.progress = undefined;
statusTools.setStatus(status); statusTools.setStatus(status);
logger.info(`...Upload finish !`); logger.info(`...Upload finished !`);
fs.unlinkSync(localPath); fs.unlinkSync(localPath);
} catch (err) { } catch (err) {
if (err instanceof RequestError) { if (err instanceof RequestError) {
@ -534,7 +539,7 @@ function initChunkedUpload(
finalDestination: string, finalDestination: string,
config: WebdavConfig config: WebdavConfig
) { ) {
logger.info(`Init chuncked upload.`); logger.debug(`Init chuncked upload.`);
logger.debug(`...URI: ${encodeURI(url)}`); logger.debug(`...URI: ${encodeURI(url)}`);
logger.debug(`...Final destination: ${encodeURI(finalDestination)}`); logger.debug(`...Final destination: ${encodeURI(finalDestination)}`);
return got(encodeURI(url), { return got(encodeURI(url), {