From 25ab7dfce74ed1eb340264dd303a7bf8c245b164 Mon Sep 17 00:00:00 2001
From: nmemmert <67961292+nmemmert@users.noreply.github.com>
Date: Fri, 7 Nov 2025 08:10:16 -0500
Subject: [PATCH] realtime updated

---
 __pycache__/pdf_renamer.cpython-313.pyc | Bin 71676 -> 73240 bytes
 jobs.json                               |  18 ++++++++++++++
 pdf_renamer.py                          |  30 ++++++++++++++++++++++++
 3 files changed, 48 insertions(+)
 create mode 100644 jobs.json

diff --git a/__pycache__/pdf_renamer.cpython-313.pyc b/__pycache__/pdf_renamer.cpython-313.pyc
index 74a68fe4c67b25a10882262e7f9545df973c1378..89c93b7a0df93869183fef106fbd8896319030ed 100644
GIT binary patch
delta 1663
zcmZuyZD><h7{2FzB<XF^RBKw3*6wz8O<Xmpo0+U_CbxBCI_A{)F_?p1lbhx?H@Ru<
zjqz*Kt>Ta2aB|927=C~Z9l~^HAZ-3{C=B+MR0WaxV^qbD*d|d28_3u>NsT(ZKhC-5
zJ@5Ox&-=XZO&)#A9yrU|AJ}X>g`d?0n=;0N)AqeVup1r@hR{^-8yZdpXQ2b@M(Wsi
zD5@2T>)%Hic_s}D!3KCptwnG!3c!5$D7p%)g)0;vSOh;-vS0$P7#asF;mfht!2%SH
z4KcupvWay7xKKy(3k!e7N>P9Bq>8i-&u#XhyPMwz+%?OLJ+<hStxL_I0cAdM0LD35
z3qSjG3=G2!BTK<+=;#O!z-)MO*V!HY+;BT}-sXzg>GSS}p<eEMw|i)@<-$uQvUc*=
za=~xGw-*9^HQ4oMbKerxPXA&O`B;GawO;JTr{C+AoAGv~sjnSxS9=)jcy)<rjR)xQ
zT5=e#dvg{({MjzH;cbF*VB3VtrgiRMCpt}9Cp)pQ4V$hvi1U&(b)&bhPU~WB@#0K;
zy4|t}U)`y<4ZpzNX{#fvPc&oG-NhVccej_1S!?np26N2UkYssl`Q6UPy1Bg55%Y6-
zFY(X&Ib!K9`viE^T6535!-5Ilv-9z8?w(V0#Qof4*>}><Vbf&UcQU|h9&XAkI<&c5
zp@l#d=5p9n@L0%u7q2Zb7rHH&Ymw%MTbQC%<c6D=(hL*6E;Vu3RB9ovrFLGYn37kt
zq<Wb9J)BOVo4eaA;5%gAdy)m$(D!g32mV5D9sHaFGtuQk12pg>|IxD?5YhdwJ7_S7
zoF`tjfL`?O>7_L72*9sS^r9@vxi<KG!kUy6iV4Y-yh+j0x-g_|6m&x}(z>h*h9-n%
zLk<~2NQ);`*-*3uFFf^NQ#EwCwlVlPFd%IE2oBt8-hZSH)S%;k^aFVKVvDmsD&t%c
zEmcnQ1XG6~=WHQhQAuARXZowzgn$r{R9!}6SpeXv-&l;}gr_dnHdnBeNEvD<tyek9
zVffRPHWuG_U}?PB+tKkniXY%YmxVtR0)c?wPNuYwtm{f*&<zJJwUaze&tYPu(lQ*&
zy5P#36`snnFqCu55T4E5HUM+kW{hBgQ#n_8pJv>+HW`)-xk_eQW<nMdsL216hE;;3
zKyRfb<>W+!e{alzg`5+M(dr8;DbgX_t7$>yFbUBGtbp`Horsc9^e7f*)#W+$|1S<#
zEs%<Qnksu$ZP4RhEmv@{CeMLRN`tc3>vd1p%Gz|<Sfj*cEp2!_^Wb~gR#Le;qa?yw
z1_Op9GCJO9N{--;x_woq3kXxV?{)(`a>=%EzTofbn%5)Xu?)r~RmIb%N?S;NJ*s6M
z*N2gWjVVQrs9W&d%y}av8|hS{5@l#fEb!xQl1OQjri6vH%Y<}Ueq9KsQ>3WWbb%1u
zbfH3SZ=<#>p%{v!DqElG5vEuD9G;o{3fgka-cupGI-L--L`W8tcpO9HPOD|+NiCUH
zN#C*l1ilJ~q+7?Bj!}l9bOHYb?4%x=DC>(wY8x}x@^F)xvd=DM%-a~N6PsXXemfXN
z$Md^ra1bq+8ezaObh<Rr3Vt{<S`Q+e$)G`3QT?(JTyNZtfA1eK6kSi2Sw)tdi`)1A
P(+JMd>plB_Yy#qc9i&SI

delta 800
zcmW-fT}YEr7{|}^o}KOW&8eB&oNlhE`H`TTlf;i^ubPn%N{U@XU}ctD<J}CxK0r%J
z5X$60S_Ima34zH8f><CZK~Y#YnRZhaeQd66Di|Tvc|8};^Zb9$pL6~fXDq1Mn${$*
z>-7@iXJ%F3b>uIaNgi&2MmpYdni*T~2yC{kKS?7alto8QxM*|h9yWd^RiI7BB(`w&
z9N=_>=!Dlmo4P7NrbAsNuy<Q8bUlL)bjb4&H*iPuc?%uzW<m~|@Om($vmHtsfSH~0
z-xj5Zi3t7fLovZmw|YvL<5C^4p3C(*NM+Bj8GtTcUjQGS?5~G1w%RWN80qFfu(!4<
zpha^y!{Zd@th+o}WX_TAF^lt=TD96GPUee5zMXf;HQf5bRa@hA3NK4#$!jC8s^v<q
zURO5icw5A^xx6jqV{Tk3k`sM4VYyrt%asSyxcHPJ+j;x!G;p?})hqg5&5B8@=rt==
zyNYV$LM0b{EvQXWQt`KavdGnUcNt&(DAfl*^Ajhjb*HT3C}bu)T_{WP6eolVFwYn&
zQXdNyZ_iH2YayX3gV#jDDXKqgBAkRRswZrdyu}IO!d{UF4m%|uUsTBkpNT}ay%7`P
zD6;L1*d#?FkwV#^5c12dUKJ&Tqo^dRbE>4+by16&HJU5=-8fn-6MqGcxwL#8s~{Z3
z+^RLMmAbQWJVh3}t$58!y0e*M&@RF>J39PG154~59U-vBM(*Aukj!l3?E;jtz6U`9
zZnl3iPk;{AG364Wf{o483qpN44GdPZj3;k1MuTaPz&s0eK>sZD(5ZI{y%n;u-uJ^s
zb}urB^F}a27k2Y6+J`o@C^0*R+HsD!aX^QX)8n$P9VePOqKD#F;Ub%l4+wCD9p322
zaD%<sT*-p_PahkhlV}41IAWcn77Khap2T2Y$4E#~OIl2$>R7|5!3wj&@%+(6E6D!=
D;7k4?

diff --git a/jobs.json b/jobs.json
new file mode 100644
index 0000000..6a6842c
--- /dev/null
+++ b/jobs.json
@@ -0,0 +1,18 @@
+{
+  "2024-01-01_12-00-00": {
+    "status": "processing",
+    "files": [
+      {
+        "name": "test.pdf",
+        "path": "/tmp/test.pdf"
+      }
+    ],
+    "zip_path": null,
+    "zip_name": null,
+    "processed_files": [],
+    "skipped": [],
+    "created_at": "2024-01-01 12:00:00",
+    "job_id": "2024-01-01_12-00-00",
+    "progress": "Created ZIP archive with 1 organized files"
+  }
+}
\ No newline at end of file
diff --git a/pdf_renamer.py b/pdf_renamer.py
index 013812f..8c4c9e9 100644
--- a/pdf_renamer.py
+++ b/pdf_renamer.py
@@ -510,6 +510,7 @@ def process_job(job_id, files):
         print("=== DEBUG: process_job STARTED ===")
         job_queue[job_id]['status'] = 'processing'
         job_queue[job_id]['progress'] = 'Starting job processing...'
+        save_jobs()  # Persist initial progress
         save_jobs()  # Persist status change
         processed_files = []
         temp_extract_dirs = []
@@ -538,6 +539,7 @@ def process_job(job_id, files):
                           for file_info in files if file_info['name'].lower().endswith('.zip'))
         
         job_queue[job_id]['progress'] = f'Found {total_files} files to process'
+        save_jobs()  # Persist file count
         
         processed_count = 0
         
@@ -662,6 +664,7 @@ def process_job(job_id, files):
                 job_queue[job_id]['zip_path'] = zip_output
                 job_queue[job_id]['zip_name'] = f'renamed_{job_id}.zip'
                 job_queue[job_id]['progress'] = f'Created ZIP archive with {len(successful_files)} organized files'
+                save_jobs()  # Persist completion progress
                 print(f"DEBUG: ZIP creation completed successfully")
             except Exception as e:
                 job_queue[job_id]['progress'] = f'Error creating ZIP: {str(e)}'
@@ -1028,17 +1031,41 @@ def jobs():
         <p>No jobs yet. <a href="/">Upload some files</a> to get started.</p>
         {% endif %}
         <script>
+            // Track previous job statuses to detect completion
+            let previousJobStatuses = {};
+            
             function updateJobs() {
                 fetch('/api/jobs', { credentials: 'same-origin' })
                     .then(response => response.json())
                     .then(data => {
                         console.log('Job update received:', data);
                         const jobs = Object.entries(data);
+                        
+                        // Check for job completions
+                        let hasNewCompletion = false;
                         if (jobs.length > 0) {
                             jobs.forEach(([jobId, job]) => {
                                 console.log(`Job ${jobId}: status=${job.status}, progress=${job.progress || 'none'}`);
+                                
+                                // Check if job just completed
+                                if (job.status === 'completed' && previousJobStatuses[jobId] === 'processing') {
+                                    hasNewCompletion = true;
+                                    console.log(`Job ${jobId} just completed!`);
+                                }
+                                
+                                // Update previous status
+                                previousJobStatuses[jobId] = job.status;
                             });
                         }
+                        
+                        // Redirect to completed jobs if a job just finished
+                        if (hasNewCompletion) {
+                            console.log('Redirecting to completed jobs page...');
+                            setTimeout(() => {
+                                window.location.href = '/completed-jobs';
+                            }, 500); // Small delay to show completion briefly
+                            return; // Stop processing to avoid UI updates during redirect
+                        }
                         const jobsContainer = document.querySelector('h1').parentNode;
                         const existingJobs = jobsContainer.querySelectorAll('.job');
                         const existingNoJobsMsg = jobsContainer.querySelectorAll('p');
@@ -1120,6 +1147,9 @@ def jobs():
             // Update jobs every 1 second
             setInterval(updateJobs, 1000);
             
+            // Initialize previous job statuses
+            updateJobs(); // Run once immediately to populate initial statuses
+            
             // Collapsible section functions
             function toggleZipDetails(element) {
                 const details = element.nextElementSibling;