X-Git-Url: https://code.citadel.org/?a=blobdiff_plain;f=webcit%2Ffeed_generator.c;h=34b721bdd248ec35fd8902a6558e69902d2eb6f5;hb=4b4dc864ede7c5d8d956febe4a0afb422b78e7c4;hp=648309cc4551d54dc95212497bd2f5af50588046;hpb=1d82485e0277efce7a74c579584a588f681c7c89;p=citadel.git diff --git a/webcit/feed_generator.c b/webcit/feed_generator.c index 648309cc4..34b721bdd 100644 --- a/webcit/feed_generator.c +++ b/webcit/feed_generator.c @@ -36,9 +36,9 @@ void feed_rss_one_message(long msgnum) { const char *BufPtr = NULL; StrBuf *Line = NewStrBufPlain(NULL, 1024); char buf[1024]; + int permalink_hash = 0; - /* FIXME if this is a blog room we only want to include top-level messages */ - + /* Phase 1: read the message into memory */ serv_printf("MSG4 %ld", msgnum); serv_getln(buf, sizeof buf); if (buf[0] != '1') return; @@ -47,64 +47,95 @@ void feed_rss_one_message(long msgnum) { StrBufAppendPrintf(ServerResponse, "%s\n", buf); } - wc_printf(""); - wc_printf("%s/readfwd?go=", ChrPtr(site_prefix)); - urlescputs(ChrPtr(WC->CurRoom.name)); - wc_printf("?start_reading_at=%ld", msgnum); - + /* Phase 2: help SkyNet become self-aware */ + BufPtr = NULL; while (StrBufSipLine(Line, ServerResponse, &BufPtr), ((BufPtr!=StrBufNOTNULL)&&(BufPtr!=NULL)) ) { - safestrncpy(buf, ChrPtr(Line), sizeof buf); if (in_body) { - if (in_messagetext) { - StrBufAppendBufPlain(messagetext, buf, -1, 0); - StrBufAppendBufPlain(messagetext, HKEY("\r\n"), 0); - } - else if (IsEmptyStr(buf)) { - in_messagetext = 1; - } + /* do nothing */ + } + else if (StrLength(Line) == 0) { + ++in_body; } - else if (!strncasecmp(buf, "subj=", 5)) { - wc_printf(""); - escputs(&buf[5]); - wc_printf(""); - ++found_title; + else if ((StrLength(Line) > 5) && (!strncasecmp(ChrPtr(Line), "wefw=", 5))) { + is_top_level_post = 0; /* presence of references means it's a reply/comment */ } - else if (!strncasecmp(buf, "exti=", 5)) { - wc_printf(""); - escputs(&buf[5]); - wc_printf(""); - ++found_guid; + else if ((StrLength(Line) > 5) && (!strncasecmp(ChrPtr(Line), "msgn=", 5))) { + StrBufCutLeft(Line, 5); + permalink_hash = ThreadIdHash(Line); } - else if (!strncasecmp(buf, "time=", 5)) { - http_datestring(pubdate, sizeof pubdate, atol(&buf[5])); - wc_printf("%s", pubdate); + } + + /* + * Phase 3: output the message in RSS form + * (suppress replies [comments] if this is a blog room) + */ + if ( (WC->CurRoom.view != VIEW_BLOG) || (is_top_level_post == 1) ) { + wc_printf(""); + wc_printf("%s/readfwd?go=", ChrPtr(site_prefix)); + urlescputs(ChrPtr(WC->CurRoom.name)); + if ((WC->CurRoom.view == VIEW_BLOG) && (permalink_hash != 0)) { + wc_printf("?p=%d", permalink_hash); } - else if (!strncasecmp(buf, "wefw=", 5)) { - is_top_level_post = 0; /* presence of references means it's a reply/comment */ + else { + wc_printf("?start_reading_at=%ld", msgnum); } - else if (!strncasecmp(buf, "text", 4)) { - if (!found_title) { - wc_printf("Message #%ld", msgnum); + wc_printf(""); + + BufPtr = NULL; + in_body = 0; + in_messagetext = 0; + while (StrBufSipLine(Line, ServerResponse, &BufPtr), ((BufPtr!=StrBufNOTNULL)&&(BufPtr!=NULL)) ) { + safestrncpy(buf, ChrPtr(Line), sizeof buf); + if (in_body) { + if (in_messagetext) { + StrBufAppendBufPlain(messagetext, buf, -1, 0); + StrBufAppendBufPlain(messagetext, HKEY("\r\n"), 0); + } + else if (IsEmptyStr(buf)) { + in_messagetext = 1; + } + } + else if (!strncasecmp(buf, "subj=", 5)) { + wc_printf(""); + escputs(&buf[5]); + wc_printf(""); + ++found_title; + } + else if (!strncasecmp(buf, "exti=", 5)) { + wc_printf(""); + escputs(&buf[5]); + wc_printf(""); + ++found_guid; } - if (!found_guid) { - wc_printf("%ld@%s", - msgnum, - ChrPtr(WC->serv_info->serv_humannode) - ); + else if (!strncasecmp(buf, "time=", 5)) { + http_datestring(pubdate, sizeof pubdate, atol(&buf[5])); + wc_printf("%s", pubdate); + } + else if (!strncasecmp(buf, "text", 4)) { + if (!found_title) { + wc_printf("Message #%ld", msgnum); + } + if (!found_guid) { + wc_printf("%ld@%s", + msgnum, + ChrPtr(WC->serv_info->serv_humannode) + ); + } + wc_printf(""); + in_body = 1; + messagetext = NewStrBuf(); } - wc_printf(""); - in_body = 1; - messagetext = NewStrBuf(); } - } + + if (in_body) { + cdataout((char*)ChrPtr(messagetext)); + FreeStrBuf(&messagetext); + wc_printf(""); + } - if (in_body) { - cdataout((char*)ChrPtr(messagetext)); - FreeStrBuf(&messagetext); - wc_printf(""); + wc_printf(""); } - wc_printf(""); FreeStrBuf(&Line); FreeStrBuf(&ServerResponse); return; @@ -124,7 +155,7 @@ void feed_rss_do_messages(void) { Stat.maxload = INT_MAX; Stat.lowest_found = (-1); Stat.highest_found = (-1); - num_msgs = load_msg_ptrs("MSGS ALL", &Stat, NULL); + num_msgs = load_msg_ptrs("MSGS ALL", NULL, &Stat, NULL); if (num_msgs < 1) return; i = num_msgs; /* convention is to feed newest-to-oldest */ @@ -236,17 +267,16 @@ void tmplput_rssmeta(StrBuf *Target, WCTemplputParams *TP) */ void tmplput_rssbutton(StrBuf *Target, WCTemplputParams *TP) { - wcsession *WCC = WC; - char feed_link[1024]; - char encoded_link[1024]; + StrBuf *FeedLink = NULL; - strcpy(feed_link, "/feed_rss?go="); - urlesc(&feed_link[20], sizeof(feed_link) - 20, (char *)ChrPtr(WCC->CurRoom.name) ); - CtdlEncodeBase64(encoded_link, feed_link, strlen(feed_link), 0); + FeedLink = NewStrBufPlain(HKEY("/feed_rss?go=")); + StrBufUrlescAppend(FeedLink, WC->CurRoom.name, NULL); - StrBufAppendPrintf(Target, "", encoded_link); - StrBufAppendPrintf(Target, "\"RSS\""); + StrBufAppendPrintf(Target, "\"RSS\""); StrBufAppendPrintf(Target, ""); + FreeStrBuf(&FeedLink); }