Add connection deletion actions

app.py

@@ -560,22 +560,46 @@ def get_hospital_connections():
     return jsonify({"connections": db.get_hospital_connections(session["hospital_id"])})
 
 
-@app.route("/api/hospital/connections/<cid>/status", methods=["PUT"])
-def update_hospital_connection_status(cid):
-    err = _hospital_required()
-    if err:
-        return err
+@app.route("/api/hospital/connections/<cid>/status", methods=["PUT"])
+def update_hospital_connection_status(cid):
+    err = _hospital_required()
+    if err:
+        return err
     data   = request.get_json(force=True) or {}
     status = data.get("status", "")
     if status not in ("pending", "accepted", "rejected", "completed"):
         return jsonify({"error": "Invalid status"}), 400
-    db.update_connection_status(cid, status)
-    return jsonify({"success": True})
-
-
-# ---------------------------------------------------------------------------
-# Connection Messages
-# ---------------------------------------------------------------------------
+    db.update_connection_status(cid, status)
+    return jsonify({"success": True})
+
+
+@app.route("/api/patient/connections/<cid>", methods=["DELETE"])
+def delete_patient_connection(cid):
+    err = _patient_required()
+    if err:
+        return err
+    conn = db.get_connection(cid)
+    if not conn or conn["patient_id"] != session["patient_id"]:
+        return jsonify({"error": "Not found"}), 404
+    db.delete_connection(cid)
+    return jsonify({"success": True})
+
+
+@app.route("/api/hospital/connections/<cid>", methods=["DELETE"])
+def delete_hospital_connection(cid):
+    err = _hospital_required()
+    if err:
+        return err
+    conn = db.get_connection(cid)
+    if not conn or conn["hospital_id"] != session["hospital_id"]:
+        return jsonify({"error": "Not found"}), 404
+    db.delete_connection(cid)
+    return jsonify({"success": True})
+
+
+# ---------------------------------------------------------------------------
+# Connection Messages
+# ---------------------------------------------------------------------------
 
 @app.route("/api/patient/connections/<cid>/messages", methods=["GET"])
 def get_patient_connection_messages(cid):

database.py

@@ -559,14 +559,23 @@ def get_hospital_connections(hospital_id: str) -> list:
     return result
 
 
