Add endpoint to fetch session messages and update frontend handling

- Implemented a new API endpoint to retrieve messages for a specific session, enhancing data retrieval from the content service.
- Updated the ProjectSessionDetailPage to fetch and display messages, ensuring real-time updates and improved user experience.
- Modified the AgenticSessionStatus type to include message count, aligning with the new message handling logic.

Author: Gkrumbach07

components/backend/handlers.go

@@ -806,6 +806,22 @@ func getSession(c *gin.Context) {
 	c.JSON(http.StatusOK, session)
 }
 
+// GET /api/projects/:projectName/agentic-sessions/:sessionName/messages
+// Returns the messages.json content for a session by fetching from the per-project content service
+// and falling back to local state directory if the content service is unavailable.
+func getSessionMessages(c *gin.Context) {
+	project := c.GetString("project")
+	sessionName := c.Param("sessionName")
+
+	// First try via per-namespace content service using caller's token
+	data, err := readProjectContentFile(c, project, fmt.Sprintf("/sessions/%s/messages.json", sessionName))
+	if err != nil {
+		c.JSON(http.StatusBadGateway, gin.H{"error": "failed to fetch messages"})
+		return
+	}
+	c.Data(http.StatusOK, "application/json", data)
+}
+
 // --- Git helpers (project-scoped) ---
 
 func stringPtr(s string) *string { return &s }

components/backend/main.go

@@ -101,6 +101,7 @@ func main() {
 			projectGroup.POST("/agentic-sessions/:sessionName/stop", stopSession)
 			projectGroup.PUT("/agentic-sessions/:sessionName/status", updateSessionStatus)
 			projectGroup.PUT("/agentic-sessions/:sessionName/displayname", updateSessionDisplayName)
+			projectGroup.GET("/agentic-sessions/:sessionName/messages", getSessionMessages)
 
 			// RFE workflow endpoints (project-scoped)
 			projectGroup.GET("/rfe-workflows", listProjectRFEWorkflows)

components/frontend/src/app/api/projects/[name]/sessions/[sessionName]/messages/route.ts

@@ -0,0 +1,16 @@
+import { BACKEND_URL } from '@/lib/config'
+import { buildForwardHeadersAsync } from '@/lib/auth'
+
+export async function GET(
+  request: Request,
+  { params }: { params: Promise<{ name: string; sessionName: string }> },
+) {
+  const { name, sessionName } = await params
+  const headers = await buildForwardHeadersAsync(request)
+  const resp = await fetch(`${BACKEND_URL}/projects/${encodeURIComponent(name)}/agentic-sessions/${encodeURIComponent(sessionName)}/messages`, { headers })
+  const contentType = resp.headers.get('content-type') || 'application/json'
+  const body = await resp.text()
+  return new Response(body, { status: resp.status, headers: { 'Content-Type': contentType } })
+}
+
+

components/frontend/src/app/projects/[name]/sessions/[sessionName]/page.tsx

@@ -121,6 +121,7 @@ export default function ProjectSessionDetailPage({ params }: { params: Promise<{
   const [sessionName, setSessionName] = useState<string>("");
 
   const [session, setSession] = useState<AgenticSession | null>(null);
+  const [messages, setMessages] = useState<MessageObject[]>([]);
   const [loading, setLoading] = useState(true);
   const [error, setError] = useState<string | null>(null);
   const [actionLoading, setActionLoading] = useState<string | null>(null);
@@ -151,6 +152,14 @@ export default function ProjectSessionDetailPage({ params }: { params: Promise<{
       }
       const data = await response.json();
       setSession(data);
+      // Fetch messages from proxy endpoint to ensure latest content
+      const msgResp = await fetch(
+        `${apiUrl}/projects/${encodeURIComponent(projectName)}/sessions/${encodeURIComponent(sessionName)}/messages`
+      );
+      if (msgResp.ok) {
+        const msgData = await msgResp.json();
+        if (Array.isArray(msgData)) setMessages(msgData);
+      }
     } catch (err) {
       setError(err instanceof Error ? err.message : "Unknown error");
     } finally {
@@ -522,7 +531,7 @@ export default function ProjectSessionDetailPage({ params }: { params: Promise<{
         )}
 
         {/* Real-time Messages Progress*/}
-        {((session.status?.messages && session.status.messages.length > 0) ||
+        {(messages.length > 0 ||
           session.status?.phase === "Running" ||
           session.status?.phase === "Pending" ||
           session.status?.phase === "Creating") && (
@@ -531,16 +540,16 @@ export default function ProjectSessionDetailPage({ params }: { params: Promise<{
               <CardTitle className="flex items-center justify-between">
                 <span>Agentic Progress</span>
                 <Badge variant="secondary">
-                  {mergeToolUseAndResults(session.status?.messages).length} message
-                  {mergeToolUseAndResults(session.status?.messages).length !== 1 ? "s" : ""}
+                  {mergeToolUseAndResults(messages).length} message
+                  {mergeToolUseAndResults(messages).length !== 1 ? "s" : ""}
                 </Badge>
               </CardTitle>
               <CardDescription>Live analysis from Claude AI</CardDescription>
             </CardHeader>
             <CardContent>
               <div className="max-h-96 overflow-y-auto space-y-4 bg-gray-50 rounded-lg p-4">
                 {/* Display all existing messages (normalized/merged) */}
-                {mergeToolUseAndResults(session.status?.messages).map((message, index) => (
+                {mergeToolUseAndResults(messages).map((message, index) => (
                   <StreamMessage key={`msg-${index}`} message={message as any} />
                 ))}
 
@@ -563,7 +572,7 @@ export default function ProjectSessionDetailPage({ params }: { params: Promise<{
                 )}
 
                 {/* Show empty state if no messages yet */}
-                {(!session.status?.messages || session.status.messages.length === 0) &&
+                {(messages.length === 0) &&
                   session.status?.phase !== "Running" &&
                   session.status?.phase !== "Pending" &&
                   session.status?.phase !== "Creating" && (

components/frontend/src/types/agentic-session.ts

@@ -106,7 +106,10 @@ export type AgenticSessionStatus = {
 	jobName?: string;
 	finalOutput?: string;
 	cost?: number;
-	messages?: MessageObject[];
+  	// Storage & counts (align with CRD)
+  	stateDir?: string;
+  	artifactsCount?: number;
+  	messagesCount?: number;
 	// Runner result summary fields
 	subtype?: string;
 	duration_ms?: number;