Update script.js

script.js

@@ -1,80 +1,101 @@
 document.addEventListener("DOMContentLoaded", () => {
-    const workerUrl = "https://ctmresearchagent.aiagents.workers.dev"; // Replace if your URL is different
+    const workerUrl = "https://ctmresearchagent.aiagents.workers.dev"; // Your worker URL
     
     // Event Listeners
-    document.getElementById("uploadForm").addEventListener("submit", handleFileUpload);
+    document.getElementById("uploadForm").addEventListener("submit", handleReportUpload);
     document.getElementById("submitButton").addEventListener("click", handleAiQuerySubmit);
 
     // Initial data load
-    loadReportsFromRss();
+    loadReportsList();
     loadResearchHistory();
 
     /**
-     * Fetches and displays the list of reports from the backend's RSS parser
+     * NEW: Submits the structured report data as JSON
      */
-    async function loadReportsFromRss() {
+    async function handleReportUpload(event) {
+        event.preventDefault();
+        const uploadButton = document.getElementById("uploadButton");
+        const uploadStatus = document.getElementById("uploadStatus");
+        const report = {
+            title: document.getElementById('reportTitle').value,
+            description: document.getElementById('reportDescription').value,
+            body: document.getElementById('reportBody').value,
+        };
+
+        if (!report.title || !report.description || !report.body) {
+            uploadStatus.textContent = 'Please fill out all fields.';
+            return;
+        }
+
+        uploadButton.disabled = true;
+        uploadButton.innerText = "Processing...";
+        uploadStatus.textContent = "Submitting and processing report. This may take a moment...";
+
+        try {
+            const response = await fetch(`${workerUrl}/api/upload`, {
+                method: 'POST',
+                headers: { 'Content-Type': 'application/json' },
+                body: JSON.stringify(report),
+            });
+            const data = await response.json();
+            if (!response.ok) throw new Error(data.error || 'Failed to process report.');
+            
+            uploadStatus.textContent = `Success: ${data.message}`;
+            document.getElementById("uploadForm").reset();
+            await loadReportsList(); // Refresh the list
+        } catch (error) {
+            uploadStatus.textContent = `Error: ${error.message}`;
+        } finally {
+            uploadButton.disabled = false;
+            uploadButton.innerText = "Process and Add Report";
+        }
+    }
+
+    /**
+     * NEW: Loads the list of reports directly from the database
+     */
+    async function loadReportsList() {
         const reportsList = document.getElementById("reportsList");
         reportsList.innerHTML = "<p>Fetching reports...</p>";
         try {
-            const response = await fetch(`${workerUrl}/api/rss`);
-            if (!response.ok) throw new Error('Failed to fetch RSS feed.');
-            const items = await response.json();
+            const response = await fetch(`${workerUrl}/api/documents`);
+            if (!response.ok) throw new Error('Failed to fetch reports list.');
+            const documents = await response.json();
             
             reportsList.innerHTML = "";
-            if (items.length === 0) { reportsList.innerHTML = "<p>No reports found in the feed.</p>"; return; }
+            if (documents.length === 0) { reportsList.innerHTML = "<p>No reports have been added yet.</p>"; return; }
             
-            items.forEach(item => {
+            documents.forEach(doc => {
                 const entryDiv = document.createElement("div");
                 entryDiv.className = "report-entry";
-                entryDiv.innerHTML = `<a href="${item.link}" target="_blank" rel="noopener noreferrer">${item.title}</a><p>${item.description}</p>`;
+                entryDiv.innerHTML = `<h3>${doc.title}</h3><p>${doc.description}</p>`;
                 reportsList.appendChild(entryDiv);
             });
         } catch (error) {
             reportsList.innerHTML = `<p>Could not load reports: ${error.message}</p>`;
         }
     }
-    
-    // Simplified File Upload
-    async function handleFileUpload(event) {
-        event.preventDefault();
-        const fileInput = document.getElementById("fileInput");
-        const uploadStatus = document.getElementById("uploadStatus");
-        const file = fileInput.files[0];
-        if (!file) { uploadStatus.textContent = 'Please select a file.'; return; }
-        
-        uploadStatus.textContent = `Uploading ${file.name}...`;
-        const formData = new FormData();
-        formData.append('file', file);
-        
-        try {
-            const response = await fetch(`${workerUrl}/api/upload`, { method: 'POST', body: formData });
-            const data = await response.json();
-            if (!response.ok) throw new Error(data.error || 'Upload failed');
-            uploadStatus.textContent = `Success: ${data.message}`;
-            fileInput.value = ''; // Clear the file input
-        } catch (error) {
-            uploadStatus.textContent = `Error: ${error.message}`;
-        }
-    }
 
-    // Simplified AI Query
+    // AI Query and History functions remain the same as the last working version
+    async function handleAiQuerySubmit() { /* ... function code is unchanged ... */ }
+    async function loadResearchHistory() { /* ... function code is unchanged ... */ }
+
+    // Paste the unchanged functions here
     async function handleAiQuerySubmit() {
         const researchQueryInput = document.getElementById("researchQuery");
         const resultDisplay = document.getElementById("resultDisplay");
         const submitButton = document.getElementById("submitButton");
         const query = researchQueryInput.value.trim();
         if (!query) { alert("Please enter a query."); return; }
-        
         submitButton.disabled = true;
         submitButton.innerText = "Thinking...";
         resultDisplay.innerHTML = "<p>Generating response...</p>";
-        
         try {
             const response = await fetch(`${workerUrl}/api/query`, { method: "POST", headers: { "Content-Type": "application/json" }, body: JSON.stringify({ query: query }) });
             const data = await response.json();
             if (!response.ok) throw new Error(data.error || "An unknown error occurred.");
             resultDisplay.innerText = data.result;
-            await loadResearchHistory(); // Refresh history after a successful query
+            await loadResearchHistory();
         } catch (error) {
             resultDisplay.innerText = `Error: ${error.message}`;
         } finally {
@@ -82,8 +103,6 @@ document.addEventListener("DOMContentLoaded", () => {
             submitButton.innerText = "Submit";
         }
     }
-
-    // Unchanged History Loader
     async function loadResearchHistory() {
         const historyContainer = document.getElementById("historyContainer");
         try {