Skip to content
Merged
Show file tree
Hide file tree
Changes from 9 commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion ballerina/Dependencies.toml
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@

[ballerina]
dependencies-toml-version = "2"
distribution-version = "2201.12.3"
distribution-version = "2201.12.0"

[[package]]
org = "ballerina"
Expand Down
24 changes: 12 additions & 12 deletions ballerina/mssql_listener.bal
Original file line number Diff line number Diff line change
Expand Up @@ -37,13 +37,13 @@
# + return - An error if the service cannot be attached, or `()` if successful
public isolated function attach(Service s, string[]|string? name = ()) returns Error? {
lock {
if self.isStarted {
return error OperationNotPermittedError("Cannot attach CDC service to the listener once it is running.");
}
if self.isStarted {
return error OperationNotPermittedError("Cannot attach CDC service to the listener once it is running.");

Check warning on line 41 in ballerina/mssql_listener.bal

View check run for this annotation

Codecov / codecov/patch

ballerina/mssql_listener.bal#L41

Added line #L41 was not covered by tests
}
}
check externAttach(self, s);
lock {
self.hasAttachedService = true;
self.hasAttachedService = true;

Check warning on line 46 in ballerina/mssql_listener.bal

View check run for this annotation

Codecov / codecov/patch

ballerina/mssql_listener.bal#L46

Added line #L46 was not covered by tests
}
}

Expand All @@ -52,13 +52,13 @@
# + return - An error if the listener cannot be started, or `()` if successful
public isolated function 'start() returns Error? {
lock {
if !self.hasAttachedService {
return error OperationNotPermittedError("Cannot start the listener without at least one attached service.");
}
if !self.hasAttachedService {
return error OperationNotPermittedError("Cannot start the listener without at least one attached service.");

Check warning on line 56 in ballerina/mssql_listener.bal

View check run for this annotation

Codecov / codecov/patch

ballerina/mssql_listener.bal#L56

Added line #L56 was not covered by tests
}
}
check externStart(self, self.config);
lock {
self.isStarted = true;
self.isStarted = true;

Check warning on line 61 in ballerina/mssql_listener.bal

View check run for this annotation

Codecov / codecov/patch

ballerina/mssql_listener.bal#L61

Added line #L61 was not covered by tests
}
}

Expand All @@ -68,16 +68,16 @@
# + return - An error if the service cannot be detached, or `()` if successful
public isolated function detach(Service s) returns Error? {
lock {
if self.isStarted {
return error OperationNotPermittedError("Cannot detach a service from the listener once it is running.");
}
if self.isStarted {
return error OperationNotPermittedError("Cannot detach a service from the listener once it is running.");

Check warning on line 72 in ballerina/mssql_listener.bal

View check run for this annotation

Codecov / codecov/patch

ballerina/mssql_listener.bal#L72

Added line #L72 was not covered by tests
}
if !self.hasAttachedService {
return;
}
}
boolean result = check externDetach(self, s);
lock {
self.hasAttachedService = result;
self.hasAttachedService = result;

Check warning on line 80 in ballerina/mssql_listener.bal

View check run for this annotation

Codecov / codecov/patch

ballerina/mssql_listener.bal#L80

Added line #L80 was not covered by tests
}
}

Expand Down
24 changes: 12 additions & 12 deletions ballerina/mysql_listener.bal
Original file line number Diff line number Diff line change
Expand Up @@ -36,13 +36,13 @@
# + return - An error if the service cannot be attached, or `()` if successful
public isolated function attach(Service s, string[]|string? name = ()) returns Error? {
lock {
if self.isStarted {
return error OperationNotPermittedError("Cannot attach CDC service to the listener once it is running.");
}
if self.isStarted {
return error OperationNotPermittedError("Cannot attach CDC service to the listener once it is running.");

Check warning on line 40 in ballerina/mysql_listener.bal

View check run for this annotation

Codecov / codecov/patch

ballerina/mysql_listener.bal#L40

Added line #L40 was not covered by tests
}
}
check externAttach(self, s);
lock {
self.hasAttachedService = true;
self.hasAttachedService = true;
}
}

