/
app.go
168 lines (144 loc) · 5.56 KB
/
app.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
package app
import (
attestkeeper "github.com/omni-network/omni/halo/attest/keeper"
atypes "github.com/omni-network/omni/halo/attest/types"
"github.com/omni-network/omni/halo/comet"
evmengkeeper "github.com/omni-network/omni/halo/evmengine/keeper"
"github.com/omni-network/omni/halo/evmstaking"
valsynckeeper "github.com/omni-network/omni/halo/valsync/keeper"
"github.com/omni-network/omni/lib/errors"
"github.com/omni-network/omni/lib/ethclient"
"cosmossdk.io/depinject"
"cosmossdk.io/log"
dbm "github.com/cosmos/cosmos-db"
"github.com/cosmos/cosmos-sdk/baseapp"
"github.com/cosmos/cosmos-sdk/client"
"github.com/cosmos/cosmos-sdk/codec"
codectypes "github.com/cosmos/cosmos-sdk/codec/types"
"github.com/cosmos/cosmos-sdk/runtime"
servertypes "github.com/cosmos/cosmos-sdk/server/types"
"github.com/cosmos/cosmos-sdk/types/module"
authkeeper "github.com/cosmos/cosmos-sdk/x/auth/keeper"
bankkeeper "github.com/cosmos/cosmos-sdk/x/bank/keeper"
consensuskeeper "github.com/cosmos/cosmos-sdk/x/consensus/keeper"
distrkeeper "github.com/cosmos/cosmos-sdk/x/distribution/keeper"
stakingkeeper "github.com/cosmos/cosmos-sdk/x/staking/keeper"
_ "cosmossdk.io/api/cosmos/tx/config/v1" // import for side-effects
_ "github.com/cosmos/cosmos-sdk/x/auth" // import for side-effects
_ "github.com/cosmos/cosmos-sdk/x/auth/tx/config" // import for side-effects
_ "github.com/cosmos/cosmos-sdk/x/bank" // import for side-effects
_ "github.com/cosmos/cosmos-sdk/x/consensus" // import for side-effects
_ "github.com/cosmos/cosmos-sdk/x/distribution" // import for side-effects
_ "github.com/cosmos/cosmos-sdk/x/genutil" // import for side-effects
_ "github.com/cosmos/cosmos-sdk/x/mint" // import for side-effects
_ "github.com/cosmos/cosmos-sdk/x/staking" // import for side-effects
)
const Name = "halo"
// App extends an ABCI application, but with most of its parameters exported.
// They are exported for convenience in creating helper functions, as object
// capabilities aren't needed for testing.
type App struct {
*runtime.App
appCodec codec.Codec
txConfig client.TxConfig
interfaceRegistry codectypes.InterfaceRegistry
// keepers
AccountKeeper authkeeper.AccountKeeper
BankKeeper bankkeeper.Keeper
StakingKeeper *stakingkeeper.Keeper
DistrKeeper distrkeeper.Keeper
ConsensusParamsKeeper consensuskeeper.Keeper
EVMEngKeeper *evmengkeeper.Keeper
AttestKeeper *attestkeeper.Keeper
ValSyncKeeper valsynckeeper.Keeper
}
// newApp returns a reference to an initialized App.
func newApp(
logger log.Logger,
db dbm.DB,
engineCl ethclient.EngineClient,
namer atypes.ChainNameFunc,
baseAppOpts ...func(*baseapp.BaseApp),
) (*App, error) {
depCfg := depinject.Configs(
DepConfig(),
depinject.Supply(
logger, engineCl, namer,
),
)
var (
app = new(App)
appBuilder = new(runtime.AppBuilder)
)
if err := depinject.Inject(depCfg,
&appBuilder,
&app.appCodec,
&app.txConfig,
&app.interfaceRegistry,
&app.AccountKeeper,
&app.BankKeeper,
&app.StakingKeeper,
&app.DistrKeeper,
&app.ConsensusParamsKeeper,
&app.EVMEngKeeper,
&app.AttestKeeper,
&app.ValSyncKeeper,
); err != nil {
return nil, errors.Wrap(err, "dep inject")
}
// TODO(corver): Refactor this to use depinject
evmStaking, err := evmstaking.New(engineCl, app.StakingKeeper, app.BankKeeper, app.AccountKeeper)
if err != nil {
return nil, errors.Wrap(err, "create evm staking")
}
// Set evmengine vote and evm msg providers.
app.EVMEngKeeper.SetVoteProvider(app.AttestKeeper)
app.EVMEngKeeper.AddEventProcessor(evmStaking)
app.AttestKeeper.SetValidatorProvider(app.ValSyncKeeper)
baseAppOpts = append(baseAppOpts, func(bapp *baseapp.BaseApp) {
// Use evm engine to create block proposals.
// Note that we do not check MaxTxBytes since all EngineEVM transaction MUST be included since we cannot
// postpone them to the next block. Nit: we could drop some vote extensions though...?
bapp.SetPrepareProposal(app.EVMEngKeeper.PrepareProposal)
// Route proposed messaged to keepers for verification and external state updates.
bapp.SetProcessProposal(makeProcessProposalHandler(app))
// Use attest keeper to extend votes.
bapp.SetExtendVoteHandler(app.AttestKeeper.ExtendVote)
bapp.SetVerifyVoteExtensionHandler(app.AttestKeeper.VerifyVoteExtension)
})
app.App = appBuilder.Build(db, nil, baseAppOpts...)
// Workaround for official endblockers since valsync replaces staking endblocker, but cosmos panics if it's not there.
{
app.ModuleManager.OrderEndBlockers = endBlockers
app.SetEndBlocker(app.EndBlocker)
}
if err := app.Load(true); err != nil {
return nil, errors.Wrap(err, "load app")
}
return app, nil
}
func (App) LegacyAmino() *codec.LegacyAmino {
return nil
}
func (App) ExportAppStateAndValidators(_ bool, _, _ []string) (servertypes.ExportedApp, error) {
return servertypes.ExportedApp{}, errors.New("not implemented")
}
// SimulationManager implements the SimulationApp interface.
func (App) SimulationManager() *module.SimulationManager {
return nil
}
// SetCometAPI sets the comet API client.
// TODO(corver): Figure out how to use depinject to set this.
func (a App) SetCometAPI(api comet.API) {
a.EVMEngKeeper.SetCometAPI(api)
}
// SetVoter sets the voter.
// TODO(corver): Figure out how to use depinject to set this.
func (a App) SetVoter(voter atypes.Voter) {
a.AttestKeeper.SetVoter(voter)
a.EVMEngKeeper.SetAddressProvider(voter)
}
var (
_ runtime.AppI = (*App)(nil)
_ servertypes.Application = (*App)(nil)
)