43 lines
1005 B
Go
43 lines
1005 B
Go
|
package pubsub
|
||
|
|
|
||
|
|
import (
|
||
|
|
"context"
|
||
|
|
"oc-discovery/daemons/node/common"
|
||
|
|
|
||
|
|
"cloud.o-forge.io/core/oc-lib/tools"
|
||
|
|
)
|
||
|
|
|
||
|
|
func (ps *PubSubService) handleEvent(ctx context.Context, topicName string, evt *common.Event) error {
|
||
|
|
action := ps.getTopicName(topicName)
|
||
|
|
if err := ps.handleEventSearch(ctx, evt, action); err != nil {
|
||
|
|
return err
|
||
|
|
}
|
||
|
|
return nil
|
||
|
|
}
|
||
|
|
|
||
|
|
func (ps *PubSubService) handleEventSearch( // only : on partner followings. 3 canals for every partner.
|
||
|
|
ctx context.Context,
|
||
|
|
evt *common.Event,
|
||
|
|
action tools.PubSubAction,
|
||
|
|
) error {
|
||
|
|
if !(action == tools.PB_SEARCH_RESPONSE || action == tools.PB_SEARCH) {
|
||
|
|
return nil
|
||
|
|
}
|
||
|
|
// TODO VERIFY: FROM SHOULD BE A PEER ID OR A DID
|
||
|
|
if p, err := ps.Node.GetPeerRecord(ctx, evt.From); err == nil {
|
||
|
|
if err := evt.Verify(p); err != nil {
|
||
|
|
return err
|
||
|
|
}
|
||
|
|
switch action {
|
||
|
|
case tools.PB_SEARCH: // when someone ask for search.
|
||
|
|
if err := ps.StreamService.SendResponse(p, evt); err != nil {
|
||
|
|
return err
|
||
|
|
}
|
||
|
|
|
||
|
|
default:
|
||
|
|
return nil
|
||
|
|
}
|
||
|
|
}
|
||
|
|
return nil
|
||
|
|
}
|