feat: implement wallet deletion functionality (#89)

Author: lucasfleischer7

go.mod

@@ -11,7 +11,7 @@ require (
 	github.com/hashicorp/vault/api v1.20.0
 	github.com/oapi-codegen/runtime v1.1.2
 	github.com/smartcontractkit/chain-selectors v1.0.82
-	github.com/smartcontractkit/crec-api-go v0.3.8-0.20260113233243-298d281b2ab6
+	github.com/smartcontractkit/crec-api-go v0.3.8-0.20260115174532-3d075a87c5fb
 	github.com/stretchr/testify v1.10.0
 	github.com/testcontainers/testcontainers-go v0.38.0
 	github.com/testcontainers/testcontainers-go/modules/vault v0.38.0

go.sum

@@ -453,6 +453,8 @@ github.com/smartcontractkit/crec-api-go v0.3.8-0.20260113152121-3ff31eb7e4ce h1:
 github.com/smartcontractkit/crec-api-go v0.3.8-0.20260113152121-3ff31eb7e4ce/go.mod h1:TuDZiMoStNQBv3HYA5pqpwPyecbMh8p5momO4b1A9Eg=
 github.com/smartcontractkit/crec-api-go v0.3.8-0.20260113233243-298d281b2ab6 h1:GjHgFIYaeuifJJpchd+ytTCYnKIeQseubxn/BZ5sLmo=
 github.com/smartcontractkit/crec-api-go v0.3.8-0.20260113233243-298d281b2ab6/go.mod h1:TuDZiMoStNQBv3HYA5pqpwPyecbMh8p5momO4b1A9Eg=
+github.com/smartcontractkit/crec-api-go v0.3.8-0.20260115174532-3d075a87c5fb h1:jqwuLPkCM26GsXrh6pV/pZYUvVEg45xFQ/+L4gWw0mQ=
+github.com/smartcontractkit/crec-api-go v0.3.8-0.20260115174532-3d075a87c5fb/go.mod h1:TuDZiMoStNQBv3HYA5pqpwPyecbMh8p5momO4b1A9Eg=
 github.com/sourcegraph/conc v0.3.0 h1:OQTbbt6P72L20UqAkXXuLOj79LfEanQ+YQFNpLA9ySo=
 github.com/sourcegraph/conc v0.3.0/go.mod h1:Sdozi7LEKbFPqYX2/J+iBAM6HpqSLTASQIKqDmF7Mt0=
 github.com/spf13/afero v1.12.0 h1:UcOPyRBYczmFn6yvphxkn9ZEOY65cpwGKb5mL36mrqs=

mocks/server/server.go

@@ -621,6 +621,21 @@ func (s *MockServer) PatchWalletsWalletId(w http.ResponseWriter, r *http.Request
 	http.Error(w, "wallet not found", http.StatusNotFound)
 }
 
+func (s *MockServer) DeleteWalletsWalletId(w http.ResponseWriter, r *http.Request, walletId openapiTypes.UUID) {
+	s.mu.Lock()
+	defer s.mu.Unlock()
+
+	// Find and remove the wallet
+	for i, wallet := range s.wallets {
+		if wallet.WalletId == walletId {
+			s.wallets = append(s.wallets[:i], s.wallets[i+1:]...)
+			w.WriteHeader(http.StatusOK)
+			return
+		}
+	}
+	http.Error(w, "wallet not found", http.StatusNotFound)
+}
+
 // ============================================================================
 // HELPER METHODS (INTERNAL)
 // ============================================================================

wallets/wallets.go

@@ -47,6 +47,7 @@ var (
 	ErrGetWallet    = errors.New("failed to get wallet")
 	ErrListWallets  = errors.New("failed to list wallets")
 	ErrUpdateWallet = errors.New("failed to update wallet")
+	ErrDeleteWallet = errors.New("failed to delete wallet")
 
 	// Response errors
 	ErrUnexpectedStatusCode = errors.New("unexpected status code")
@@ -390,3 +391,40 @@ func (c *Client) Update(ctx context.Context, walletID uuid.UUID, input UpdateInp
 
 	return nil
 }
+
+// Delete deletes a wallet.
+//
+// Parameters:
+//   - ctx: The context for the request.
+//   - walletID: The UUID of the wallet to delete.
+//
+// Returns an error if the operation fails or the wallet is not found.
+func (c *Client) Delete(ctx context.Context, walletID uuid.UUID) error {
+	c.logger.Debug("Deleting wallet", "wallet_id", walletID.String())
+
+	if walletID == uuid.Nil {
+		return ErrWalletIDRequired
+	}
+
+	resp, err := c.apiClient.DeleteWalletsWalletIdWithResponse(ctx, walletID)
+	if err != nil {
+		c.logger.Error("Failed to delete wallet", "error", err)
+		return fmt.Errorf("%w: %w", ErrDeleteWallet, err)
+	}
+
+	if resp.StatusCode() == 404 {
+		c.logger.Warn("Wallet not found", "wallet_id", walletID.String())
+		return fmt.Errorf("%w: wallet ID %s", ErrWalletNotFound, walletID.String())
+	}
+
+	if resp.StatusCode() != 200 {
+		c.logger.Error("Unexpected status code when deleting wallet",
+			"status_code", resp.StatusCode(),
+			"body", string(resp.Body))
+		return fmt.Errorf("%w: %w (status code %d)", ErrDeleteWallet, ErrUnexpectedStatusCode, resp.StatusCode())
+	}
+
+	c.logger.Info("Wallet deleted successfully", "wallet_id", walletID.String())
+
+	return nil
+}

wallets/wallets_test.go

@@ -871,3 +871,72 @@ func TestClient_Update(t *testing.T) {
 		assert.True(t, errors.Is(err, ErrUpdateWallet))
 	})
 }
+
+func TestClient_Delete(t *testing.T) {
+	t.Run("Success", func(t *testing.T) {
+		walletID := uuid.New()
+
+		handler := func(w http.ResponseWriter, r *http.Request) {
+			assert.Equal(t, "/wallets/"+walletID.String(), r.URL.Path)
+			assert.Equal(t, "DELETE", r.Method)
+			assert.Equal(t, "test-api-key", r.Header.Get("Api-Key"))
+
+			w.WriteHeader(http.StatusOK)
+		}
+
+		client, server := setupTestClient(t, handler)
+		defer server.Close()
+
+		err := client.Delete(context.Background(), walletID)
+
+		require.NoError(t, err)
+	})
+
+	t.Run("NilWalletID", func(t *testing.T) {
+		client, server := setupTestClient(t, nil)
+		defer server.Close()
+
+		err := client.Delete(context.Background(), uuid.Nil)
+
+		require.Error(t, err)
+		assert.True(t, errors.Is(err, ErrWalletIDRequired))
+	})
+
+	t.Run("NotFound", func(t *testing.T) {
+		walletID := uuid.New()
+
+		handler := func(w http.ResponseWriter, r *http.Request) {
+			w.Header().Set("Content-Type", "application/json")
+			w.WriteHeader(http.StatusNotFound)
+			json.NewEncoder(w).Encode(map[string]string{
+				"message": "Wallet not found",
+				"type":    "Not found",
+			})
+		}
+
+		client, server := setupTestClient(t, handler)
+		defer server.Close()
+
+		err := client.Delete(context.Background(), walletID)
+
+		require.Error(t, err)
+		assert.True(t, errors.Is(err, ErrWalletNotFound))
+	})
+
+	t.Run("UnexpectedStatusCode", func(t *testing.T) {
+		walletID := uuid.New()
+
+		handler := func(w http.ResponseWriter, r *http.Request) {
+			w.WriteHeader(http.StatusInternalServerError)
+		}
+
+		client, server := setupTestClient(t, handler)
+		defer server.Close()
+
+		err := client.Delete(context.Background(), walletID)
+
+		require.Error(t, err)
+		assert.True(t, errors.Is(err, ErrDeleteWallet))
+		assert.True(t, errors.Is(err, ErrUnexpectedStatusCode))
+	})
+}