feat(api-service): add typing indicator toggle to agent settings fixes NV-7366

Allow users to disable the typing indicator per-agent from the dashboard.
Defaults to enabled (preserving current behavior), only an explicit
`false` suppresses the `startTyping()` call on inbound messages.

Made-with: Cursor

Author: ChmaraX

apps/api/src/app/agents/agents.controller.ts

@@ -287,6 +287,7 @@ export class AgentsController {
         identifier,
         name: body.name,
         description: body.description,
+        typingIndicatorEnabled: body.typingIndicatorEnabled,
       })
     );
   }

apps/api/src/app/agents/dtos/agent-response.dto.ts

@@ -21,6 +21,9 @@ export class AgentResponseDto {
   @ApiProperty()
   _organizationId: string;
 
+  @ApiPropertyOptional({ description: 'Show a typing indicator while the agent is processing a message' })
+  typingIndicatorEnabled?: boolean;
+
   @ApiProperty()
   createdAt: string;
 

apps/api/src/app/agents/dtos/update-agent-request.dto.ts

@@ -1,5 +1,5 @@
 import { ApiPropertyOptional } from '@nestjs/swagger';
-import { IsOptional, IsString } from 'class-validator';
+import { IsBoolean, IsOptional, IsString } from 'class-validator';
 
 export class UpdateAgentRequestDto {
   @ApiPropertyOptional()
@@ -11,4 +11,9 @@ export class UpdateAgentRequestDto {
   @IsString()
   @IsOptional()
   description?: string;
+
+  @ApiPropertyOptional({ description: 'Show a typing indicator while the agent is processing a message' })
+  @IsBoolean()
+  @IsOptional()
+  typingIndicatorEnabled?: boolean;
 }

apps/api/src/app/agents/mappers/agent-response.mapper.ts

@@ -8,6 +8,7 @@ export function toAgentResponse(agent: AgentEntity): AgentResponseDto {
     name: agent.name,
     identifier: agent.identifier,
     description: agent.description,
+    typingIndicatorEnabled: agent.typingIndicatorEnabled,
     _environmentId: agent._environmentId,
     _organizationId: agent._organizationId,
     createdAt: agent.createdAt,

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

@@ -20,6 +20,7 @@ export interface ResolvedPlatformConfig {
   agentIdentifier: string;
   integrationIdentifier: string;
   integrationId: string;
+  typingIndicatorEnabled: boolean;
 }
 
 @Injectable()
@@ -100,6 +101,7 @@ export class AgentCredentialService {
       agentIdentifier: agent.identifier,
       integrationIdentifier,
       integrationId: integration._id,
+      typingIndicatorEnabled: agent.typingIndicatorEnabled !== false,
     };
   }
 }

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

@@ -75,7 +75,9 @@ export class AgentInboundHandler {
       organizationId: config.organizationId,
     });
 
-    await thread.startTyping();
+    if (config.typingIndicatorEnabled) {
+      await thread.startTyping();
+    }
 
     const serializedThread = thread.toJSON() as unknown as Record<string, unknown>;
     await this.conversationService.updateChannelThread(

apps/api/src/app/agents/usecases/update-agent/update-agent.command.ts

@@ -1,4 +1,4 @@
-import { IsNotEmpty, IsOptional, IsString } from 'class-validator';
+import { IsBoolean, IsNotEmpty, IsOptional, IsString } from 'class-validator';
 
 import { EnvironmentWithUserCommand } from '../../../shared/commands/project.command';
 
@@ -14,4 +14,8 @@ export class UpdateAgentCommand extends EnvironmentWithUserCommand {
   @IsString()
   @IsOptional()
   description?: string;
+
+  @IsBoolean()
+  @IsOptional()
+  typingIndicatorEnabled?: boolean;
 }

apps/api/src/app/agents/usecases/update-agent/update-agent.usecase.ts

@@ -10,8 +10,8 @@ export class UpdateAgent {
   constructor(private readonly agentRepository: AgentRepository) {}
 
   async execute(command: UpdateAgentCommand): Promise<AgentResponseDto> {
-    if (command.name === undefined && command.description === undefined) {
-      throw new BadRequestException('At least one of name or description must be provided.');
+    if (command.name === undefined && command.description === undefined && command.typingIndicatorEnabled === undefined) {
+      throw new BadRequestException('At least one of name, description, or typingIndicatorEnabled must be provided.');
     }
 
     const existing = await this.agentRepository.findOne(
@@ -27,7 +27,7 @@ export class UpdateAgent {
       throw new NotFoundException(`Agent with identifier "${command.identifier}" was not found.`);
     }
 
-    const $set: Record<string, string> = {};
+    const $set: Record<string, unknown> = {};
 
     if (command.name !== undefined) {
       $set.name = command.name;
@@ -37,6 +37,10 @@ export class UpdateAgent {
       $set.description = command.description;
     }
 
+    if (command.typingIndicatorEnabled !== undefined) {
+      $set.typingIndicatorEnabled = command.typingIndicatorEnabled;
+    }
+
     await this.agentRepository.updateOne(
       {
         _id: existing._id,

libs/dal/src/repositories/agent/agent.entity.ts

@@ -15,6 +15,8 @@ export class AgentEntity {
 
   _organizationId: OrganizationId;
 
+  typingIndicatorEnabled?: boolean;
+
   createdAt: string;
 
   updatedAt: string;

libs/dal/src/repositories/agent/agent.schema.ts

@@ -14,6 +14,7 @@ const agentSchema = new Schema<AgentDBModel>(
       required: true,
     },
     description: Schema.Types.String,
+    typingIndicatorEnabled: Schema.Types.Boolean,
     _organizationId: {
       type: Schema.Types.ObjectId,
       ref: 'Organization',