summaryrefslogtreecommitdiff
path: root/data.c
diff options
context:
space:
mode:
authorGravatar default2022-11-18 08:21:40 +0100
committerGravatar default2022-11-18 08:21:40 +0100
commit654326aa8bb1cae5105ffca2f227b71e5981290a (patch)
treeff4df0c3e747c936286049b7e86694c85c583931 /data.c
parentFixed Follow bug, introduced by latest sharedInbox change. (diff)
downloadsnac2-654326aa8bb1cae5105ffca2f227b71e5981290a.tar.gz
snac2-654326aa8bb1cae5105ffca2f227b71e5981290a.tar.xz
snac2-654326aa8bb1cae5105ffca2f227b71e5981290a.zip
New function enqueue_output_to_actor().
Diffstat (limited to 'data.c')
-rw-r--r--data.c14
1 files changed, 13 insertions, 1 deletions
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)
1064 1064
1065 1065
1066void enqueue_output(snac *snac, char *msg, char *inbox, int retries) 1066void enqueue_output(snac *snac, char *msg, char *inbox, int retries)
1067/* enqueues an output message for an actor */ 1067/* enqueues an output message to an inbox */
1068{ 1068{
1069 if (xs_startswith(inbox, snac->actor)) { 1069 if (xs_startswith(inbox, snac->actor)) {
1070 snac_debug(snac, 1, xs_str_new("refusing enqueue to myself")); 1070 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)
1088} 1088}
1089 1089
1090 1090
1091void enqueue_output_by_actor(snac *snac, char *msg, char *actor, int retries)
1092/* enqueues an output message for an actor */
1093{
1094 xs *inbox = get_actor_inbox(snac, actor);
1095
1096 if (!xs_is_null(inbox))
1097 enqueue_output(snac, msg, inbox, retries);
1098 else
1099 snac_log(snac, xs_fmt("enqueue_output_by_actor cannot get inbox %s", actor));
1100}
1101
1102
1091void enqueue_email(snac *snac, char *msg, int retries) 1103void enqueue_email(snac *snac, char *msg, int retries)
1092/* enqueues an email message to be sent */ 1104/* enqueues an email message to be sent */
1093{ 1105{