Skip to content

Commit

Permalink
Envelope ID
Browse files Browse the repository at this point in the history
  • Loading branch information
TedSjoblom committed Mar 29, 2023
1 parent 54c2889 commit 144a9bb
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions main.py
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,7 @@
MQTT_BASE_TOPIC = env("MQTT_BASE_TOPIC")

CLUON_CID = env.int("CLUON_CID", 111)
CLUON_MSG_ID = env.int("CLUON_MS_ID", 1201)
CLUON_ENVELOPE_ID = env.int("CLUON_MS_ID", 1201)

RADAR_ATTITUDE: list = env.list("RADAR_ATTITUDE", [0, 0, 0], subcast=float, validate=lambda x: len(x) == 3)
RADAR_MIN_READING_WEIGHT = env.int("RADAR_MIN_READING_WEIGHT", 0)
Expand Down Expand Up @@ -84,7 +84,7 @@ def unpack_spoke(envelope: cEnvelope) -> Tuple[float, np.ndarray, np.ndarray]:
str_id = envelope.sender_stamp
# str_time = str(envelope.sender_timestamp)

if CLUON_MSG_ID == str_id:
if CLUON_ENVELOPE_ID == str_id:
LOGGER.info("Sender ID: %s", str_id)


Expand Down Expand Up @@ -239,6 +239,6 @@ def to_mqtt(envelope: Envelope):

# Register triggers
session = OD4Session(CLUON_CID)
session.add_data_trigger(1201, source.emit)
session.add_data_trigger(CLUON_ENVELOPE_ID, source.emit)

mq.loop_forever()

0 comments on commit 144a9bb

Please sign in to comment.