whatever dude
This commit is contained in:
@@ -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})
|
||||
}
|
||||
}
|
||||
|
||||
@@ -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")
|
||||
|
||||
|
||||
Reference in New Issue
Block a user