diff --git a/components/payments/cmd/connectors/internal/api/connector.go b/components/payments/cmd/connectors/internal/api/connector.go index d6e82dfba9..8d9a5e42e7 100644 --- a/components/payments/cmd/connectors/internal/api/connector.go +++ b/components/payments/cmd/connectors/internal/api/connector.go @@ -13,7 +13,6 @@ import ( "github.com/formancehq/payments/internal/otel" "github.com/formancehq/stack/libs/go-libs/api" "github.com/formancehq/stack/libs/go-libs/bun/bunpaginate" - "github.com/formancehq/stack/libs/go-libs/logging" "github.com/formancehq/stack/libs/go-libs/pointer" "github.com/google/uuid" "github.com/gorilla/mux" @@ -132,24 +131,6 @@ func readConfig[Config models.ConnectorConfigObject]( caser := cases.Title(language.English) m["provider"] = caser.String(connectorID.Provider.String()) - // rewrite pollingDuration struct as a string to match API spec - pollingPeriod, ok := m["pollingPeriod"].(map[string]interface{}) - if ok { - duration, found := pollingPeriod["duration"] - if found { - var ns int64 - switch v := duration.(type) { - case int64: - ns = v - case float64: - ns = int64(v) - default: - logging.FromContext(ctx).Debugf("pollingPeriod.Duration was of an unexpected type: %T", v) - } - m["pollingPeriod"] = time.Duration(ns).String() - } - } - result, err := json.Marshal(m) if err != nil { otel.RecordError(span, err) diff --git a/components/payments/cmd/connectors/internal/connectors/duration.go b/components/payments/cmd/connectors/internal/connectors/duration.go index c6e5ee31d1..e1e9e1985e 100644 --- a/components/payments/cmd/connectors/internal/connectors/duration.go +++ b/components/payments/cmd/connectors/internal/connectors/duration.go @@ -10,7 +10,7 @@ type Duration struct { time.Duration `json:"duration"` } -func (d *Duration) MarshalJSON() ([]byte, error) { +func (d Duration) MarshalJSON() ([]byte, error) { return json.Marshal(d.Duration.String()) }