From feea1b4634ca56b1503e92b92f14628abbe05d14 Mon Sep 17 00:00:00 2001
From: MachinePainting <machinepainting@proton.me>
Date: Sun, 1 Feb 2026 01:57:54 -0800
Subject: [PATCH] changes to transfer ownership from service acct to user

---
 drivesend_uploader_node.py |  3 ++-
 monitor_output.py          | 12 ++++++++++--
 2 files changed, 12 insertions(+), 3 deletions(-)

diff --git a/drivesend_uploader_node.py b/drivesend_uploader_node.py
index 6013f22..84d9464 100644
--- a/drivesend_uploader_node.py
+++ b/drivesend_uploader_node.py
@@ -108,7 +108,8 @@ class DriveSendAutoUploaderNode:
                     recursive=Subfolder_Monitor,
                     enable_encryption=enable_encryption,
                     post_delete_enc=Post_Delete_Enc,
-                    auth_method=auth_method
+                    auth_method=auth_method,
+                    owner_email=effective_owner_email
                 )
                 
                 status_lines.append(f"✓ Monitor started")
diff --git a/monitor_output.py b/monitor_output.py
index 0e4c920..9259e7e 100644
--- a/monitor_output.py
+++ b/monitor_output.py
@@ -63,6 +63,7 @@ class OutputMonitor:
         enable_encryption=False,
         post_delete_enc=False,
         auth_method='service_account',
+        owner_email=None,
         **auth_kwargs
     ):
         self.watch_dir = Path(watch_dir)
@@ -71,6 +72,7 @@ class OutputMonitor:
         self.enable_encryption = enable_encryption
         self.post_delete_enc = post_delete_enc
         self.auth_method = auth_method
+        self.owner_email = owner_email or os.environ.get('GOOGLE_OWNER_EMAIL')
         self.auth_kwargs = auth_kwargs
         
         self.upload_queue = queue.Queue()
@@ -114,11 +116,13 @@ class OutputMonitor:
                     else:
                         print("[DriveSend] Warning: Encryption enabled but no key found")
                 
-                # Upload file
+                # Upload file with owner_email for ownership transfer
                 result = upload_file(
                     file_to_upload,
                     folder_id=self.folder_id,
-                    service=self.service
+                    service=self.service,
+                    auth_method=self.auth_method,
+                    owner_email=self.owner_email
                 )
                 
                 if result['success']:
@@ -165,6 +169,10 @@ class OutputMonitor:
             print("[DriveSend] Recursive monitoring enabled")
         if self.enable_encryption:
             print("[DriveSend] Encryption enabled")
+        if self.owner_email:
+            print(f"[DriveSend] Ownership will transfer to: {self.owner_email}")
+        elif self.auth_method == 'service_account':
+            print("[DriveSend] WARNING: No owner_email set - uploads may fail due to quota!")
     
     def stop(self):
         """Stop monitoring the directory."""