-
Notifications
You must be signed in to change notification settings - Fork 176
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #6278 from onflow/bastian/fungible-token-program-r…
…ecovery [FVM] Implement program recovery for fungible tokens
- Loading branch information
Showing
6 changed files
with
458 additions
and
10 deletions.
There are no files selected for viewing
203 changes: 203 additions & 0 deletions
203
cmd/util/ledger/migrations/contract_checking_migration_test.go
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,203 @@ | ||
| package migrations | ||
|
|
||
| import ( | ||
| "fmt" | ||
| "sort" | ||
| "testing" | ||
|
|
||
| "github.com/onflow/cadence/runtime/common" | ||
| "github.com/onflow/cadence/runtime/interpreter" | ||
| coreContracts "github.com/onflow/flow-core-contracts/lib/go/contracts" | ||
| "github.com/onflow/flow-core-contracts/lib/go/templates" | ||
| "github.com/rs/zerolog" | ||
| "github.com/stretchr/testify/assert" | ||
| "github.com/stretchr/testify/require" | ||
|
|
||
| "github.com/onflow/flow-go/cmd/util/ledger/util/registers" | ||
| "github.com/onflow/flow-go/fvm/environment" | ||
| "github.com/onflow/flow-go/fvm/systemcontracts" | ||
| "github.com/onflow/flow-go/model/flow" | ||
| ) | ||
|
|
||
| func oldExampleTokenCode(fungibleTokenAddress flow.Address) string { | ||
| return fmt.Sprintf( | ||
| ` | ||
| import FungibleToken from 0x%s | ||
| pub contract ExampleToken: FungibleToken { | ||
| pub var totalSupply: UFix64 | ||
| pub resource Vault: FungibleToken.Provider, FungibleToken.Receiver, FungibleToken.Balance { | ||
| pub var balance: UFix64 | ||
| init(balance: UFix64) { | ||
| self.balance = balance | ||
| } | ||
| pub fun withdraw(amount: UFix64): @FungibleToken.Vault { | ||
| self.balance = self.balance - amount | ||
| emit TokensWithdrawn(amount: amount, from: self.owner?.address) | ||
| return <-create Vault(balance: amount) | ||
| } | ||
| pub fun deposit(from: @FungibleToken.Vault) { | ||
| let vault <- from as! @ExampleToken.Vault | ||
| self.balance = self.balance + vault.balance | ||
| emit TokensDeposited(amount: vault.balance, to: self.owner?.address) | ||
| vault.balance = 0.0 | ||
| destroy vault | ||
| } | ||
| destroy() { | ||
| if self.balance > 0.0 { | ||
| ExampleToken.totalSupply = ExampleToken.totalSupply - self.balance | ||
| } | ||
| } | ||
| } | ||
| pub fun createEmptyVault(): @Vault { | ||
| return <-create Vault(balance: 0.0) | ||
| } | ||
| init() { | ||
| self.totalSupply = 0.0 | ||
| } | ||
| } | ||
| `, | ||
| fungibleTokenAddress.Hex(), | ||
| ) | ||
| } | ||
|
|
||
| func TestContractCheckingMigrationProgramRecovery(t *testing.T) { | ||
|
|
||
| t.Parallel() | ||
|
|
||
| registersByAccount := registers.NewByAccount() | ||
|
|
||
| // Set up contracts | ||
|
|
||
| const chainID = flow.Testnet | ||
|
|
||
| systemContracts := systemcontracts.SystemContractsForChain(chainID) | ||
|
|
||
| contracts := map[flow.Address]map[string][]byte{} | ||
|
|
||
| addContract := func(address flow.Address, name string, code []byte) { | ||
| addressContracts, ok := contracts[address] | ||
| if !ok { | ||
| addressContracts = map[string][]byte{} | ||
| contracts[address] = addressContracts | ||
| } | ||
| require.Empty(t, addressContracts[name]) | ||
| addressContracts[name] = code | ||
| } | ||
|
|
||
| addSystemContract := func(systemContract systemcontracts.SystemContract, code []byte) { | ||
| addContract(systemContract.Address, systemContract.Name, code) | ||
| } | ||
|
|
||
| env := templates.Environment{} | ||
|
|
||
| addSystemContract( | ||
| systemContracts.ViewResolver, | ||
| coreContracts.ViewResolver(), | ||
| ) | ||
| env.ViewResolverAddress = systemContracts.ViewResolver.Address.Hex() | ||
|
|
||
| addSystemContract( | ||
| systemContracts.Burner, | ||
| coreContracts.Burner(), | ||
| ) | ||
| env.BurnerAddress = systemContracts.Burner.Address.Hex() | ||
|
|
||
| addSystemContract( | ||
| systemContracts.FungibleToken, | ||
| coreContracts.FungibleToken(env), | ||
| ) | ||
|
|
||
| // Use an old version of the ExampleToken contract, | ||
| // and "deploy" it at some arbitrary, high (i.e. non-system) address | ||
| exampleTokenAddress, err := chainID.Chain().AddressAtIndex(1000) | ||
| require.NoError(t, err) | ||
| addContract( | ||
| exampleTokenAddress, | ||
| "ExampleToken", | ||
| []byte(oldExampleTokenCode(systemContracts.FungibleToken.Address)), | ||
| ) | ||
|
|
||
| for address, addressContracts := range contracts { | ||
|
|
||
| for contractName, code := range addressContracts { | ||
|
|
||
| err := registersByAccount.Set( | ||
| string(address[:]), | ||
| flow.ContractKey(contractName), | ||
| code, | ||
| ) | ||
| require.NoError(t, err) | ||
| } | ||
|
|
||
| contractNames := make([]string, 0, len(addressContracts)) | ||
| for contractName := range addressContracts { | ||
| contractNames = append(contractNames, contractName) | ||
| } | ||
| sort.Strings(contractNames) | ||
|
|
||
| encodedContractNames, err := environment.EncodeContractNames(contractNames) | ||
| require.NoError(t, err) | ||
|
|
||
| err = registersByAccount.Set( | ||
| string(address[:]), | ||
| flow.ContractNamesKey, | ||
| encodedContractNames, | ||
| ) | ||
| require.NoError(t, err) | ||
| } | ||
|
|
||
| programs := map[common.Location]*interpreter.Program{} | ||
|
|
||
| rwf := &testReportWriterFactory{} | ||
|
|
||
| // Run contract checking migration | ||
|
|
||
| log := zerolog.Nop() | ||
| checkingMigration := NewContractCheckingMigration( | ||
| log, | ||
| rwf, | ||
| chainID, | ||
| false, | ||
| nil, | ||
| programs, | ||
| ) | ||
|
|
||
| err = checkingMigration(registersByAccount) | ||
| require.NoError(t, err) | ||
|
|
||
| reporter := rwf.reportWriters[contractCheckingReporterName] | ||
|
|
||
| assert.Equal(t, | ||
| []any{ | ||
| contractCheckingSuccess{ | ||
| AccountAddress: common.Address(systemContracts.ViewResolver.Address), | ||
| ContractName: systemcontracts.ContractNameViewResolver, | ||
| Code: string(coreContracts.ViewResolver()), | ||
| }, | ||
| contractCheckingSuccess{ | ||
| AccountAddress: common.Address(systemContracts.Burner.Address), | ||
| ContractName: systemcontracts.ContractNameBurner, | ||
| Code: string(coreContracts.Burner()), | ||
| }, | ||
| contractCheckingSuccess{ | ||
| AccountAddress: common.Address(systemContracts.FungibleToken.Address), | ||
| ContractName: systemcontracts.ContractNameFungibleToken, | ||
| Code: string(coreContracts.FungibleToken(env)), | ||
| }, | ||
| contractCheckingSuccess{ | ||
| AccountAddress: common.Address(exampleTokenAddress), | ||
| ContractName: "ExampleToken", | ||
| Code: oldExampleTokenCode(systemContracts.FungibleToken.Address), | ||
| }, | ||
| }, | ||
| reporter.entries, | ||
| ) | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.