add timestamps to messenger

Author: shikokuchuo

R/messenger.R

@@ -46,20 +46,23 @@ messenger <- function(dial = NULL, listen = NULL) {
     cat("\r", `length<-`(intro, i), sep = " ", file = stdout())
     Sys.sleep(0.02)
   }
-  cat("  |  type your message:\n", file = stdout())
+  cat("\n", file = stdout())
   s <- .Call(rnng_send, sock, as.raw(0L), 0L)
   if (is.integer(s)) {
-    cat("[ peer offline ] waiting for connection...\n", file = stdout())
+    cat(sprintf("| peer offline: waiting for connection: %s\n", format.POSIXct(Sys.time())),
+        file = stderr())
   } else {
-    cat("[ peer online ] connected\n", file = stdout())
+    cat(sprintf("| peer online: connected: %s\n", format.POSIXct(Sys.time())),
+        file = stderr())
   }
+  cat("type your message:\n", file = stdout())
   repeat {
     data <- readline()
     if (identical(data, ":q")) break
     if (identical(data, "")) next
     data <- writeBin(object = data, con = raw())
     s <- .Call(rnng_send, sock, data, 0L)
-    if (is.integer(s)) message(sprintf("%s [ peer offline ] message not sent", format.POSIXct(Sys.time())))
+    if (is.integer(s)) message(sprintf("| peer offline: message not sent > %s", format.POSIXct(Sys.time())))
   }
 
 }

src/sockets.c

@@ -1,5 +1,6 @@
 /* nanonext - C level - Sockets and Protocols ------------------------------- */
 
+#include <time.h>
 #include <nng/nng.h>
 #include <nng/protocol/bus0/bus.h>
 #include <nng/protocol/pair0/pair.h>
@@ -100,25 +101,38 @@ static void rnng_thread(void *arg) {
   unsigned char *buf = NULL;
   size_t sz;
   int xc;
+  time_t now;
+  struct tm *tms;
   nng_socket *sock = (nng_socket *) arg;
 
   while (1) {
     xc = nng_recv(*sock, &buf, &sz, 1u);
+    time(&now);
     if (xc) {
-      REprintf("messenger session ended\n");
+      tms = localtime(&now);
+      REprintf("| messenger session: ended: %d-%02d-%02d %02d:%02d:%02d\n",
+               tms->tm_year + 1900, tms->tm_mon + 1, tms->tm_mday,
+               tms->tm_hour, tms->tm_min, tms->tm_sec);
       break;
     }
     if (!strcmp((const char *) buf, ":q")) {
       nng_free(buf, sz);
       break;
     }
     if (!strcmp((const char *) buf, "")) {
+      tms = localtime(&now);
+      REprintf("| peer status: changed: %d-%02d-%02d %02d:%02d:%02d\n",
+               tms->tm_year + 1900, tms->tm_mon + 1, tms->tm_mday,
+               tms->tm_hour, tms->tm_min, tms->tm_sec);
       nng_free(buf, sz);
-      Rprintf("[ peer status ] changed\n");
       continue;
     }
 
-    Rprintf("> %s\n", buf);
+    tms = localtime(&now);
+    Rprintf("%s < %d-%02d-%02d %02d:%02d:%02d\n",
+            buf,
+            tms->tm_year + 1900, tms->tm_mon + 1, tms->tm_mday,
+            tms->tm_hour, tms->tm_min, tms->tm_sec);
     nng_free(buf, sz);
   }