We now tail the Mystic log files for the node.

build_images.sh

@@ -3,14 +3,18 @@
 BASE=.$$images.h
 FINAL=images.h
 
-./ansi-to-src skull.ans > $BASE
-./ansi-to-src skull-blink.ans >> $BASE
-./ansi-to-src ghead.ans >> $BASE
-./ansi-to-src ghost.ans >> $BASE
-./ansi-to-src wolf.ans >> $BASE
-./ansi-to-src panther.ans >> $BASE
-./ansi-to-src bat.ans >> $BASE
-./ansi-to-src icu.ans >> $BASE
+export PATH=$PATH:build:.
+
+# echo $PATH
+
+ansi-to-src skull.ans > $BASE
+ansi-to-src skull-blink.ans >> $BASE
+ansi-to-src ghead.ans >> $BASE
+ansi-to-src ghost.ans >> $BASE
+ansi-to-src wolf.ans >> $BASE
+ansi-to-src panther.ans >> $BASE
+ansi-to-src bat.ans >> $BASE
+ansi-to-src icu.ans >> $BASE
 
 mv -f $BASE $FINAL
 

hharry.cpp

@@ -7,6 +7,8 @@
 #include <termios.h>
 #include <unistd.h>
 
+#include <fstream>
+#include <iostream>
 #include <sstream>
 #include <string>
 
@@ -114,6 +116,7 @@ connections.
  */
 string username;
 string fullname;
