Skip to content

Commit

Permalink
Merge pull request #2574 from 0chain/fix/block-rewards-endpoint
Browse files Browse the repository at this point in the history
Fix block rewards endpoint
  • Loading branch information
dabasov committed Jul 6, 2023
2 parents f25fe4c + ea9b823 commit 5a0b496
Show file tree
Hide file tree
Showing 2 changed files with 7 additions and 6 deletions.
2 changes: 1 addition & 1 deletion code/go/0chain.net/smartcontract/dbs/event/challenge.go
Expand Up @@ -36,7 +36,7 @@ func (edb *EventDb) GetAllChallengesByAllocationID(allocationID string) (Challen
}

func (edb *EventDb) GetPassedChallengesForBlobberAllocation(allocationID string) (map[string]int, error) {
var result map[string]int
result := make(map[string]int)

edb.Store.Get().Table("challenges").
Select("blobber_id, count(*) as count").
Expand Down
Expand Up @@ -171,7 +171,7 @@ func (edb *EventDb) GetBlockRewards(startBlock, endBlock string) ([]int64, error

var blockRewards []BlockReward

err := edb.Get().Table("reward_providers").Select("provider_id, sum(amount) as amount").Where("block_number >= ? AND block_number <= ?", startBlock, endBlock).Group("provider_id").Scan(&blockRewards).Error
err := edb.Get().Table("reward_providers").Select("provider_id, sum(amount) as amount").Where("reward_type = ? AND block_number >= ? AND block_number <= ?", spenum.BlockRewardBlobber, startBlock, endBlock).Group("provider_id").Order("provider_id").Scan(&blockRewards).Error
if err != nil {
return nil, err
}
Expand All @@ -182,15 +182,16 @@ func (edb *EventDb) GetBlockRewards(startBlock, endBlock string) ([]int64, error

for _, br := range blockRewards {

var delegateRewards BlockReward
err = edb.Get().Table("reward_delegates").Select("provider_id, sum(amount) as amount").Where("block_number >= ? AND block_number <= ?", startBlock, endBlock).Group("provider_id").Scan(&delegateRewards).Error
var delegateReward int64

err = edb.Get().Table("reward_delegates").Select("sum(amount) as amount").Where("reward_type = ? AND provider_id = ? AND block_number >= ? AND block_number <= ?", spenum.BlockRewardBlobber, br.ProviderID, startBlock, endBlock).Scan(&delegateReward).Error
if err != nil {
return nil, err
}

result = append(result, delegateRewards.Amount)
result = append(result, delegateReward)

totals = append(totals, br.Amount+delegateRewards.Amount)
totals = append(totals, br.Amount+delegateReward)
}

result = append(result, totals...)
Expand Down

0 comments on commit 5a0b496

Please sign in to comment.