fix: (cqrs): remove delete metadata when update object with field is …

…null
LerianStudio · May 20, 2024 · 9142901 · 9142901
1 parent 6f6c044
commit 9142901
Show file tree

Hide file tree

Showing 7 changed files with 1 addition and 34 deletions.
diff --git a/components/ledger/internal/app/command/update-account.go b/components/ledger/internal/app/command/update-account.go
@@ -55,11 +55,6 @@ func (uc *UseCase) UpdateAccountByID(ctx context.Context, organizationID, ledger
 		}
 
 		accountUpdated.Metadata = uai.Metadata
-	} else {
-		err := uc.MetadataRepo.Delete(ctx, reflect.TypeOf(a.Account{}).Name(), id)
-		if err != nil {
-			return nil, err
-		}
 	}
 
 	return accountUpdated, nil

diff --git a/components/ledger/internal/app/command/update-instrument.go b/components/ledger/internal/app/command/update-instrument.go
@@ -60,12 +60,6 @@ func (uc *UseCase) UpdateInstrumentByID(ctx context.Context, organizationID, led
 		}
 
 		instrumentUpdated.Metadata = uii.Metadata
-
-		return instrumentUpdated, nil
-	}
-
-	if err := uc.MetadataRepo.Delete(ctx, reflect.TypeOf(i.Instrument{}).Name(), id.String()); err != nil {
-		return nil, err
 	}
 
 	return instrumentUpdated, nil

diff --git a/components/ledger/internal/app/command/update-ledger.go b/components/ledger/internal/app/command/update-ledger.go
@@ -58,12 +58,6 @@ func (uc *UseCase) UpdateLedgerByID(ctx context.Context, organizationID, id stri
 		}
 
 		ledgerUpdated.Metadata = uli.Metadata
-
-		return ledgerUpdated, nil
-	}
-
-	if err := uc.MetadataRepo.Delete(ctx, reflect.TypeOf(l.Ledger{}).Name(), id); err != nil {
-		return nil, err
 	}
 
 	return ledgerUpdated, nil

diff --git a/components/ledger/internal/app/command/update-organization.go b/components/ledger/internal/app/command/update-organization.go
@@ -59,12 +59,6 @@ func (uc *UseCase) UpdateOrganizationByID(ctx context.Context, id string, uoi *o
 		}
 
 		organizationUpdated.Metadata = uoi.Metadata
-
-		return organizationUpdated, nil
-	}
-
-	if err := uc.MetadataRepo.Delete(ctx, reflect.TypeOf(o.Organization{}).Name(), id); err != nil {
-		return nil, err
 	}
 
 	return organizationUpdated, nil

diff --git a/components/ledger/internal/app/command/update-portfolio.go b/components/ledger/internal/app/command/update-portfolio.go
@@ -57,12 +57,6 @@ func (uc *UseCase) UpdatePortfolioByID(ctx context.Context, organizationID, ledg
 		}
 
 		portfolioUpdated.Metadata = upi.Metadata
-
-		return portfolioUpdated, nil
-	}
-
-	if err := uc.MetadataRepo.Delete(ctx, reflect.TypeOf(p.Portfolio{}).Name(), id); err != nil {
-		return nil, err
 	}
 
 	return portfolioUpdated, nil

diff --git a/components/ledger/internal/app/command/update-product.go b/components/ledger/internal/app/command/update-product.go
@@ -57,10 +57,6 @@ func (uc *UseCase) UpdateProductByID(ctx context.Context, organizationID, ledger
 		}
 
 		productUpdated.Metadata = upi.Metadata
-	} else {
-		if err := uc.MetadataRepo.Delete(ctx, reflect.TypeOf(r.Product{}).Name(), id); err != nil {
-			return nil, err
-		}
 	}
 
 	return productUpdated, nil

diff --git a/components/ledger/internal/domain/onboarding/organization/organization.go b/components/ledger/internal/domain/onboarding/organization/organization.go
@@ -40,7 +40,7 @@ type UpdateOrganizationInput struct {
 	DoingBusinessAs *string        `json:"doingBusinessAs,omitempty"`
 	Address         Address        `json:"address"`
 	Status          Status         `json:"status"`
-	Metadata        map[string]any `json:"metadata,omitempty"`
+	Metadata        map[string]any `json:"metadata"`
 }
 
 // Organization is a struct designed to encapsulate response payload data.