fix: add dynamic names to endpoints in APIConnection and update Iteration ID handling

Author: flarco

core/dbio/api/api.go

@@ -672,6 +672,7 @@ func (ac *APIConnection) RenderDynamicEndpoints() (err error) {
 			g.Debug("running setup sequence (%d calls)", len(dynEndpoint.Setup))
 
 			baseEndpoint := &Endpoint{
+				Name:    "dynamic.setup",
 				context: g.NewContext(ac.Context.Ctx),
 				conn:    ac,
 				State:   setupState,

core/dbio/api/api_test.go

@@ -707,7 +707,7 @@ func TestHTTPCallAndResponseExtraction(t *testing.T) {
 		Env  map[string]string `yaml:"env"`
 		Err  bool              `yaml:"err"`
 
-		MockResponse      any              `yaml:"mock_response"`  // can be map or string (for CSV)
+		MockResponse      any              `yaml:"mock_response"` // can be map or string (for CSV)
 		ExpectedRecords   []map[string]any `yaml:"expected_records"`
 		ExpectedState     map[string]any   `yaml:"expected_state"`
 		ExpectedNextState map[string]any   `yaml:"expected_next_state"`
@@ -970,7 +970,7 @@ func TestHTTPCallAndResponseExtraction(t *testing.T) {
 
 					// Create a mock single request with our response data
 					iter := &Iteration{
-						id:       1,
+						id:       g.F("i%02d", 1),
 						state:    endpoint.State,
 						endpoint: endpoint,
 						context:  g.NewContext(context.Background()),

core/dbio/api/auth.go

@@ -68,6 +68,7 @@ func (ac *APIConnection) Authenticate() (err error) {
 	case AuthTypeSequence:
 		// create ephemeral endpoint
 		baseEndpoint := &Endpoint{
+			Name:    "api.auth",
 			State:   g.M(),
 			context: g.NewContext(ac.Context.Ctx),
 			conn:    ac,

core/dbio/api/spec.go

@@ -581,6 +581,7 @@ func (ep *Endpoint) setup() (err error) {
 	g.Debug("running endpoint setup sequence (%d calls)", len(ep.Setup))
 
 	baseEndpoint := &Endpoint{
+		Name:    g.F("%s.setup", ep.Name),
 		context: g.NewContext(ep.context.Ctx),
 		conn:    ep.conn,
 		State:   g.M(),
@@ -618,6 +619,7 @@ func (ep *Endpoint) teardown() (err error) {
 	g.Debug("running endpoint teardown sequence (%d calls)", len(ep.Teardown))
 
 	baseEndpoint := &Endpoint{
+		Name:    g.F("%s.teardown", ep.Name),
 		context: g.NewContext(ep.context.Ctx),
 		conn:    ep.conn,
 		State:   g.M(),
@@ -721,20 +723,20 @@ type Iterate struct {
 }
 
 type Iteration struct {
-	state    StateMap // each iteration has its own state
-	id       int      // iteration ID
-	sequence int      // paginated request number
-	field    string   // state field
-	value    any      // state value
-	stop     bool     // whether to stop the iteration
-	context  *g.Context
-	endpoint *Endpoint
+	state     StateMap // each iteration has its own state
+	id        string   // iteration ID
+	sequence  int      // paginated request number
+	field     string   // state field
+	value     any      // state value
+	stop      bool     // whether to stop the iteration
+	context   *g.Context
+	endpoint  *Endpoint
+	requestWg sync.WaitGroup // request wait group
 }
 
 func (iter *Iteration) Debug(text string, args ...any) {
-	if iter.field != "" {
-		id := g.F("i%02d", iter.id)
-		text = env.DarkGrayString(id) + " " + text
+	if iter.id != "" {
+		text = env.DarkGrayString(iter.id) + " " + text
 	}
 	g.Debug(text, args...)
 }
@@ -866,7 +868,7 @@ func NewSingleRequest(iter *Iteration) *SingleRequest {
 
 	id := g.F("r.%04d.%s", iter.endpoint.totalReqs, g.RandString(g.AlphaRunesLower, 3))
 	if iter.field != "" {
-		id = g.F("i%02d.r%03d.%s", iter.id, iter.sequence, g.RandString(g.AlphaRunesLower, 3))
+		id = g.F("%s.r%03d.%s", iter.id, iter.sequence, g.RandString(g.AlphaRunesLower, 3))
 	}
 
 	return &SingleRequest{