Skip to content

Commit

Permalink
MongoDB update (#449)
Browse files Browse the repository at this point in the history
* MongoDB update

* Add limit parameter to BsonReaderDecoder/BsonWriterDecoder

* Hacky workaround for build fix

* update to latest milestones

---------

Co-authored-by: radovanradic <[email protected]>
  • Loading branch information
sdelamo and radovanradic committed Jul 6, 2023
1 parent 8abe0fa commit fa4168c
Show file tree
Hide file tree
Showing 3 changed files with 17 additions and 7 deletions.
10 changes: 5 additions & 5 deletions gradle/libs.versions.toml
Original file line number Diff line number Diff line change
@@ -1,21 +1,21 @@
[versions]
micronaut = "4.0.0-RC5"
micronaut-platform = "4.0.0-M4"
micronaut-platform = "4.0.0-M5"
micronaut-docs = "2.0.0"
micronaut-gradle-plugin = "4.0.0-M8"

groovy = "4.0.11"
groovy = "4.0.13"
spock = "2.3-groovy-4.0"
testcontainers = "1.18.3"

managed-mongo = "4.10.1"
managed-mongo-reactive = "4.10.1"

micronaut-micrometer = "5.0.0-M5"
micronaut-serde = "2.0.0-M12"
micronaut-micrometer = "5.0.0-M6"
micronaut-serde = "2.0.0-M13"
micronaut-test = "4.0.0-M9"
micronaut-testresources = "2.0.0-M8"
micronaut-validation = "4.0.0-M11"
micronaut-validation = "4.0.0-M12"
micronaut-logging = "1.0.0-M5"

[libraries]
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -17,6 +17,7 @@

import io.micronaut.core.type.Argument;
import io.micronaut.serde.Deserializer;
import io.micronaut.serde.LimitingStream;
import io.micronaut.serde.SerdeRegistry;
import io.micronaut.serde.Serializer;
import io.micronaut.serde.bson.BsonReaderDecoder;
Expand Down Expand Up @@ -73,7 +74,7 @@ class SerdeCodec<T> implements Codec<T> {
@Override
public T decode(BsonReader reader, DecoderContext decoderContext) {
try {
return deserializer.deserialize(new BsonReaderDecoder(reader), this.decoderContext, argument);
return deserializer.deserialize(new BsonReaderDecoder(reader, LimitingStream.DEFAULT_LIMITS), this.decoderContext, argument);
} catch (IOException e) {
throw new IllegalStateException("Cannot deserialize: " + type, e);
}
Expand All @@ -82,7 +83,7 @@ public T decode(BsonReader reader, DecoderContext decoderContext) {
@Override
public void encode(BsonWriter writer, T value, EncoderContext encoderContext) {
try {
serializer.serialize(new BsonWriterEncoder(writer), this.encoderContext, argument, value);
serializer.serialize(new BsonWriterEncoder(writer, LimitingStream.DEFAULT_LIMITS), this.encoderContext, argument, value);
} catch (IOException e) {
throw new IllegalStateException("Cannot serialize: " + value, e);
}
Expand Down
9 changes: 9 additions & 0 deletions tests/mongo-serde/build.gradle
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,16 @@ plugins {
id "io.micronaut.build.internal.mongodb-functional-test"
}

micronaut {
importMicronautPlatform = false
}

dependencies {
micronautBoms(
platform(mn.micronaut.core.bom),
platform(mnTest.micronaut.test.bom),
platform("io.micronaut.serde:micronaut-serde-bom:${libs.versions.micronaut.serde.get()}")
)
annotationProcessor mnSerde.micronaut.serde.processor

implementation projects.micronautMongoSync
Expand Down

0 comments on commit fa4168c

Please sign in to comment.