mirror of
https://github.com/luxfi/evm.git
synced 2026-09-24 00:27:44 +00:00
100 lines
3.3 KiB
Go
100 lines
3.3 KiB
Go
// (c) 2023, Lux Industries, Inc. All rights reserved.
|
|
// See the file LICENSE for licensing terms.
|
|
|
|
package core
|
|
|
|
import (
|
|
"math/big"
|
|
"strings"
|
|
"testing"
|
|
"github.com/luxfi/evm/accounts/abi"
|
|
"github.com/luxfi/evm/consensus/dummy"
|
|
"github.com/luxfi/evm/core/rawdb"
|
|
"github.com/luxfi/evm/core/types"
|
|
"github.com/luxfi/evm/core/vm"
|
|
"github.com/luxfi/evm/params"
|
|
"github.com/luxfi/geth/common"
|
|
"github.com/luxfi/geth/crypto"
|
|
"github.com/stretchr/testify/require"
|
|
)
|
|
|
|
func TestAcceptedLogsSubscription(t *testing.T) {
|
|
/*
|
|
Example contract to test event emission:
|
|
|
|
pragma solidity >=0.7.0 <0.9.0;
|
|
contract Callable {
|
|
event Called();
|
|
function Call() public { emit Called(); }
|
|
}
|
|
*/
|
|
|
|
const (
|
|
callableABI = "[{\"anonymous\":false,\"inputs\":[],\"name\":\"Called\",\"type\":\"event\"},{\"inputs\":[],\"name\":\"Call\",\"outputs\":[],\"stateMutability\":\"nonpayable\",\"type\":\"function\"}]"
|
|
callableBin = "6080604052348015600f57600080fd5b5060998061001e6000396000f3fe6080604052348015600f57600080fd5b506004361060285760003560e01c806334e2292114602d575b600080fd5b60336035565b005b7f81fab7a4a0aa961db47eefc81f143a5220e8c8495260dd65b1356f1d19d3c7b860405160405180910390a156fea2646970667358221220029436d24f3ac598ceca41d4d712e13ced6d70727f4cdc580667de66d2f51d8b64736f6c63430008010033"
|
|
)
|
|
var (
|
|
require = require.New(t)
|
|
engine = dummy.NewCoinbaseFaker()
|
|
key1, _ = crypto.HexToECDSA("b71c71a67e1177ad4e901695e1b4b9ee17ae16c6668d313eac2f96dbcda3f291")
|
|
addr1 = crypto.PubkeyToAddress(key1.PublicKey)
|
|
funds = new(big.Int).Mul(big.NewInt(100), big.NewInt(params.Ether))
|
|
gspec = &Genesis{
|
|
Config: params.TestChainConfig,
|
|
Alloc: GenesisAlloc{addr1: {Balance: funds}},
|
|
BaseFee: big.NewInt(params.TestInitialBaseFee),
|
|
}
|
|
contractAddress = crypto.CreateAddress(addr1, 0)
|
|
signer = types.LatestSigner(gspec.Config)
|
|
)
|
|
|
|
parsed, err := abi.JSON(strings.NewReader(callableABI))
|
|
require.NoError(err)
|
|
|
|
packedFunction, err := parsed.Pack("Call")
|
|
require.NoError(err)
|
|
|
|
_, blocks, _, err := GenerateChainWithGenesis(gspec, engine, 2, 10, func(i int, b *BlockGen) {
|
|
switch i {
|
|
case 0:
|
|
// First, we deploy the contract
|
|
contractTx := types.NewContractCreation(0, common.Big0, 200000, big.NewInt(params.TestInitialBaseFee), common.FromHex(callableBin))
|
|
contractSignedTx, err := types.SignTx(contractTx, signer, key1)
|
|
require.NoError(err)
|
|
b.AddTx(contractSignedTx)
|
|
case 1:
|
|
// In the next block, we call the contract function
|
|
tx := types.NewTransaction(1, contractAddress, common.Big0, 23000, big.NewInt(params.TestInitialBaseFee), packedFunction)
|
|
tx, err := types.SignTx(tx, signer, key1)
|
|
require.NoError(err)
|
|
b.AddTx(tx)
|
|
}
|
|
})
|
|
require.NoError(err)
|
|
|
|
chain, err := NewBlockChain(rawdb.NewMemoryDatabase(), DefaultCacheConfig, gspec, engine, vm.Config{}, common.Hash{}, false)
|
|
require.NoError(err)
|
|
defer chain.Stop()
|
|
|
|
// Create Log Subscriber
|
|
logsCh := make(chan []*types.Log, 10)
|
|
defer close(logsCh)
|
|
|
|
sub := chain.SubscribeAcceptedLogsEvent(logsCh)
|
|
defer sub.Unsubscribe()
|
|
|
|
_, err = chain.InsertChain(blocks)
|
|
require.NoError(err)
|
|
|
|
for _, block := range blocks {
|
|
err := chain.Accept(block)
|
|
require.NoError(err)
|
|
}
|
|
chain.DrainAcceptorQueue()
|
|
|
|
logs := <-logsCh
|
|
require.Len(logs, 1)
|
|
require.Equal(blocks[1].Hash(), logs[0].BlockHash)
|
|
require.Equal(blocks[1].Number().Uint64(), logs[0].BlockNumber)
|
|
}
|