Rewritten notify() to write the message in bulk.

This was meant to avoid some 32 EPIPE from sendmail,
but it's still happening.

1 files changed, 43 insertions, 23 deletions

diff --git a/activitypub.c b/activitypub.c
index 6aaabc9..f154515 100644
--- a/activitypub.c
+++ b/activitypub.c
@@ -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);
+
+    xs *body = xs_str_new(header);
+
+    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);
+    }
 
-    fprintf(f, "From: %s\n", from);
-    fprintf(f, "To: %s\n", email);
-    fprintf(f, "Subject: %s\n", subject);
-    fprintf(f, "\n");
-
-    fprintf(f, "Type  : %s", type);
-
-    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));
 }