-def update_connection_status(cid: str, status: str):
-    with _conn() as c:
-        c.execute("UPDATE connections SET status=? WHERE id=?", (status, cid))
-        c.commit()
-
-
-def get_open_patients_for_hospital(hospital_id: str, condition_filter: str = "",
-                                    include_connected: bool = False) -> list:
+def update_connection_status(cid: str, status: str):
+    with _conn() as c:
+        c.execute("UPDATE connections SET status=? WHERE id=?", (status, cid))
+        c.commit()
+
+
+def delete_connection(cid: str) -> bool:
+    """Delete a connection and its message history."""
+    with _conn() as c:
+        c.execute("DELETE FROM connection_messages WHERE connection_id=?", (cid,))
+        cur = c.execute("DELETE FROM connections WHERE id=?", (cid,))
+        c.commit()
+    return cur.rowcount > 0
+
+
+def get_open_patients_for_hospital(hospital_id: str, condition_filter: str = "",
+                                    include_connected: bool = False) -> list:
     """
     Returns patients who are open_to_trials=1, optionally filtered by condition.
     When include_connected=False (default), excludes patients already connected to this hospital.

templates/hospital.html

@@ -163,7 +163,7 @@ body{background:#0d1117;}
         <table class="table table-dark table-hover table-sm align-middle">
           <thead><tr>
             <th>Patient</th><th>Age/Gender</th><th>Conditions</th>
-            <th>Trial</th><th>Initiated</th><th>Status</th><th>Message</th><th>Action</th><th>Chat</th>
+            <th>Trial</th><th>Initiated</th><th>Status</th><th>Message</th><th>Status Action</th><th>Actions</th>
           </tr></thead>
           <tbody id="cTbody"></tbody>
         </table>
@@ -264,6 +264,7 @@ document.addEventListener('DOMContentLoaded', () => {
     if (!btn) return;
     if (btn.dataset.st)                     updateStatus(btn.dataset.cid, btn.dataset.st);
     else if ('chat' in btn.dataset)         openMsgModal(btn.dataset.cid, btn.dataset.chat);
+    else if ('del' in btn.dataset)          deleteConnection(btn.dataset.cid, btn.dataset.del);
   });
 
   loadPatients();
@@ -451,6 +452,15 @@ async function loadConnections() {
         `<button class="btn btn-sm btn-outline-info py-0 px-2" style="font-size:.72rem"
            data-cid="${escA(c.id)}" data-chat="${escA(pname)}">💬 Chat</button>`,
       ].map(v=>`<td>${v}</td>`).join('');
+      const actionsCell = tr.lastElementChild;
+      const delBtn = document.createElement('button');
+      delBtn.type = 'button';
+      delBtn.className = 'btn btn-sm btn-outline-danger py-0 px-2 ms-1';
+      delBtn.style.fontSize = '.72rem';
+      delBtn.textContent = 'Delete';
+      delBtn.dataset.cid = c.id;
+      delBtn.dataset.del = pname;
+      actionsCell.appendChild(delBtn);
       tbody.appendChild(tr);
     });
   } catch(e) {}
@@ -477,6 +487,20 @@ async function updateStatus(cid, status) {
 }
 
 // ── MY TRIALS ────────────────────────────────────────────────────────────────
+async function deleteConnection(cid, patientName) {
+  const ok = confirm(`Remove connection with ${patientName || 'this patient'}? This will also remove the chat thread.`);
+  if (!ok) return;
+  try {
+    const r = await fetch('/api/hospital/connections/'+encodeURIComponent(cid), {method:'DELETE'});
+    const d = await r.json();
+    if (!r.ok) { alert(d.error || 'Delete failed'); return; }
+    await loadConnections();
+    loadInbox();
+  } catch(e) {
+    alert('Network error');
+  }
+}
+
 async function loadTrials() {
   show('tLoading'); hide('tEmpty'); document.getElementById('tGrid').innerHTML = '';
   try {

templates/patient.html

@@ -192,7 +192,7 @@ body{background:#0d1117;}
         <table class="table table-dark table-hover table-sm align-middle">
           <thead><tr>
             <th>Hospital</th><th>Trial</th><th>Initiated By</th>
-            <th>Status</th><th>Message</th><th>Date</th><th>Chat</th>
+            <th>Status</th><th>Message</th><th>Date</th><th>Actions</th>
           </tr></thead>
           <tbody id="connsTbody"></tbody>
         </table>
@@ -678,12 +678,36 @@ async function loadConnections() {
         `<button class="btn btn-sm btn-outline-info py-0 px-2" style="font-size:.72rem"
            onclick="openMsgModal('${escA(c.id)}','${escA(hname)}')">💬 Chat</button>`,
       ].map(v=>`<td>${v}</td>`).join('');
+      const actionsCell = tr.lastElementChild;
+      const delBtn = document.createElement('button');
+      delBtn.type = 'button';
+      delBtn.className = 'btn btn-sm btn-outline-danger py-0 px-2 ms-1';
+      delBtn.style.fontSize = '.72rem';
+      delBtn.textContent = 'Delete';
+      delBtn.addEventListener('click', () => deleteConnection(c.id, hname));
+      actionsCell.appendChild(delBtn);
       tbody.appendChild(tr);
     });
   } catch(e) {}
 }
 
-// ── DOCUMENTS ─────────────────────────────────────────────────────────────────
+// Connection removal
+// Remove the selected hospital connection and associated chat thread.
+async function deleteConnection(cid, hospitalName) {
+  const ok = confirm(`Remove connection with ${hospitalName || 'this hospital'}? This will also remove the chat thread.`);
+  if (!ok) return;
+  try {
+    const r = await fetch('/api/patient/connections/'+encodeURIComponent(cid), {method:'DELETE'});
+    const d = await r.json();
+    if (!r.ok) { alert(d.error || 'Delete failed'); return; }
+    await loadConnections();
+    loadInbox();
+  } catch(e) {
+    alert('Network error');
+  }
+}
+
+// Documents
 function renderDocList() {
   const wrap = document.getElementById('docList');
   wrap.innerHTML = '';