From 177e71f62a21143bb4e5dce7c91452f98e067ea6 Mon Sep 17 00:00:00 2001 From: Ayesh Almeida Date: Sat, 14 Feb 2026 21:18:16 +0530 Subject: [PATCH 01/15] Introduce support for liveness check for MSSQL CDC listener --- ballerina/cdc_listener.bal | 16 ++++++++++------ gradle.properties | 2 +- 2 files changed, 11 insertions(+), 7 deletions(-) diff --git a/ballerina/cdc_listener.bal b/ballerina/cdc_listener.bal index ee2dd538..cfcc5be6 100644 --- a/ballerina/cdc_listener.bal +++ b/ballerina/cdc_listener.bal @@ -19,7 +19,7 @@ import ballerinax/cdc; public isolated class CdcListener { *cdc:Listener; - private final map & readonly config; + private final map & readonly config; private boolean isStarted = false; private boolean hasAttachedService = false; @@ -27,13 +27,13 @@ public isolated class CdcListener { # # + config - The configuration for the MSSQL connector public isolated function init(*MsSqlListenerConfiguration config) { - map configMap = {}; + map debeziumConfigs = {}; cdc:populateDebeziumProperties({ engineName: config.engineName, offsetStorage: config.offsetStorage, internalSchemaStorage: config.internalSchemaStorage, options: config.options - }, configMap); + }, debeziumConfigs); cdc:populateDatabaseConfigurations({ connectorClass: config.database.connectorClass, hostname: config.database.hostname, @@ -47,9 +47,13 @@ public isolated class CdcListener { excludedTables: config.database.excludedTables, includedColumns: config.database.includedColumns, excludedColumns: config.database.excludedColumns - }, configMap); - populateMsSqlConfigurations(config.database, configMap); - self.config = configMap.cloneReadOnly(); + }, debeziumConfigs); + populateMsSqlConfigurations(config.database, debeziumConfigs); + map listenerConfigs = { + ...debeziumConfigs + }; + listenerConfigs["livenessInterval"] = config.livenessInterval; + self.config = listenerConfigs.cloneReadOnly(); } # Attaches a CDC service to the MSSQL listener. diff --git a/gradle.properties b/gradle.properties index cda1230d..f3b06471 100644 --- a/gradle.properties +++ b/gradle.properties @@ -30,7 +30,7 @@ stdlibFileVersion=1.12.0 observeVersion=1.5.0 observeInternalVersion=1.5.0 -stdlibCdcVersion=1.0.2 +stdlibCdcVersion=1.2.0-20260213-180200-2268a4d stdlibMSSQLCdcDriverVersion=1.0.0 # Transitive Dependencies From b08c1ec27091fc099c7ed4611d2e998620be9865 Mon Sep 17 00:00:00 2001 From: Ayesh Almeida Date: Sat, 14 Feb 2026 21:44:35 +0530 Subject: [PATCH 02/15] [Automated] Update the native jar versions --- ballerina/Ballerina.toml | 6 +++--- ballerina/CompilerPlugin.toml | 2 +- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/ballerina/Ballerina.toml b/ballerina/Ballerina.toml index a615067c..9b1194b3 100644 --- a/ballerina/Ballerina.toml +++ b/ballerina/Ballerina.toml @@ -1,7 +1,7 @@ [package] org = "ballerinax" name = "mssql" -version = "1.16.2" +version = "1.16.3" authors = ["Ballerina"] keywords = ["client", "network", "SQL", "RDBMS", "SQLServer", "MSSQL", "Vendor/Microsoft", "Area/Database", "Type/Connector"] repository = "https://github.com/ballerina-platform/module-ballerinax-mssql" @@ -15,8 +15,8 @@ graalvmCompatible = true [[platform.java21.dependency]] groupId = "io.ballerina.stdlib" artifactId = "mssql-native" -version = "1.16.2" -path = "../native/build/libs/mssql-native-1.16.2.jar" +version = "1.16.3" +path = "../native/build/libs/mssql-native-1.16.3-SNAPSHOT.jar" [[platform.java21.dependency]] groupId = "io.ballerina.stdlib" diff --git a/ballerina/CompilerPlugin.toml b/ballerina/CompilerPlugin.toml index bcbd6d31..8bfe0411 100644 --- a/ballerina/CompilerPlugin.toml +++ b/ballerina/CompilerPlugin.toml @@ -3,4 +3,4 @@ id = "mssql-compiler-plugin" class = "io.ballerina.stdlib.mssql.compiler.MSSQLCompilerPlugin" [[dependency]] -path = "../compiler-plugin/build/libs/mssql-compiler-plugin-1.16.2.jar" +path = "../compiler-plugin/build/libs/mssql-compiler-plugin-1.16.3-SNAPSHOT.jar" From 41ca431ad66eebf1a80c5e469324ff0eb22c387e Mon Sep 17 00:00:00 2001 From: Ayesh Almeida Date: Sat, 14 Feb 2026 22:33:12 +0530 Subject: [PATCH 03/15] [Automated] Update the native jar versions --- ballerina/Dependencies.toml | 83 +++++++++++++++++++++++++++---------- 1 file changed, 62 insertions(+), 21 deletions(-) diff --git a/ballerina/Dependencies.toml b/ballerina/Dependencies.toml index 492f3b96..ef46c04c 100644 --- a/ballerina/Dependencies.toml +++ b/ballerina/Dependencies.toml @@ -20,6 +20,14 @@ dependencies = [ {org = "ballerina", name = "log"} ] +[[package]] +org = "ballerina" +name = "avro" +version = "1.2.0" +dependencies = [ + {org = "ballerina", name = "jballerina.java"} +] + [[package]] org = "ballerina" name = "cache" @@ -44,7 +52,7 @@ dependencies = [ [[package]] org = "ballerina" name = "crypto" -version = "2.9.0" +version = "2.10.1" dependencies = [ {org = "ballerina", name = "jballerina.java"}, {org = "ballerina", name = "time"} @@ -56,7 +64,7 @@ modules = [ [[package]] org = "ballerina" name = "data.jsondata" -version = "1.1.0" +version = "1.1.3" dependencies = [ {org = "ballerina", name = "jballerina.java"}, {org = "ballerina", name = "lang.object"} @@ -80,7 +88,7 @@ modules = [ [[package]] org = "ballerina" name = "http" -version = "2.14.0" +version = "2.14.9" scope = "testOnly" dependencies = [ {org = "ballerina", name = "auth"}, @@ -127,7 +135,7 @@ modules = [ [[package]] org = "ballerina" name = "jwt" -version = "2.15.0" +version = "2.15.1" scope = "testOnly" dependencies = [ {org = "ballerina", name = "cache"}, @@ -144,7 +152,6 @@ dependencies = [ org = "ballerina" name = "lang.__internal" version = "0.0.0" -scope = "testOnly" dependencies = [ {org = "ballerina", name = "jballerina.java"}, {org = "ballerina", name = "lang.object"} @@ -182,7 +189,6 @@ dependencies = [ org = "ballerina" name = "lang.int" version = "0.0.0" -scope = "testOnly" dependencies = [ {org = "ballerina", name = "jballerina.java"}, {org = "ballerina", name = "lang.__internal"}, @@ -248,8 +254,7 @@ dependencies = [ [[package]] org = "ballerina" name = "log" -version = "2.12.0" -scope = "testOnly" +version = "2.14.0" dependencies = [ {org = "ballerina", name = "io"}, {org = "ballerina", name = "jballerina.java"}, @@ -260,7 +265,7 @@ dependencies = [ [[package]] org = "ballerina" name = "mime" -version = "2.12.0" +version = "2.12.1" scope = "testOnly" dependencies = [ {org = "ballerina", name = "io"}, @@ -272,7 +277,7 @@ dependencies = [ [[package]] org = "ballerina" name = "oauth2" -version = "2.14.0" +version = "2.14.1" scope = "testOnly" dependencies = [ {org = "ballerina", name = "cache"}, @@ -286,7 +291,7 @@ dependencies = [ [[package]] org = "ballerina" name = "observe" -version = "1.5.0" +version = "1.6.0" dependencies = [ {org = "ballerina", name = "jballerina.java"} ] @@ -294,7 +299,7 @@ dependencies = [ [[package]] org = "ballerina" name = "os" -version = "1.10.0" +version = "1.10.1" scope = "testOnly" dependencies = [ {org = "ballerina", name = "io"}, @@ -304,7 +309,7 @@ dependencies = [ [[package]] org = "ballerina" name = "sql" -version = "1.16.0" +version = "1.17.1" dependencies = [ {org = "ballerina", name = "io"}, {org = "ballerina", name = "jballerina.java"}, @@ -318,11 +323,12 @@ modules = [ [[package]] org = "ballerina" name = "task" -version = "2.7.0" +version = "2.11.1" scope = "testOnly" dependencies = [ {org = "ballerina", name = "jballerina.java"}, - {org = "ballerina", name = "time"} + {org = "ballerina", name = "time"}, + {org = "ballerina", name = "uuid"} ] [[package]] @@ -342,7 +348,7 @@ modules = [ [[package]] org = "ballerina" name = "time" -version = "2.7.0" +version = "2.8.0" dependencies = [ {org = "ballerina", name = "jballerina.java"} ] @@ -353,7 +359,7 @@ modules = [ [[package]] org = "ballerina" name = "url" -version = "2.6.0" +version = "2.6.1" scope = "testOnly" dependencies = [ {org = "ballerina", name = "jballerina.java"} @@ -363,7 +369,6 @@ dependencies = [ org = "ballerina" name = "uuid" version = "1.10.0" -scope = "testOnly" dependencies = [ {org = "ballerina", name = "crypto"}, {org = "ballerina", name = "jballerina.java"}, @@ -405,21 +410,57 @@ modules = [ [[package]] org = "ballerinax" name = "cdc" -version = "1.0.2" +version = "1.2.0" dependencies = [ {org = "ballerina", name = "crypto"}, {org = "ballerina", name = "data.jsondata"}, + {org = "ballerina", name = "io"}, {org = "ballerina", name = "jballerina.java"}, - {org = "ballerinai", name = "observe"} + {org = "ballerina", name = "log"}, + {org = "ballerinai", name = "observe"}, + {org = "ballerinax", name = "kafka"} ] modules = [ {org = "ballerinax", packageName = "cdc", moduleName = "cdc"} ] +[[package]] +org = "ballerinax" +name = "confluent.cavroserdes" +version = "1.0.2" +dependencies = [ + {org = "ballerina", name = "avro"}, + {org = "ballerina", name = "jballerina.java"}, + {org = "ballerinai", name = "observe"}, + {org = "ballerinax", name = "confluent.cregistry"} +] + +[[package]] +org = "ballerinax" +name = "confluent.cregistry" +version = "0.4.3" +dependencies = [ + {org = "ballerina", name = "jballerina.java"} +] + +[[package]] +org = "ballerinax" +name = "kafka" +version = "4.6.3" +dependencies = [ + {org = "ballerina", name = "crypto"}, + {org = "ballerina", name = "jballerina.java"}, + {org = "ballerina", name = "time"}, + {org = "ballerina", name = "uuid"}, + {org = "ballerinai", name = "observe"}, + {org = "ballerinax", name = "confluent.cavroserdes"}, + {org = "ballerinax", name = "confluent.cregistry"} +] + [[package]] org = "ballerinax" name = "mssql" -version = "1.16.2" +version = "1.16.3" dependencies = [ {org = "ballerina", name = "crypto"}, {org = "ballerina", name = "file"}, From fdd727b7318c993f749aeacc10dedeedddc3b371 Mon Sep 17 00:00:00 2001 From: Ayesh Almeida Date: Sat, 14 Feb 2026 22:53:33 +0530 Subject: [PATCH 04/15] Update dependencies --- gradle.properties | 22 +++++++++++----------- 1 file changed, 11 insertions(+), 11 deletions(-) diff --git a/gradle.properties b/gradle.properties index f3b06471..adcd6fa6 100644 --- a/gradle.properties +++ b/gradle.properties @@ -17,18 +17,18 @@ stdlibSqlVersion=1.16.0 # Direct Dependencies # Level 01 stdlibIoVersion=1.8.0 -stdlibTimeVersion=2.7.0 +stdlibTimeVersion=2.8.0 # Level 02 -stdlibLogVersion=2.12.0 -stdlibOsVersion=1.10.0 +stdlibLogVersion=2.14.0 +stdlibOsVersion=1.10.1 # Level 03 stdlibFileVersion=1.12.0 # Ballerinax Observer -observeVersion=1.5.0 -observeInternalVersion=1.5.0 +observeVersion=1.6.0 +observeInternalVersion=1.6.0 stdlibCdcVersion=1.2.0-20260213-180200-2268a4d stdlibMSSQLCdcDriverVersion=1.0.0 @@ -39,22 +39,22 @@ stdlibConstraintVersion=1.7.0 stdlibUrlVersion=2.6.0 # Level 02 -stdlibCryptoVersion=2.9.0 -stdlibTaskVersion=2.7.0 +stdlibCryptoVersion=2.10.1 +stdlibTaskVersion=2.11.1 # Level 03 stdlibCacheVersion=3.10.0 -stdlibMimeVersion=2.12.0 +stdlibMimeVersion=2.12.1 stdlibUuidVersion=1.10.0 # Level 04 stdlibDataJsonDataVersion=1.1.0 stdlibAuthVersion=2.14.0 -stdlibJwtVersion=2.15.0 -stdlibOAuth2Version=2.14.0 +stdlibJwtVersion=2.15.1 +stdlibOAuth2Version=2.14.1 # Level 05 -stdlibHttpVersion=2.14.0 +stdlibHttpVersion=2.14.9 # Level 06 stdlibTransactionVersion=1.12.0 From b9661d5368a1db6d6b51033da43e393df7270c92 Mon Sep 17 00:00:00 2001 From: gayaldassanayake Date: Tue, 17 Feb 2026 20:47:26 +0530 Subject: [PATCH 05/15] [Automated] Update the native jar versions --- ballerina/Dependencies.toml | 17 ++++++++--------- 1 file changed, 8 insertions(+), 9 deletions(-) diff --git a/ballerina/Dependencies.toml b/ballerina/Dependencies.toml index ef46c04c..2e8d021e 100644 --- a/ballerina/Dependencies.toml +++ b/ballerina/Dependencies.toml @@ -52,7 +52,7 @@ dependencies = [ [[package]] org = "ballerina" name = "crypto" -version = "2.10.1" +version = "2.9.3" dependencies = [ {org = "ballerina", name = "jballerina.java"}, {org = "ballerina", name = "time"} @@ -88,7 +88,7 @@ modules = [ [[package]] org = "ballerina" name = "http" -version = "2.14.9" +version = "2.14.0" scope = "testOnly" dependencies = [ {org = "ballerina", name = "auth"}, @@ -254,7 +254,7 @@ dependencies = [ [[package]] org = "ballerina" name = "log" -version = "2.14.0" +version = "2.12.0" dependencies = [ {org = "ballerina", name = "io"}, {org = "ballerina", name = "jballerina.java"}, @@ -277,7 +277,7 @@ dependencies = [ [[package]] org = "ballerina" name = "oauth2" -version = "2.14.1" +version = "2.14.0" scope = "testOnly" dependencies = [ {org = "ballerina", name = "cache"}, @@ -291,7 +291,7 @@ dependencies = [ [[package]] org = "ballerina" name = "observe" -version = "1.6.0" +version = "1.5.1" dependencies = [ {org = "ballerina", name = "jballerina.java"} ] @@ -309,7 +309,7 @@ dependencies = [ [[package]] org = "ballerina" name = "sql" -version = "1.17.1" +version = "1.16.0" dependencies = [ {org = "ballerina", name = "io"}, {org = "ballerina", name = "jballerina.java"}, @@ -323,12 +323,11 @@ modules = [ [[package]] org = "ballerina" name = "task" -version = "2.11.1" +version = "2.7.0" scope = "testOnly" dependencies = [ {org = "ballerina", name = "jballerina.java"}, - {org = "ballerina", name = "time"}, - {org = "ballerina", name = "uuid"} + {org = "ballerina", name = "time"} ] [[package]] From 4de95587ccdd6790c33f52101bd9ab095f44ef57 Mon Sep 17 00:00:00 2001 From: gayaldassanayake Date: Tue, 17 Feb 2026 21:23:17 +0530 Subject: [PATCH 06/15] Fix dependency issues --- build.gradle | 4 ++++ gradle.properties | 27 +++++++++++++++------------ 2 files changed, 19 insertions(+), 12 deletions(-) diff --git a/build.gradle b/build.gradle index 32f18830..90d77986 100644 --- a/build.gradle +++ b/build.gradle @@ -99,9 +99,13 @@ subprojects { ballerinaStdLibs "io.ballerina.stdlib:observe-ballerina:${observeVersion}" ballerinaStdLibs "io.ballerina:observe-ballerina:${observeInternalVersion}" ballerinaStdLibs "io.ballerina.stdlib:mssql.driver-ballerina:${stdlibMssqlDriverVersion}" + ballerinaStdLibs "io.ballerina.lib:avro-ballerina:${stdlibAvroVersion}" ballerinaStdLibs "io.ballerina.lib:cdc-ballerina:${stdlibCdcVersion}" ballerinaStdLibs "io.ballerina.lib:mssql.cdc.driver-ballerina:${stdlibMSSQLCdcDriverVersion}" + ballerinaStdLibs "io.ballerina.stdlib:kafka-ballerina:${stdlibKafkaVersion}" + ballerinaStdLibs "io.ballerina.lib:confluent.cavroserdes-ballerina:${stdlibConfluentAvroSerDesVersion}" + ballerinaStdLibs "io.ballerina.lib:confluent.cregistry-ballerina:${stdlibConfluentSchemaRegistryVersion}" } } diff --git a/gradle.properties b/gradle.properties index adcd6fa6..a71b94eb 100644 --- a/gradle.properties +++ b/gradle.properties @@ -20,15 +20,15 @@ stdlibIoVersion=1.8.0 stdlibTimeVersion=2.8.0 # Level 02 -stdlibLogVersion=2.14.0 -stdlibOsVersion=1.10.1 +stdlibLogVersion=2.12.0 +stdlibOsVersion=1.10.0 # Level 03 stdlibFileVersion=1.12.0 # Ballerinax Observer -observeVersion=1.6.0 -observeInternalVersion=1.6.0 +observeVersion=1.5.1 +observeInternalVersion=1.5.0 stdlibCdcVersion=1.2.0-20260213-180200-2268a4d stdlibMSSQLCdcDriverVersion=1.0.0 @@ -39,26 +39,29 @@ stdlibConstraintVersion=1.7.0 stdlibUrlVersion=2.6.0 # Level 02 -stdlibCryptoVersion=2.10.1 -stdlibTaskVersion=2.11.1 +stdlibCryptoVersion=2.9.3 +stdlibTaskVersion=2.7.0 +stdlibAvroVersion=1.2.0 # Level 03 stdlibCacheVersion=3.10.0 -stdlibMimeVersion=2.12.1 +stdlibMimeVersion=2.12.0 stdlibUuidVersion=1.10.0 # Level 04 -stdlibDataJsonDataVersion=1.1.0 +stdlibDataJsonDataVersion=1.1.3 stdlibAuthVersion=2.14.0 -stdlibJwtVersion=2.15.1 -stdlibOAuth2Version=2.14.1 +stdlibJwtVersion=2.15.0 +stdlibOAuth2Version=2.14.0 # Level 05 -stdlibHttpVersion=2.14.9 +stdlibHttpVersion=2.14.0 # Level 06 stdlibTransactionVersion=1.12.0 # Ballerina library stdlibMssqlDriverVersion=1.7.0 - +stdlibConfluentAvroSerDesVersion=1.0.2 +stdlibConfluentSchemaRegistryVersion=0.4.3 +stdlibKafkaVersion=4.6.3 From 7322dc0de2284f1db60e40c06e30de7ee9ebe648 Mon Sep 17 00:00:00 2001 From: gayaldassanayake Date: Tue, 17 Feb 2026 23:11:30 +0530 Subject: [PATCH 07/15] Add tests --- ballerina/tests/listener_liveness_tests.bal | 107 ++++++++++++++++++++ ballerina/tests/listener_tests.bal | 8 +- 2 files changed, 111 insertions(+), 4 deletions(-) create mode 100644 ballerina/tests/listener_liveness_tests.bal diff --git a/ballerina/tests/listener_liveness_tests.bal b/ballerina/tests/listener_liveness_tests.bal new file mode 100644 index 00000000..84e651bf --- /dev/null +++ b/ballerina/tests/listener_liveness_tests.bal @@ -0,0 +1,107 @@ +// Copyright (c) 2026, WSO2 LLC. (https://www.wso2.com). +// +// WSO2 LLC. 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. + +import ballerina/lang.runtime; +import ballerina/test; +import ballerinax/cdc; + +@test:Config { + groups: ["liveness"] +} +function testLivenessBeforeListenerStart() returns error? { + CdcListener mssqlListener = new ({ + database: { + username: cdcUsername, + password: cdcPassword, + port: cdcPort, + databaseNames: cdcDatabase + }, + options: { + snapshotMode: cdc:NO_DATA + } + }); + check mssqlListener.attach(testService); + boolean liveness = check cdc:isLive(mssqlListener); + test:assertFalse(liveness, "Liveness check passes even before listener starts"); +} + +@test:Config { + groups: ["liveness"] +} +function testLivenessWithStartedListener() returns error? { + CdcListener mssqlListener = new ({ + database: { + username: cdcUsername, + password: cdcPassword, + port: cdcPort, + databaseNames: cdcDatabase + }, + options: { + snapshotMode: cdc:NO_DATA + } + }); + check mssqlListener.attach(testService); + check mssqlListener.'start(); + boolean liveness = check cdc:isLive(mssqlListener); + test:assertTrue(liveness, "Liveness fails for a started listener"); + check mssqlListener.gracefulStop(); +} + +@test:Config { + groups: ["liveness"] +} +function testLivenessAfterListenerStop() returns error? { + CdcListener mssqlListener = new ({ + database: { + username: cdcUsername, + password: cdcPassword, + port: cdcPort, + databaseNames: cdcDatabase + }, + options: { + snapshotMode: cdc:NO_DATA + } + }); + check mssqlListener.attach(testService); + check mssqlListener.'start(); + check mssqlListener.gracefulStop(); + boolean liveness = check cdc:isLive(mssqlListener); + test:assertFalse(liveness, "Liveness check passes after the listener has stopped"); +} + +@test:Config { + groups: ["liveness"] +} +function testLivenessWithoutReceivingEvents() returns error? { + CdcListener mssqlListener = new ({ + database: { + username: cdcUsername, + password: cdcPassword, + port: cdcPort, + databaseNames: cdcDatabase + }, + options: { + snapshotMode: cdc:NO_DATA + }, + livenessInterval: 5.0 + }); + check mssqlListener.attach(testService); + check mssqlListener.'start(); + runtime:sleep(10); + boolean liveness = check cdc:isLive(mssqlListener); + test:assertFalse(liveness, "Liveness check passes even after not receiving events within the liveness interval"); + check mssqlListener.gracefulStop(); +} diff --git a/ballerina/tests/listener_tests.bal b/ballerina/tests/listener_tests.bal index ede3f1b4..c7a15da7 100644 --- a/ballerina/tests/listener_tests.bal +++ b/ballerina/tests/listener_tests.bal @@ -156,7 +156,7 @@ function testDetachAfterStart() returns error? { } cdc:Service mssqlTestService = -@cdc:ServiceConfig {tables: "store_db.products"} +@cdc:ServiceConfig {tables: "store_db.dbo.products"} service object { remote function onCreate(record {} after, string tableName) returns error? { createEventCount = createEventCount + 1; @@ -176,7 +176,7 @@ service object { }; cdc:Service mssqlDataBindingFailService = -@cdc:ServiceConfig {tables: "store_db.vendors"} +@cdc:ServiceConfig {tables: "store_db.dbo.vendors"} service object { remote function onCreate(WrongVendor after) returns error? { @@ -216,8 +216,8 @@ function testCdcListenerEvents() returns error? { password: cdcPassword, port: cdcPort, databaseNames: cdcDatabase - // , - // includedTables: ["store_db.products", "store_db.vendors"] + , + includedTables: ["store_db.dbo.products", "store_db.dbo.vendors"] } }); From a4bb5b5986fc8c10157b34c956110f857ccbd869 Mon Sep 17 00:00:00 2001 From: gayaldassanayake Date: Wed, 18 Feb 2026 08:36:55 +0530 Subject: [PATCH 08/15] [Automated] Update the native jar versions --- ballerina/Dependencies.toml | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/ballerina/Dependencies.toml b/ballerina/Dependencies.toml index 2e8d021e..67bdb71a 100644 --- a/ballerina/Dependencies.toml +++ b/ballerina/Dependencies.toml @@ -88,7 +88,7 @@ modules = [ [[package]] org = "ballerina" name = "http" -version = "2.14.0" +version = "2.14.9" scope = "testOnly" dependencies = [ {org = "ballerina", name = "auth"}, @@ -277,7 +277,7 @@ dependencies = [ [[package]] org = "ballerina" name = "oauth2" -version = "2.14.0" +version = "2.14.1" scope = "testOnly" dependencies = [ {org = "ballerina", name = "cache"}, From 262b760925ecbc1231a0268a1f9f41029b8525d9 Mon Sep 17 00:00:00 2001 From: gayaldassanayake Date: Wed, 18 Feb 2026 10:00:39 +0530 Subject: [PATCH 09/15] [Automated] Update the native jar versions --- ballerina/Dependencies.toml | 170 ------------------------------------ 1 file changed, 170 deletions(-) diff --git a/ballerina/Dependencies.toml b/ballerina/Dependencies.toml index 67bdb71a..9b92fc0d 100644 --- a/ballerina/Dependencies.toml +++ b/ballerina/Dependencies.toml @@ -7,19 +7,6 @@ dependencies-toml-version = "2" distribution-version = "2201.12.0" -[[package]] -org = "ballerina" -name = "auth" -version = "2.14.0" -scope = "testOnly" -dependencies = [ - {org = "ballerina", name = "crypto"}, - {org = "ballerina", name = "jballerina.java"}, - {org = "ballerina", name = "lang.array"}, - {org = "ballerina", name = "lang.string"}, - {org = "ballerina", name = "log"} -] - [[package]] org = "ballerina" name = "avro" @@ -28,27 +15,6 @@ dependencies = [ {org = "ballerina", name = "jballerina.java"} ] -[[package]] -org = "ballerina" -name = "cache" -version = "3.10.0" -scope = "testOnly" -dependencies = [ - {org = "ballerina", name = "constraint"}, - {org = "ballerina", name = "jballerina.java"}, - {org = "ballerina", name = "task"}, - {org = "ballerina", name = "time"} -] - -[[package]] -org = "ballerina" -name = "constraint" -version = "1.7.0" -scope = "testOnly" -dependencies = [ - {org = "ballerina", name = "jballerina.java"} -] - [[package]] org = "ballerina" name = "crypto" @@ -85,36 +51,6 @@ modules = [ {org = "ballerina", packageName = "file", moduleName = "file"} ] -[[package]] -org = "ballerina" -name = "http" -version = "2.14.9" -scope = "testOnly" -dependencies = [ - {org = "ballerina", name = "auth"}, - {org = "ballerina", name = "cache"}, - {org = "ballerina", name = "constraint"}, - {org = "ballerina", name = "crypto"}, - {org = "ballerina", name = "data.jsondata"}, - {org = "ballerina", name = "file"}, - {org = "ballerina", name = "io"}, - {org = "ballerina", name = "jballerina.java"}, - {org = "ballerina", name = "jwt"}, - {org = "ballerina", name = "lang.array"}, - {org = "ballerina", name = "lang.decimal"}, - {org = "ballerina", name = "lang.int"}, - {org = "ballerina", name = "lang.regexp"}, - {org = "ballerina", name = "lang.runtime"}, - {org = "ballerina", name = "lang.string"}, - {org = "ballerina", name = "lang.value"}, - {org = "ballerina", name = "log"}, - {org = "ballerina", name = "mime"}, - {org = "ballerina", name = "oauth2"}, - {org = "ballerina", name = "observe"}, - {org = "ballerina", name = "time"}, - {org = "ballerina", name = "url"} -] - [[package]] org = "ballerina" name = "io" @@ -132,22 +68,6 @@ modules = [ {org = "ballerina", packageName = "jballerina.java", moduleName = "jballerina.java"} ] -[[package]] -org = "ballerina" -name = "jwt" -version = "2.15.1" -scope = "testOnly" -dependencies = [ - {org = "ballerina", name = "cache"}, - {org = "ballerina", name = "crypto"}, - {org = "ballerina", name = "io"}, - {org = "ballerina", name = "jballerina.java"}, - {org = "ballerina", name = "lang.int"}, - {org = "ballerina", name = "lang.string"}, - {org = "ballerina", name = "log"}, - {org = "ballerina", name = "time"} -] - [[package]] org = "ballerina" name = "lang.__internal" @@ -167,15 +87,6 @@ dependencies = [ {org = "ballerina", name = "lang.__internal"} ] -[[package]] -org = "ballerina" -name = "lang.decimal" -version = "0.0.0" -scope = "testOnly" -dependencies = [ - {org = "ballerina", name = "jballerina.java"} -] - [[package]] org = "ballerina" name = "lang.error" @@ -234,15 +145,6 @@ modules = [ {org = "ballerina", packageName = "lang.string", moduleName = "lang.string"} ] -[[package]] -org = "ballerina" -name = "lang.transaction" -version = "0.0.0" -scope = "testOnly" -dependencies = [ - {org = "ballerina", name = "jballerina.java"} -] - [[package]] org = "ballerina" name = "lang.value" @@ -262,32 +164,6 @@ dependencies = [ {org = "ballerina", name = "observe"} ] -[[package]] -org = "ballerina" -name = "mime" -version = "2.12.1" -scope = "testOnly" -dependencies = [ - {org = "ballerina", name = "io"}, - {org = "ballerina", name = "jballerina.java"}, - {org = "ballerina", name = "lang.int"}, - {org = "ballerina", name = "log"} -] - -[[package]] -org = "ballerina" -name = "oauth2" -version = "2.14.1" -scope = "testOnly" -dependencies = [ - {org = "ballerina", name = "cache"}, - {org = "ballerina", name = "crypto"}, - {org = "ballerina", name = "jballerina.java"}, - {org = "ballerina", name = "log"}, - {org = "ballerina", name = "time"}, - {org = "ballerina", name = "url"} -] - [[package]] org = "ballerina" name = "observe" @@ -320,16 +196,6 @@ modules = [ {org = "ballerina", packageName = "sql", moduleName = "sql"} ] -[[package]] -org = "ballerina" -name = "task" -version = "2.7.0" -scope = "testOnly" -dependencies = [ - {org = "ballerina", name = "jballerina.java"}, - {org = "ballerina", name = "time"} -] - [[package]] org = "ballerina" name = "test" @@ -351,18 +217,6 @@ version = "2.8.0" dependencies = [ {org = "ballerina", name = "jballerina.java"} ] -modules = [ - {org = "ballerina", packageName = "time", moduleName = "time"} -] - -[[package]] -org = "ballerina" -name = "url" -version = "2.6.1" -scope = "testOnly" -dependencies = [ - {org = "ballerina", name = "jballerina.java"} -] [[package]] org = "ballerina" @@ -384,28 +238,6 @@ dependencies = [ {org = "ballerina", name = "observe"} ] -[[package]] -org = "ballerinai" -name = "transaction" -version = "0.0.0" -scope = "testOnly" -dependencies = [ - {org = "ballerina", name = "cache"}, - {org = "ballerina", name = "http"}, - {org = "ballerina", name = "io"}, - {org = "ballerina", name = "jballerina.java"}, - {org = "ballerina", name = "lang.runtime"}, - {org = "ballerina", name = "lang.transaction"}, - {org = "ballerina", name = "lang.value"}, - {org = "ballerina", name = "log"}, - {org = "ballerina", name = "task"}, - {org = "ballerina", name = "time"}, - {org = "ballerina", name = "uuid"} -] -modules = [ - {org = "ballerinai", packageName = "transaction", moduleName = "transaction"} -] - [[package]] org = "ballerinax" name = "cdc" @@ -468,8 +300,6 @@ dependencies = [ {org = "ballerina", name = "lang.string"}, {org = "ballerina", name = "sql"}, {org = "ballerina", name = "test"}, - {org = "ballerina", name = "time"}, - {org = "ballerinai", name = "transaction"}, {org = "ballerinax", name = "cdc"}, {org = "ballerinax", name = "mssql.cdc.driver"}, {org = "ballerinax", name = "mssql.driver"} From ad6a9e7ae1e4f7708c47e7758f846ea7258672a8 Mon Sep 17 00:00:00 2001 From: gayaldassanayake Date: Wed, 18 Feb 2026 10:10:20 +0530 Subject: [PATCH 10/15] [Automated] Update the native jar versions --- ballerina/Dependencies.toml | 29 +++++------------------------ 1 file changed, 5 insertions(+), 24 deletions(-) diff --git a/ballerina/Dependencies.toml b/ballerina/Dependencies.toml index 9b92fc0d..165656e6 100644 --- a/ballerina/Dependencies.toml +++ b/ballerina/Dependencies.toml @@ -111,15 +111,6 @@ org = "ballerina" name = "lang.object" version = "0.0.0" -[[package]] -org = "ballerina" -name = "lang.regexp" -version = "0.0.0" -scope = "testOnly" -dependencies = [ - {org = "ballerina", name = "jballerina.java"} -] - [[package]] org = "ballerina" name = "lang.runtime" @@ -132,19 +123,6 @@ modules = [ {org = "ballerina", packageName = "lang.runtime", moduleName = "lang.runtime"} ] -[[package]] -org = "ballerina" -name = "lang.string" -version = "0.0.0" -scope = "testOnly" -dependencies = [ - {org = "ballerina", name = "jballerina.java"}, - {org = "ballerina", name = "lang.regexp"} -] -modules = [ - {org = "ballerina", packageName = "lang.string", moduleName = "lang.string"} -] - [[package]] org = "ballerina" name = "lang.value" @@ -156,13 +134,16 @@ dependencies = [ [[package]] org = "ballerina" name = "log" -version = "2.12.0" +version = "2.14.0" dependencies = [ {org = "ballerina", name = "io"}, {org = "ballerina", name = "jballerina.java"}, {org = "ballerina", name = "lang.value"}, {org = "ballerina", name = "observe"} ] +modules = [ + {org = "ballerina", packageName = "log", moduleName = "log"} +] [[package]] org = "ballerina" @@ -297,7 +278,7 @@ dependencies = [ {org = "ballerina", name = "file"}, {org = "ballerina", name = "jballerina.java"}, {org = "ballerina", name = "lang.runtime"}, - {org = "ballerina", name = "lang.string"}, + {org = "ballerina", name = "log"}, {org = "ballerina", name = "sql"}, {org = "ballerina", name = "test"}, {org = "ballerinax", name = "cdc"}, From 5a489b7fc5fd1411a01fb7131edc1a29b99d2853 Mon Sep 17 00:00:00 2001 From: gayaldassanayake Date: Wed, 18 Feb 2026 11:36:05 +0530 Subject: [PATCH 11/15] Comment out includedTables in tests --- ballerina/tests/listener_tests.bal | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/ballerina/tests/listener_tests.bal b/ballerina/tests/listener_tests.bal index c7a15da7..80ea32dc 100644 --- a/ballerina/tests/listener_tests.bal +++ b/ballerina/tests/listener_tests.bal @@ -216,8 +216,8 @@ function testCdcListenerEvents() returns error? { password: cdcPassword, port: cdcPort, databaseNames: cdcDatabase - , - includedTables: ["store_db.dbo.products", "store_db.dbo.vendors"] + // , + // includedTables: ["store_db.dbo.products", "store_db.dbo.vendors"] } }); From 7bf8a8001a1de590818cb8e55d92c8fda25328fe Mon Sep 17 00:00:00 2001 From: gayaldassanayake Date: Wed, 18 Feb 2026 12:01:07 +0530 Subject: [PATCH 12/15] [Automated] Update the native jar versions --- ballerina/Dependencies.toml | 195 +++++++++++++++++++++++++++++++++++- 1 file changed, 192 insertions(+), 3 deletions(-) diff --git a/ballerina/Dependencies.toml b/ballerina/Dependencies.toml index 165656e6..8b008142 100644 --- a/ballerina/Dependencies.toml +++ b/ballerina/Dependencies.toml @@ -7,6 +7,19 @@ dependencies-toml-version = "2" distribution-version = "2201.12.0" +[[package]] +org = "ballerina" +name = "auth" +version = "2.14.0" +scope = "testOnly" +dependencies = [ + {org = "ballerina", name = "crypto"}, + {org = "ballerina", name = "jballerina.java"}, + {org = "ballerina", name = "lang.array"}, + {org = "ballerina", name = "lang.string"}, + {org = "ballerina", name = "log"} +] + [[package]] org = "ballerina" name = "avro" @@ -15,6 +28,27 @@ dependencies = [ {org = "ballerina", name = "jballerina.java"} ] +[[package]] +org = "ballerina" +name = "cache" +version = "3.10.0" +scope = "testOnly" +dependencies = [ + {org = "ballerina", name = "constraint"}, + {org = "ballerina", name = "jballerina.java"}, + {org = "ballerina", name = "task"}, + {org = "ballerina", name = "time"} +] + +[[package]] +org = "ballerina" +name = "constraint" +version = "1.7.0" +scope = "testOnly" +dependencies = [ + {org = "ballerina", name = "jballerina.java"} +] + [[package]] org = "ballerina" name = "crypto" @@ -51,6 +85,36 @@ modules = [ {org = "ballerina", packageName = "file", moduleName = "file"} ] +[[package]] +org = "ballerina" +name = "http" +version = "2.14.9" +scope = "testOnly" +dependencies = [ + {org = "ballerina", name = "auth"}, + {org = "ballerina", name = "cache"}, + {org = "ballerina", name = "constraint"}, + {org = "ballerina", name = "crypto"}, + {org = "ballerina", name = "data.jsondata"}, + {org = "ballerina", name = "file"}, + {org = "ballerina", name = "io"}, + {org = "ballerina", name = "jballerina.java"}, + {org = "ballerina", name = "jwt"}, + {org = "ballerina", name = "lang.array"}, + {org = "ballerina", name = "lang.decimal"}, + {org = "ballerina", name = "lang.int"}, + {org = "ballerina", name = "lang.regexp"}, + {org = "ballerina", name = "lang.runtime"}, + {org = "ballerina", name = "lang.string"}, + {org = "ballerina", name = "lang.value"}, + {org = "ballerina", name = "log"}, + {org = "ballerina", name = "mime"}, + {org = "ballerina", name = "oauth2"}, + {org = "ballerina", name = "observe"}, + {org = "ballerina", name = "time"}, + {org = "ballerina", name = "url"} +] + [[package]] org = "ballerina" name = "io" @@ -68,6 +132,22 @@ modules = [ {org = "ballerina", packageName = "jballerina.java", moduleName = "jballerina.java"} ] +[[package]] +org = "ballerina" +name = "jwt" +version = "2.15.1" +scope = "testOnly" +dependencies = [ + {org = "ballerina", name = "cache"}, + {org = "ballerina", name = "crypto"}, + {org = "ballerina", name = "io"}, + {org = "ballerina", name = "jballerina.java"}, + {org = "ballerina", name = "lang.int"}, + {org = "ballerina", name = "lang.string"}, + {org = "ballerina", name = "log"}, + {org = "ballerina", name = "time"} +] + [[package]] org = "ballerina" name = "lang.__internal" @@ -87,6 +167,15 @@ dependencies = [ {org = "ballerina", name = "lang.__internal"} ] +[[package]] +org = "ballerina" +name = "lang.decimal" +version = "0.0.0" +scope = "testOnly" +dependencies = [ + {org = "ballerina", name = "jballerina.java"} +] + [[package]] org = "ballerina" name = "lang.error" @@ -111,6 +200,15 @@ org = "ballerina" name = "lang.object" version = "0.0.0" +[[package]] +org = "ballerina" +name = "lang.regexp" +version = "0.0.0" +scope = "testOnly" +dependencies = [ + {org = "ballerina", name = "jballerina.java"} +] + [[package]] org = "ballerina" name = "lang.runtime" @@ -123,6 +221,28 @@ modules = [ {org = "ballerina", packageName = "lang.runtime", moduleName = "lang.runtime"} ] +[[package]] +org = "ballerina" +name = "lang.string" +version = "0.0.0" +scope = "testOnly" +dependencies = [ + {org = "ballerina", name = "jballerina.java"}, + {org = "ballerina", name = "lang.regexp"} +] +modules = [ + {org = "ballerina", packageName = "lang.string", moduleName = "lang.string"} +] + +[[package]] +org = "ballerina" +name = "lang.transaction" +version = "0.0.0" +scope = "testOnly" +dependencies = [ + {org = "ballerina", name = "jballerina.java"} +] + [[package]] org = "ballerina" name = "lang.value" @@ -141,8 +261,31 @@ dependencies = [ {org = "ballerina", name = "lang.value"}, {org = "ballerina", name = "observe"} ] -modules = [ - {org = "ballerina", packageName = "log", moduleName = "log"} + +[[package]] +org = "ballerina" +name = "mime" +version = "2.12.1" +scope = "testOnly" +dependencies = [ + {org = "ballerina", name = "io"}, + {org = "ballerina", name = "jballerina.java"}, + {org = "ballerina", name = "lang.int"}, + {org = "ballerina", name = "log"} +] + +[[package]] +org = "ballerina" +name = "oauth2" +version = "2.14.1" +scope = "testOnly" +dependencies = [ + {org = "ballerina", name = "cache"}, + {org = "ballerina", name = "crypto"}, + {org = "ballerina", name = "jballerina.java"}, + {org = "ballerina", name = "log"}, + {org = "ballerina", name = "time"}, + {org = "ballerina", name = "url"} ] [[package]] @@ -177,6 +320,16 @@ modules = [ {org = "ballerina", packageName = "sql", moduleName = "sql"} ] +[[package]] +org = "ballerina" +name = "task" +version = "2.7.0" +scope = "testOnly" +dependencies = [ + {org = "ballerina", name = "jballerina.java"}, + {org = "ballerina", name = "time"} +] + [[package]] org = "ballerina" name = "test" @@ -198,6 +351,18 @@ version = "2.8.0" dependencies = [ {org = "ballerina", name = "jballerina.java"} ] +modules = [ + {org = "ballerina", packageName = "time", moduleName = "time"} +] + +[[package]] +org = "ballerina" +name = "url" +version = "2.6.1" +scope = "testOnly" +dependencies = [ + {org = "ballerina", name = "jballerina.java"} +] [[package]] org = "ballerina" @@ -219,6 +384,28 @@ dependencies = [ {org = "ballerina", name = "observe"} ] +[[package]] +org = "ballerinai" +name = "transaction" +version = "0.0.0" +scope = "testOnly" +dependencies = [ + {org = "ballerina", name = "cache"}, + {org = "ballerina", name = "http"}, + {org = "ballerina", name = "io"}, + {org = "ballerina", name = "jballerina.java"}, + {org = "ballerina", name = "lang.runtime"}, + {org = "ballerina", name = "lang.transaction"}, + {org = "ballerina", name = "lang.value"}, + {org = "ballerina", name = "log"}, + {org = "ballerina", name = "task"}, + {org = "ballerina", name = "time"}, + {org = "ballerina", name = "uuid"} +] +modules = [ + {org = "ballerinai", packageName = "transaction", moduleName = "transaction"} +] + [[package]] org = "ballerinax" name = "cdc" @@ -278,9 +465,11 @@ dependencies = [ {org = "ballerina", name = "file"}, {org = "ballerina", name = "jballerina.java"}, {org = "ballerina", name = "lang.runtime"}, - {org = "ballerina", name = "log"}, + {org = "ballerina", name = "lang.string"}, {org = "ballerina", name = "sql"}, {org = "ballerina", name = "test"}, + {org = "ballerina", name = "time"}, + {org = "ballerinai", name = "transaction"}, {org = "ballerinax", name = "cdc"}, {org = "ballerinax", name = "mssql.cdc.driver"}, {org = "ballerinax", name = "mssql.driver"} From 39aed1de1dc71c0816796677562d020f8023e7bc Mon Sep 17 00:00:00 2001 From: gayaldassanayake Date: Wed, 18 Feb 2026 12:02:08 +0530 Subject: [PATCH 13/15] Bump dependency patch versions --- gradle.properties | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/gradle.properties b/gradle.properties index a71b94eb..68a00ae4 100644 --- a/gradle.properties +++ b/gradle.properties @@ -36,7 +36,7 @@ stdlibMSSQLCdcDriverVersion=1.0.0 # Transitive Dependencies # Level 01 stdlibConstraintVersion=1.7.0 -stdlibUrlVersion=2.6.0 +stdlibUrlVersion=2.6.1 # Level 02 stdlibCryptoVersion=2.9.3 @@ -45,17 +45,17 @@ stdlibAvroVersion=1.2.0 # Level 03 stdlibCacheVersion=3.10.0 -stdlibMimeVersion=2.12.0 +stdlibMimeVersion=2.12.1 stdlibUuidVersion=1.10.0 # Level 04 stdlibDataJsonDataVersion=1.1.3 stdlibAuthVersion=2.14.0 -stdlibJwtVersion=2.15.0 -stdlibOAuth2Version=2.14.0 +stdlibJwtVersion=2.15.1 +stdlibOAuth2Version=2.14.1 # Level 05 -stdlibHttpVersion=2.14.0 +stdlibHttpVersion=2.14.9 # Level 06 stdlibTransactionVersion=1.12.0 From 15fe2f224dc698bf52ccc8ab449820d67bff2993 Mon Sep 17 00:00:00 2001 From: gayaldassanayake Date: Wed, 18 Feb 2026 12:10:59 +0530 Subject: [PATCH 14/15] fix os dep issue --- ballerina/Dependencies.toml | 2 +- gradle.properties | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/ballerina/Dependencies.toml b/ballerina/Dependencies.toml index 8b008142..67bdb71a 100644 --- a/ballerina/Dependencies.toml +++ b/ballerina/Dependencies.toml @@ -254,7 +254,7 @@ dependencies = [ [[package]] org = "ballerina" name = "log" -version = "2.14.0" +version = "2.12.0" dependencies = [ {org = "ballerina", name = "io"}, {org = "ballerina", name = "jballerina.java"}, diff --git a/gradle.properties b/gradle.properties index 68a00ae4..e3281f08 100644 --- a/gradle.properties +++ b/gradle.properties @@ -21,7 +21,7 @@ stdlibTimeVersion=2.8.0 # Level 02 stdlibLogVersion=2.12.0 -stdlibOsVersion=1.10.0 +stdlibOsVersion=1.10.1 # Level 03 stdlibFileVersion=1.12.0 From 119c08c64ab0dd8a8bce0720176ca23b4bbda117 Mon Sep 17 00:00:00 2001 From: gayaldassanayake Date: Wed, 18 Feb 2026 12:57:12 +0530 Subject: [PATCH 15/15] Bump cdc version --- gradle.properties | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/gradle.properties b/gradle.properties index e3281f08..578901a1 100644 --- a/gradle.properties +++ b/gradle.properties @@ -30,7 +30,7 @@ stdlibFileVersion=1.12.0 observeVersion=1.5.1 observeInternalVersion=1.5.0 -stdlibCdcVersion=1.2.0-20260213-180200-2268a4d +stdlibCdcVersion=1.2.0 stdlibMSSQLCdcDriverVersion=1.0.0 # Transitive Dependencies