diff --git a/daemons/node/nats.go b/daemons/node/nats.go index 8bb40d6..1b1a0cc 100644 --- a/daemons/node/nats.go +++ b/daemons/node/nats.go @@ -146,6 +146,18 @@ func ListenNATS(n *Node) { } } } + default: + // minio / admiralty config considers — route back to OriginID. + var m struct { + OriginID string `json:"origin_id"` + } + if err := json.Unmarshal(propalgation.Payload, &m); err == nil && m.OriginID != "" { + peers, _ := n.GetPeerRecord(context.Background(), m.OriginID) + for _, p := range peers { + n.StreamService.PublishCommon(nil, resp.User, + p.PeerID, stream.ProtocolConsidersResource, propalgation.Payload) + } + } } case tools.PB_PLANNER: m := map[string]interface{}{} diff --git a/daemons/node/stream/handler.go b/daemons/node/stream/handler.go index 79e96c7..c14be49 100644 --- a/daemons/node/stream/handler.go +++ b/daemons/node/stream/handler.go @@ -41,7 +41,7 @@ func (ps *StreamService) handleEvent(protocol string, evt *common.Event) error { return err } } - if protocol == ProtocolConsidersResource && evt.DataType > -1 { + if protocol == ProtocolConsidersResource { if err := ps.pass(evt, tools.PB_CONSIDERS); err != nil { return err }