Expand All @@ -51,13 +51,13 @@
# + return - An error if the listener cannot be started, or `()` if successful
public isolated function 'start() returns Error? {
lock {
if !self.hasAttachedService {
return error OperationNotPermittedError("Cannot start the listener without at least one attached service.");
}
if !self.hasAttachedService {
return error OperationNotPermittedError("Cannot start the listener without at least one attached service.");
}
}
check externStart(self, self.config);
lock {
self.isStarted = true;
self.isStarted = true;

Check warning on line 60 in ballerina/mysql_listener.bal

View check run for this annotation

Codecov / codecov/patch

ballerina/mysql_listener.bal#L60

Added line #L60 was not covered by tests
}
}

Expand All @@ -67,16 +67,16 @@
# + return - An error if the service cannot be detached, or `()` if successful
public isolated function detach(Service s) returns Error? {
lock {
if self.isStarted {
return error OperationNotPermittedError("Cannot detach a service from the listener once it is running.");
}
if self.isStarted {
return error OperationNotPermittedError("Cannot detach a service from the listener once it is running.");

Check warning on line 71 in ballerina/mysql_listener.bal

View check run for this annotation

Codecov / codecov/patch

ballerina/mysql_listener.bal#L71

Added line #L71 was not covered by tests
}
if !self.hasAttachedService {
return;
}
}
boolean result = check externDetach(self, s);
lock {
self.hasAttachedService = result;
self.hasAttachedService = result;

Check warning on line 79 in ballerina/mysql_listener.bal

View check run for this annotation

Codecov / codecov/patch

ballerina/mysql_listener.bal#L79

Added line #L79 was not covered by tests
}
}

Expand Down
24 changes: 12 additions & 12 deletions ballerina/oracledb_listener.bal
Original file line number Diff line number Diff line change
Expand Up @@ -37,13 +37,13 @@
# + return - An error if the service cannot be attached, or `()` if successful
public isolated function attach(Service s, string[]|string? name = ()) returns Error? {
lock {
if self.isStarted {
return error OperationNotPermittedError("Cannot attach CDC service to the listener once it is running.");
}
if self.isStarted {
return error OperationNotPermittedError("Cannot attach CDC service to the listener once it is running.");

Check warning on line 41 in ballerina/oracledb_listener.bal

View check run for this annotation

Codecov / codecov/patch

ballerina/oracledb_listener.bal#L41

Added line #L41 was not covered by tests
}
}
check externAttach(self, s);
lock {
self.hasAttachedService = true;
self.hasAttachedService = true;

Check warning on line 46 in ballerina/oracledb_listener.bal

View check run for this annotation

Codecov / codecov/patch

ballerina/oracledb_listener.bal#L46

Added line #L46 was not covered by tests
}
}

Expand All @@ -52,13 +52,13 @@
# + return - An error if the listener cannot be started, or `()` if successful
public isolated function 'start() returns Error? {
lock {
if !self.hasAttachedService {
return error OperationNotPermittedError("Cannot start the listener without at least one attached service.");
}
if !self.hasAttachedService {
return error OperationNotPermittedError("Cannot start the listener without at least one attached service.");

Check warning on line 56 in ballerina/oracledb_listener.bal

View check run for this annotation

Codecov / codecov/patch

ballerina/oracledb_listener.bal#L56

Added line #L56 was not covered by tests
}
}
check externStart(self, self.config);
lock {
self.isStarted = true;
self.isStarted = true;

Check warning on line 61 in ballerina/oracledb_listener.bal

View check run for this annotation

Codecov / codecov/patch

ballerina/oracledb_listener.bal#L61

Added line #L61 was not covered by tests
}
}

Expand All @@ -68,16 +68,16 @@
# + return - An error if the service cannot be detached, or `()` if successful
public isolated function detach(Service s) returns Error? {
lock {
if self.isStarted {
return error OperationNotPermittedError("Cannot detach a service from the listener once it is running.");
}
if self.isStarted {
return error OperationNotPermittedError("Cannot detach a service from the listener once it is running.");

Check warning on line 72 in ballerina/oracledb_listener.bal

View check run for this annotation

Codecov / codecov/patch

ballerina/oracledb_listener.bal#L72

Added line #L72 was not covered by tests
}
if !self.hasAttachedService {
return;
}
}
boolean result = check externDetach(self, s);
lock {
self.hasAttachedService = result;
self.hasAttachedService = result;

Check warning on line 80 in ballerina/oracledb_listener.bal

View check run for this annotation

Codecov / codecov/patch

ballerina/oracledb_listener.bal#L80

Added line #L80 was not covered by tests
}
}

Expand Down
24 changes: 12 additions & 12 deletions ballerina/postgresql_listener.bal
Original file line number Diff line number Diff line change
Expand Up @@ -37,13 +37,13 @@
# + return - An error if the service cannot be attached, or `()` if successful
public isolated function attach(Service s, string[]|string? name = ()) returns Error? {
lock {
if self.isStarted {
return error OperationNotPermittedError("Cannot attach CDC service to the listener once it is running.");
}
if self.isStarted {
return error OperationNotPermittedError("Cannot attach CDC service to the listener once it is running.");

Check warning on line 41 in ballerina/postgresql_listener.bal

View check run for this annotation

Codecov / codecov/patch

ballerina/postgresql_listener.bal#L41

Added line #L41 was not covered by tests
}
}
check externAttach(self, s);
lock {
self.hasAttachedService = true;
self.hasAttachedService = true;

Check warning on line 46 in ballerina/postgresql_listener.bal

View check run for this annotation

Codecov / codecov/patch

ballerina/postgresql_listener.bal#L46

Added line #L46 was not covered by tests
}
}

Expand All @@ -52,13 +52,13 @@
# + return - An error if the listener cannot be started, or `()` if successful
public isolated function 'start() returns Error? {
lock {
if !self.hasAttachedService {
return error OperationNotPermittedError("Cannot start the listener without at least one attached service.");
}
if !self.hasAttachedService {
return error OperationNotPermittedError("Cannot start the listener without at least one attached service.");

Check warning on line 56 in ballerina/postgresql_listener.bal

View check run for this annotation

Codecov / codecov/patch

ballerina/postgresql_listener.bal#L56

Added line #L56 was not covered by tests
}
}
check externStart(self, self.config);
lock {
self.isStarted = true;
self.isStarted = true;

Check warning on line 61 in ballerina/postgresql_listener.bal

View check run for this annotation

Codecov / codecov/patch

ballerina/postgresql_listener.bal#L61

Added line #L61 was not covered by tests
}
}

Expand All @@ -68,16 +68,16 @@
# + return - An error if the service cannot be detached, or `()` if successful
public isolated function detach(Service s) returns Error? {
lock {
if self.isStarted {
return error OperationNotPermittedError("Cannot detach a service from the listener once it is running.");
}
if self.isStarted {
return error OperationNotPermittedError("Cannot detach a service from the listener once it is running.");

Check warning on line 72 in ballerina/postgresql_listener.bal

View check run for this annotation

Codecov / codecov/patch

ballerina/postgresql_listener.bal#L72

Added line #L72 was not covered by tests
}
if !self.hasAttachedService {
return;
}
}
boolean result = check externDetach(self, s);
lock {
self.hasAttachedService = result;
self.hasAttachedService = result;

Check warning on line 80 in ballerina/postgresql_listener.bal

View check run for this annotation

Codecov / codecov/patch

ballerina/postgresql_listener.bal#L80

Added line #L80 was not covered by tests
}
}

Expand Down
2 changes: 1 addition & 1 deletion ballerina/utils.bal
Original file line number Diff line number Diff line change
Expand Up @@ -77,7 +77,7 @@ const string ORACLE_URL = "database.url";
const string ORACLE_PDB_NAME = "database.dbname";
const string ORACLE_CONNECTION_ADAPTER = "database.connection.adapter";

isolated function getDebeziumProperties(MySqlListenerConfiguration|MsSqlListenerConfiguration|PostgresListenerConfiguration|OracleListenerConfiguration config) returns map<string> & readonly{
isolated function getDebeziumProperties(MySqlListenerConfiguration|MsSqlListenerConfiguration|PostgresListenerConfiguration|OracleListenerConfiguration config) returns map<string> & readonly {
map<string> configMap = {};

// Common configurations
Expand Down

This file was deleted.

Loading
Loading