void createLockIndex()

in spi/src/main/java/org/opensearch/jobscheduler/spi/utils/LockService.java [81:99]

19 lines of code
4 McCabe index (conditional complexity)


    void createLockIndex(ActionListener<Boolean> listener) {
        if (lockIndexExist()) {
            listener.onResponse(true);
        } else {
            final CreateIndexRequest request = new CreateIndexRequest(LOCK_INDEX_NAME)
                    .mapping(MAPPING_TYPE, lockMapping(), XContentType.JSON);
            client.admin().indices().create(request, ActionListener.wrap(
               response -> listener.onResponse(response.isAcknowledged()),
               exception -> {
                   if (exception instanceof ResourceAlreadyExistsException
                           || exception.getCause() instanceof ResourceAlreadyExistsException) {
                       listener.onResponse(true);
                   } else {
                       listener.onFailure(exception);
                   }
               }
            ));
        }
    }