monkee.ch/snac2
1
0
Fork 0
mirror of https://codeberg.org/grunfink/snac2.git synced 2024-11-22 13:25:04 +00:00
Code Issues Projects Releases Packages Wiki Activity

Rewritten notify() to write the message in bulk.

Browse source 
This was meant to avoid some 32 EPIPE from sendmail,
but it's still happening.
This commit is contained in:
default 2022-10-21 10:26:45 +02:00
parent 7cd67e7835
commit 6e470440f9
1 changed files with 41 additions and 21 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

62
activitypub.c
View file

@ -650,30 +650,33 @@ void notify(snac *snac, char *type, char *utype, char *actor, char *msg)
snac_debug(snac, 1, xs_fmt("notify(%s, %s, %s)", type, utype, actor));
/* now write */
FILE *f;
if ((f = popen("/usr/sbin/sendmail -t", "w")) == NULL) {
snac_log(snac, xs_fmt("cannot pipe to sendmail (errno: %d)", errno));
return;
}
/* prepare message */
xs *subject = xs_fmt("snac notify for @%s@%s",
xs_dict_get(snac->config, "uid"), xs_dict_get(srv_config, "host"));
xs *from = xs_fmt("snac-daemon@%s (snac daemon)", xs_dict_get(srv_config, "host"));
xs *header = xs_fmt(
"From: %s\n"
"To: %s\n"
"Subject: %s\n"
"\n",
from, email, subject);
fprintf(f, "From: %s\n", from);
fprintf(f, "To: %s\n", email);
fprintf(f, "Subject: %s\n", subject);
fprintf(f, "\n");
xs *body = xs_str_new(header);
fprintf(f, "Type : %s", type);
if (strcmp(utype, "(null)") != 0) {
xs *s1 = xs_fmt("Type : %s + %s\n", type, utype);
body = xs_str_cat(body, s1);
}
else {
xs *s1 = xs_fmt("Type : %s\n", type);
body = xs_str_cat(body, s1);
}
if (strcmp(utype, "(null)") != 0)
fprintf(f, " + %s", utype);
fprintf(f, "\n");
fprintf(f, "Actor : %s\n", actor);
{
xs *s1 = xs_fmt("Actor : %s\n", actor);
body = xs_str_cat(body, s1);
}
if (strcmp(type, "Like") == 0 || strcmp(type, "Announce") == 0) {
/* there is a related object: add it */
@ -683,13 +686,30 @@ void notify(snac *snac, char *type, char *utype, char *actor, char *msg)
if (xs_type(object) == XSTYPE_DICT)
object = xs_dict_get(object, "id");
if (!xs_is_null(object))
fprintf(f, "Object: %s\n", object);
if (!xs_is_null(object)) {
xs *s1 = xs_fmt("Object: %s\n", object);
body = xs_str_cat(body, s1);
}
}
}
if (fclose(f) == EOF)
snac_log(snac, xs_fmt("fclose error in pipe to sendmail (errno: %d)", errno));
/* now write */
FILE *f;
if ((f = popen("/usr/sbin/sendmail -t", "w")) != NULL) {
fprintf(f, "%s\n", body);
if (fclose(f) == EOF) {
snac_log(snac, xs_fmt("fclose error in pipe to sendmail (errno: %d)", errno));
if ((f = fopen("/tmp/dead-letter", "w")) != NULL) {
fprintf(f, "%s\n", body);
fclose(f);
}
}
}
else
snac_log(snac, xs_fmt("cannot pipe to sendmail (errno: %d)", errno));
}