From c21f683c0fe94d8ed69856c54de09daab841c810 Mon Sep 17 00:00:00 2001 From: Christian Krakau-Louis Date: Tue, 11 Feb 2025 23:42:19 +0100 Subject: [PATCH] changed nextcloud code --- app/tasks/upload_to_nextcloud.py | 13 +++++++------ 1 file changed, 7 insertions(+), 6 deletions(-) diff --git a/app/tasks/upload_to_nextcloud.py b/app/tasks/upload_to_nextcloud.py index b1fc0d27..6f8fee64 100644 --- a/app/tasks/upload_to_nextcloud.py +++ b/app/tasks/upload_to_nextcloud.py @@ -9,7 +9,7 @@ from app.celery_app import celery @celery.task(base=BaseTaskWithRetry) def upload_to_nextcloud(file_path: str): """Uploads a file to Nextcloud in the configured folder.""" - + if not os.path.exists(file_path): raise FileNotFoundError(f"File not found: {file_path}") @@ -17,20 +17,21 @@ def upload_to_nextcloud(file_path: str): filename = os.path.basename(file_path) # Construct the full upload URL - nextcloud_url = f"{settings.NEXTCLOUD_UPLOAD_URL}/{settings.NEXTCLOUD_FOLDER}/{filename}" + nextcloud_url = f"{settings.nextcloud_upload_url}/{settings.nextcloud_folder}/{filename}" # Read file content with open(file_path, "rb") as file_data: response = requests.put( nextcloud_url, - auth=(settings.NEXTCLOUD_USERNAME, settings.NEXTCLOUD_PASSWORD), + auth=(settings.nextcloud_username, settings.nextcloud_password), data=file_data ) # Check if upload was successful if response.status_code in (200, 201): - print(f"[INFO] Successfully uploaded {filename} to Nextcloud.") + print(f"[INFO] Successfully uploaded {filename} to Nextcloud at {nextcloud_url}.") return {"status": "Completed", "file": file_path} else: - print(f"[ERROR] Failed to upload {filename} to Nextcloud: {response.status_code}, {response.text}") - raise Exception(f"Upload failed: {response.status_code} - {response.text}") + error_msg = f"[ERROR] Failed to upload {filename} to Nextcloud: {response.status_code} - {response.text}" + print(error_msg) + raise Exception(error_msg)