hunk.code_window:     await workflowQueueService.work(delayedJob);
       const jobs = await jobRepository.find({
         _templateId: template._id,
       });
       const digestjobs = jobs.find((item) => item.digest.events.length > 0);
       await workflowQueueService.work(digestjobs);
       const messages = await messageRepository.find({
         _environmentId: session.environment._id,
         _subscriberId: subscriber._id,
         channel: ChannelTypeEnum.SMS,
  
hunk.labels: keep replace replace replace replace replace replace keep keep keep keep keep
hunk.after_edit:     for (const job of delayedJobs) {
         await workflowQueueService.work(job);
       }
       await awaitRunningJobs(0);
  
hunk.file_path: apps/api/src/app/events/e2e/digest-events.e2e.ts
hunk.type: replace
file: import { IntegrationEntity } from '@novu/dal';
  import { ISmsHandler } from './sms.handler.interface';
  
  export interface ISmsFactory {
    getHandler(integration: IntegrationEntity): ISmsHandler;
  }
  