From da7023133825a00e58daa543b24855b0d7c41b46 Mon Sep 17 00:00:00 2001 From: "A.Unger" Date: Thu, 15 Oct 2020 17:08:16 +0200 Subject: [PATCH] whatever dude --- accounts/pkg/indexer/indexer.go | 6 +++--- accounts/pkg/service/v0/accounts.go | 8 ++++---- 2 files changed, 7 insertions(+), 7 deletions(-) diff --git a/accounts/pkg/indexer/indexer.go b/accounts/pkg/indexer/indexer.go index 9ff0ae0000..349b603699 100644 --- a/accounts/pkg/indexer/indexer.go +++ b/accounts/pkg/indexer/indexer.go @@ -85,12 +85,12 @@ func (i Indexer) Add(t interface{}) ([]IdxAddResult, error) { pkVal := valueOf(t, fields.PKFieldName) idxByVal := valueOf(t, idx.IndexBy()) value, err := idx.Add(pkVal, idxByVal) - if value == "" { - continue - } if err != nil { return []IdxAddResult{}, err } + if value == "" { + continue + } results = append(results, IdxAddResult{Field: idx.IndexBy(), Value: value}) } } diff --git a/accounts/pkg/service/v0/accounts.go b/accounts/pkg/service/v0/accounts.go index 3ccfc345f2..8bb979b8ec 100644 --- a/accounts/pkg/service/v0/accounts.go +++ b/accounts/pkg/service/v0/accounts.go @@ -319,10 +319,10 @@ func (s Service) CreateAccount(ctx context.Context, in *proto.CreateAccountReque s.debugLogAccount(acc).Msg("could not persist new account") return merrors.InternalServerError(s.id, "could not persist new account: %v", err.Error()) } - indexResults, err := s.index.Add(acc) - if err != nil { - s.rollbackCreateAccount(ctx, acc) - return merrors.InternalServerError(s.id, "could not index new account: %v", err.Error()) + indexResults, err2 := s.index.Add(acc) + if err2 != nil { + //s.rollbackCreateAccount(ctx, acc) + return merrors.InternalServerError(s.id, "could not index new account: %v", err2.Error()) } s.log.Debug().Interface("account", acc).Msg("account after indexing")