Skip to content

Commit

Permalink
fix: init tmclient (#176)
Browse files Browse the repository at this point in the history
  • Loading branch information
alexgao001 authored and randyahx committed Apr 20, 2023
1 parent 10ce00c commit 70a2a89
Show file tree
Hide file tree
Showing 2 changed files with 8 additions and 7 deletions.
14 changes: 7 additions & 7 deletions e2e/tests/storage_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -567,7 +567,7 @@ func (s *StorageTestSuite) TestPayment_Smoke() {
emptyChecksum := sdk.Keccak256(emptyBuffer.Bytes())
emptyExpectChecksum := [][]byte{emptyChecksum, emptyChecksum, emptyChecksum, emptyChecksum, emptyChecksum, emptyChecksum, emptyChecksum}
msgCreateEmptyObject := storagetypes.NewMsgCreateObject(user.GetAddr(), bucketName, emptyObjectName, uint64(emptyPayloadSize), storagetypes.VISIBILITY_TYPE_PRIVATE, emptyExpectChecksum, contextType, storagetypes.REDUNDANCY_EC_TYPE, math.MaxUint, nil, nil)
msgCreateEmptyObject.PrimarySpApproval.Sig, err = sp.ApprovalKey.GetPrivKey().Sign(msgCreateEmptyObject.GetApprovalBytes())
msgCreateEmptyObject.PrimarySpApproval.Sig, err = sp.ApprovalKey.Sign(msgCreateEmptyObject.GetApprovalBytes())
s.Require().NoError(err)
s.SendTxBlock(msgCreateEmptyObject, user)

Expand Down Expand Up @@ -1169,7 +1169,7 @@ func (s *StorageTestSuite) createObject() (core.SPKeyManagers, keys.KeyManager,
msgCreateBucket := storagetypes.NewMsgCreateBucket(
user.GetAddr(), bucketName, storagetypes.VISIBILITY_TYPE_PRIVATE, sp.OperatorKey.GetAddr(),
nil, math.MaxUint, nil, 0)
msgCreateBucket.PrimarySpApproval.Sig, err = sp.ApprovalKey.GetPrivKey().Sign(msgCreateBucket.GetApprovalBytes())
msgCreateBucket.PrimarySpApproval.Sig, err = sp.ApprovalKey.Sign(msgCreateBucket.GetApprovalBytes())
s.Require().NoError(err)
s.SendTxBlock(msgCreateBucket, user)

Expand Down Expand Up @@ -1210,7 +1210,7 @@ func (s *StorageTestSuite) createObject() (core.SPKeyManagers, keys.KeyManager,
expectChecksum := [][]byte{checksum, checksum, checksum, checksum, checksum, checksum, checksum}
contextType := "text/event-stream"
msgCreateObject := storagetypes.NewMsgCreateObject(user.GetAddr(), bucketName, objectName, uint64(payloadSize), storagetypes.VISIBILITY_TYPE_PRIVATE, expectChecksum, contextType, storagetypes.REDUNDANCY_EC_TYPE, math.MaxUint, nil, nil)
msgCreateObject.PrimarySpApproval.Sig, err = sp.ApprovalKey.GetPrivKey().Sign(msgCreateObject.GetApprovalBytes())
msgCreateObject.PrimarySpApproval.Sig, err = sp.ApprovalKey.Sign(msgCreateObject.GetApprovalBytes())
s.Require().NoError(err)
s.SendTxBlock(msgCreateObject, user)

Expand Down Expand Up @@ -1240,7 +1240,7 @@ func (s *StorageTestSuite) createObject() (core.SPKeyManagers, keys.KeyManager,
}
msgSealObject := storagetypes.NewMsgSealObject(sp.SealKey.GetAddr(), bucketName, objectName, secondarySPs, nil)
sr := storagetypes.NewSecondarySpSignDoc(sp.OperatorKey.GetAddr(), queryHeadObjectResponse.ObjectInfo.Id, checksum)
secondarySig, err := sp.ApprovalKey.GetPrivKey().Sign(sr.GetSignBytes())
secondarySig, err := sp.ApprovalKey.Sign(sr.GetSignBytes())
s.Require().NoError(err)
err = storagetypes.VerifySignature(s.StorageProviders[0].ApprovalKey.GetAddr(), sdk.Keccak256(sr.GetSignBytes()),
secondarySig)
Expand Down Expand Up @@ -1457,7 +1457,7 @@ func (s *StorageTestSuite) TestCreateObjectWithCommonPrefix() {
msgCreateBucket := storagetypes.NewMsgCreateBucket(
user.GetAddr(), bucketName, storagetypes.VISIBILITY_TYPE_PRIVATE, sp.OperatorKey.GetAddr(),
nil, math.MaxUint, nil, 0)
msgCreateBucket.PrimarySpApproval.Sig, err = sp.ApprovalKey.GetPrivKey().Sign(msgCreateBucket.GetApprovalBytes())
msgCreateBucket.PrimarySpApproval.Sig, err = sp.ApprovalKey.Sign(msgCreateBucket.GetApprovalBytes())
s.Require().NoError(err)
s.SendTxBlock(msgCreateBucket, user)

Expand Down Expand Up @@ -1485,7 +1485,7 @@ func (s *StorageTestSuite) TestCreateObjectWithCommonPrefix() {
expectChecksum := [][]byte{checksum, checksum, checksum, checksum, checksum, checksum, checksum}
contextType := "text/event-stream"
msgCreateObject := storagetypes.NewMsgCreateObject(user.GetAddr(), bucketName, objectName, uint64(payloadSize), storagetypes.VISIBILITY_TYPE_PRIVATE, expectChecksum, contextType, storagetypes.REDUNDANCY_EC_TYPE, math.MaxUint, nil, nil)
msgCreateObject.PrimarySpApproval.Sig, err = sp.ApprovalKey.GetPrivKey().Sign(msgCreateObject.GetApprovalBytes())
msgCreateObject.PrimarySpApproval.Sig, err = sp.ApprovalKey.Sign(msgCreateObject.GetApprovalBytes())
s.Require().NoError(err)
s.SendTxBlock(msgCreateObject, user)

Expand All @@ -1512,7 +1512,7 @@ func (s *StorageTestSuite) TestCreateObjectWithCommonPrefix() {
dstBucketName := bucketName
dstObjectName := "new_directory/"
msgCopyObject := storagetypes.NewMsgCopyObject(user.GetAddr(), bucketName, dstBucketName, objectName, dstObjectName, math.MaxUint, nil)
msgCopyObject.DstPrimarySpApproval.Sig, err = sp.ApprovalKey.GetPrivKey().Sign(msgCopyObject.GetApprovalBytes())
msgCopyObject.DstPrimarySpApproval.Sig, err = sp.ApprovalKey.Sign(msgCopyObject.GetApprovalBytes())
s.Require().NoError(err)
s.SendTxBlock(msgCopyObject, user)

Expand Down
1 change: 1 addition & 0 deletions sdk/client/gnfd_client.go
Original file line number Diff line number Diff line change
Expand Up @@ -202,6 +202,7 @@ func setClientsConn(c *GreenfieldClient, conn grpc1.ClientConn) {
c.SlashingQueryClient = slashingtypes.NewQueryClient(conn)
c.StakingQueryClient = stakingtypes.NewQueryClient(conn)
c.UpgradeQueryClient = upgradetypes.NewQueryClient(conn)
c.TmClient = tmservice.NewServiceClient(conn)
c.TxClient = tx.NewServiceClient(conn)
}

Expand Down

0 comments on commit 70a2a89

Please sign in to comment.