Hotfix: storing delegates

goverland-labs · Oct 25, 2024 · b086699 · b086699
1 parent 4dae065
commit b086699
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git 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
@@ -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(),