hemna/aprsd
1
0
Fork 0
mirror of https://github.com/craigerl/aprsd.git synced 2026-02-12 19:13:45 -05:00
Code Issues Projects Releases Wiki Activity

Fixed an issue with dev command

Browse Source
This commit is contained in:
Walter Boring 2026-02-07 17:17:15 -05:00
parent 3128f24ef7
commit 008fe3c83e
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
aprsd/cmds/dev.py
View File

@ -10,6 +10,7 @@ import click
from oslo_config import cfg
import aprsd
import aprsd.packets.log as packet_log
from aprsd import cli_helper, packets, plugin, utils
# local imports here
@ -128,15 +129,17 @@ def test_plugin(
message_text=message,
)
LOG.info(f"P'{plugin_path}' F'{fromcall}' C'{message}'")
packet_log.log(packet)
for _ in range(number):
# PluginManager.run() executes all plugins in parallel
# Results may be in a different order than plugin registration
# NULL_MESSAGE results are already filtered out
replies = pm.run(packet)
results, handled = pm.run(packet)
LOG.debug(f'Replies: {results}')
# Plugin might have threads, so lets stop them so we can exit.
# obj.stop_threads()
for reply in replies:
for reply in results:
if isinstance(reply, list):
# one of the plugins wants to send multiple messages
for subreply in reply:
@ -157,6 +160,7 @@ def test_plugin(
# Note: NULL_MESSAGE results are already filtered out
# in PluginManager.run(), but keeping this check for safety
if reply is not packets.NULL_MESSAGE:
LOG.debug(f'Reply: {reply}')
LOG.info(
packets.MessagePacket(
from_call=CONF.callsign,