feat(connection): add GetTestEndpoint method for optimal endpoint selection in tests

Author: flarco

core/dbio/api/api.go

@@ -148,6 +148,49 @@ func (ac *APIConnection) ListEndpoints(patterns ...string) (endpoints Endpoints,
 	return endpoints, nil
 }
 
+// GetTestEndpoint returns the best endpoint for testing connectivity/authentication.
+// Ranking: (1) non-incremental with auth, (2) incremental with auth, (3) non-incremental, (4) first endpoint
+func (ac *APIConnection) GetTestEndpoint() string {
+	endpoints, err := ac.ListEndpoints()
+	if err != nil || len(endpoints) == 0 {
+		return ""
+	}
+
+	hasSpecAuth := ac.Spec.Authentication.Type() != AuthTypeNone
+
+	var nonIncrementalWithAuth, incrementalWithAuth, nonIncremental string
+
+	for _, ep := range endpoints {
+		// Determine if incremental (has sync values or update key)
+		isIncremental := len(ep.Sync) > 0 || ep.Response.Records.UpdateKey != ""
+
+		// Determine if has auth (spec-level or endpoint-level)
+		hasAuth := hasSpecAuth || ep.Authentication != nil
+
+		if !isIncremental && hasAuth && nonIncrementalWithAuth == "" {
+			nonIncrementalWithAuth = ep.Name
+		} else if isIncremental && hasAuth && incrementalWithAuth == "" {
+			incrementalWithAuth = ep.Name
+		} else if !isIncremental && nonIncremental == "" {
+			nonIncremental = ep.Name
+		}
+	}
+
+	// Return by priority
+	if nonIncrementalWithAuth != "" {
+		return nonIncrementalWithAuth
+	}
+	if incrementalWithAuth != "" {
+		return incrementalWithAuth
+	}
+	if nonIncremental != "" {
+		return nonIncremental
+	}
+
+	// Fallback: first endpoint (already sorted alphabetically)
+	return endpoints[0].Name
+}
+
 // compile all spec endpoints
 func (ac *APIConnection) CompileEndpoints() (compiledEndpoints Endpoints, err error) {
 	// render dynamic endpoint if needed

core/dbio/connection/connection_discover.go

@@ -95,6 +95,11 @@ func (c *Connection) Test() (ok bool, err error) {
 			g.Debug(env.MagentaString(g.F("testing endpoints with a max requests: %d. Set env var SLING_TEST_ENDPOINT_MAX_REQUESTS to modify.", maxRequests)))
 		}
 
+		// obtain the best endpoint for testing one (for connectivity/authentication)
+		if cast.ToBool(g.Getenv("SLING_TEST_SINGLE_ENDPOINT")) {
+			testEndpoints = []string{apiClient.GetTestEndpoint()}
+		}
+
 		for _, endpoint := range endpoints {
 			// check for match to test (if provided)
 			allowTest := len(testEndpoints) == 0