Skip to content

Commit

Permalink
Test progress...
Browse files Browse the repository at this point in the history
  • Loading branch information
@boojamya
boojamya committed May 6, 2024
1 parent 931c9ee commit 906a75f
Showing 1 changed file with 185 additions and 16 deletions.
201 changes: 185 additions & 16 deletions interchaintest/fiat_tf_test.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -9,12 +9,13 @@ import (
sdktypes "github.com/cosmos/cosmos-sdk/types"
"github.com/strangelove-ventures/interchaintest/v4"
"github.com/strangelove-ventures/interchaintest/v4/chain/cosmos"
"github.com/strangelove-ventures/interchaintest/v4/ibc"
"github.com/strangelove-ventures/interchaintest/v4/testreporter"
"github.com/stretchr/testify/require"
"go.uber.org/zap/zaptest"
)

func TestFiatTFOwner(t *testing.T) {
func TestFiatTFUpdateOwner(t *testing.T) {
if testing.Short() {
t.Skip()
}
Expand All @@ -26,43 +27,211 @@ func TestFiatTFOwner(t *testing.T) {
noble := gw.chain
val := noble.Validators[0]

// -- Update Owner --
// Note: because there is no way to query for a 'pending owner', the only way
// to ensure the 'update-owner' message succeeded is to query for the tx hash
// and ensure a 0 response code.

// Update owner while paused
pauseFiatTF(t, ctx, val, gw.fiatTfRoles.Pauser.KeyName())
// - Update owner while paused -
pauseFiatTF(t, ctx, val, gw.fiatTfRoles.Pauser)

w := interchaintest.GetAndFundTestUsers(t, ctx, "new-owner-1", 1, noble)
newOwner1 := w[0]

_, err := val.ExecTx(ctx, gw.fiatTfRoles.Owner.KeyName(), "fiat-tokenfactory", "update-owner", string(newOwner1.FormattedAddress()))
hash, err := val.ExecTx(ctx, gw.fiatTfRoles.Owner.KeyName(), "fiat-tokenfactory", "update-owner", string(newOwner1.FormattedAddress()))
require.NoError(t, err, "error broadcasting update owner message")

unpauseFiatTF(t, ctx, val, gw.fiatTfRoles.Pauser.KeyName())
// TODO: after updating to latest interchaintest, replaces all these tx hash queries with: noble.GetTransaction(hash)
res, _, err := val.ExecQuery(ctx, "tx", hash)
require.NoError(t, err, "error querying for tx hash")

var txResponse sdktypes.TxResponse
_ = json.Unmarshal(res, &txResponse)
// ignore the error since some types do not unmarshal (ex: height of int64 vs string)

require.Equal(t, uint32(0), txResponse.Code, "update owner failed")

// Update owner from unprivileged account
unpauseFiatTF(t, ctx, val, gw.fiatTfRoles.Pauser)

// - Update owner from unprivileged account -
w = interchaintest.GetAndFundTestUsers(t, ctx, "new-owner-2", 1, noble)
newOwner2 := w[0]

hash, err := val.ExecTx(ctx, gw.extraWallets.Alice.KeyName(), "fiat-tokenfactory", "update-owner", string(newOwner2.FormattedAddress()))
hash, err = val.ExecTx(ctx, gw.extraWallets.Alice.KeyName(), "fiat-tokenfactory", "update-owner", string(newOwner2.FormattedAddress()))
require.NoError(t, err, "error broadcasting update owner message")

res, _, err = val.ExecQuery(ctx, "tx", hash)
require.NoError(t, err, "error querying for tx hash")

_ = json.Unmarshal(res, &txResponse)
// ignore the error since some types do not unmarshal (ex: height of int64 vs string)

require.Contains(t, txResponse.RawLog, "you are not the owner: unauthorized")
require.Greater(t, txResponse.Code, uint32(0), "got 'successful' code response")

// - Update Owner from blacklisted owner account -
blacklistAccount(t, ctx, val, gw.fiatTfRoles.Blacklister, gw.fiatTfRoles.Owner)

w = interchaintest.GetAndFundTestUsers(t, ctx, "new-owner-3", 1, noble)
newOwner3 := w[0]

hash, err = val.ExecTx(ctx, gw.fiatTfRoles.Owner.KeyName(), "fiat-tokenfactory", "update-owner", string(newOwner3.FormattedAddress()))
require.NoError(t, err, "error broadcasting update owner message")

res, _, err = val.ExecQuery(ctx, "tx", hash)
require.NoError(t, err, "error querying for tx hash")

_ = json.Unmarshal(res, &txResponse)
// ignore the error since some types do not unmarshal (ex: height of int64 vs string)

require.Equal(t, uint32(0), txResponse.Code, "update owner failed")

// - Update Owner to a blacklisted account -
w = interchaintest.GetAndFundTestUsers(t, ctx, "new-owner-4", 1, noble)
newOwner4 := w[0]

blacklistAccount(t, ctx, val, gw.fiatTfRoles.Blacklister, newOwner4)

hash, err = val.ExecTx(ctx, gw.fiatTfRoles.Owner.KeyName(), "fiat-tokenfactory", "update-owner", string(newOwner4.FormattedAddress()))
require.NoError(t, err, "error broadcasting update owner message")

res, _, err = val.ExecQuery(ctx, "tx", hash)
require.NoError(t, err, "error querying for tx hash")

_ = json.Unmarshal(res, &txResponse)
// ignore the error since some types do not unmarshal (ex: height of int64 vs string)

require.Equal(t, uint32(0), txResponse.Code, "update owner failed")
}

func TestFiatTFAcceptOwner(t *testing.T) {
if testing.Short() {
t.Skip()
}
t.Parallel()

ctx := context.Background()

gw := nobleSpinUp(ctx, t)
noble := gw.chain
val := noble.Validators[0]

// - Accpet owner while TF is paused -

w := interchaintest.GetAndFundTestUsers(t, ctx, "new-owner-1", 1, noble)
newOwner1 := w[0]

hash, err := val.ExecTx(ctx, gw.fiatTfRoles.Owner.KeyName(), "fiat-tokenfactory", "update-owner", newOwner1.FormattedAddress())
require.NoError(t, err, "error broadcasting update owner message")

res, _, err := val.ExecQuery(ctx, "tx", hash)
require.NoError(t, err, "error querying for tx hash")

// TODO: after updating to latest interchaintest, use noble.GetTransaction(hash)
var txResponse sdktypes.TxResponse
_ = json.Unmarshal(res, &txResponse)
// ignore the error since some types do not unmarshal (ex: height of int64 vs string)

require.Contains(t, txResponse.RawLog, "you are not the owner: unauthorized")
require.Greater(t, txResponse.Code, uint32(1))
require.Equal(t, uint32(0), txResponse.Code, "update owner failed")

pauseFiatTF(t, ctx, val, gw.fiatTfRoles.Pauser)

_, err = val.ExecTx(ctx, newOwner1.KeyName(), "fiat-tokenfactory", "accept-owner")
require.NoError(t, err, "failed to accept owner")

res, _, err = val.ExecQuery(ctx, "fiat-tokenfactory", "show-owner")
require.NoError(t, err, "failed to query show-owner")

var showOwnerResponse fiattokenfactorytypes.QueryGetOwnerResponse
err = json.Unmarshal(res, &showOwnerResponse)
require.NoError(t, err, "failed to unmarshall show-owner response")

expectedOwnerResponse := fiattokenfactorytypes.QueryGetOwnerResponse{
Owner: fiattokenfactorytypes.Owner{
Address: string(newOwner1.FormattedAddress()),
},
}

require.Equal(t, expectedOwnerResponse.Owner, showOwnerResponse.Owner)

unpauseFiatTF(t, ctx, val, gw.fiatTfRoles.Pauser)

// - Accept owner from non pending owner -
// Status:
// Owner: newOwner1

w = interchaintest.GetAndFundTestUsers(t, ctx, "new-owner-2", 1, noble)
newOwner2 := w[0]

hash, err = val.ExecTx(ctx, newOwner1.KeyName(), "fiat-tokenfactory", "update-owner", newOwner2.FormattedAddress())
require.NoError(t, err, "error broadcasting update owner message")

res, _, err = val.ExecQuery(ctx, "tx", hash)
require.NoError(t, err, "error querying for tx hash")

_ = json.Unmarshal(res, &txResponse)
// ignore the error since some types do not unmarshal (ex: height of int64 vs string)

// Update Owner from blacklisted account
require.Equal(t, uint32(0), txResponse.Code, "update owner failed")

hash, err = val.ExecTx(ctx, gw.extraWallets.Alice.KeyName(), "fiat-tokenfactory", "accept-owner")
require.NoError(t, err, "failed to accept owner")

res, _, err = val.ExecQuery(ctx, "tx", hash)
require.NoError(t, err, "error querying for tx hash")

_ = json.Unmarshal(res, &txResponse)
// ignore the error since some types do not unmarshal (ex: height of int64 vs string)

require.Contains(t, txResponse.RawLog, "you are not the pending owner: unauthorized")
require.Greater(t, txResponse.Code, uint32(0), "got 'successful' code response")

// - Accpet owner from blacklisted pending owner -
// Status:
// Owner: newOwner1
// Pending: newOwner2

blacklistAccount(t, ctx, val, gw.fiatTfRoles.Blacklister, newOwner2)

_, err = val.ExecTx(ctx, newOwner2.KeyName(), "fiat-tokenfactory", "accept-owner")
require.NoError(t, err, "failed to accept owner")

res, _, err = val.ExecQuery(ctx, "fiat-tokenfactory", "show-owner")
require.NoError(t, err, "failed to query show-owner")

err = json.Unmarshal(res, &showOwnerResponse)
require.NoError(t, err, "failed to unmarshall show-owner response")

expectedOwnerResponse = fiattokenfactorytypes.QueryGetOwnerResponse{
Owner: fiattokenfactorytypes.Owner{
Address: string(newOwner2.FormattedAddress()),
},
}

require.Equal(t, expectedOwnerResponse.Owner, showOwnerResponse.Owner)

}

func blacklistAccount(t *testing.T, ctx context.Context, val *cosmos.ChainNode, blacklister ibc.Wallet, toBlacklist ibc.Wallet) {
_, err := val.ExecTx(ctx, blacklister.KeyName(), "fiat-tokenfactory", "blacklist", toBlacklist.FormattedAddress())
require.NoError(t, err, "failed to broadcast blacklist message")

res, _, err := val.ExecQuery(ctx, "fiat-tokenfactory", "show-blacklisted", toBlacklist.FormattedAddress())
require.NoError(t, err, "failed to query show-blacklisted")

var showBlacklistedResponse fiattokenfactorytypes.QueryGetBlacklistedResponse
err = json.Unmarshal(res, &showBlacklistedResponse)
require.NoError(t, err, "failed to unmarshall show-blacklisted response")

expectedBlacklistResponse := fiattokenfactorytypes.QueryGetBlacklistedResponse{
Blacklisted: fiattokenfactorytypes.Blacklisted{
AddressBz: toBlacklist.Address(),
},
}

require.Equal(t, expectedBlacklistResponse.Blacklisted, showBlacklistedResponse.Blacklisted)
}

func pauseFiatTF(t *testing.T, ctx context.Context, val *cosmos.ChainNode, pauser string) {
_, err := val.ExecTx(ctx, pauser, "fiat-tokenfactory", "pause")
func pauseFiatTF(t *testing.T, ctx context.Context, val *cosmos.ChainNode, pauser ibc.Wallet) {
_, err := val.ExecTx(ctx, pauser.KeyName(), "fiat-tokenfactory", "pause")
require.NoError(t, err, "error pausing fiat-tokenfactory")

res, _, err := val.ExecQuery(ctx, "fiat-tokenfactory", "show-paused")
Expand All @@ -80,8 +249,8 @@ func pauseFiatTF(t *testing.T, ctx context.Context, val *cosmos.ChainNode, pause
require.Equal(t, expectedPaused, showPausedResponse)
}

func unpauseFiatTF(t *testing.T, ctx context.Context, val *cosmos.ChainNode, pauser string) {
_, err := val.ExecTx(ctx, pauser, "fiat-tokenfactory", "unpause")
func unpauseFiatTF(t *testing.T, ctx context.Context, val *cosmos.ChainNode, pauser ibc.Wallet) {
_, err := val.ExecTx(ctx, pauser.KeyName(), "fiat-tokenfactory", "unpause")
require.NoError(t, err, "error pausing fiat-tokenfactory")

res, _, err := val.ExecQuery(ctx, "fiat-tokenfactory", "show-paused")
Expand Down

0 comments on commit 906a75f

Please sign in to comment.