worker: execute upload_pdf jobs

worker.py

@@ -115,6 +115,31 @@ def poll_loop():
                 job = r.json()
                 job_id = job.get("job_id") or job.get("id")
                 print(f"claimed job {job_id}", flush=True)
+
+                payload = job.get("payload", {})
+
+                try:
+                    action = payload.get("action")
+
+                    if action == "upload_pdf":
+                        pdf_id = payload["pdf_id"]
+                        pdf_b64 = payload["pdf_b64"]
+
+                        import base64
+                        from sftp_store import upload_bytes
+
+                        data = base64.b64decode(pdf_b64)
+                        remote_path = f"pdfs/{pdf_id}.pdf"
+
+                        print(f"uploading pdf {pdf_id} ({len(data)} bytes)", flush=True)
+                        upload_bytes(remote_path, data)
+                        print(f"uploaded to {remote_path}", flush=True)
+
+                    else:
+                        print(f"unknown action: {action}", flush=True)
+
+                except Exception as e:
+                    print(f"job {job_id} failed: {e}", flush=True)
                 # processing placeholder
 
         except Exception as e: