Add capability to update the currently existing service definitions

ballerina/Ballerina.toml

@@ -1,7 +1,7 @@
 [package]
 org = "ballerinax"
 name = "wso2.apim.catalog"
-version = "1.1.0"
+version = "1.1.1"
 distribution = "2201.12.0"
 
 [platform.java21]
@@ -10,8 +10,8 @@ graalvmCompatible = true
 [[platform.java21.dependency]]
 groupId = "io.ballerina"
 artifactId = "wso2.apim.catalog-native"
-version = "1.1.0"
-path = "../native/build/libs/wso2.apim.catalog-native-1.1.0.jar"
+version = "1.1.1"
+path = "../native/build/libs/wso2.apim.catalog-native-1.1.1-SNAPSHOT.jar"
 
 [[platform.java21.dependency]]
 groupId = "com.fasterxml.jackson.core"

ballerina/CompilerPlugin.toml

@@ -3,7 +3,7 @@ id = "wso2.apim.catalog-compiler-plugin"
 class = "io.ballerina.wso2.apim.catalog.ServiceCatalogCompilerPlugin"
 
 [[dependency]]
-path = "../compiler-plugin/build/libs/wso2.apim.catalog-compiler-plugin-1.1.0.jar"
+path = "../compiler-plugin/build/libs/wso2.apim.catalog-compiler-plugin-1.1.1-SNAPSHOT.jar"
 
 [[dependency]]
 path = "lib/ballerina-to-openapi-2.0.3.jar"

ballerina/Dependencies.toml

@@ -301,7 +301,7 @@ modules = [
 [[package]]
 org = "ballerinax"
 name = "wso2.apim.catalog"
-version = "1.1.0"
+version = "1.1.1"
 dependencies = [
 	{org = "ballerina", name = "constraint"},
 	{org = "ballerina", name = "http"},

ballerina/listener.bal

@@ -22,9 +22,11 @@ public class Listener {
     }
 
     public function gracefulStop() returns error? {
+        check removeExistingServices(apimClient);
     }
 
     public function immediateStop() returns error? {
+        check removeExistingServices(apimClient);
     }
 
     public function detach(service object {} s) returns error? {

ballerina/service.bal

@@ -33,29 +33,22 @@ configurable string[] scopes = ["service_catalog:service_view", "apim:api_view",
 
 listener Listener 'listener = new Listener(port);
 
-service / on 'listener {
+final string[] publishedServiceIds = [];
 
-}
+Client apimClient = check new (serviceUrl = serviceUrl, config = {
+    auth: {
+        username,
+        tokenUrl,
+        password,
+        clientId,
+        clientSecret,
+        scopes,
+        clientConfig: getClientConfig(clientSecureSocketpath, clientSecureSocketpassword)
+    },
+    secureSocket: getServerCert(serverCert)
+});
 
 function publishArtifacts(ServiceArtifact[] artifacts) returns error? {
-    Client|error apimClient = new (serviceUrl = serviceUrl, config = {
-        auth: {
-            username,
-            tokenUrl,
-            password,
-            clientId,
-            clientSecret,
-            scopes,
-            clientConfig: getClientConfig(clientSecureSocketpath, clientSecureSocketpassword)
-        },
-        secureSocket: getServerCert(serverCert)
-    });
-
-    if apimClient is error {
-        log:printError("Error occurred while creating the client: ", apimClient);
-        return apimClient;
-    }
-
     error? e = ();
     foreach ServiceArtifact artifact in artifacts {
         Service|error res = apimClient->/services.post({
@@ -76,7 +69,15 @@ function publishArtifacts(ServiceArtifact[] artifacts) returns error? {
         // If there is an error, wait until other artifacts get published
         if res is error {
             e = res;
+            continue;
         }
+
+        string? id = res?.id;
+        if id == () {
+            continue;
+        }
+
+        publishedServiceIds.push(id);
     }
     return e;
 }
@@ -99,3 +100,19 @@ function getServerCert(string? serverCert) returns http:ClientSecureSocket? {
     }
     return {enable: false};
 }
+
+function removeExistingServices(Client apimClient) returns error? {
+    foreach string id in publishedServiceIds {
+        http:Response|error response = apimClient->/services/[id].delete();
+        if response is error {
+            log:printError("Error occurred while deleting the service: ", response, serviceId = id);
+            return response;
+        }
+
+        if response.statusCode != 204 {
+            string responseMessage = (check response.getJsonPayload()).toJsonString();
+            log:printError("Failed to delete service: ", serviceId = id, message = responseMessage);
+            return error("Failed to delete the service with id: " + id, cause = responseMessage);
+        }
+    }
+}