diff --git a/go.mod b/go.mod index 9bee496..a96720c 100644 --- a/go.mod +++ b/go.mod @@ -7,7 +7,7 @@ require ( github.com/go-chi/httprate v0.4.0 github.com/go-echarts/go-echarts/v2 v2.2.4 github.com/sirupsen/logrus v1.8.1 - github.com/skycoin/dmsg v1.3.12-0.20231120175607-0b6d5135bbc5 + github.com/skycoin/dmsg v1.3.12-0.20231130180155-65d707cd1b01 github.com/skycoin/skywire-utilities v0.0.0-20231120175000-12be4345eb26 github.com/spf13/cobra v1.4.0 github.com/stretchr/testify v1.8.1 diff --git a/go.sum b/go.sum index 6c7ff4e..cbf0a58 100644 --- a/go.sum +++ b/go.sum @@ -156,6 +156,8 @@ github.com/sirupsen/logrus v1.8.1 h1:dJKuHgqk1NNQlqoA6BTlM1Wf9DOH3NBjQyu0h9+AZZE github.com/sirupsen/logrus v1.8.1/go.mod h1:yWOB1SBYBC5VeMP7gHvWumXLIWorT60ONWic61uBYv0= github.com/skycoin/dmsg v1.3.12-0.20231120175607-0b6d5135bbc5 h1:yGTInFb9SqchM5w0RrFA4vgq9tzhKQStURpetUor+4s= github.com/skycoin/dmsg v1.3.12-0.20231120175607-0b6d5135bbc5/go.mod h1:HPGbmjaaKzGGOL8B0Rksc9+asBEAjnmPkJ2t1Hfl+uI= +github.com/skycoin/dmsg v1.3.12-0.20231130180155-65d707cd1b01 h1:dZD0r4a6pyCpyMYzQxdatmmTScpNj0gYlPQghKfBKes= +github.com/skycoin/dmsg v1.3.12-0.20231130180155-65d707cd1b01/go.mod h1:HPGbmjaaKzGGOL8B0Rksc9+asBEAjnmPkJ2t1Hfl+uI= github.com/skycoin/noise v0.0.0-20180327030543-2492fe189ae6 h1:1Nc5EBY6pjfw1kwW0duwyG+7WliWz5u9kgk1h5MnLuA= github.com/skycoin/noise v0.0.0-20180327030543-2492fe189ae6/go.mod h1:UXghlricA7J3aRD/k7p/zBObQfmBawwCxIVPVjz2Q3o= github.com/skycoin/skycoin v0.27.1 h1:HatxsRwVSPaV4qxH6290xPBmkH/HgiuAoY2qC+e8C9I= diff --git a/vendor/github.com/skycoin/dmsg/pkg/dmsg/client.go b/vendor/github.com/skycoin/dmsg/pkg/dmsg/client.go index e23860f..27e86e1 100644 --- a/vendor/github.com/skycoin/dmsg/pkg/dmsg/client.go +++ b/vendor/github.com/skycoin/dmsg/pkg/dmsg/client.go @@ -472,6 +472,16 @@ func (ce *Client) AllEntries(ctx context.Context) (entries []string, err error) return entries, err } +// ConnectedServersPK return keys of all connected dmsg servers +func (ce *Client) ConnectedServersPK() []string { + sessions := ce.allClientSessions(ce.porter) + addrs := make([]string, len(sessions)) + for i, s := range sessions { + addrs[i] = s.RemotePK().String() + } + return addrs +} + // ConnectionsSummary associates connected clients, and the servers that connect such clients. // Key: Client PK, Value: Slice of Server PKs type ConnectionsSummary map[cipher.PubKey][]cipher.PubKey diff --git a/vendor/modules.txt b/vendor/modules.txt index ea556d7..dee9af6 100644 --- a/vendor/modules.txt +++ b/vendor/modules.txt @@ -107,7 +107,7 @@ github.com/pmezard/go-difflib/difflib ## explicit; go 1.13 github.com/sirupsen/logrus github.com/sirupsen/logrus/hooks/syslog -# github.com/skycoin/dmsg v1.3.12-0.20231120175607-0b6d5135bbc5 +# github.com/skycoin/dmsg v1.3.12-0.20231130180155-65d707cd1b01 ## explicit; go 1.18 github.com/skycoin/dmsg/internal/servermetrics github.com/skycoin/dmsg/pkg/direct