feat: add provider config in API responses

Author: Swop

e2e/api_test.go

@@ -89,9 +89,15 @@ var _ = Describe("API", Ordered, func() {
 					"%s:%s:%s": {
 						"last_updated_at": "%s",
 						"acquired": null,
-						"known": []
+						"known": [],
+						"config": {
+							"stabilize_duration": %d,
+							"ttl": %d,
+							"expected_request_count": %d,
+							"delay_assignment_count": %d
+						}
 					}
-				}`, owner, repo, baseRef, now.Format(time.RFC3339))
+				}`, owner, repo, baseRef, now.Format(time.RFC3339), configHelper.DefaultConfigRepoStabilizeDurationSeconds, configHelper.DefaultConfigRepoTTLSeconds, configHelper.DefaultConfigRepoExpectedRequestCount, configHelper.DefaultConfigRepoDelayAssignmentCount)
 
 				Expect(providerListingRespBody).To(MatchJSON(expectedPayload))
 			})
@@ -122,9 +128,15 @@ var _ = Describe("API", Ordered, func() {
 					"%s:%s:%s": {
 						"last_updated_at": "%s",
 						"acquired": %s,
-						"known": %s
+						"known": %s,
+						"config": {
+							"stabilize_duration": %d,
+							"ttl": %d,
+							"expected_request_count": %d,
+							"delay_assignment_count": %d
+						}
 					}
-				}`, owner, repo, baseRef, providerStateOpts.LastUpdatedAt.Format(time.RFC3339), acquiredLeaseRequestPayloadJSON, leaseRequestsPayloadsJSON)
+				}`, owner, repo, baseRef, providerStateOpts.LastUpdatedAt.Format(time.RFC3339), acquiredLeaseRequestPayloadJSON, leaseRequestsPayloadsJSON, configHelper.DefaultConfigRepoStabilizeDurationSeconds, configHelper.DefaultConfigRepoTTLSeconds, configHelper.DefaultConfigRepoExpectedRequestCount, configHelper.DefaultConfigRepoDelayAssignmentCount)
 
 				Expect(providerListingRespBody).To(MatchJSON(expectedPayload))
 			})
@@ -159,8 +171,14 @@ var _ = Describe("API", Ordered, func() {
 					expectedPayload := fmt.Sprintf(`{
 						"last_updated_at": "%s",
 						"acquired": null,
-						"known": []
-					}`, now.Format(time.RFC3339))
+						"known": [],
+						"config": {
+							"stabilize_duration": %d,
+							"ttl": %d,
+							"expected_request_count": %d,
+							"delay_assignment_count": %d
+						}
+					}`, now.Format(time.RFC3339), configHelper.DefaultConfigRepoStabilizeDurationSeconds, configHelper.DefaultConfigRepoTTLSeconds, configHelper.DefaultConfigRepoExpectedRequestCount, configHelper.DefaultConfigRepoDelayAssignmentCount)
 
 					Expect(providerDetailsRespBody).To(MatchJSON(expectedPayload))
 				})
@@ -190,8 +208,14 @@ var _ = Describe("API", Ordered, func() {
 					expectedPayload := fmt.Sprintf(`{
 						"last_updated_at": "%s",
 						"acquired": %s,
-						"known": %s
-					}`, providerStateOpts.LastUpdatedAt.Format(time.RFC3339), acquiredLeaseRequestPayloadJSON, leaseRequestsPayloadsJSON)
+						"known": %s,
+						"config": {
+							"stabilize_duration": %d,
+							"ttl": %d,
+							"expected_request_count": %d,
+							"delay_assignment_count": %d
+						}
+					}`, providerStateOpts.LastUpdatedAt.Format(time.RFC3339), acquiredLeaseRequestPayloadJSON, leaseRequestsPayloadsJSON, configHelper.DefaultConfigRepoStabilizeDurationSeconds, configHelper.DefaultConfigRepoTTLSeconds, configHelper.DefaultConfigRepoExpectedRequestCount, configHelper.DefaultConfigRepoDelayAssignmentCount)
 
 					Expect(providerDetailsRespBody).To(MatchJSON(expectedPayload))
 				})
@@ -220,8 +244,14 @@ var _ = Describe("API", Ordered, func() {
 					expectedPayload := fmt.Sprintf(`{
 						"last_updated_at": "%s",
 						"acquired": null,
-						"known": []
-					}`, clk.Now().Format(time.RFC3339))
+						"known": [],
+						"config": {
+							"stabilize_duration": %d,
+							"ttl": %d,
+							"expected_request_count": %d,
+							"delay_assignment_count": %d
+						}
+					}`, clk.Now().Format(time.RFC3339), configHelper.DefaultConfigRepoStabilizeDurationSeconds, configHelper.DefaultConfigRepoTTLSeconds, configHelper.DefaultConfigRepoExpectedRequestCount, configHelper.DefaultConfigRepoDelayAssignmentCount)
 					Expect(respBody).To(MatchJSON(expectedPayload))
 				}
 

internal/lease/leaseprovider.go

@@ -254,14 +254,28 @@ func (lp *leaseProviderImpl) MarshalJSON() ([]byte, error) {
 		return []byte{}, err
 	}
 
+	type providerConfigJSON struct {
+		StabilizeDuration    int `json:"stabilize_duration"`
+		TTL                  int `json:"ttl"`
+		ExpectedRequestCount int `json:"expected_request_count"`
+		DelayAssignmentCount int `json:"delay_assignment_count"`
+	}
+
 	return json.Marshal(&struct {
-		LastUpdatedAt time.Time         `json:"last_updated_at"`
-		Acquired      *RequestContext   `json:"acquired"`
-		Known         []*RequestContext `json:"known"`
+		LastUpdatedAt time.Time          `json:"last_updated_at"`
+		Acquired      *RequestContext    `json:"acquired"`
+		Known         []*RequestContext  `json:"known"`
+		Config        providerConfigJSON `json:"config"`
 	}{
 		LastUpdatedAt: lp.state.lastUpdatedAt,
 		Acquired:      acquiredReqContext,
 		Known:         requestContexts,
+		Config: providerConfigJSON{
+			StabilizeDuration:    int(lp.opts.StabilizeDuration.Seconds()),
+			TTL:                  int(lp.opts.TTL.Seconds()),
+			ExpectedRequestCount: lp.opts.ExpectedRequestCount,
+			DelayAssignmentCount: lp.opts.DelayAssignmentCount,
+		},
 	})
 }