From 79aa3cc2b313d1a355a8950a19dcf9fbe6f7f813 Mon Sep 17 00:00:00 2001
From: mr <morgane.roques@irt-saintexupery.com>
Date: Thu, 26 Feb 2026 09:14:34 +0100
Subject: [PATCH] adjust

---
 daemons/node/nats.go           | 12 ++++++++++++
 daemons/node/stream/handler.go |  2 +-
 2 files changed, 13 insertions(+), 1 deletion(-)

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
 		}