diff --git a/processor/jsonpath/jsonpath.go b/processor/jsonpath/jsonpath.go
index 97cb6fa..33818b8 100644
--- a/processor/jsonpath/jsonpath.go
+++ b/processor/jsonpath/jsonpath.go
@@ -2,6 +2,7 @@ package jsonpath
 
 import (
 	"fmt"
+	"log"
 	"strconv"
 )
 
@@ -97,7 +98,7 @@ func readIndex(path string, start int) (string, int) {
 
 func EvaluateJSONPath(data interface{}, steps []JSONStep) []interface{} {
 	current := []interface{}{data}
-	
+
 	for _, step := range steps {
 		var next []interface{}
 		for _, node := range current {
@@ -105,7 +106,7 @@ func EvaluateJSONPath(data interface{}, steps []JSONStep) []interface{} {
 		}
 		current = next
 	}
-	
+
 	return current
 }
 
@@ -119,7 +120,10 @@ func evalStep(node interface{}, step JSONStep) []interface{} {
 		return evalWildcard(node)
 	case IndexStep:
 		return evalIndex(node, step.Index)
+	case RootStep:
+		return []interface{}{node}
 	default:
+		log.Println("Unknown step type:", step.Type)
 		return nil
 	}
 }
@@ -141,12 +145,15 @@ func evalRecursiveDescent(node interface{}, targetKey string) []interface{} {
 		current := queue[0]
 		queue = queue[1:]
 
-		if m, ok := current.(map[string]interface{}); ok {
-			// Check if current level has target key
+		if targetKey == "*" {
+			results = append(results, current)
+		} else if m, ok := current.(map[string]interface{}); ok {
 			if val, exists := m[targetKey]; exists {
 				results = append(results, val)
 			}
-			// Add all children to queue
+		}
+
+		if m, ok := current.(map[string]interface{}); ok {
 			for _, v := range m {
 				queue = append(queue, v)
 			}
diff --git a/processor/jsonpath/jsonpath_test.go b/processor/jsonpath/jsonpath_test.go
index 82d8cba..e4b7ec4 100644
--- a/processor/jsonpath/jsonpath_test.go
+++ b/processor/jsonpath/jsonpath_test.go
@@ -5,7 +5,7 @@ import (
 	"testing"
 )
 
-var testData = map[string]interface{}{
+	var testData = map[string]interface{}{
 	"store": map[string]interface{}{
 		"book": []interface{}{
 			map[string]interface{}{
@@ -173,9 +173,24 @@ func TestEvaluator(t *testing.T) {
 				return
 			}
 
-			if !reflect.DeepEqual(result, tt.expected) {
-				t.Errorf("EvaluateJSONPath() = %v, want %v", result, tt.expected)
+			if len(result) != len(tt.expected) {
+				t.Errorf("Expected %d items, got %d", len(tt.expected), len(result))
 			}
+
+			expectedSet := make(map[interface{}]bool, len(tt.expected))
+			for _, expected := range tt.expected {
+				expectedSet[expected] = true
+			}
+
+			for _, resultItem := range result {
+				if !expectedSet[resultItem] {
+					t.Errorf("Expected %v, got %v", tt.expected, resultItem)
+				}
+			}
+
+			// if !reflect.DeepEqual(result, tt.expected) {
+			// 	t.Errorf("EvaluateJSONPath() = %v, want %v", result, tt.expected)
+			// }
 		})
 	}
 }