hunk.code_window: import com.appsmith.external.models.Datasource;
   import com.appsmith.external.models.DatasourceTestResult;
   import com.appsmith.server.acl.AclPermission;
   import com.appsmith.server.services.CrudService;
   import reactor.core.publisher.Flux;
   import reactor.core.publisher.Mono;
   import java.util.List;
  
hunk.labels: keep keep add keep keep keep keep keep
hunk.after_edit: import com.appsmith.server.dtos.ActionDTO;
  
hunk.file_path: app/server/appsmith-server/src/main/java/com/appsmith/server/services/ce/DatasourceServiceCE.java
hunk.type: add
file: package com.appsmith.server.services;
  
  import com.appsmith.server.helpers.ResponseUtils;
  import com.appsmith.server.repositories.NotificationRepository;
  import com.appsmith.server.services.ce.NotificationServiceCEImpl;
  import lombok.extern.slf4j.Slf4j;
  import org.springframework.data.mongodb.core.ReactiveMongoTemplate;
  import org.springframework.data.mongodb.core.convert.MongoConverter;
  import org.springframework.stereotype.Service;
  import reactor.core.scheduler.Scheduler;
  
  import javax.validation.Validator;
  
  @Slf4j
  @Service
  public class NotificationServiceImpl extends NotificationServiceCEImpl implements NotificationService {
  
      public NotificationServiceImpl(Scheduler scheduler,
                                     Validator validator,
                                     MongoConverter mongoConverter,
                                     ReactiveMongoTemplate reactiveMongoTemplate,
                                     NotificationRepository repository,
                                     AnalyticsService analyticsService,
                                     SessionUserService sessionUserService,
                                     ResponseUtils responseUtils) {
  
          super(scheduler, validator, mongoConverter, reactiveMongoTemplate, repository, analyticsService,
                  sessionUserService, responseUtils);
      }
  }
  