feat(react): create connect chat channel connections

apps/api/src/app/channel-connections/channel-connections.controller.ts

@@ -130,6 +130,7 @@ export class ChannelConnectionsController {
         integrationIdentifier: body.integrationIdentifier,
         subscriberId: body.subscriberId,
         context: body.context,
+        connectionMode: body.connectionMode,
         workspace: body.workspace,
         auth: body.auth,
       })

apps/api/src/app/channel-connections/dtos/create-channel-connection-request.dto.ts

@@ -1,8 +1,8 @@
 import { ApiProperty, ApiPropertyOptional } from '@nestjs/swagger';
 import { ApiContextPayload, IsValidContextPayload } from '@novu/application-generic';
-import { ContextPayload } from '@novu/shared';
+import { ConnectionMode, ContextPayload } from '@novu/shared';
 import { Type } from 'class-transformer';
-import { IsDefined, IsOptional, IsString, ValidateNested } from 'class-validator';
+import { IsDefined, IsIn, IsOptional, IsString, ValidateNested } from 'class-validator';
 import { AuthDto, WorkspaceDto } from './shared.dto';
 
 export class CreateChannelConnectionRequestDto {
@@ -30,6 +30,20 @@ export class CreateChannelConnectionRequestDto {
   @IsValidContextPayload({ maxCount: 5 })
   context?: ContextPayload;
 
+  @ApiPropertyOptional({
+    description:
+      'Connection mode that determines how the channel connection is scoped. ' +
+      'Use "subscriber" (default) to associate the connection with a specific subscriber. ' +
+      'Use "shared" to associate the connection with a context instead of a subscriber — ' +
+      'subscriberId will not be stored on the connection.',
+    enum: ['subscriber', 'shared'],
+    example: 'shared',
+  })
+  @IsOptional()
+  @IsString()
+  @IsIn(['subscriber', 'shared'])
+  connectionMode?: ConnectionMode;
+
   @ApiProperty({
     description: 'The identifier of the integration to use for this channel connection.',
     type: String,

apps/api/src/app/channel-connections/usecases/channel-connection.utils.ts

@@ -0,0 +1,44 @@
+import { BadRequestException } from '@nestjs/common';
+import { ConnectionMode, ContextPayload } from '@novu/shared';
+
+/**
+ * Validates that the subscriber/context combination is consistent with the
+ * requested connectionMode. Throws a BadRequestException when the caller
+ * violates the scoping rules for the chosen mode.
+ *
+ * Called from both CreateChannelConnection and GenerateSlackOauthUrl so the
+ * rules are enforced in one place.
+ */
+export function validateConnectionMode({
+  connectionMode,
+  subscriberId,
+  context,
+}: {
+  connectionMode?: ConnectionMode;
+  subscriberId?: string;
+  context?: ContextPayload;
+}): void {
+  if (connectionMode === 'shared') {
+    if (!context) {
+      throw new BadRequestException('context is required when connectionMode is "shared"');
+    }
+
+    if (subscriberId) {
+      throw new BadRequestException('subscriberId must not be provided when connectionMode is "shared"');
+    }
+
+    return;
+  }
+
+  if (connectionMode === 'subscriber') {
+    if (!subscriberId) {
+      throw new BadRequestException('subscriberId is required when connectionMode is "subscriber"');
+    }
+
+    return;
+  }
+
+  if (!subscriberId && !context) {
+    throw new BadRequestException('Either subscriberId or context must be provided');
+  }
+}

apps/api/src/app/channel-connections/usecases/create-channel-connection/create-channel-connection.command.ts

@@ -1,7 +1,7 @@
 import { IsValidContextPayload } from '@novu/application-generic';
-import { ContextPayload } from '@novu/shared';
+import { ConnectionMode, ContextPayload } from '@novu/shared';
 import { Type } from 'class-transformer';
-import { IsDefined, IsOptional, IsString, ValidateNested } from 'class-validator';
+import { IsDefined, IsIn, IsOptional, IsString, ValidateNested } from 'class-validator';
 import { EnvironmentCommand } from '../../../shared/commands/project.command';
 import { AuthDto, WorkspaceDto } from '../../dtos/shared.dto';
 
@@ -22,6 +22,11 @@ export class CreateChannelConnectionCommand extends EnvironmentCommand {
   @IsValidContextPayload({ maxCount: 5 })
   context?: ContextPayload;
 
+  @IsOptional()
+  @IsString()
+  @IsIn(['subscriber', 'shared'])
+  connectionMode?: ConnectionMode;
+
   @IsDefined()
   @ValidateNested()
   @Type(() => WorkspaceDto)

apps/api/src/app/channel-connections/usecases/create-channel-connection/create-channel-connection.usecase.ts

@@ -1,4 +1,4 @@
-import { BadRequestException, ConflictException, Injectable, NotFoundException } from '@nestjs/common';
+import { ConflictException, Injectable, NotFoundException } from '@nestjs/common';
 import { InstrumentUsecase, shortId } from '@novu/application-generic';
 import {
   ChannelConnectionEntity,
@@ -8,6 +8,7 @@ import {
   IntegrationRepository,
   SubscriberRepository,
 } from '@novu/dal';
+import { validateConnectionMode } from '../channel-connection.utils';
 import { CreateChannelConnectionCommand } from './create-channel-connection.command';
 
 @Injectable()
@@ -50,11 +51,11 @@ export class CreateChannelConnection {
   }
 
   private validateResourceOrContext(command: CreateChannelConnectionCommand) {
-    const { subscriberId, context } = command;
-
-    if (!subscriberId && !context) {
-      throw new BadRequestException('Either subscriberId or context must be provided');
-    }
+    validateConnectionMode({
+      connectionMode: command.connectionMode,
+      subscriberId: command.subscriberId,
+      context: command.context,
+    });
   }
 
   private async resolveContexts(command: CreateChannelConnectionCommand): Promise<string[]> {