#1810 Add Jackson3JsonpMapper

java-client/build.gradle.kts

@@ -180,6 +180,7 @@ val opensearchVersion = "3.5.0-SNAPSHOT"
 
 dependencies {
     val jacksonVersion = "2.20.1"
+    val jackson3Version = "3.0.4"
     val jacksonDatabindVersion = "2.20.1"
 
     // Apache 2.0
@@ -217,6 +218,8 @@ dependencies {
     // Apache 2.0
     implementation("com.fasterxml.jackson.core", "jackson-core", jacksonVersion)
     implementation("com.fasterxml.jackson.core", "jackson-databind", jacksonDatabindVersion)
+    implementation("tools.jackson.core", "jackson-core", jackson3Version)
+    implementation("tools.jackson.core", "jackson-databind", jackson3Version)
     testImplementation("com.fasterxml.jackson.datatype", "jackson-datatype-jakarta-jsonp", jacksonVersion)
 
     // For AwsSdk2Transport

java-client/src/main/java/org/opensearch/client/json/jackson/Jackson3JsonProvider.java

@@ -0,0 +1,297 @@
+/*
+ * SPDX-License-Identifier: Apache-2.0
+ *
+ * The OpenSearch Contributors require contributions made to
+ * this file be licensed under the Apache-2.0 license or a
+ * compatible open source license.
+ */
+
+/*
+ * Licensed to Elasticsearch B.V. under one or more contributor
+ * license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright
+ * ownership. Elasticsearch B.V. licenses this file to you under
+ * the Apache License, Version 2.0 (the "License"); you may
+ * not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+/*
+ * Modifications Copyright OpenSearch Contributors. See
+ * GitHub history for details.
+ */
+
+package org.opensearch.client.json.jackson;
+
+import jakarta.json.*;
+import jakarta.json.spi.JsonProvider;
+import jakarta.json.stream.JsonGenerator;
+import jakarta.json.stream.JsonGeneratorFactory;
+import jakarta.json.stream.JsonParser;
+import jakarta.json.stream.JsonParserFactory;
+import tools.jackson.core.JacksonException;
+import tools.jackson.core.json.JsonFactory;
+
+import java.io.*;
+import java.nio.charset.Charset;
+import java.util.Collections;
+import java.util.Map;
+
+/**
+ * A partial implementation of JSONP's SPI on top of Jackson.
+ */
+public class Jackson3JsonProvider extends JsonProvider {
+
+    private final JsonFactory jsonFactory;
+
+    public Jackson3JsonProvider(JsonFactory jsonFactory) {
+        this.jsonFactory = jsonFactory;
+    }
+
+    public Jackson3JsonProvider() {
+        this(new JsonFactory());
+    }
+
+    /**
+     * Return the underlying Jackson {@link JsonFactory}.
+     */
+    public JsonFactory jacksonJsonFactory() {
+        return this.jsonFactory;
+    }
+
+    // ---------------------------------------------------------------------------------------------
+    // Parser
+
+    private final ParserFactory defaultParserFactory = new ParserFactory(null);
+
+    @Override
+    public JsonParserFactory createParserFactory(Map<String, ?> config) {
+        if (config == null || config.isEmpty()) {
+            return defaultParserFactory;
+        } else {
+            // TODO: handle specific configuration
+            return defaultParserFactory;
+        }
+    }
+
+    @Override
+    public JsonParser createParser(Reader reader) {
+        return defaultParserFactory.createParser(reader);
+    }
+
+    @Override
+    public JsonParser createParser(InputStream in) {
+        return defaultParserFactory.createParser(in);
+    }
+
+    private class ParserFactory implements JsonParserFactory {
+
+        private final Map<String, ?> config;
+
+        ParserFactory(Map<String, ?> config) {
+            this.config = config == null ? Collections.emptyMap() : config;
+        }
+
+        @Override
+        public JsonParser createParser(Reader reader) {
+            try {
+                return new Jackson3JsonpParser(jsonFactory.createParser(reader));
+            } catch (JacksonException je) {
+                throw Jackson3Utils.convertException(je);
+            }
+        }
+
+        @Override
+        public JsonParser createParser(InputStream in) {
+            try {
+                return new Jackson3JsonpParser(jsonFactory.createParser(in));
+            } catch (JacksonException je) {
+                throw Jackson3Utils.convertException(je);
+            }
+        }
+
+        @Override
+        public JsonParser createParser(InputStream in, Charset charset) {
+            try {
+                return new Jackson3JsonpParser(jsonFactory.createParser(new InputStreamReader(in, charset)));
+            } catch (JacksonException je) {
+                throw Jackson3Utils.convertException(je);
+            }
+        }
+
+        /**
+         * Not implemented.
+         */
+        @Override
+        public JsonParser createParser(JsonObject obj) {
+            return JsonProvider.provider().createParserFactory(null).createParser(obj);
+        }
+
+        /**
+         * Not implemented.
+         */
+        @Override
+        public JsonParser createParser(JsonArray array) {
+            return JsonProvider.provider().createParserFactory(null).createParser(array);
+        }
+
+        /**
+         * Not implemented.
+         */
+        @Override
+        public Map<String, ?> getConfigInUse() {
+            return config;
+        }
+    }
+
+    // ---------------------------------------------------------------------------------------------
+    // Generator
+
+    private final JsonGeneratorFactory defaultGeneratorFactory = new GeneratorFactory(null);
+
+    @Override
+    public JsonGeneratorFactory createGeneratorFactory(Map<String, ?> config) {
+        if (config == null || config.isEmpty()) {
+            return defaultGeneratorFactory;
+        } else {
+            // TODO: handle specific configuration
+            return defaultGeneratorFactory;
+        }
+    }
+
+    @Override
+    public JsonGenerator createGenerator(Writer writer) {
+        return defaultGeneratorFactory.createGenerator(writer);
+    }
+
+    @Override
+    public JsonGenerator createGenerator(OutputStream out) {
+        return defaultGeneratorFactory.createGenerator(out);
+    }
+
+    private class GeneratorFactory implements JsonGeneratorFactory {
+
+        private final Map<String, ?> config;
+
+        GeneratorFactory(Map<String, ?> config) {
+            this.config = config == null ? Collections.emptyMap() : config;
+        }
+
+        @Override
+        public JsonGenerator createGenerator(Writer writer) {
+            try {
+                return new Jackson3JsonpGenerator(jsonFactory.createGenerator(writer));
+            } catch (JacksonException je) {
+                throw Jackson3Utils.convertException(je);
+            }
+        }
+
+        @Override
+        public JsonGenerator createGenerator(OutputStream out) {
+            try {
+                return new Jackson3JsonpGenerator(jsonFactory.createGenerator(out));
+            } catch (JacksonException je) {
+                throw Jackson3Utils.convertException(je);
+            }
+        }
+
+        @Override
+        public JsonGenerator createGenerator(OutputStream out, Charset charset) {
+            try {
+                return new Jackson3JsonpGenerator(jsonFactory.createGenerator(new OutputStreamWriter(out, charset)));
+            } catch (JacksonException je) {
+                throw Jackson3Utils.convertException(je);
+            }
+
+        }
+
+        @Override
+        public Map<String, ?> getConfigInUse() {
+            return config;
+        }
+    }
+
+    // ---------------------------------------------------------------------------------------------
+    // Unsupported operations
+
+    /**
+     * Not implemented.
+     */
+    @Override
+    public JsonReader createReader(Reader reader) {
+        throw new UnsupportedOperationException();
+    }
+
+    /**
+     * Not implemented.
+     */
+    @Override
+    public JsonReader createReader(InputStream in) {
+        throw new UnsupportedOperationException();
+    }
+
+    /**
+     * Not implemented.
+     */
+    @Override
+    public JsonWriter createWriter(Writer writer) {
+        throw new UnsupportedOperationException();
+    }
+
+    /**
+     * Not implemented.
+     */
+    @Override
+    public JsonWriter createWriter(OutputStream out) {
+        throw new UnsupportedOperationException();
+    }
+
+    /**
+     * Not implemented.
+     */
+    @Override
+    public JsonWriterFactory createWriterFactory(Map<String, ?> config) {
+        throw new UnsupportedOperationException();
+    }
+
+    /**
+     * Not implemented.
+     */
+    @Override
+    public JsonReaderFactory createReaderFactory(Map<String, ?> config) {
+        throw new UnsupportedOperationException();
+    }
+
+    /**
+     * Not implemented.
+     */
+    @Override
+    public JsonObjectBuilder createObjectBuilder() {
+        throw new UnsupportedOperationException();
+    }
+
+    /**
+     * Not implemented.
+     */
+    @Override
+    public JsonArrayBuilder createArrayBuilder() {
+        throw new UnsupportedOperationException();
+    }
+
+    /**
+     * Not implemented.
+     */
+    @Override
+    public JsonBuilderFactory createBuilderFactory(Map<String, ?> config) {
+        throw new UnsupportedOperationException();
+    }
+}