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

@@ -53,7 +53,7 @@ dependencies = [
 [[package]]
 org = "ballerina"
 name = "data.jsondata"
-version = "1.1.0"
+version = "1.1.1"
 dependencies = [
 	{org = "ballerina", name = "jballerina.java"},
 	{org = "ballerina", name = "lang.object"}
@@ -73,7 +73,7 @@ dependencies = [
 [[package]]
 org = "ballerina"
 name = "http"
-version = "2.14.0"
+version = "2.14.3"
 dependencies = [
 	{org = "ballerina", name = "auth"},
 	{org = "ballerina", name = "cache"},
@@ -240,7 +240,7 @@ modules = [
 [[package]]
 org = "ballerina"
 name = "oauth2"
-version = "2.14.0"
+version = "2.14.1"
 dependencies = [
 	{org = "ballerina", name = "cache"},
 	{org = "ballerina", name = "crypto"},
@@ -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/service.bal

@@ -56,6 +56,18 @@ function publishArtifacts(ServiceArtifact[] artifacts) returns error? {
         return apimClient;
     }
 
+    Service[]|error services = retrieveAllExisitingservices(apimClient, artifacts);
+    if services is error {
+        log:printError("Error occurred while retrieving existing services: ", services);
+        return services;
+    }
+
+    error? removeResult = removeExistingServices(apimClient, services);
+    if removeResult is error {
+        log:printError("Error occurred while removing existing services: ", removeResult);
+        return removeResult;
+    }   
+
     error? e = ();
     foreach ServiceArtifact artifact in artifacts {
         Service|error res = apimClient->/services.post({
@@ -99,3 +111,47 @@ function getServerCert(string? serverCert) returns http:ClientSecureSocket? {
     }
     return {enable: false};
 }
+
+function retrieveAllExisitingservices(Client apimClient, ServiceArtifact[] artifacts) returns Service[]|error {
+    Service[] services = [];
+    string serviceKeys = getCommaSeparatedServiceKeys(artifacts);
+    int offset = 0;
+    int 'limit = 25;
+    while true {
+        ServiceList|error serviceList = apimClient->/services(key = serviceKeys, offset = offset, 'limit = 'limit);
+        if serviceList is error {
+            log:printError("Error occurred while retrieving existing services: ", serviceList);
+            return serviceList;
+        }
+
+        Service[]? fetchedServices = serviceList.list;
+        Pagination? pagination = serviceList.pagination;
+        if fetchedServices != () {
+            services.push(...fetchedServices);
+        }
+
+        if pagination?.next == () {
+            break;
+        }
+
+        offset += 'limit;
+    }
+
+    return services;
+}
+
+function removeExistingServices(Client apimClient, Service[] services) returns error? {
+    foreach Service serviceObject in services {
+        string? id = serviceObject.id;
+        if id == () {
+            log:printWarn("Service ID is not available for service: " + serviceObject.serviceKey.toBalString());
+            continue;
+        }
+
+        http:Response|error response = apimClient->/services/[id].delete();
+        if response is error {
+            log:printError("Error occurred while deleting existing service: ", response);
+            return response;
+        }
+    }
+}

ballerina/utils.bal

@@ -250,3 +250,6 @@ isolated function createBodyParts(record {|anydata...;|} anyRecord, map<Encoding
     }
     return entities;
 }
+
+function getCommaSeparatedServiceKeys(ServiceArtifact[] artifacts) returns string =>
+    string:'join(",", ...from ServiceArtifact artifact in artifacts select artifact.serviceKey);