/
upgrades.go
257 lines (225 loc) · 15.5 KB
/
upgrades.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
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
package v16
import (
"fmt"
"time"
sdk "github.com/cosmos/cosmos-sdk/types"
"github.com/cosmos/cosmos-sdk/types/module"
upgradetypes "github.com/cosmos/cosmos-sdk/x/upgrade/types"
"github.com/osmosis-labs/osmosis/osmomath"
"github.com/fury-labs/furya/v20/app/keepers"
"github.com/fury-labs/furya/v20/app/upgrades"
cosmwasmtypes "github.com/CosmWasm/wasmd/x/wasm/types"
distrtypes "github.com/cosmos/cosmos-sdk/x/distribution/types"
cltypes "github.com/fury-labs/furya/v20/x/concentrated-liquidity/types"
cosmwasmpooltypes "github.com/fury-labs/furya/v20/x/cosmwasmpool/types"
superfluidtypes "github.com/fury-labs/furya/v20/x/superfluid/types"
tokenfactorykeeper "github.com/fury-labs/furya/v20/x/tokenfactory/keeper"
tokenfactorytypes "github.com/fury-labs/furya/v20/x/tokenfactory/types"
)
const (
// DAI/FURY pool ID
// https://app.furya.zone/pool/674
// Note, new concentrated liquidity pool
// spread factor is initialized to be the same as the balancers pool spread factor of 0.2%.
DaiFuryPoolId = uint64(674)
// Denom0 translates to a base asset while denom1 to a quote asset
// We want quote asset to be DAI so that when the limit orders on ticks
// are implemented, we have tick spacing in terms of DAI as the quote.
DesiredDenom0 = "ufury"
TickSpacing = 100
// isPermissionlessPoolCreationEnabledCL is a boolean that determines if
// concentrated liquidity pools can be created via message. At launch,
// we consider allowing only governance to create pools, and then later
// allowing permissionless pool creation by switching this flag to true
// with a governance proposal.
IsPermissionlessPoolCreationEnabledCL = false
)
var (
ATOMIBCDenom = "ibc/27394FB092D2ECCD56123C74F36E4C1F926001CEADA9CA97EA622B25F41E5EB2"
DAIIBCDenom = "ibc/0CD3A0285E1341859B5E86B6AB7682F023D03E97607CCC1DC95706411D866DF7"
USDCIBCDenom = "ibc/D189335C6E4A68B513C10AB227BF1C1D38C746766278BA3EEB4FB14124F1D858"
SpreadFactor = osmomath.MustNewDecFromStr("0.002")
// authorized_quote_denoms quote assets that can be used as token1
// when creating a pool. We limit the quote assets to a small set
// for the purposes of having convenient price increments stemming
// from tick to price conversion. These increments are in a human
// understandeable magnitude only for token1 as a quote.
authorizedQuoteDenoms []string = []string{
"ufury",
ATOMIBCDenom,
DAIIBCDenom,
USDCIBCDenom,
}
// authorizedUptimes is the list of uptimes that are allowed to be
// incentivized. It is a subset of SupportedUptimes (which can be
// found under CL types) and is set initially to be 1ns, which is
// equivalent to a 1 block required uptime to qualify for claiming incentives.
authorizedUptimes []time.Duration = []time.Duration{time.Nanosecond}
)
func CreateUpgradeHandler(
mm *module.Manager,
configurator module.Configurator,
bpm upgrades.BaseAppParamManager,
keepers *keepers.AppKeepers,
) upgradetypes.UpgradeHandler {
return func(ctx sdk.Context, plan upgradetypes.Plan, fromVM module.VersionMap) (module.VersionMap, error) {
// Run migrations before applying any other state changes.
// NOTE: DO NOT PUT ANY STATE CHANGES BEFORE RunMigrations().
migrations, err := mm.RunMigrations(ctx, configurator, fromVM)
if err != nil {
return nil, err
}
// Update expedited governance param
// In particular, set expedited quorum to 2/3.
params := keepers.GovKeeper.GetTallyParams(ctx)
params.ExpeditedQuorum = osmomath.NewDec(2).Quo(osmomath.NewDec(3))
keepers.GovKeeper.SetTallyParams(ctx, params)
// Add cosmwasmpool module address to the list of allowed addresses to upload contract code.
cwPoolModuleAddress := keepers.AccountKeeper.GetModuleAddress(cosmwasmpooltypes.ModuleName)
wasmParams := keepers.WasmKeeper.GetParams(ctx)
wasmParams.CodeUploadAccess.Addresses = append(wasmParams.CodeUploadAccess.Addresses, cwPoolModuleAddress.String())
keepers.WasmKeeper.SetParams(ctx, wasmParams)
// Add both MsgExecuteContract and MsgInstantiateContract to the list of allowed messages.
hostParams := keepers.ICAHostKeeper.GetParams(ctx)
msgExecuteContractExists := false
msgInstantiateContractExists := false
for _, msg := range hostParams.AllowMessages {
if msg == sdk.MsgTypeURL(&cosmwasmtypes.MsgExecuteContract{}) {
msgExecuteContractExists = true
}
if msg == sdk.MsgTypeURL(&cosmwasmtypes.MsgInstantiateContract{}) {
msgInstantiateContractExists = true
}
}
if !msgExecuteContractExists {
hostParams.AllowMessages = append(hostParams.AllowMessages, sdk.MsgTypeURL(&cosmwasmtypes.MsgExecuteContract{}))
}
if !msgInstantiateContractExists {
hostParams.AllowMessages = append(hostParams.AllowMessages, sdk.MsgTypeURL(&cosmwasmtypes.MsgInstantiateContract{}))
}
keepers.ICAHostKeeper.SetParams(ctx, hostParams)
// Although parameters are set on InitGenesis() in RunMigrations(), we reset them here
// for visibility of the final configuration.
defaultConcentratedLiquidityParams := keepers.ConcentratedLiquidityKeeper.GetParams(ctx)
defaultConcentratedLiquidityParams.AuthorizedQuoteDenoms = authorizedQuoteDenoms
defaultConcentratedLiquidityParams.AuthorizedQuoteDenoms = authorizedQuoteDenoms
defaultConcentratedLiquidityParams.AuthorizedUptimes = authorizedUptimes
defaultConcentratedLiquidityParams.IsPermissionlessPoolCreationEnabled = IsPermissionlessPoolCreationEnabledCL
keepers.ConcentratedLiquidityKeeper.SetParams(ctx, defaultConcentratedLiquidityParams)
// Create a concentrated liquidity pool for DAI/FURY.
// Link the DAI/FURY balancer pool to the cl pool.
clPool, err := keepers.GAMMKeeper.CreateCanonicalConcentratedLiquidityPoolAndMigrationLink(ctx, DaiFuryPoolId, DesiredDenom0, SpreadFactor, TickSpacing)
if err != nil {
return nil, err
}
clPoolId := clPool.GetId()
clPoolDenom := cltypes.GetConcentratedLockupDenomFromPoolId(clPoolId)
// Create a position to initialize the balancerPool.
// Get community pool and DAI/FURY pool address.
communityPoolAddress := keepers.AccountKeeper.GetModuleAddress(distrtypes.ModuleName)
// Determine the amount of FURY that can be bought with 1 DAI.
oneDai := sdk.NewCoin(DAIIBCDenom, osmomath.NewInt(1000000000000000000))
daiFuryGammPool, err := keepers.PoolManagerKeeper.GetPool(ctx, DaiFuryPoolId)
if err != nil {
return nil, err
}
respectiveFury, err := keepers.GAMMKeeper.CalcOutAmtGivenIn(ctx, daiFuryGammPool, oneDai, DesiredDenom0, osmomath.ZeroDec())
if err != nil {
return nil, err
}
// Create a full range position via the community pool with the funds that were swapped.
fullRangeFuryDaiCoins := sdk.NewCoins(respectiveFury, oneDai)
positionData, err := keepers.ConcentratedLiquidityKeeper.CreateFullRangePosition(ctx, clPoolId, communityPoolAddress, fullRangeFuryDaiCoins)
if err != nil {
return nil, err
}
// Because we are doing a direct send from the community pool, we need to manually change the fee pool to reflect the change.
// Remove coins we used from the community pool to make the CL position
feePool := keepers.DistrKeeper.GetFeePool(ctx)
fulllRangeFuryDaiCoinsUsed := sdk.NewCoins(sdk.NewCoin(DesiredDenom0, positionData.Amount0), sdk.NewCoin(DAIIBCDenom, positionData.Amount1))
newPool, negative := feePool.CommunityPool.SafeSub(sdk.NewDecCoinsFromCoins(fulllRangeFuryDaiCoinsUsed...))
if negative {
return nil, fmt.Errorf("community pool cannot be negative: %s", newPool)
}
// Update and set the new fee pool
feePool.CommunityPool = newPool
keepers.DistrKeeper.SetFeePool(ctx, feePool)
// Add the cl pool's full range denom as an authorized superfluid asset.
superfluidAsset := superfluidtypes.SuperfluidAsset{
Denom: clPoolDenom,
AssetType: superfluidtypes.SuperfluidAssetTypeConcentratedShare,
}
err = keepers.SuperfluidKeeper.AddNewSuperfluidAsset(ctx, superfluidAsset)
if err != nil {
return nil, err
}
clPoolTwapRecords, err := keepers.TwapKeeper.GetAllMostRecentRecordsForPool(ctx, clPoolId)
if err != nil {
return nil, err
}
for _, twapRecord := range clPoolTwapRecords {
twapRecord.LastErrorTime = time.Time{}
keepers.TwapKeeper.StoreNewRecord(ctx, twapRecord)
}
updateTokenFactoryParams(ctx, keepers.TokenFactoryKeeper)
// Transfers out all the dev fees in kvstore to dev account during upgrade
if err := keepers.ProtoRevKeeper.SendDeveloperFeesToDeveloperAccount(ctx); err != nil {
return nil, err
}
ctx.Logger().Info(`
.:^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^:.
.~?5GBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBG5?~.
.7PB#BG5J????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????J5GB#BP7.
^PBBBJ^. .^JBBBP^
:GBBP^ ^PBBG:
JBBB^ .^~~. .~!77!^ ^BBBJ
5BBG. 75YGB: .JJ7!!JG5. .GBB5
5BBG. :. PG: J#7 .GBB5
5BBG. PG: :PG^ .GBB5
5BBG. PG: !G5: .GBB5
5BBG. PG: .!55~ .GBB5
5BBG. PB: :?GG?^^^^^ .GBB5
5BBG. ?J. ~JJ??JJJJ7 .GBB5
5BBG. .GBB5
5BBG. .GBB5
5BBG. .GBB5
5BBG. .GBB5
5BBG. .GBB5
5BBG. .77777~ ^77777^ .GBB5
5BBG. ~#BBBBB~ :P#BBB#? .GBB5
5BBG. 7BBBGBBP. 5BBGBBBY .GBB5
5BBG. JBBB7GBBY ?BBG!GBB5 .GBB5
5BBG. 5BBB:JBBB7 !BBB7:GBBP. .^!7?JJ?!^. :!~!^ .GBB5
5BBG. .PBBG..GBBB~ ^GBB5 .GBBG: ~JPB##BBBBBBGY:7#B#7 .GBB5
5BBG. :GBBP. !BBBP. .PBBG: .GBBB^ ^5BBBGJ!^:::^75BGPBBB! .GBB5
5BBG. ^BBBP JBBBY YBBB! PBBB! ^GBBBJ: ~GBBBB! .GBB5
5BBG. !BBB5 .PBBB7 7BBBJ 5BBB7 .PBBBY ~BBBB! .GBB5
5BBG. 7BBBJ ~BBBB^ ^BBB5 JBBBJ !BBBB^ :GBBB! .GBB5
5BBG. JBBB? ?BBB5. .PBBG: ?BBB5 ?BBBG. :GBBB! .GBB5
5BBG. 5BBB! 5BBB? JBBB~ !BBBP. !BBBB^ :GBBB! .GBB5
5BBG. .PBBB^ :GBBG:^BBB7 ~BBBG. .PBBB5. ?BBBB! .GBB5
5BBG. :GBBG: !BBBY5BBY ^BBBB^ ^PBBBP~ :JBBBBB! .GBB5
5BBG. ^BBBG. JBBBBBP. :GBBB~ :JGBBBPJ7!!7?5BBJGBBB! .GBB5
5BBG. !#B#P .P#BBG^ .PBB#7 :7YPBBBBBBG57:.GBBB~ .GBB5
5BBG. !5Y5? ^JJJ! ?5Y5! .:^^^^:. ^BBBB: .GBB5
5BBG. YBBBY .GBB5
5BBG. .: ^YBBBP: .GBB5
5BBG. .5BPY?7!!!!7JPB#BGJ. .GBB5
5BBG. :J5GBBB#BBBBBGPJ!: .GBB5
5BBG. .GBB5
5BBG. .GBB5
5BBG. .GBB5
5BBG. .GBB5
JBBB^ ^BBBJ
:GBBP^ ^PBBG:
^PBBBJ^. .^JBBBP^
.7PB#BG5J????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????????J5GB#BP7.
.~?5GBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBBG5?~.
.::^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^::.
`)
return migrations, nil
}
}
func updateTokenFactoryParams(ctx sdk.Context, tokenFactoryKeeper *tokenfactorykeeper.Keeper) {
tokenFactoryKeeper.SetParams(ctx, tokenfactorytypes.NewParams(nil, NewDenomCreationGasConsume))
}