advance messenger

Author: shikokuchuo

R/messenger.R

@@ -37,30 +37,30 @@ messenger <- function(dial = NULL, listen = NULL) {
     return(invisible(sock))
   }
   on.exit(expr = {
+    s <- .Call(rnng_send, sock, as.raw(0L), 0L)
     close(sock)
     invisible()
   })
-  . <- unlist(strsplit("nanonext messenger", ""))
-  .. <- .[length(.):1]
-  for (i in seq_along(..)) {
-    cat("\r", `length<-`(.., i), sep = " ", file = stdout())
-    if (i %in% c(1:5, 15:20)) Sys.sleep(0.03) else Sys.sleep(0.01)
-  }
-  for (i in seq_along(.)) {
-    cat("\r", `length<-`(., i), sep = " ", file = stdout())
-    if (i %in% c(1:5, 15:20)) Sys.sleep(0.01) else Sys.sleep(0.03)
+  intro <- unlist(strsplit("nanonext messenger", ""))
+  for (i in seq_along(intro)) {
+    cat("\r", `length<-`(intro, i), sep = " ", file = stdout())
+    Sys.sleep(0.02)
   }
   cat("  |  type your message:\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())
+  } else {
+    cat("[ peer online ] connected\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, FALSE)
-    if (is.integer(s)) message(sprintf("%s [ no connection ] message not sent", format.POSIXct(Sys.time())))
+    s <- .Call(rnng_send, sock, data, 0L)
+    if (is.integer(s)) message(sprintf("%s [ peer offline ] message not sent", format.POSIXct(Sys.time())))
   }
-  on.exit()
-  close(sock)
-  invisible()
 
 }
 

src/sockets.c

@@ -99,16 +99,26 @@ static void rnng_thread(void *arg) {
 
   unsigned char *buf = NULL;
   size_t sz;
+  int xc;
   nng_socket *sock = (nng_socket *) arg;
 
   while (1) {
-    int xc = nng_recv(*sock, &buf, &sz, 1u);
+    xc = nng_recv(*sock, &buf, &sz, 1u);
     if (xc) {
-      REprintf("Messenger session ended\n");
+      REprintf("messenger session ended\n");
+      break;
+    }
+    if (!strcmp((const char *) buf, ":q")) {
+      nng_free(buf, sz);
       break;
     }
-    if (!strcmp((const char *) buf, ":q")) break;
-    REprintf("> %s\n", buf);
+    if (!strcmp((const char *) buf, "")) {
+      nng_free(buf, sz);
+      Rprintf("[ peer status ] changed\n");
+      continue;
+    }
+
+    Rprintf("> %s\n", buf);
     nng_free(buf, sz);
   }