hunk.code_window:     });
       const delayedCount = await jobRepository.count({
         _templateId: template._id,
         type: ChannelTypeEnum.DIGEST,
  
hunk.labels: keep keep replace keep keep
hunk.after_edit:     await awaitRunningJobs(2);
       const delayedJobs = await jobRepository.find({
  
hunk.file_path: apps/api/src/app/events/e2e/digest-events.e2e.ts
hunk.type: replace
file: import { IsDefined, IsEmail, IsOptional, IsString } from 'class-validator';
  import { CommandHelper } from '../../../shared/commands/command.helper';
  import { EnvironmentCommand } from '../../../shared/commands/project.command';
  
  export class CreateSubscriberCommand extends EnvironmentCommand {
    static create(data: CreateSubscriberCommand) {
      return CommandHelper.create(CreateSubscriberCommand, data);
    }
  
    @IsString()
    @IsDefined()
    subscriberId: string;
  
    @IsEmail()
    @IsOptional()
    email?: string;
  
    @IsString()
    @IsOptional()
    firstName?: string;
  
    @IsString()
    @IsOptional()
    lastName?: string;
  
    @IsString()
    @IsOptional()
    phone?: string;
  
    @IsString()
    @IsOptional()
    avatar?: string;
  }
  