Commit 0c4adece authored by obscuren's avatar obscuren

Properly list caps

parent f76f953f
......@@ -673,6 +673,7 @@ func (p *Peer) pushPeers() {
}
func (self *Peer) pushStatus() {
fmt.Println("push status")
msg := wire.NewMessage(wire.MsgStatusTy, []interface{}{
uint32(ProtocolVersion),
uint32(NetVersion),
......@@ -825,7 +826,7 @@ func (p *Peer) handleHandshake(msg *wire.Msg) {
p.pushStatus()
}
capsStrs = append(capsStrs, cap)
capsStrs = append(capsStrs, fmt.Sprintf("%s/%d", cap, ver))
}
peerlogger.Infof("Added peer (%s) %d / %d (%v)\n", p.conn.RemoteAddr(), p.ethereum.Peers().Len(), p.ethereum.MaxPeers, capsStrs)
......
......@@ -176,10 +176,12 @@ func NewJSPeer(peer chain.Peer) *JSPeer {
var caps []string
capsIt := peer.Caps().NewIterator()
for capsIt.Next() {
caps = append(caps, capsIt.Value().Str())
cap := capsIt.Value().Get(0).Str()
ver := capsIt.Value().Get(1).Uint()
caps = append(caps, fmt.Sprintf("%s/%d", cap, ver))
}
return &JSPeer{ref: &peer, Inbound: peer.Inbound(), LastSend: peer.LastSend().Unix(), LastPong: peer.LastPong(), Version: peer.Version(), Ip: ipAddress, Port: int(peer.Port()), Latency: peer.PingTime(), Caps: fmt.Sprintf("%v", caps)}
return &JSPeer{ref: &peer, Inbound: peer.Inbound(), LastSend: peer.LastSend().Unix(), LastPong: peer.LastPong(), Version: peer.Version(), Ip: ipAddress, Port: int(peer.Port()), Latency: peer.PingTime(), Caps: "[" + strings.Join(caps, ", ") + "]"}
}
type JSReceipt struct {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment