Subscription manager v0.10.0

[ric-plt/submgr.git] / pkg / control / client.go

diff --git a/pkg/control/client.go b/pkg/control/client.go
index 598c7ef..1c07ad4 100644 (file)
--- a/pkg/control/client.go
+++ b/pkg/control/client.go
@@ -32,6 +32,7 @@ import (
 type RtmgrClient struct {
        rtClient         *rtmgrclient.RoutingManager
        xappHandleParams *rtmgrhandle.ProvideXappSubscriptionHandleParams
+       xappDeleteParams *rtmgrhandle.DeleteXappSubscriptionHandleParams
 }
 
 func (rc *RtmgrClient) SubscriptionRequestUpdate() error {
@@ -54,6 +55,15 @@ func (rc *RtmgrClient) SubscriptionRequestUpdate() error {
                        xapp.Logger.Info("Succesfully updated routing manager about the subscription: %d", subID)
                        return nil
                }
+       case DELETE:
+               _, _, deleteErr := rc.rtClient.Handle.DeleteXappSubscriptionHandle(rc.xappDeleteParams.WithXappSubscriptionData(&xappSubReq))
+               if deleteErr != nil && !(strings.Contains(deleteErr.Error(), "status 200"))  {
+                       xapp.Logger.Error("Deleting subscription id = %d  in routing manager, failed with error: %v", subID, deleteErr)
+                       return deleteErr
+               } else {
+                       xapp.Logger.Info("Succesfully deleted subscription: %d in routing manager.", subID)
+                       return nil
+               }
        default:
                return nil
        }