fix resourceAddress prefix (redhat-cne#75)

Signed-off-by: Jack Ding <jackding@gmail.com>
jzding · Aug 29, 2024 · 3ecae44 · 3ecae44
1 parent 6103cbb
commit 3ecae44
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 6 deletions.
diff --git a/v2/routes.go b/v2/routes.go
@@ -454,16 +454,16 @@ func (s *Server) getCurrentState(w http.ResponseWriter, r *http.Request) {
 		return
 	}
 
+	if !strings.HasPrefix(resourceAddress, "/") {
+		resourceAddress = fmt.Sprintf("/%s", resourceAddress)
+	}
+
 	eventSubscribers := s.subscriberAPI.GetClientIDAddressByResource(resourceAddress)
 	if len(eventSubscribers) == 0 {
 		respondWithStatusCode(w, http.StatusNotFound, fmt.Sprintf("subscription not found for %s", resourceAddress))
 		return
 	}
 
-	if !strings.HasPrefix(resourceAddress, "/") {
-		resourceAddress = fmt.Sprintf("/%s", resourceAddress)
-	}
-
 	// this is placeholder not sending back to report
 	out := channel.DataChan{
 		Address: resourceAddress,

diff --git a/v2/server_test.go b/v2/server_test.go
@@ -52,8 +52,8 @@ var (
 	port                   = 8990
 	apHost                 = "localhost"
 	apPath                 = "/api/ocloudNotifications/v2/"
-	resource               = "test/test"
-	resourceNoneSubscribed = "test/nonesubscribed"
+	resource               = "/test/test"
+	resourceNoneSubscribed = "/test/nonesubscribed"
 	storePath              = "."
 	ObjSub                 pubsub.PubSub
 	ObjPub                 pubsub.PubSub