+int node;
 
 /*
 This only works for those few idiots that use the
@@ -146,6 +149,76 @@ int locate_user(const char *alias) {
   return 1;
 }
 
+ifstream logfile;
+streampos log_pos;
+
+void open_mystic_log(void) {
+  string mystic_logfile;
+  {
+    ostringstream buffer;
+
+    buffer << "logs/node" << node << ".log";
+    mystic_logfile = buffer.str();
+  };
+  logfile.open(mystic_logfile, ios_base::in | ios_base::ate);
+  // Ok, we're at the end of the file.  Or should be.
+  if (logfile.is_open()) {
+    ZF_LOGD("Log %s open", (const char *)mystic_logfile.c_str());
+    log_pos = logfile.tellg();
+  } else {
+    ZF_LOGE("Failed to open: %s", (const char *)mystic_logfile.c_str());
+  }
+}
+
+void scan_mystic_log(void) {
+
+  if (logfile.is_open()) {
+    int again = 0;
+    do {
+      string line = find_new_text(logfile, log_pos);
+      if (line.empty())
+        return;
+      again = 1;
+
+      ZF_LOGD("mystic log: %s", (const char *)line.c_str());
+      // Ok, we have a line, look for interesting details
+      if (line.find("New user application") != string::npos) {
+        ZF_LOGE("New User");
+      }
+
+      int pos;
+      pos = line.find("Created Account: ");
+      if (pos != string::npos) {
+        pos += 18 - 1;
+        // Ok, find the end '#'
+        int len = line.find('#', pos);
+        if (len != string::npos) {
+          username = line.substr(pos, len - pos - 1);
+          ZF_LOGE("New User: %s", (const char *)username.c_str());
+          // once we know this works -- lookup user's record
+          locate_user(username.c_str());
+          ZF_LOGD("Username: [%s] A.K.A. [%s]", (const char *)username.c_str(),
+                  (const char *)fullname.c_str());
+        }
+      }
+      pos = line.find(" logged in");
+      if (pos != string::npos) {
+        --pos;
+        int len = line.rfind(' ', pos);
+        if (len != string::npos) {
+          len++;
+          username = line.substr(len, pos + 1 - len);
+          ZF_LOGE("User: %s", (const char *)username.c_str());
+          // verify this works, lookup
+          locate_user(username.c_str());
+          ZF_LOGD("Username: [%s] A.K.A. [%s]", (const char *)username.c_str(),
+                  (const char *)fullname.c_str());
+        }
+      }
+    } while (again);
+  }
+}
+
 /*
 
 This is done.  :D  My buffering system works with stack'em.
@@ -167,22 +240,23 @@ Here's the "plan":
   NOT EMPTY:
       // we're in luck!  The last parameter is time interval/timeout.  :D
       timeout.tv_sec = 0;
-      timeout.tv_usec = 10;   // Wild Guess Here?  Maybe higher, maybe lower?
-      time_idle = 0;
+      timeout.tv_usec = 10;   // Wild Guess Here?  Maybe higher, maybe
+lower? time_idle = 0;
 
   ON READ:
     read/append to current buffer.
-    We can't use nulls -- what if they are using ZModem, there's nulls in the
-file! Look for trailing  / the very last "\r\n".
+    We can't use nulls -- what if they are using ZModem, there's nulls in
+the file! Look for trailing  / the very last "\r\n".
 
     (I could mangle/chunk it line by line.  But I'm not sure I'd need to do
 that.)
 
-    Optional "mangle" buffer up to that very point -- and send up to that point.
+    Optional "mangle" buffer up to that very point -- and send up to that
+point.
 
-    Option #2:  Maybe we send everything if program has been running for under
-    20 seconds.  This would allow the ANSI detect to not get screwed up by this
-    new idea.
+    Option #2:  Maybe we send everything if program has been running for
+under 20 seconds.  This would allow the ANSI detect to not get screwed up by
+this new idea.
 
   ON TIMEOUT:
     if time_idle:
@@ -194,8 +268,9 @@ that.)
       Maybe this is a prompt, and there won't be a \r\n.
 
 This allows for cleaner process of "lines" of buffer.  We shouldn't break
-in the midDLE OF A WORD.  Downside is that we sit on buffer contents a little
-while / some amount of time -- which will add some lag to prompts showing up.
+in the midDLE OF A WORD.  Downside is that we sit on buffer contents a
+little while / some amount of time -- which will add some lag to prompts
+showing up.
 
 (LAG?  Are you kidding?)
 
@@ -225,7 +300,7 @@ ZModem:
 int main(int argc, char *argv[]) {
   int master;
   pid_t pid;
-  int node = -1;
+  node = -1;
 
   init_harry();
   srandom(time(NULL));
@@ -281,7 +356,6 @@ int main(int argc, char *argv[]) {
     return 2;
   }
 
-
   string logfile;
   {
     ostringstream buffer;
@@ -299,6 +373,7 @@ int main(int argc, char *argv[]) {
     ZF_LOGD("Username: [%s] A.K.A. [%s]", (const char *)username.c_str(),
             (const char *)fullname.c_str());
   }
+  open_mystic_log();
 
   pid = forkpty(&master, NULL, NULL, NULL);
 
@@ -332,6 +407,7 @@ int main(int argc, char *argv[]) {
     struct termios tios, orig1;
     struct timeval timeout;
     time_t last_event = 0; // time(NULL);
+    time_t last_logscan = time(NULL);
 
     ZF_LOGD("starting");
 
@@ -405,6 +481,14 @@ int main(int argc, char *argv[]) {
         time_idle = 0;
       }
 
+      if (last_logscan < time(NULL)) {
+        scan_mystic_log();
+        if (username.empty())
+          last_logscan = time(NULL) + 2;
+        else
+          last_logscan = time(NULL) + 30;
+      }
+
       if (select(master + 1, &read_fd, &write_fd, &except_fd, &timeout) == 0) {
         ZF_LOGI("TIMEOUT");
         // This means timeout!

utils.cpp

@@ -1,6 +1,8 @@
+#include <fstream>
 #include <stdio.h>
 #include <stdlib.h>
 #include <string.h>
+#include <string>
 
 #include "utils.h"
 
@@ -224,3 +226,59 @@ void pcopy(char *pstring, char *str) {
   strncpy(str, pstring + 1, len);
   str[len] = 0;
 }
+
+/*
+ * tail file, return new lines of text.
+ *
+ * Only handles lines < 256 chars.
+ * Does not handle if the file is closed/unlinked/...
+ *
+ */
+std::string &find_new_text(std::ifstream &infile,
+                           std::streampos &last_position) {
+  static std::string line;
+  line.clear();
+
+  infile.seekg(0, std::ios::end);
+  std::streampos filesize = infile.tellg();
+
+  if (filesize == -1) {
+    // Ok, we've failed somehow.  Now what?
+    // cout << "SNAP!";
+    return line;
+  }
+
+  // check if the new file started
+  // we don't detect if the file has been unlinked/reset
+  if (filesize < last_position) {
+    // cout << "reset! " << filesize << endl;
+    last_position = 0;
+  }
+
+  while (last_position < filesize) {
+    // this loop -- seems broken.
+    // for (long n = last_position; n < filesize; n++) {
+
+    infile.seekg(last_position, std::ios::beg);
+
+    char test[256];
+    infile.getline(test, sizeof(test));
+
+    if (infile.eof()) {
+      // We got EOF instead of something.
+      // Seek back to our last, good, known position
+      // and exit (wait for the rest of the line)
+      infile.seekg(last_position, std::ios::beg);
+      return line;
+    }
+
+    std::streampos new_pos = infile.tellg();
+    if (new_pos == -1)
+      return line;
+
+    last_position = new_pos;
+    line.assign(test);
+    return line;
+  }
+  return line;
+}

utils.h

@@ -1,6 +1,9 @@
 #ifndef UTILS_H
 #define UTILS_H
 
+#include <fstream>
+#include <string>
+
 // http://c-faq.com/lib/randrange.html
 int randint(int N);
 
@@ -23,4 +26,6 @@ int rstrnstr(const char *buffer, int len, const char *find);
 int string_insert(char *buffer, int max_length, int pos, const char *insert);
 void pcopy(char *pstring, char *str);
 
+std::string &find_new_text(std::ifstream &infile,
+                           std::streampos &last_position);
 #endif