diff options
author | Wei-Ning Huang <w@cobinhood.com> | 2018-10-13 15:22:08 +0800 |
---|---|---|
committer | Wei-Ning Huang <w@dexon.org> | 2019-03-12 12:19:09 +0800 |
commit | 40b1f02b48cd275b878e9c4308c4373f2c6329e2 (patch) | |
tree | 19353d6d57a0f674b134454fbf59ab0bae0333a4 /dex | |
parent | 7774f1809297b1d158cef504a56bf49296f90609 (diff) | |
download | dexon-40b1f02b48cd275b878e9c4308c4373f2c6329e2.tar dexon-40b1f02b48cd275b878e9c4308c4373f2c6329e2.tar.gz dexon-40b1f02b48cd275b878e9c4308c4373f2c6329e2.tar.bz2 dexon-40b1f02b48cd275b878e9c4308c4373f2c6329e2.tar.lz dexon-40b1f02b48cd275b878e9c4308c4373f2c6329e2.tar.xz dexon-40b1f02b48cd275b878e9c4308c4373f2c6329e2.tar.zst dexon-40b1f02b48cd275b878e9c4308c4373f2c6329e2.zip |
dex: implement sendTx related governance methods
Diffstat (limited to 'dex')
-rw-r--r-- | dex/backend.go | 2 | ||||
-rw-r--r-- | dex/governance.go | 132 |
2 files changed, 128 insertions, 6 deletions
diff --git a/dex/backend.go b/dex/backend.go index 2396f0f71..2b4db94c4 100644 --- a/dex/backend.go +++ b/dex/backend.go @@ -148,7 +148,7 @@ func New(ctx *node.ServiceContext, config *Config) (*Dexon, error) { //} dex.APIBackend.gpo = gasprice.NewOracle(dex.APIBackend, gpoParams) - dex.governance = NewDexconGovernance(dex.APIBackend, config.PrivateKey) + dex.governance = NewDexconGovernance(dex.APIBackend, dex.chainConfig, config.PrivateKey) dex.app = NewDexconApp(dex.txPool, dex.blockchain, dex.governance, chainDb, config, vmConfig) privKey := coreEcdsa.NewPrivateKeyFromECDSA(config.PrivateKey) diff --git a/dex/governance.go b/dex/governance.go index 8993152df..3f50ae408 100644 --- a/dex/governance.go +++ b/dex/governance.go @@ -10,22 +10,32 @@ import ( coreCrypto "github.com/dexon-foundation/dexon-consensus-core/core/crypto" coreEcdsa "github.com/dexon-foundation/dexon-consensus-core/core/crypto/ecdsa" coreTypes "github.com/dexon-foundation/dexon-consensus-core/core/types" + "github.com/dexon-foundation/dexon/common" + "github.com/dexon-foundation/dexon/core/types" "github.com/dexon-foundation/dexon/core/vm" + "github.com/dexon-foundation/dexon/crypto" + "github.com/dexon-foundation/dexon/log" + "github.com/dexon-foundation/dexon/params" "github.com/dexon-foundation/dexon/rlp" "github.com/dexon-foundation/dexon/rpc" ) type DexconGovernance struct { - b *DexAPIBackend - privateKey *ecdsa.PrivateKey + b *DexAPIBackend + chainConfig *params.ChainConfig + privateKey *ecdsa.PrivateKey + address common.Address } // NewDexconGovernance retruns a governance implementation of the DEXON // consensus governance interface. -func NewDexconGovernance(backend *DexAPIBackend, privKey *ecdsa.PrivateKey) *DexconGovernance { +func NewDexconGovernance(backend *DexAPIBackend, chainConfig *params.ChainConfig, + privKey *ecdsa.PrivateKey) *DexconGovernance { return &DexconGovernance{ - b: backend, - privateKey: privKey, + b: backend, + chainConfig: chainConfig, + privateKey: privKey, + address: crypto.PubkeyToAddress(privKey.PublicKey), } } @@ -90,6 +100,19 @@ func (d *DexconGovernance) CRS(round uint64) coreCommon.Hash { // ProposeCRS send proposals of a new CRS func (d *DexconGovernance) ProposeCRS(signedCRS []byte) { + method := vm.GovernanceContractName2Method["proposeCRS"] + + res, err := method.Inputs.Pack(signedCRS) + if err != nil { + log.Error("failed to pack proposeCRS input: %s", err) + return + } + + data := append(method.Id(), res...) + err = d.sendGovTx(context.Background(), data) + if err != nil { + log.Error("failed to send proposeCRS tx: %s", err) + } } // NodeSet returns the current notary set. @@ -103,12 +126,73 @@ func (d *DexconGovernance) NodeSet(round uint64) []coreCrypto.PublicKey { return pks } +func (d *DexconGovernance) sendGovTx(ctx context.Context, data []byte) error { + gasPrice, err := d.b.SuggestPrice(ctx) + if err != nil { + return err + } + + nonce, err := d.b.GetPoolNonce(ctx, d.address) + if err != nil { + return err + } + + tx := types.NewTransaction( + nonce, + vm.GovernanceContractAddress, + big.NewInt(0), + uint64(200000), + gasPrice, + data) + + signer := types.NewEIP155Signer(d.chainConfig.ChainID) + + tx, err = types.SignTx(tx, signer, d.privateKey) + if err != nil { + return err + } + return d.b.SendTx(ctx, tx) +} + // NotifyRoundHeight register the mapping between round and height. func (d *DexconGovernance) NotifyRoundHeight(targetRound, consensusHeight uint64) { + method := vm.GovernanceContractName2Method["snapshotRound"] + + res, err := method.Inputs.Pack( + big.NewInt(int64(targetRound)), big.NewInt(int64(consensusHeight))) + if err != nil { + log.Error("failed to pack snapshotRound input: %s", err) + return + } + + data := append(method.Id(), res...) + err = d.sendGovTx(context.Background(), data) + if err != nil { + log.Error("failed to send snapshotRound tx: %s", err) + } } // AddDKGComplaint adds a DKGComplaint. func (d *DexconGovernance) AddDKGComplaint(round uint64, complaint *coreTypes.DKGComplaint) { + method := vm.GovernanceContractName2Method["addDKGComplaint"] + + encoded, err := rlp.EncodeToBytes(complaint) + if err != nil { + log.Error("failed to RLP encode complaint to bytes: %s", err) + return + } + + res, err := method.Inputs.Pack(big.NewInt(int64(round)), encoded) + if err != nil { + log.Error("failed to pack addDKGComplaint input: %s", err) + return + } + + data := append(method.Id(), res...) + err = d.sendGovTx(context.Background(), data) + if err != nil { + log.Error("failed to send addDKGComplaint tx: %s", err) + } } // DKGComplaints gets all the DKGComplaints of round. @@ -127,6 +211,25 @@ func (d *DexconGovernance) DKGComplaints(round uint64) []*coreTypes.DKGComplaint // AddDKGMasterPublicKey adds a DKGMasterPublicKey. func (d *DexconGovernance) AddDKGMasterPublicKey(round uint64, masterPublicKey *coreTypes.DKGMasterPublicKey) { + method := vm.GovernanceContractName2Method["addDKGMasterPublicKey"] + + encoded, err := rlp.EncodeToBytes(masterPublicKey) + if err != nil { + log.Error("failed to RLP encode mpk to bytes: %s", err) + return + } + + res, err := method.Inputs.Pack(big.NewInt(int64(round)), encoded) + if err != nil { + log.Error("failed to pack addDKGMasterPublicKey input: %s", err) + return + } + + data := append(method.Id(), res...) + err = d.sendGovTx(context.Background(), data) + if err != nil { + log.Error("failed to send addDKGMasterPublicKey tx: %s", err) + } } // DKGMasterPublicKeys gets all the DKGMasterPublicKey of round. @@ -145,6 +248,25 @@ func (d *DexconGovernance) DKGMasterPublicKeys(round uint64) []*coreTypes.DKGMas // AddDKGFinalize adds a DKG finalize message. func (d *DexconGovernance) AddDKGFinalize(round uint64, final *coreTypes.DKGFinalize) { + method := vm.GovernanceContractName2Method["addDKGFinalize"] + + encoded, err := rlp.EncodeToBytes(final) + if err != nil { + log.Error("failed to RLP encode finalize to bytes: %s", err) + return + } + + res, err := method.Inputs.Pack(big.NewInt(int64(round)), encoded) + if err != nil { + log.Error("failed to pack addDKGFinalize input: %s", err) + return + } + + data := append(method.Id(), res...) + err = d.sendGovTx(context.Background(), data) + if err != nil { + log.Error("failed to send addDKGFinalize tx: %s", err) + } } // IsDKGFinal checks if DKG is final. |