block_rewards.go

// VulcanizeDB
// Copyright © 2019 Vulcanize

// This program is free software: you can redistribute it and/or modify
// it under the terms of the GNU Affero General Public License as published by
// the Free Software Foundation, either version 3 of the License, or
// (at your option) any later version.

// This program is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
// GNU Affero General Public License for more details.

// You should have received a copy of the GNU Affero General Public License
// along with this program.  If not, see <http://www.gnu.org/licenses/>.

package common

import (
	"math/big"

	"github.com/ethereum/go-ethereum/core/types"
	"github.com/vulcanize/vulcanizedb/pkg/core"
)

func CalcBlockReward(block core.Block, uncles []*types.Header) *big.Int {
	staticBlockReward := staticRewardByBlockNumber(block.Number)
	transactionFees := calcTransactionFees(block)
	uncleInclusionRewards := calcUncleInclusionRewards(block, uncles)
	tmp := transactionFees.Add(transactionFees, uncleInclusionRewards)
	return tmp.Add(tmp, staticBlockReward)
}

func calcUncleMinerReward(blockNumber, uncleBlockNumber int64) *big.Int {
	staticBlockReward := staticRewardByBlockNumber(blockNumber)
	rewardDiv8 := staticBlockReward.Div(staticBlockReward, big.NewInt(8))
	mainBlock := big.NewInt(blockNumber)
	uncleBlock := big.NewInt(uncleBlockNumber)
	uncleBlockPlus8 := uncleBlock.Add(uncleBlock, big.NewInt(8))
	uncleBlockPlus8MinusMainBlock := uncleBlockPlus8.Sub(uncleBlockPlus8, mainBlock)
	return rewardDiv8.Mul(rewardDiv8, uncleBlockPlus8MinusMainBlock)
}

func calcTransactionFees(block core.Block) *big.Int {
	transactionFees := new(big.Int)
	for _, transaction := range block.Transactions {
		receipt := transaction.Receipt
		gasPrice := big.NewInt(transaction.GasPrice)
		gasUsed := big.NewInt(int64(receipt.GasUsed))
		transactionFee := gasPrice.Mul(gasPrice, gasUsed)
		transactionFees = transactionFees.Add(transactionFees, transactionFee)
	}
	return transactionFees
}

func calcUncleInclusionRewards(block core.Block, uncles []*types.Header) *big.Int {
	uncleInclusionRewards := new(big.Int)
	for range uncles {
		staticBlockReward := staticRewardByBlockNumber(block.Number)
		staticBlockReward.Div(staticBlockReward, big.NewInt(32))
		uncleInclusionRewards.Add(uncleInclusionRewards, staticBlockReward)
	}
	return uncleInclusionRewards
}

func staticRewardByBlockNumber(blockNumber int64) *big.Int {
	staticBlockReward := new(big.Int)
	//https://blog.ethereum.org/2017/10/12/byzantium-hf-announcement/
	if blockNumber >= 7280000 {
		staticBlockReward.SetString("2000000000000000000", 10)
	} else if blockNumber >= 4370000 {
		staticBlockReward.SetString("3000000000000000000", 10)
	} else {
		staticBlockReward.SetString("5000000000000000000", 10)
	}
	return staticBlockReward
}