Update src/streamlit_app.py

src/streamlit_app.py

@@ -91,6 +91,7 @@ for k, v in {
     "token": None,
     "oauth_state": None,
     "messages": [],
+    "messages_df": None,
     "target_emails": [],
     "target_emails_df": None,
     "rj_emails": [],
@@ -321,6 +322,28 @@ def build_target_emails(messages, sender_filter, target_filter):
     return rows
 
 
+def build_fetched_emails(messages):
+    rows = []
+    for i, msg in enumerate(messages, 1):
+        info = extract_info(msg)
+        forwarded = fwd_headers(info.get("body_html", ""))
+        rows.append({
+            "email_id": info.get("id") or f"msg_{i}",
+            "subject": info.get("subject"),
+            "from": info.get("from"),
+            "to": ", ".join(info.get("to", [])),
+            "cc": ", ".join(info.get("cc", [])),
+            "received_time": info.get("received_time"),
+            "is_rj_forward": is_rj(info),
+            "forwarded_from": forwarded.get("forwarded_from", ""),
+            "forwarded_to": forwarded.get("forwarded_to", ""),
+            "forwarded_cc": forwarded.get("forwarded_cc", ""),
+            "forwarded_subject": forwarded.get("forwarded_subject", ""),
+            "body_preview": html_to_text(info.get("body_html", ""))[:300],
+        })
+    return rows
+
+
 def extract_tables(body_html):
     if not body_html:
         return []
@@ -452,6 +475,7 @@ if st.button("▶ Run", disabled=not st.session_state.token):
         try:
             raw = get_emails(st.session_state.token, int(top_n))
             st.session_state.messages = raw
+            st.session_state.messages_df = pd.DataFrame(build_fetched_emails(raw)) if raw else pd.DataFrame()
         except requests.HTTPError as e:
             if e.response.status_code == 401:
                 st.error("Session expired. Please sign in again.")
@@ -508,6 +532,16 @@ if st.button("▶ Run", disabled=not st.session_state.token):
 
 # ── Results ────────────────────────────────────────────────────────────────────
 st.markdown('<div class="step-label">Step 4</div>', unsafe_allow_html=True)
+st.markdown('<div class="step-title">Debug: All Fetched Inbox Emails</div>', unsafe_allow_html=True)
+
+fetched_df = st.session_state.messages_df
+if fetched_df is not None:
+    if not fetched_df.empty:
+        st.dataframe(fetched_df, width="stretch", hide_index=True)
+    elif st.session_state.messages == []:
+        st.caption("Run the fetch step to inspect all fetched inbox emails.")
+
+st.markdown('<div class="step-label">Step 5</div>', unsafe_allow_html=True)
 st.markdown('<div class="step-title">Debug: All Emails from A to B</div>', unsafe_allow_html=True)
 
 debug_df = st.session_state.target_emails_df