Skip to content

Commit

Permalink
bump the go version to v1.20 and some libs to newer version (#1)
Browse files Browse the repository at this point in the history
1. go 1.20
2. cosmos-sdk v0.45.1 to v0.46.8
3. go-libp2p v0.24.1 to v0.27.3
4. go-libp2p-kad-dht v0.19.0 to v0.23.0
5. protobuf v1.28.1 to v1.30.0
6. tss-lib v0.1.2 to v0.1.4
  • Loading branch information
miraclesu authored May 30, 2023
1 parent 9e8084d commit 0089d07
Show file tree
Hide file tree
Showing 15 changed files with 473 additions and 674 deletions.
2 changes: 1 addition & 1 deletion .gitlab-ci.yml
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
image: golang:1.15
image: golang:1.20

cache:
paths:
Expand Down
2 changes: 1 addition & 1 deletion Dockerfile
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
FROM golang:1.15.6-alpine AS builder
FROM golang:1.20-alpine AS builder

RUN apk update && apk add --no-cache git
WORKDIR /go/src/app
Expand Down
5 changes: 2 additions & 3 deletions cmd/tss/main.go
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,6 @@ import (
"encoding/json"
"flag"
"fmt"
"github.com/tendermint/tendermint/crypto/ed25519"
"log"
"os"
"os/signal"
Expand All @@ -14,7 +13,7 @@ import (
"time"

golog "github.com/ipfs/go-log"
"github.com/libp2p/go-libp2p-peerstore/addr"
"github.com/tendermint/tendermint/crypto/ed25519"
"gitlab.com/thorchain/binance-sdk/common/types"

"github.com/joltify-finance/tss/common"
Expand Down Expand Up @@ -86,7 +85,7 @@ func main() {

// init tss module
tss, err := tss.NewTss(
addr.AddrList(p2pConf.BootstrapPeers),
p2pConf.BootstrapPeers,
p2pConf.Port,
privKey,
p2pConf.RendezvousString,
Expand Down
218 changes: 113 additions & 105 deletions go.mod

Large diffs are not rendered by default.

839 changes: 321 additions & 518 deletions go.sum

Large diffs are not rendered by default.

14 changes: 7 additions & 7 deletions keysign/keysign_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,6 @@ import (
"encoding/base64"
"encoding/json"
"fmt"
"github.com/tendermint/tendermint/crypto/ed25519"
"io/ioutil"
"os"
"path"
Expand All @@ -15,16 +14,17 @@ import (
"testing"
"time"

"github.com/tendermint/tendermint/crypto/ed25519"

tsslibcommon "github.com/binance-chain/tss-lib/common"
btss "github.com/binance-chain/tss-lib/tss"
"github.com/ipfs/go-log"
"github.com/libp2p/go-libp2p-peerstore/addr"
zlog "github.com/rs/zerolog/log"

"github.com/joltify-finance/tss/conversion"

"github.com/libp2p/go-libp2p/core/peer"
maddr "github.com/multiformats/go-multiaddr"
ma "github.com/multiformats/go-multiaddr"
tcrypto "github.com/tendermint/tendermint/crypto"
. "gopkg.in/check.v1"

Expand Down Expand Up @@ -86,11 +86,11 @@ func (m *MockLocalStateManager) GetLocalState(pubKey string) (storage.KeygenLoca
return state, nil
}

func (s *MockLocalStateManager) SaveAddressBook(address map[peer.ID]addr.AddrList) error {
func (s *MockLocalStateManager) SaveAddressBook(address map[peer.ID][]ma.Multiaddr) error {
return nil
}

func (s *MockLocalStateManager) RetrieveP2PAddresses() (addr.AddrList, error) {
func (s *MockLocalStateManager) RetrieveP2PAddresses() ([]ma.Multiaddr, error) {
return nil, os.ErrNotExist
}

Expand Down Expand Up @@ -137,7 +137,7 @@ func (s *TssKeysignTestSuite) SetUpTest(c *C) {
s.comms = make([]*p2p.Communication, s.partyNum)
s.stateMgrs = make([]storage.LocalStateManager, s.partyNum)
bootstrapPeer := "/ip4/127.0.0.1/tcp/17666/p2p/12D3KooWJ9ne4fSbjE4bZdsikkmxZYurdDDr74Lx4Ghm73ZqSKwZ"
multiAddr, err := maddr.NewMultiaddr(bootstrapPeer)
multiAddr, err := ma.NewMultiaddr(bootstrapPeer)
c.Assert(err, IsNil)
for i := 0; i < s.partyNum; i++ {
buf, err := base64.StdEncoding.DecodeString(testPriKeyArr[i])
Expand All @@ -149,7 +149,7 @@ func (s *TssKeysignTestSuite) SetUpTest(c *C) {
s.comms[i] = comm
continue
}
comm, err := p2p.NewCommunication("asgard", []maddr.Multiaddr{multiAddr}, ports[i], "")
comm, err := p2p.NewCommunication("asgard", []ma.Multiaddr{multiAddr}, ports[i], "")
c.Assert(err, IsNil)
c.Assert(comm.Start(buf), IsNil)
s.comms[i] = comm
Expand Down
2 changes: 1 addition & 1 deletion keysign/signature_notifier.go
Original file line number Diff line number Diff line change
Expand Up @@ -8,13 +8,13 @@ import (

"github.com/binance-chain/tss-lib/common"
tsslibcommon "github.com/binance-chain/tss-lib/common"
"github.com/golang/protobuf/proto"
"github.com/libp2p/go-libp2p/core/host"
"github.com/libp2p/go-libp2p/core/network"
"github.com/libp2p/go-libp2p/core/peer"
"github.com/libp2p/go-libp2p/core/protocol"
"github.com/rs/zerolog"
"github.com/rs/zerolog/log"
"google.golang.org/protobuf/proto"

"github.com/joltify-finance/tss/messages"
"github.com/joltify-finance/tss/p2p"
Expand Down
5 changes: 3 additions & 2 deletions messages/generate.sh
Original file line number Diff line number Diff line change
@@ -1,2 +1,3 @@

protoc --go_out=. *.proto
protoc --go_out=. --go_opt=paths=source_relative \
--go-grpc_out=. --go-grpc_opt=paths=source_relative \
*.proto
9 changes: 2 additions & 7 deletions messages/join_party.pb.go

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

9 changes: 2 additions & 7 deletions messages/signature_notifier.pb.go

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

6 changes: 3 additions & 3 deletions p2p/peer_address.go
Original file line number Diff line number Diff line change
@@ -1,14 +1,14 @@
package p2p

import (
"github.com/libp2p/go-libp2p-peerstore/addr"
"github.com/libp2p/go-libp2p/core/peer"
ma "github.com/multiformats/go-multiaddr"
)

func (c *Communication) ExportPeerAddress() map[peer.ID]addr.AddrList {
func (c *Communication) ExportPeerAddress() map[peer.ID][]ma.Multiaddr {
peerStore := c.dht.Host().Peerstore()
peers := peerStore.Peers()
addressBook := make(map[peer.ID]addr.AddrList)
addressBook := make(map[peer.ID][]ma.Multiaddr)
for _, el := range peers {
addrs := peerStore.Addrs(el)
addressBook[el] = addrs
Expand Down
9 changes: 4 additions & 5 deletions storage/localstate_mgr.go
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,6 @@ import (
"sync"

"github.com/binance-chain/tss-lib/ecdsa/keygen"
"github.com/libp2p/go-libp2p-peerstore/addr"
"github.com/libp2p/go-libp2p/core/peer"
ma "github.com/multiformats/go-multiaddr"

Expand All @@ -32,8 +31,8 @@ type KeygenLocalState struct {
type LocalStateManager interface {
SaveLocalState(state KeygenLocalState) error
GetLocalState(pubKey string) (KeygenLocalState, error)
SaveAddressBook(addressBook map[peer.ID]addr.AddrList) error
RetrieveP2PAddresses() (addr.AddrList, error)
SaveAddressBook(addressBook map[peer.ID][]ma.Multiaddr) error
RetrieveP2PAddresses() ([]ma.Multiaddr, error)
}

// FileStateMgr save the local state to file
Expand Down Expand Up @@ -111,7 +110,7 @@ func (fsm *FileStateMgr) GetLocalState(pubKey string) (KeygenLocalState, error)
return localState, nil
}

func (fsm *FileStateMgr) SaveAddressBook(address map[peer.ID]addr.AddrList) error {
func (fsm *FileStateMgr) SaveAddressBook(address map[peer.ID][]ma.Multiaddr) error {
if len(fsm.folder) < 1 {
return errors.New("base file path is invalid")
}
Expand All @@ -136,7 +135,7 @@ func (fsm *FileStateMgr) SaveAddressBook(address map[peer.ID]addr.AddrList) erro
return ioutil.WriteFile(filePathName, buf.Bytes(), 0o655)
}

func (fsm *FileStateMgr) RetrieveP2PAddresses() (addr.AddrList, error) {
func (fsm *FileStateMgr) RetrieveP2PAddresses() ([]ma.Multiaddr, error) {
if len(fsm.folder) < 1 {
return nil, errors.New("base file path is invalid")
}
Expand Down
12 changes: 6 additions & 6 deletions storage/localstate_mgr_test.go
Original file line number Diff line number Diff line change
@@ -1,18 +1,18 @@
package storage

import (
"github.com/joltify-finance/tss/conversion"
"os"
"path/filepath"
"reflect"
"testing"

"github.com/binance-chain/tss-lib/ecdsa/keygen"
"github.com/libp2p/go-libp2p-peerstore/addr"
tnet "github.com/libp2p/go-libp2p-testing/net"
"github.com/libp2p/go-libp2p/core/peer"
maddr "github.com/multiformats/go-multiaddr"
ma "github.com/multiformats/go-multiaddr"
. "gopkg.in/check.v1"

"github.com/joltify-finance/tss/conversion"
)

type FileStateMgrTestSuite struct{}
Expand Down Expand Up @@ -74,16 +74,16 @@ func (s *FileStateMgrTestSuite) TestSaveLocalState(c *C) {
}

func (s *FileStateMgrTestSuite) TestSaveAddressBook(c *C) {
testAddresses := make(map[peer.ID]addr.AddrList)
testAddresses := make(map[peer.ID][]ma.Multiaddr)
var t *testing.T
id1 := tnet.RandIdentityOrFatal(t)
id2 := tnet.RandIdentityOrFatal(t)
id3 := tnet.RandIdentityOrFatal(t)
mockAddr, err := maddr.NewMultiaddr("/ip4/192.168.3.5/tcp/6668")
mockAddr, err := ma.NewMultiaddr("/ip4/192.168.3.5/tcp/6668")
c.Assert(err, IsNil)
peers := []peer.ID{id1.ID(), id2.ID(), id3.ID()}
for _, each := range peers {
testAddresses[each] = []maddr.Multiaddr{mockAddr}
testAddresses[each] = []ma.Multiaddr{mockAddr}
}
folder := os.TempDir()
f := filepath.Join(folder, "test")
Expand Down
6 changes: 3 additions & 3 deletions storage/mock_localstatemanager.go
Original file line number Diff line number Diff line change
@@ -1,8 +1,8 @@
package storage

import (
"github.com/libp2p/go-libp2p-peerstore/addr"
"github.com/libp2p/go-libp2p/core/peer"
ma "github.com/multiformats/go-multiaddr"
)

// MockLocalStateManager is a mock use for test purpose
Expand All @@ -17,10 +17,10 @@ func (s *MockLocalStateManager) GetLocalState(pubKey string) (KeygenLocalState,
return KeygenLocalState{}, nil
}

func (s *MockLocalStateManager) SaveAddressBook(address map[peer.ID]addr.AddrList) error {
func (s *MockLocalStateManager) SaveAddressBook(address map[peer.ID][]ma.Multiaddr) error {
return nil
}

func (s *MockLocalStateManager) RetrieveP2PAddresses() (addr.AddrList, error) {
func (s *MockLocalStateManager) RetrieveP2PAddresses() ([]ma.Multiaddr, error) {
return nil, nil
}
9 changes: 4 additions & 5 deletions tss/tss.go
Original file line number Diff line number Diff line change
Expand Up @@ -8,12 +8,11 @@ import (
"strings"
"sync"

"github.com/cosmos/cosmos-sdk/types/bech32/legacybech32"

bkeygen "github.com/binance-chain/tss-lib/ecdsa/keygen"
coskey "github.com/cosmos/cosmos-sdk/crypto/keys/ed25519"
"github.com/libp2p/go-libp2p-peerstore/addr"
"github.com/cosmos/cosmos-sdk/types/bech32/legacybech32"
"github.com/libp2p/go-libp2p/core/peer"
ma "github.com/multiformats/go-multiaddr"
"github.com/rs/zerolog"
"github.com/rs/zerolog/log"
tcrypto "github.com/tendermint/tendermint/crypto"
Expand Down Expand Up @@ -46,7 +45,7 @@ type TssServer struct {

// NewTss create a new instance of Tss
func NewTss(
cmdBootstrapPeers addr.AddrList,
cmdBootstrapPeers []ma.Multiaddr,
p2pPort int,
priKey tcrypto.PrivKey,
rendezvous,
Expand All @@ -69,7 +68,7 @@ func NewTss(
return nil, fmt.Errorf("fail to create file state manager")
}

var bootstrapPeers addr.AddrList
var bootstrapPeers []ma.Multiaddr
savedPeers, err := stateManager.RetrieveP2PAddresses()
if err != nil {
bootstrapPeers = cmdBootstrapPeers
Expand Down

0 comments on commit 0089d07

Please sign in to comment.