Add capability to update the currently existing service definitions

ballerina/Dependencies.toml

@@ -5,7 +5,7 @@
 
 [ballerina]
 dependencies-toml-version = "2"
-distribution-version = "2201.12.0"
+distribution-version = "2201.12.7"
 
 [[package]]
 org = "ballerina"
@@ -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"},

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,58 @@ 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);
+    boolean isFirstIteration = true;
+    string? next = ();
+    int offset = 0;
+    int 'limit = 25;
+    while isFirstIteration || next != "" {
+        isFirstIteration = false;
+        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 = ""; 
+           continue;
+        }
+
+        string? nextResult = pagination.next;
+        if nextResult == () {
+            next = "";
+            continue;
+        }
+
+        offset += 'limit;
+        next = nextResult;
+    }
+
+    return services;
+}
+
+function removeExistingServices(Client apimClient, Service[] services) returns error? {
+    foreach Service serviceObject in services {
+        string? id = serviceObject.id;
+        if id == () {
+            log:printInfo("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,11 @@ isolated function createBodyParts(record {|anydata...;|} anyRecord, map<Encoding
     }
     return entities;
 }
+
+function getCommaSeparatedServiceKeys(ServiceArtifact[] artifacts) returns string {
+    string[] serviceKeys = [];
+    foreach ServiceArtifact artifact in artifacts {
+        serviceKeys.push(artifact.serviceKey);
+    }
+    return string:'join(",", ...serviceKeys);
+}