Error in subscription notifications when TROE is enabled

[ravaga]

I've deployed (with @p4lik4ri) a dockerized Orion-LD instance with TROE enabled (-troe) and the TimescaleDB properly configured. Then, we have created an entity of type Vehicle and a Subscription with an MQTT endpoint.

{
    "id": "urn:ngsi-ld:vehicle:5g-car:2",
    "type": "Vehicle",
    "category": {
        "type": "Property",
        "value": [
            "specialUsage",
            "Tracked"
        ]
    },
    "vehicleType": {
        "type": "Property",
        "value": "car"
    },
    "name": {
        "type": "Property",
        "value": "pi"
    },
    "vehiclePlateIdentifier": {
        "type": "Property",
        "value": "ncsrd"
    },
    "location": {
        "type": "GeoProperty",
        "value": {
            "type": "Point",
            "coordinates": [
                94.0913,
                38.1031
            ]
        }
    },
    "move": {
        "type": "Property",
        "value": true
    },
    "direction": {
        "type": "Property",
        "value": 40
    },
    "heading": {
        "type": "Property",
        "value": "188 degrees"
    },
    "owner": {
        "type": "Relationship",
        "object": "urn:ngsi-ld:Organization:NCSRD"
    },
    "areaServed": {
        "type": "Property",
        "value": "NCSRD-IIT"
    },
    "serviceStatus": {
        "type": "Property",
        "value": "parked"
    },
    "distanceCollision": {
        "type": "Property",
        "value": 543333
    },
    "signalQuality": {
        "type": "Property",
        "value": "0"
    },
    "cargoWeight": {
        "type": "Property",
        "value": 0.5
    },
    "speed": {
        "type": "Property",
        "value": 89
    }
}

{
    "id": "urn:aeros:subscription:car:test",
    "type": "Subscription",
    "description": "Subscription to Vehicle entity type for the demo",
    "entities": [
        {
            "id": "urn:ngsi-ld:vehicle:5g-car:2",
            "type": "Vehicle"
        }
    ],
    "watchedAttributes": [
        "distanceCollision"
    ],
    "notification": {
        "attributes": [
            "distanceCollision"
        ],
        "format": "normalized",
        "endpoint": {
            "uri": "mqtt://10.220.2.101:30083/example",
            "accept": "application/json"
        }
    }
}

However, when we modify the distanceCollision attribute, the broker crashes without displaying any error message in the logs, the notification isn't sent (although we can check in the logs of the Mosquitto server that the broker has tried to connect to it) and the failure isn't registered in the Subscription (status, isActive ... attributes are not creates).

Finally, if we restart the broker without the TROE enabled, the notifications are properly sent to the MQTT topic. However, if we restart the broker with the TROE enabled again, the notifications sometimes are sent (and the broker doesn't crash) but without including the value of the distanceCollision attribute.

{
  "metadata": {
    "Content-Type": "application/json",
    "User-Agent": "orionld/post-v1.7.0",
    "Host": "10.220.2.101:30083",
    "Accept": "application/json",
    "Ngsild-Attribute-Format": "Normalized",
    "Link": "https://uri.etsi.org/ngsi-ld/v1/ngsi-ld-core-context-v1.6.jsonld"
  },
  "body": {
    "id": "urn:ngsi-ld:Notification:af424890-b0c5-11ef-b29e-a623640fa18a",
    "type": "Notification",
    "subscriptionId": "urn:aeros:subscription:car:test",
    "notifiedAt": "2024-12-02T15:54:16.707Z",
    "data": [
      {
        "id": "urn:ngsi-ld:vehicle:5g-car:2",
        "type": "Vehicle"
      }
    ]
  }
}

[kzangeli]

ok, noted. Not sure I've ever tested TRoE and MQTT at the same time.
I will now :)

[ravaga]

The issue happened also with HTTP notifications, so I think it might be a more global issue with the notifications + TRoE.

[kzangeli]

So, started testing this.
All ok when creating the entity, but:
"However, when we modify the distanceCollision attribute"

I'm gonna need some more info there ... :)
Exactly how is the attribute modified?

[ravaga]

We were sending a PATCH /entities/urn:ngsi-ld:vehicle:5g-car:2 with this body:

{
  "distanceCollision": {
    "type": "Property",
    "value": 525
  }
}