Merge pull request #30 from HindujaB/java21

Migrate to new Runtime APIs for Java 21

ballerina/Ballerina.toml

@@ -1,7 +1,7 @@
 [package]
 org = "ballerina"
 name = "avro"
-version = "1.0.0"
+version = "1.0.2"
 authors = ["Ballerina"]
 export=["avro"]
 keywords = ["avro", "serialization", "deserialization", "serdes"]
@@ -12,35 +12,35 @@ distribution = "2201.8.0"
 [build-options]
 observabilityIncluded = true
 
-[platform.java17]
+[platform.java21]
 graalvmCompatible = true
 
-[[platform.java17.dependency]]
+[[platform.java21.dependency]]
 groupId = "io.ballerina.lib"
 artifactId = "avro-native"
-version = "1.0.0"
-path = "../native/build/libs/avro-native-1.0.0.jar"
+version = "1.0.2"
+path = "../native/build/libs/avro-native-1.0.2.jar"
 
-[[platform.java17.dependency]]
+[[platform.java21.dependency]]
 groupId = "org.apache.avro"
 artifactId = "avro"
-version = "1.11.3"
-path = "./lib/avro-1.11.3.jar"
+version = "1.11.4"
+path = "./lib/avro-1.11.4.jar"
 
-[[platform.java17.dependency]]
+[[platform.java21.dependency]]
 groupId = "com.fasterxml.jackson.core"
 artifactId = "jackson-core"
-version = "2.17.0"
-path = "./lib/jackson-core-2.17.0.jar"
+version = "2.18.0"
+path = "./lib/jackson-core-2.18.0.jar"
 
-[[platform.java11.dependency]]
+[[platform.java17.dependency]]
 groupId = "com.fasterxml.jackson.core"
 artifactId = "jackson-annotations"
-version = "2.17.0"
-path = "./lib/jackson-annotations-2.17.0.jar"
+version = "2.18.0"
+path = "./lib/jackson-annotations-2.18.0.jar"
 
-[[platform.java11.dependency]]
+[[platform.java17.dependency]]
 groupId = "com.fasterxml.jackson.core"
 artifactId = "jackson-databind"
-version = "2.17.0"
-path = "./lib/jackson-databind-2.17.0.jar"
+version = "2.18.0"
+path = "./lib/jackson-databind-2.18.0.jar"

ballerina/Dependencies.toml

@@ -5,12 +5,12 @@
 
 [ballerina]
 dependencies-toml-version = "2"
-distribution-version = "2201.9.0"
+distribution-version = "2201.10.0-20240926-231800-8a5a4343"
 
 [[package]]
 org = "ballerina"
 name = "avro"
