fix streaming endpoint bug

Author: santiagomed

.vscode/launch.json

@@ -5,11 +5,12 @@
     "version": "0.2.0",
     "configurations": [
         {
-            "type": "lldb",
-            "request": "launch",
             "name": "Debug",
-            "program": "${workspaceFolder}/<executable file>",
-            "args": [],
+            "type": "go",
+            "request": "launch",
+            "mode": "auto",
+            "program": "${workspaceFolder}",
+            "args": ["auth", "oauth2"],
             "cwd": "${workspaceFolder}"
         }
     ]

api/endpoints.go

@@ -26,6 +26,11 @@ func IsStreamingEndpoint(endpoint string) bool {
 		}
 	}
 
+	// Remove query parameters if present
+	if queryIndex := strings.Index(path, "?"); queryIndex != -1 {
+		path = path[:queryIndex]
+	}
+
 	normalizedEndpoint := strings.TrimSuffix(path, "/")
 
 	return StreamingEndpoints[normalizedEndpoint]

auth/auth.go

@@ -312,20 +312,20 @@ func (a *Auth) fetchUsername(accessToken string) (string, error) {
 		return "", xurlErrors.NewAuthError("IOError", err)
 	}
 
-	var data map[string]interface{}
+	var data map[string]any
 	if err := json.Unmarshal(body, &data); err != nil {
 		return "", xurlErrors.NewAuthError("JSONDeserializationError", err)
 	}
 
 	if data["data"] != nil {
-		if userData, ok := data["data"].(map[string]interface{}); ok {
+		if userData, ok := data["data"].(map[string]any); ok {
 			if username, ok := userData["username"].(string); ok {
 				return username, nil
 			}
 		}
 	}
 
-	return "", xurlErrors.NewAuthError("UsernameNotFound", errors.New("username not found in response"))
+	return "", xurlErrors.NewAuthError("UsernameNotFound", errors.New("username not found when fetching username"))
 }
 
 func generateSignature(method, urlStr string, params map[string]string, consumerSecret, tokenSecret string) (string, error) {