From 654326aa8bb1cae5105ffca2f227b71e5981290a Mon Sep 17 00:00:00 2001 From: default Date: Fri, 18 Nov 2022 08:21:40 +0100 Subject: New function enqueue_output_to_actor(). --- data.c | 14 +++++++++++++- 1 file changed, 13 insertions(+), 1 deletion(-) (limited to 'data.c') diff --git a/data.c b/data.c index 2fbb49e..3f0ccf7 100644 --- a/data.c +++ b/data.c @@ -1064,7 +1064,7 @@ void enqueue_input(snac *snac, char *msg, char *req, int retries) void enqueue_output(snac *snac, char *msg, char *inbox, int retries) -/* enqueues an output message for an actor */ +/* enqueues an output message to an inbox */ { if (xs_startswith(inbox, snac->actor)) { snac_debug(snac, 1, xs_str_new("refusing enqueue to myself")); @@ -1088,6 +1088,18 @@ void enqueue_output(snac *snac, char *msg, char *inbox, int retries) } +void enqueue_output_by_actor(snac *snac, char *msg, char *actor, int retries) +/* enqueues an output message for an actor */ +{ + xs *inbox = get_actor_inbox(snac, actor); + + if (!xs_is_null(inbox)) + enqueue_output(snac, msg, inbox, retries); + else + snac_log(snac, xs_fmt("enqueue_output_by_actor cannot get inbox %s", actor)); +} + + void enqueue_email(snac *snac, char *msg, int retries) /* enqueues an email message to be sent */ { -- cgit v1.2.3