fix: return 400 instead of 500 for idempotency key reuse with different body

.gitignore

@@ -9,3 +9,4 @@ dumps
 .env
 !.envrc
 Pulumi.*.yaml
+coverage.txt

docs/api/README.md

@@ -966,6 +966,7 @@ Authorization ( Scopes: ledger:write )
 DELETE http://localhost:8080/v2/{ledger}/transactions/{id}/metadata/{key} HTTP/1.1
 Host: localhost:8080
 Accept: application/json
+Idempotency-Key: string
 
 ```
 
@@ -980,6 +981,7 @@ Delete metadata by key
 |ledger|path|string|true|Name of the ledger.|
 |id|path|integer(bigint)|true|Transaction ID.|
 |key|path|string|true|The key to remove.|
+|Idempotency-Key|header|string|false|Use an idempotency key|
 
 > Example responses
 

internal/api/common/errors.go

@@ -2,11 +2,13 @@
 
 import (
 	"errors"
+	"net/http"
+
 	"github.com/formancehq/go-libs/v3/api"
 	"github.com/formancehq/go-libs/v3/logging"
 	"github.com/formancehq/go-libs/v3/otlp"
 	"github.com/formancehq/go-libs/v3/platform/postgres"
-	"net/http"
+	ledgercontroller "github.com/formancehq/ledger/internal/controller/ledger"
 )
 
 const (
@@ -37,6 +39,19 @@
 	}
 }
 
+func HandleCommonWriteErrors(w http.ResponseWriter, r *http.Request, err error) {
+	switch {
+	case errors.Is(err, ledgercontroller.ErrIdempotencyKeyConflict{}):
+		api.WriteErrorResponse(w, http.StatusConflict, ErrConflict, err)
+	case errors.Is(err, ledgercontroller.ErrInvalidIdempotencyInput{}):
+		api.BadRequest(w, ErrValidation, err)
+	case errors.Is(err, ledgercontroller.ErrNotFound):
+		api.NotFound(w, err)
+	default:
+		HandleCommonErrors(w, r, err)
+	}
+}
+
 func InternalServerError(w http.ResponseWriter, r *http.Request, err error) {
 	otlp.RecordError(r.Context(), err)
 	logging.FromContext(r.Context()).Error(err)

internal/api/v1/controllers_accounts_add_metadata.go

@@ -2,12 +2,14 @@
 
 import (
 	"encoding/json"
-	"github.com/formancehq/ledger/internal/controller/ledger"
-	"github.com/formancehq/ledger/pkg/accounts"
 	"net/http"
 	"net/url"
 
+	"github.com/formancehq/ledger/internal/controller/ledger"
+	"github.com/formancehq/ledger/pkg/accounts"
+
 	"errors"
+
 	"github.com/formancehq/go-libs/v3/api"
 	"github.com/formancehq/go-libs/v3/metadata"
 	"github.com/formancehq/ledger/internal/api/common"
@@ -38,7 +40,7 @@
 		Metadata: m,
 	}))
 	if err != nil {
-		common.HandleCommonErrors(w, r, err)
+		common.HandleCommonWriteErrors(w, r, err)
 		return
 	}
 

internal/api/v1/controllers_accounts_delete_metadata.go

@@ -1,10 +1,11 @@
 package v1
 
 import (
-	"github.com/formancehq/ledger/internal/controller/ledger"
 	"net/http"
 	"net/url"
 
+	"github.com/formancehq/ledger/internal/controller/ledger"
+
 	"github.com/formancehq/go-libs/v3/api"
 	"github.com/formancehq/ledger/internal/api/common"
 	"github.com/go-chi/chi/v5"
@@ -25,7 +26,7 @@ func deleteAccountMetadata(w http.ResponseWriter, r *http.Request) {
 				Key:     chi.URLParam(r, "key"),
 			}),
 		); err != nil {
-		common.HandleCommonErrors(w, r, err)
+		common.HandleCommonWriteErrors(w, r, err)
 		return
 	}
 

internal/api/v1/controllers_transactions_add_metadata.go

@@ -8,6 +8,7 @@
 	ledgercontroller "github.com/formancehq/ledger/internal/controller/ledger"
 
 	"errors"
+
 	"github.com/formancehq/go-libs/v3/api"
 	"github.com/formancehq/go-libs/v3/metadata"
 	"github.com/formancehq/ledger/internal/api/common"
@@ -37,7 +38,7 @@
 		case errors.Is(err, ledgercontroller.ErrNotFound):
 			api.NotFound(w, err)
 		default:
-			common.HandleCommonErrors(w, r, err)
+			common.HandleCommonWriteErrors(w, r, err)
 		}
 		return
 	}

internal/api/v1/controllers_transactions_create.go

@@ -9,6 +9,7 @@
 	ledgercontroller "github.com/formancehq/ledger/internal/controller/ledger"
 
 	"errors"
+
 	"github.com/formancehq/go-libs/v3/api"
 	"github.com/formancehq/go-libs/v3/metadata"
 	"github.com/formancehq/go-libs/v3/time"
@@ -100,7 +101,7 @@
 			case errors.Is(err, ledgercontroller.ErrTransactionReferenceConflict{}):
 				api.WriteErrorResponse(w, http.StatusConflict, common.ErrConflict, err)
 			default:
-				common.HandleCommonErrors(w, r, err)
+				common.HandleCommonWriteErrors(w, r, err)
 			}
 			return
 		}
@@ -135,7 +136,7 @@
 		case errors.Is(err, ledgercontroller.ErrTransactionReferenceConflict{}):
 			api.WriteErrorResponse(w, http.StatusConflict, common.ErrConflict, err)
 		default:
-			common.HandleCommonErrors(w, r, err)
+			common.HandleCommonWriteErrors(w, r, err)
 		}
 		return
 	}

internal/api/v1/controllers_transactions_delete_metadata.go

@@ -7,6 +7,7 @@ import (
 	ledgercontroller "github.com/formancehq/ledger/internal/controller/ledger"
 
 	"errors"
+
 	"github.com/formancehq/go-libs/v3/api"
 	"github.com/formancehq/ledger/internal/api/common"
 	"github.com/go-chi/chi/v5"
@@ -27,12 +28,7 @@ func deleteTransactionMetadata(w http.ResponseWriter, r *http.Request) {
 		TransactionID: transactionID,
 		Key:           metadataKey,
 	})); err != nil {
-		switch {
-		case errors.Is(err, ledgercontroller.ErrNotFound):
-			api.NotFound(w, err)
-		default:
-			common.HandleCommonErrors(w, r, err)
-		}
+		common.HandleCommonWriteErrors(w, r, err)
 		return
 	}
 

internal/api/v2/controllers_accounts_add_metadata.go

@@ -2,11 +2,13 @@ package v2
 
 import (
 	"encoding/json"
-	"github.com/formancehq/ledger/internal/controller/ledger"
 	"net/http"
 	"net/url"
 
+	"github.com/formancehq/ledger/internal/controller/ledger"
+
 	"errors"
+
 	"github.com/formancehq/go-libs/v3/api"
 	"github.com/formancehq/go-libs/v3/metadata"
 	"github.com/formancehq/ledger/internal/api/common"
@@ -33,7 +35,7 @@ func addAccountMetadata(w http.ResponseWriter, r *http.Request) {
 		Metadata: m,
 	}))
 	if err != nil {
-		common.HandleCommonErrors(w, r, err)
+		common.HandleCommonWriteErrors(w, r, err)
 		return
 	}
 

internal/api/v2/controllers_accounts_delete_metadata.go

@@ -1,10 +1,11 @@
 package v2
 
 import (
-	"github.com/formancehq/ledger/internal/controller/ledger"
 	"net/http"
 	"net/url"
 
+	"github.com/formancehq/ledger/internal/controller/ledger"
+
 	"github.com/go-chi/chi/v5"
 
 	"github.com/formancehq/go-libs/v3/api"
@@ -26,7 +27,7 @@ func deleteAccountMetadata(w http.ResponseWriter, r *http.Request) {
 				Key:     chi.URLParam(r, "key"),
 			}),
 		); err != nil {
-		common.HandleCommonErrors(w, r, err)
+		common.HandleCommonWriteErrors(w, r, err)
 		return
 	}
 

internal/api/v2/controllers_ledgers_delete_metadata.go

@@ -1,9 +1,10 @@
 package v2
 
 import (
-	"github.com/formancehq/ledger/internal/api/common"
 	"net/http"
 
+	"github.com/formancehq/ledger/internal/api/common"
+
 	"github.com/formancehq/ledger/internal/controller/system"
 
 	"github.com/formancehq/go-libs/v3/api"
@@ -13,7 +14,7 @@ import (
 func deleteLedgerMetadata(b system.Controller) http.HandlerFunc {
 	return func(w http.ResponseWriter, r *http.Request) {
 		if err := b.DeleteLedgerMetadata(r.Context(), chi.URLParam(r, "ledger"), chi.URLParam(r, "key")); err != nil {
-			common.HandleCommonErrors(w, r, err)
+			common.HandleCommonWriteErrors(w, r, err)
 			return
 		}
 

internal/api/v2/controllers_ledgers_update_metadata.go

@@ -2,10 +2,12 @@
 
 import (
 	"encoding/json"
-	"github.com/formancehq/ledger/internal/api/common"
 	"net/http"
 
+	"github.com/formancehq/ledger/internal/api/common"
+
 	"errors"
+
 	"github.com/formancehq/go-libs/v3/api"
 	"github.com/formancehq/go-libs/v3/metadata"
 	systemcontroller "github.com/formancehq/ledger/internal/controller/system"
@@ -22,7 +24,7 @@
 		}
 
 		if err := systemController.UpdateLedgerMetadata(r.Context(), chi.URLParam(r, "ledger"), m); err != nil {
-			common.HandleCommonErrors(w, r, err)
+			common.HandleCommonWriteErrors(w, r, err)
 			return
 		}
 

internal/api/v2/controllers_transactions_add_metadata.go

@@ -8,6 +8,7 @@ import (
 	ledgercontroller "github.com/formancehq/ledger/internal/controller/ledger"
 
 	"errors"
+
 	"github.com/formancehq/go-libs/v3/api"
 	"github.com/formancehq/go-libs/v3/metadata"
 	"github.com/formancehq/ledger/internal/api/common"
@@ -37,7 +38,7 @@ func addTransactionMetadata(w http.ResponseWriter, r *http.Request) {
 		case errors.Is(err, ledgercontroller.ErrNotFound):
 			api.NotFound(w, err)
 		default:
-			common.HandleCommonErrors(w, r, err)
+			common.HandleCommonWriteErrors(w, r, err)
 		}
 		return
 	}

internal/api/v2/controllers_transactions_create.go

@@ -2,9 +2,10 @@ package v2
 
 import (
 	"encoding/json"
-	"github.com/formancehq/ledger/internal/api/bulking"
 	"net/http"
 
+	"github.com/formancehq/ledger/internal/api/bulking"
+
 	ledgercontroller "github.com/formancehq/ledger/internal/controller/ledger"
 
 	"errors"
@@ -51,14 +52,12 @@ func createTransaction(w http.ResponseWriter, r *http.Request) {
 			api.BadRequest(w, common.ErrNoPostings, err)
 		case errors.Is(err, ledgercontroller.ErrTransactionReferenceConflict{}):
 			api.WriteErrorResponse(w, http.StatusConflict, common.ErrConflict, err)
-		case errors.Is(err, ledgercontroller.ErrInvalidIdempotencyInput{}):
-			api.BadRequest(w, common.ErrValidation, err)
 		case errors.Is(err, ledgercontroller.ErrParsing{}):
 			api.BadRequest(w, common.ErrInterpreterParse, err)
 		case errors.Is(err, ledgercontroller.ErrRuntime{}):
 			api.BadRequest(w, common.ErrInterpreterRuntime, err)
 		default:
-			common.HandleCommonErrors(w, r, err)
+			common.HandleCommonWriteErrors(w, r, err)
 		}
 		return
 	}

internal/api/v2/controllers_transactions_delete_metadata.go

@@ -8,7 +8,6 @@ import (
 
 	"github.com/go-chi/chi/v5"
 
-	"errors"
 	"github.com/formancehq/ledger/internal/api/common"
 
 	"github.com/formancehq/go-libs/v3/api"
@@ -29,12 +28,7 @@ func deleteTransactionMetadata(w http.ResponseWriter, r *http.Request) {
 		TransactionID: txID,
 		Key:           metadataKey,
 	})); err != nil {
-		switch {
-		case errors.Is(err, ledgercontroller.ErrNotFound):
-			api.NotFound(w, err)
-		default:
-			common.HandleCommonErrors(w, r, err)
-		}
+		common.HandleCommonWriteErrors(w, r, err)
 		return
 	}
 

internal/api/v2/controllers_transactions_revert.go

@@ -7,6 +7,7 @@ import (
 	ledgercontroller "github.com/formancehq/ledger/internal/controller/ledger"
 
 	"errors"
+
 	"github.com/formancehq/go-libs/v3/api"
 	"github.com/formancehq/ledger/internal/api/common"
 	"github.com/go-chi/chi/v5"

openapi.yaml

@@ -1864,6 +1864,11 @@ paths:
           schema:
             type: string
             example: foo
+        - name: Idempotency-Key
+          in: header
+          description: Use an idempotency key
+          schema:
+            type: string
       responses:
         2XX:
           description: Key deleted
@@ -2241,6 +2246,11 @@ paths:
           schema:
             type: string
             example: foo
+        - name: Idempotency-Key
+          in: header
+          description: Use an idempotency key
+          schema:
+            type: string
       responses:
         2XX:
           description: Key deleted

openapi/v2.yaml

@@ -604,6 +604,11 @@ paths:
           schema:
             type: string
             example: foo
+        - name: Idempotency-Key
+          in: header
+          description: Use an idempotency key
+          schema:
+            type: string
       responses:
         2XX:
           description: Key deleted
@@ -983,6 +988,11 @@ paths:
           schema:
             type: string
             example: foo
+        - name: Idempotency-Key
+          in: header
+          description: Use an idempotency key
+          schema:
+            type: string
       responses:
         2XX:
           description: Key deleted