Support parsing comments. Not activated yet.

git-svn-id: http://opensvn.csie.org/pttbbs/trunk@6038 63ad8ddf-47c3-0310-b6dd-a9e9d9715204

1 files changed, 136 insertions, 0 deletions

diff --git a/pttbbs/daemon/postd/rebuild.c b/pttbbs/daemon/postd/rebuild.c
index db2fc3fc..138356a0 100644
--- a/pttbbs/daemon/postd/rebuild.c
+++ b/pttbbs/daemon/postd/rebuild.c
@@ -2,6 +2,132 @@
 #include "bbs.h"
 #include "daemons.h"
 
+// Comments format: CommentsPrefix ANSI_COLOR(33) [AUTHOR]
+//                  ANSI_RESET ANSI_COLOR(33) ":" [CONTENT]
+//                  ANSI_RESET [trailings]
+const char *CommentsPrefix[] = {
+    ANSI_COLOR(1;37) "±À ",
+    ANSI_COLOR(1;31) "¼N ",
+    ANSI_COLOR(1;31) "¡÷ ", // Shared by P1 and P2 <OLDRECOMMEND>.
+    NULL,
+};
+
+int CommentsExtract(const char *input,
+                     char *output_owner,
+                     char *output_content,
+                     char *output_trailings) {
+    int i, kind = -1;
+    const char *prefix = NULL, *p = NULL, *p2, *p3;
+    const char *pat_Prefix2 = ANSI_COLOR(33),
+               *pat_PostAuthor = ANSI_RESET ANSI_COLOR(33) ":",
+               *pat_PostContent = ANSI_RESET;
+    for (i = 0; !p && CommentsPrefix[i]; i++) {
+        prefix = CommentsPrefix[i];
+        if (!str_starts_with(input, prefix))
+            continue;
+        p = input + strlen(prefix);
+        kind = i;
+    }
+    if (!p) {
+        printf("error - !p\n");
+        return -1;
+    }
+    if (!str_starts_with(p, pat_Prefix2)) {
+        printf("error - !starts_with(prefix2)\n");
+        return -1;
+    }
+    p += strlen(pat_Prefix2);
+    p2 = strstr(p, pat_PostAuthor);
+    if (!p || p2 <= p) {
+        printf("error - !p || p2 <= p\n");
+        return -1;
+    }
+    // author = p..p2
+    *output_owner = 0;
+    strncat(output_owner, p, p2 - p);
+    p = p2 + strlen(pat_PostAuthor);
+    p2 = strstr(p, pat_PostContent);
+    if (!p2) {
+        printf("error - !p2\n");
+        return -1;
+    }
+    // content = p..[spaces]p2
+    p3 = p2 - 1;
+    while (p3 > p && *p3 == ' ')
+        p3--;
+    *output_content = 0;
+    strncat(output_content, p, p3 - p + 1);
+    p = p2 + strlen(pat_PostContent);
+    strcpy(output_trailings, p);
+    return kind;
+}
+
+int ProcessPost(const char *filename) {
+    FILE *fp = fopen(filename, "rt");
+    long offBegin, offEnd = -1;
+    char buf[ANSILINELEN];
+    assert(fp);
+
+    // first line, expecting STR_AUTHOR1 or STR_AUTHOR2.
+    if (fgets(buf, sizeof(buf), fp)) {
+        int skip_lines = 0;
+        if (strncmp(STR_AUTHOR1, buf, strlen(STR_AUTHOR1)) == 0) {
+            // local file: 3 line format. (author, subject, time)
+            skip_lines = 3;
+        } else if (strncmp(STR_AUTHOR2, buf, strlen(STR_AUTHOR2)) == 0) {
+            // remote file: 4 line format. (author, subject, time, source)
+            skip_lines = 4;
+        } else {
+            // unknown, sorry.
+            rewind(fp);
+        }
+        for (; skip_lines > 0; skip_lines--) {
+            fgets(buf, sizeof(buf), fp);
+            if (buf[0] == '\r' || buf[0] == '\n')
+                break;
+        }
+    }
+    offBegin = ftell(fp);
+    // Seek for last '--'
+    while (fgets(buf, sizeof(buf), fp)) {
+        if (strcmp(buf, "--\n") == 0 || strcmp(buf, "--\r") == 0) {
+            if (offEnd >= 0) {
+                // Note this may be caused by signatures.
+                // printf(" Warning: multiple -- in %s\n", filename);
+            }
+            offEnd = ftell(fp) - strlen(buf);
+        }
+    }
+    if (offEnd < 0)
+        offEnd = ftell(fp);
+
+    fseek(fp, offBegin, SEEK_SET);
+    // Content: offBegin to offEnd.
+
+    // Try to solve comments
+    fseek(fp, offEnd, SEEK_SET);
+    while (fgets(buf, sizeof(buf), fp)) {
+        char bufOwner[ANSILINELEN],
+             bufContent[ANSILINELEN],
+             bufTrailing[ANSILINELEN];
+        int kind;
+        if (buf[0] != ESC_CHR)
+            continue;
+        chomp(buf);
+        // See comments.c:FormatCommentString:
+        kind = CommentsExtract(buf, bufOwner, bufContent, bufTrailing);
+        if (kind < 0) {
+            printf("waring: bypassed - %s\n", buf);
+            continue;
+        }
+        printf("K[%d], A[%s], C[%s], T[%s]\n", kind,
+               bufOwner, bufContent, bufTrailing);
+    }
+
+    fclose(fp);
+    return 0;
+}
+
 int PostAddRecord(const char *board, const fileheader_t *fhdr)
 {
     int s;
@@ -51,6 +177,9 @@ int PostAddRecord(const char *board, const fileheader_t *fhdr)
     strlcpy(req.extra.userid, userid, sizeof(req.extra.userid));
     printf(" (userref: %s.%d)", req.extra.userid, req.extra.userref);
 
+    // TODO try harder to parse content, to remove header and re-construct
+    // comments.
+
     s = toconnectex(POSTD_ADDR, 10);
     if (s < 0)
         return 1;
@@ -82,13 +211,20 @@ void rebuild_board(int bid GCC_UNUSED, boardheader_t *bp)
             printf(" - Skipped (%s).\n", fhdr.filename);
             continue;
         }
+        // Not sure why but some filename may contain ' '.
+        if (strchr(fhdr.filename, ' ')) {
+            *strchr(fhdr.filename, ' ') = 0;
+        }
         setbfile(fpath, bp->brdname, fhdr.filename);
         if (dashs(fpath) < 1) {
             printf(" - Non-Exist (%s).\n", fhdr.filename);
             continue;
         }
 
+        // TODO Add .DIR sequence number.
+
         printf(" - Adding %s", fhdr.filename);
+        // ProcessPost(fpath);
         PostAddRecord(bp->brdname, &fhdr);
         printf("\n");
     }