-version = "1.0.0"
+version = "1.0.2"
 dependencies = [
 	{org = "ballerina", name = "io"},
 	{org = "ballerina", name = "jballerina.java"},
@@ -23,7 +23,7 @@ modules = [
 [[package]]
 org = "ballerina"
 name = "io"
-version = "1.6.0"
+version = "1.6.2"
 scope = "testOnly"
 dependencies = [
 	{org = "ballerina", name = "jballerina.java"},

ballerina/tests/primitive_tests.bal

@@ -134,3 +134,67 @@ public isolated function testNullValuesWithNonNullData() returns error? {
     byte[]|error serializedValue = avro.toAvro("string");
     test:assertTrue(serializedValue is error);
 }
+
+@test:Config {
+   groups: ["primitive"]
+}
+public isolated function testUnsignedShortValue() returns error? {
+    string schema = string `
+        {
+            "type": "int",
+            "name" : "shortValue", 
+            "namespace": "data"
+        }`;
+
+    int:Unsigned8 value = 255;
+    return verifyOperation(int:Unsigned8, value, schema);
+}
+
+@test:Config {
+   groups: ["primitive", "check"]
+}
+public isolated function testSignedShortValue() returns error? {
+    string schema = string `
+        {
+            "type": "int",
+            "name" : "shortValue", 
+            "namespace": "data"
+        }`;
+
+    int:Signed32 value = 555950000;
+    return verifyOperation(int:Signed32, value, schema);
+}
+
+@test:Config {
+   groups: ["primitive", "check"]
+}
+public isolated function testSignedMinusShortValue() returns error? {
+    string schema = string `
+        {
+            "type": "double",
+            "name" : "shortValue", 
+            "namespace": "data"
+        }`;
+
+    int:Signed32 value = -2147483;
+    Schema avro = check new (schema);
+    byte[] serializedValue = check avro.toAvro(value);
+    float deserializedValue = check avro.fromAvro(serializedValue);
+    test:assertEquals(deserializedValue, -2147483.0);
+}
+
+@test:Config {
+   groups: ["primitive", "check"]
+}
+public isolated function testByteValue() returns error? {
+    string schema = string `
+        {
+            "type": "bytes",
+            "name" : "byteValue", 
+            "namespace": "data"
+        }`;
+    byte[] data = [];
+    byte value = 2;
+    data.push(value);
+    return verifyOperation(ByteArray, data, schema);
+}

ballerina/tests/record_tests.bal

@@ -370,3 +370,99 @@ public isolated function testOptionalMultipleFieldsInRecords() returns error? {
     };
     return verifyOperation(Lecturer6, lecturer6, schema);
 }
+
+@test:Config {
+    groups: ["record", "union"]
+}
+public isolated function testTypeCastingInRecords() returns error? {
+    string jsonFileName = string `tests/resources/schema_complex.json`;
+    string schema = (check io:fileReadJson(jsonFileName)).toString();
+    Record recordValue = {
+        hrdCasinoGgrLt: 4999.01,
+        hrdAccountCreationTimestamp: "2024-02-25T20:50:37.891782",
+        hrdSportsBetCountLifetime: 77,
+        hrdSportsFreeBetAmountLifetime: 0,
+        hriUnityId: "807612199",
+        hrdLastRealMoneySportsbookBetTs: "2024-04-24T20:15:51.932",
+        hrdLoyaltyTier: "MEMBER_TIER",
+        rowInsertTimestampEst: "2024-09-23T03:29:43.431",
+        ltvSports365Total: 0,
+        hrdFirstDepositTimestamp: "2024-02-25T20:56:24.109021",
+        hrdVipStatus: true,
+        hrdLastRealMoneyCasinoWagerTs: null,
+        hrdSportsCashBetAmountLifetime: 731,
+        hrdAccountStatus: "ACTIVE",
+        hrdAccountId: "1362347172559585332",
+        ltvAllVerticals365Total: 0,
+        hrdOptInSms: false,
+        ltvCasino365Total: null,
+        hrdAccountSubStatus: null,
+        hrdCasinoTotalWagerLifetime: null,
+        hrdSportsGgrLt: 4999.01,
+        currentGeoSegment: "HRD_FLORIDA",
+        kycStatus: "VERIFIED",
+        signupGeoSegment: "HRD_FLORIDA",
+        hrdSportsBetAmountLifetime: 731,
+        hrdOptInEmail: false,
+        hrdOptInPush: false
+    };
+    Schema avro = check new (schema);
+    byte[] serializedValue = check avro.toAvro(recordValue);
+    Record deserializedValue = check avro.fromAvro(serializedValue);
+
+    json expected = {
+        "hrdCasinoGgrLt":4999.01,
+        "hrdAccountCreationTimestamp":"2024-02-25T20:50:37.891782",
+        "hrdSportsFreeBetAmountLifetime":0.0,
+        "hriUnityId":"807612199",
+        "hrdLastRealMoneySportsbookBetTs":"2024-04-24T20:15:51.932",
+        "hrdLoyaltyTier":"MEMBER_TIER",
+        "rowInsertTimestampEst":"2024-09-23T03:29:43.431",
+        "ltvSports365Total":0.0,
+        "hrdVipStatus":true,
+        "hrdSportsBetCountLifetime":77.0,
+        "hrdLastRealMoneyCasinoWagerTs":null,
+        "hrdSportsCashBetAmountLifetime":731.0,
+        "hrdAccountStatus":"ACTIVE",
+        "hrdAccountId":"1362347172559585332",
+        "ltvAllVerticals365Total":0.0,
+        "ltvCasino365Total":null,
+        "hrdAccountSubStatus":null,
+        "hrdCasinoTotalWagerLifetime":null,
+        "hrdSportsGgrLt":4999.01,
+        "currentGeoSegment":"HRD_FLORIDA",
+        "kycStatus":"VERIFIED",
+        "hrdOptInSms":false,
+        "hrdFirstDepositTimestamp":"2024-02-25T20:56:24.109021",
+        "signupGeoSegment":"HRD_FLORIDA",
+        "hrdSportsBetAmountLifetime":731.0,
+        "hrdOptInEmail":false,
+        "hrdOptInPush":false
+    };
+    test:assertEquals(deserializedValue.toJson(), expected.toJson());
+}
+
+@test:Config {
+    groups: ["record", "union"]
+}
+public isolated function testUnionsWithRecords() returns error? {
+    string schema = string `{
+        "type": "record",
+        "name": "DataRecord",
+        "namespace": "data",
+        "fields": [
+            {
+            "name": "shortValue",
+            "type": ["null", "int", "double"]
+            }
+        ]
+    }`;
+    int:Signed16 short = 5555;
+    json value = {
+        "shortValue": short
+    };
+    Schema avro = check new (schema);
+    byte[] serializedValue = check avro.toAvro(value);
+    DataRecord deserializedValue = check avro.fromAvro(serializedValue);
+    test:assertEquals(deserializedValue, value);
+}