feat(api,framework,dal): surface inbound attachments through agent bridge pipeline

Inbound media from chat platforms (images, documents, audio, video) was
silently dropped — the pipeline only passed message.text. This wires up
the full passthrough: Chat SDK Message.attachments → persist as
richContent on ConversationActivity → include in bridge payload and
history replay → expose as ctx.message.attachments in the framework.

Made-with: Cursor

Author: ChmaraX

apps/api/src/app/agents/services/agent-conversation.service.ts

@@ -32,6 +32,7 @@ export interface PersistInboundMessageParams {
   senderId: string;
   senderName?: string;
   content: string;
+  richContent?: Record<string, unknown>;
   platformMessageId?: string;
   environmentId: string;
   organizationId: string;
@@ -140,6 +141,7 @@ export class AgentConversationService {
         senderId: params.senderId,
         senderName: params.senderName,
         content: params.content,
+        richContent: params.richContent,
         platformMessageId: params.platformMessageId,
         environmentId: params.environmentId,
         organizationId: params.organizationId,

apps/api/src/app/agents/services/agent-inbound-handler.service.ts

@@ -90,6 +90,18 @@ export class AgentInboundHandler {
       ? ConversationActivitySenderTypeEnum.SUBSCRIBER
       : ConversationActivitySenderTypeEnum.PLATFORM_USER;
 
+    const richContent = message.attachments?.length
+      ? {
+          attachments: message.attachments.map((a) => ({
+            type: a.type,
+            url: a.url,
+            name: a.name,
+            mimeType: a.mimeType,
+            size: a.size,
+          })),
+        }
+      : undefined;
+
     await this.conversationService.persistInboundMessage({
       conversationId: conversation._id,
       platform: config.platform,
@@ -99,6 +111,7 @@ export class AgentInboundHandler {
       senderId: participantId,
       senderName: message.author.fullName,
       content: message.text,
+      richContent,
       platformMessageId: message.id,
       environmentId: config.environmentId,
       organizationId: config.organizationId,

apps/api/src/app/agents/services/bridge-executor.service.ts

@@ -51,11 +51,20 @@ interface BridgeMessageAuthor {
   isBot: boolean | 'unknown';
 }
 
+interface BridgeAttachment {
+  type: string;
+  url?: string;
+  name?: string;
+  mimeType?: string;
+  size?: number;
+}
+
 interface BridgeMessage {
   text: string;
   platformMessageId: string;
   author: BridgeMessageAuthor;
   timestamp: string;
+  attachments?: BridgeAttachment[];
 }
 
 export interface BridgeAction {
@@ -87,6 +96,7 @@ interface BridgeHistoryEntry {
   role: ConversationActivitySenderTypeEnum;
   type: ConversationActivityTypeEnum;
   content: string;
+  richContent?: Record<string, unknown>;
   senderName?: string;
   signalData?: { type: string; payload?: Record<string, unknown> };
   createdAt: string;
@@ -282,7 +292,7 @@ export class BridgeExecutorService {
   }
 
   private mapMessage(message: Message): BridgeMessage {
-    return {
+    const mapped: BridgeMessage = {
       text: message.text,
       platformMessageId: message.id,
       author: {
@@ -293,6 +303,18 @@ export class BridgeExecutorService {
       },
       timestamp: message.metadata?.dateSent?.toISOString() ?? new Date().toISOString(),
     };
+
+    if (message.attachments?.length) {
+      mapped.attachments = message.attachments.map((a) => ({
+        type: a.type,
+        url: a.url,
+        name: a.name,
+        mimeType: a.mimeType,
+        size: a.size,
+      }));
+    }
+
+    return mapped;
   }
 
   private mapConversation(conversation: ConversationEntity): BridgeConversation {
@@ -337,6 +359,7 @@ export class BridgeExecutorService {
       role: activity.senderType,
       type: activity.type,
       content: activity.content,
+      richContent: activity.richContent || undefined,
       senderName: activity.senderName || undefined,
       signalData: activity.signalData || undefined,
       createdAt: activity.createdAt,

libs/dal/src/repositories/conversation-activity/conversation-activity.repository.ts

@@ -54,6 +54,7 @@ export class ConversationActivityRepository extends BaseRepositoryV2<
     senderType: ConversationActivitySenderTypeEnum;
     senderId: string;
     content: string;
+    richContent?: Record<string, unknown>;
     platformMessageId?: string;
     senderName?: string;
     environmentId: string;
@@ -69,6 +70,7 @@ export class ConversationActivityRepository extends BaseRepositoryV2<
       senderType: params.senderType,
       senderId: params.senderId,
       content: params.content,
+      richContent: params.richContent,
       platformMessageId: params.platformMessageId,
       senderName: params.senderName,
       _environmentId: params.environmentId,

packages/framework/src/resources/agent/agent.types.ts

@@ -18,11 +18,20 @@ export interface AgentMessageAuthor {
   isBot: boolean | 'unknown';
 }
 
+export interface AgentAttachment {
+  type: string;
+  url?: string;
+  name?: string;
+  mimeType?: string;
+  size?: number;
+}
+
 export interface AgentMessage {
   text: string;
   platformMessageId: string;
   author: AgentMessageAuthor;
   timestamp: string;
+  attachments?: AgentAttachment[];
 }
 
 export interface AgentConversation {
@@ -49,6 +58,7 @@ export interface AgentHistoryEntry {
   role: string;
   type: string;
   content: string;
+  richContent?: Record<string, unknown>;
   senderName?: string;
   signalData?: { type: string; payload?: Record<string, unknown> };
   createdAt: string;

packages/framework/src/resources/agent/index.ts

@@ -16,6 +16,7 @@ export { agent } from './agent.resource';
 export type {
   Agent,
   AgentAction,
+  AgentAttachment,
   AgentBridgeRequest,
   AgentContext,
   AgentConversation,