This commit is contained in:
decanus 2019-06-20 18:39:44 +02:00
parent 18f12a9717
commit d7abdc91a4
No known key found for this signature in database
GPG Key ID: E95B8C69228FF5B4

View File

@ -148,22 +148,22 @@ func (w *DataSyncWhisperAdapter) Send(ctx context.Context, data []byte, options
}
// Request retrieves historic messages.
func (m *DataSyncWhisperAdapter) Request(ctx context.Context, params protocol.RequestOptions) error {
func (w *DataSyncWhisperAdapter) Request(ctx context.Context, params protocol.RequestOptions) error {
return nil
}
func (c *DataSyncWhisperAdapter) peer(id state.GroupID, peer *ecdsa.PublicKey) {
func (w *DataSyncWhisperAdapter) peer(id state.GroupID, peer *ecdsa.PublicKey) {
if peer == nil {
return
}
p := dspeer.PublicKeyToPeerID(*peer)
if c.node.IsPeerInGroup(id, p) {
if w.node.IsPeerInGroup(id, p) {
return
}
c.node.AddPeer(id, p)
w.node.AddPeer(id, p)
}
func toGroupId(topicType whisper.TopicType) state.GroupID {