mirror of
https://github.com/logos-messaging/go-libp2p-pubsub.git
synced 2026-01-28 09:13:09 +00:00
rename checkSignature to checkSigningPolicy
This commit is contained in:
parent
175d43f4e7
commit
84302e9633
@ -991,7 +991,7 @@ func (p *PubSub) pushMsg(msg *Message) {
|
||||
return
|
||||
}
|
||||
|
||||
err := p.checkSignature(msg)
|
||||
err := p.checkSigningPolicy(msg)
|
||||
if err != nil {
|
||||
log.Debugf("dropping message from %s: %s", src, err)
|
||||
return
|
||||
@ -1021,7 +1021,7 @@ func (p *PubSub) pushMsg(msg *Message) {
|
||||
}
|
||||
}
|
||||
|
||||
func (p *PubSub) checkSignature(msg *Message) error {
|
||||
func (p *PubSub) checkSigningPolicy(msg *Message) error {
|
||||
// reject unsigned messages when strict before we even process the id
|
||||
if p.signPolicy.mustVerify() {
|
||||
if p.signPolicy.mustSign() {
|
||||
|
||||
@ -216,7 +216,7 @@ func (v *validation) RemoveValidator(req *rmValReq) {
|
||||
func (v *validation) PushLocal(msg *Message) error {
|
||||
v.p.tracer.PublishMessage(msg)
|
||||
|
||||
err := v.p.checkSignature(msg)
|
||||
err := v.p.checkSigningPolicy(msg)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user