Skip to content

Commit 6c6cd8f

Browse files
add resend last message command to helix publisher debug script
1 parent 77180c9 commit 6c6cd8f

1 file changed

Lines changed: 6 additions & 1 deletion

File tree

plugins/helix/scripts/publisher.py

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -10,18 +10,23 @@
1010

1111
def main() -> None:
1212
sequence_number: int = 0
13+
last_message: str = ""
1314
client: redis.Redis = redis.Redis(host="localhost", port=6379, db=0)
1415

1516
while True:
1617
channels: list[str] = input("Enter channels: ").split()
1718
if not channels:
1819
break
20+
elif channels[0] == "rs" and sequence_number > 0:
21+
client.publish(channel, last_message)
22+
continue
1923

2024
command: str = input("Enter command: ")
2125
identifiers: list[str] = input("Enter identifiers: ").split()
2226

2327
for channel in channels:
24-
client.publish(channel, json.dumps({"sequence_number": sequence_number, "command": command,"instances": identifiers}))
28+
last_message: str = json.dumps({"sequence_number": sequence_number, "command": command,"instances": identifiers})
29+
client.publish(channel, last_message)
2530

2631
sequence_number += 1
2732
print()

0 commit comments

Comments
 (0)