hunk.code_window:                 .map(response -> {
                       // Choose body depending on response status
                       byte[] responseBody = response.getBody();
                       if (responseBody == null || !response.getStatusCode().is2xxSuccessful()) {
                           throw Exceptions.propagate(new AppsmithPluginException(
                                   AppsmithPluginError.PLUGIN_ERROR,
  
hunk.labels: keep keep keep keep replace keep keep
hunk.after_edit:                     if (responseBody == null) {
  
hunk.file_path: app/server/appsmith-plugins/googleSheetsPlugin/src/main/java/com/external/config/AppendMethod.java
hunk.type: replace
file: package com.appsmith.server.repositories.ce;
  
  import com.appsmith.server.acl.AclPermission;
  import com.appsmith.server.domains.CommentMode;
  import com.appsmith.server.domains.CommentThread;
  import com.appsmith.server.dtos.CommentThreadFilterDTO;
  import com.appsmith.server.repositories.AppsmithRepository;
  import com.mongodb.client.result.UpdateResult;
  import reactor.core.publisher.Flux;
  import reactor.core.publisher.Mono;
  
  import java.util.Set;
  
  public interface CustomCommentThreadRepositoryCE extends AppsmithRepository<CommentThread> {
  
      Flux<CommentThread> findByApplicationId(String applicationId, AclPermission permission);
  
      Flux<CommentThread> find(CommentThreadFilterDTO commentThreadFilterDTO, AclPermission permission);
  
      Mono<UpdateResult> addToSubscribers(String threadId, Set<String> usernames);
  
      Mono<UpdateResult> removeSubscriber(String threadId, String username);
  
      Mono<CommentThread> findPrivateThread(String applicationId);
  
      Mono<Long> countUnreadThreads(String applicationId, String userEmail);
  
      Mono<UpdateResult> archiveByPageId(String pageId, CommentMode commentMode);
  }
  