RICPLT-2954 Enhance error and info log writings
[ric-plt/submgr.git] / pkg / control / client.go
index 14e2455..6ab20fb 100644 (file)
@@ -35,14 +35,10 @@ type RtmgrClient struct {
        xappDeleteParams *rtmgrhandle.DeleteXappSubscriptionHandleParams
 }
 
-func (rc *RtmgrClient) SubscriptionRequestUpdate() error {
+func (rc *RtmgrClient) SubscriptionRequestUpdate(subRouteAction SubRouteInfo) error {
        xapp.Logger.Debug("SubscriptionRequestUpdate() invoked")
-       subRouteAction := <-SubscriptionReqChan
-       // Routing manager handles subscription id as int32 to accomodate -1 and uint16 values
        subID := int32(subRouteAction.SubID)
-
-       xapp.Logger.Debug("Subscription action details received: ", subRouteAction)
-
+       xapp.Logger.Debug("Subscription action details received. subRouteAction.Command: %v, Address %s, Port %v, subID %v", int16(subRouteAction.Command), subRouteAction.Address, subRouteAction.Port, subID)
        xappSubReq := rtmgr_models.XappSubscriptionData{&subRouteAction.Address, &subRouteAction.Port, &subID}
 
        switch subRouteAction.Command {
@@ -65,6 +61,7 @@ func (rc *RtmgrClient) SubscriptionRequestUpdate() error {
                        return nil
                }
        default:
+               xapp.Logger.Debug("Unknown subRouteAction.Command: %v, Address %s, Port %v, subID: %v", subRouteAction.Command, subRouteAction.Address, subRouteAction.Port, subID)
                return nil
        }
 }
@@ -76,7 +73,7 @@ func (rc *RtmgrClient) SplitSource(src string) (*string, *uint16, error) {
                return nil, nil, err
        }
        srcAddr := tcpSrc[0]
-       xapp.Logger.Debug("---Debugging Inside splitsource tcpsrc[0] = %s and tcpsrc[1]= %s ", tcpSrc[0], tcpSrc[1])
+       xapp.Logger.Debug("Debugging Inside splitsource tcpsrc[0] = %s and tcpsrc[1]= %s ", tcpSrc[0], tcpSrc[1])
        srcPort, err := strconv.ParseUint(tcpSrc[1], 10, 16)
        if err != nil {
                return nil, nil, err