From b0866990f8965ab2378af843bdc1431d17d0ad4b Mon Sep 17 00:00:00 2001 From: Dmitry Date: Fri, 25 Oct 2024 15:26:46 +0300 Subject: [PATCH] Hotfix: storing delegates --- internal/delegate/repo.go | 4 ++-- internal/delegate/service.go | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/internal/delegate/repo.go b/internal/delegate/repo.go index f892224..96e29ec 100644 --- a/internal/delegate/repo.go +++ b/internal/delegate/repo.go @@ -21,8 +21,8 @@ func (r *Repo) CreateHistory(tx *gorm.DB, dd History) error { } // CreateSummary creates one summary info -func (r *Repo) CreateSummary(sm Summary) error { - return r.db.Create(&sm).Error +func (r *Repo) CreateSummary(tx *gorm.DB, sm Summary) error { + return tx.Create(&sm).Error } func (r *Repo) CallInTx(cb func(tx *gorm.DB) error) error { diff --git a/internal/delegate/service.go b/internal/delegate/service.go index 9e132da..2dc005c 100644 --- a/internal/delegate/service.go +++ b/internal/delegate/service.go @@ -306,7 +306,7 @@ func (s *Service) handleDelegate(_ context.Context, hr History) error { for _, info := range hr.Delegations.Details { addresses = append(addresses, info.Address) - if err = s.repo.CreateSummary(Summary{ + if err = s.repo.CreateSummary(tx, Summary{ AddressFrom: strings.ToLower(hr.AddressFrom), AddressTo: strings.ToLower(info.Address), DaoID: daoID.String(),