diff options
author | Fumitoshi UKAI <ukai@debian.or.jp> | 2003-01-15 16:11:43 +0000 |
---|---|---|
committer | Fumitoshi UKAI <ukai@debian.or.jp> | 2003-01-15 16:11:43 +0000 |
commit | dfd33cccd5e2b4d169eb0f0ca7cccfc998b979b2 (patch) | |
tree | e48a0e99a4922bf7a8504fbbf03442c12fee49ff /news.c | |
parent | [w3m-dev 03639] Re: smb.cgi (diff) | |
download | w3m-dfd33cccd5e2b4d169eb0f0ca7cccfc998b979b2.tar.gz w3m-dfd33cccd5e2b4d169eb0f0ca7cccfc998b979b2.zip |
[w3m-dev 03640] Re: cleanup (don't close connection of news server)
* anchor.c (_put_ahchor_news): always conv_str
(_put_anchor_all): always conv_str
* etc.c (close_all_fds): deleted
(close_all_fds_except): added, except fd=f is left open
* file.c (guess_filename): added
(UFhalfclose): added
(convertLine): cleanup_line if not raw mode
check uf
(readHeader): always convertLine
(loadGeneralFile): rewrite
(loadGopherDir): return Str, args change to ParsedURL and code
rewrite
(saveBuffer): always conv_str
(_doFileCopy): close_all_fds
(doFileSave): close_all_fds_except
(uncompress_stream): dup, close_all_fds_except
* form.c (form_fputs_decode): always conv_str
(input_textarea): convertLine
* frame.c (createFrameFile): convertLine
* ftp.c (loadFTPDir): arg code
rewrite
(readFTPDir): convertLine
* html.h (UFfileno): added
* image.c (loadImage): close_all_fds
* indep.h (RAW_MODE): added
* local.c (loadLocalDir): return Str
(dirBuffer): rewrite
(localcgi_popen_r): close_all_fds
* main.c (main): check SCM_LOCAL
print err_msg
* news.c (news_command): args cmd and arg
(news_quit): news_command
(openNewsStream): news_command
(readNewsgroup): deleted
(loadNewsgroup): added
(closeNews): added
* proto.h (loadGopherDir): update
(conv_str): define for no JP_CHARSET
(readFTPDir): deleted
(loadFTPDir): added
(readNewsgroup): deleted
(loadNewsgroup): added
(dirBuffer): deleted
(loadLocalDir): added
(close_all_fds): defined by close_all_fds_except
(close_all_fds_except): added
From: Hironori SAKAMOTO <hsaka@mth.biglobe.ne.jp>
Diffstat (limited to '')
-rw-r--r-- | news.c | 73 |
1 files changed, 45 insertions, 28 deletions
@@ -1,4 +1,4 @@ -/* $Id: news.c,v 1.11 2003/01/10 17:06:25 ukai Exp $ */ +/* $Id: news.c,v 1.12 2003/01/15 16:11:43 ukai Exp $ */ #include "fm.h" #include "myctype.h" #include <stdio.h> @@ -33,14 +33,18 @@ KeyAbort(SIGNAL_ARG) } static Str -news_command(News * news, char *command, int *status) +news_command(News * news, char *cmd, char *arg, int *status) { Str tmp; if (!news->host) return NULL; - if (command) { - fprintf(news->wf, "%s\r\n", command); + if (cmd) { + if (arg) + tmp = Sprintf("%s %s\r\n", cmd, arg); + else + tmp = Sprintf("%s\r\n", cmd); + fwrite(tmp->ptr, tmp->length, sizeof(char), news->wf); fflush(news->wf); } if (!status) @@ -82,11 +86,11 @@ news_open(News * news) if (!news->rf || !news->wf) goto open_err; IStype(news->rf) |= IST_UNCLOSE; - news_command(news, NULL, &status); + news_command(news, NULL, NULL, &status); if (status != 200 && status != 201) goto open_err; if (news->mode) { - news_command(news, Sprintf("MODE %s", news->mode)->ptr, &status); + news_command(news, "MODE", news->mode, &status); if (status != 200 && status != 201) goto open_err; } @@ -99,7 +103,7 @@ news_open(News * news) static void news_quit(News * news) { - news_command(news, "QUIT", NULL); + news_command(news, "QUIT", NULL, NULL); news_close(news); } @@ -257,8 +261,8 @@ openNewsStream(ParsedURL *pu) mode = NULL; if (current_news.host) { if (!strcmp(current_news.host, host) && current_news.port == port) { - tmp = Sprintf("MODE %s", mode ? mode : "READER"); - tmp = news_command(¤t_news, tmp->ptr, &status); + tmp = news_command(¤t_news, "MODE", mode ? mode : "READER", + &status); if (status != 200 && status != 201) news_close(¤t_news); } @@ -283,17 +287,15 @@ openNewsStream(ParsedURL *pu) } else { /* <newsgroup>/<message-id or article-number> */ *p++ = '\0'; - news_command(¤t_news, Sprintf("GROUP %s", group)->ptr, - &status); + news_command(¤t_news, "GROUP", group, &status); if (status != 211) return NULL; } if (strchr(p, '@')) /* <message-id> */ - news_command(¤t_news, Sprintf("ARTICLE <%s>", p)->ptr, + news_command(¤t_news, "ARTICLE", Sprintf("<%s>", p)->ptr, &status); else /* <article-number> */ - news_command(¤t_news, Sprintf("ARTICLE %s", p)->ptr, - &status); + news_command(¤t_news, "ARTICLE", p, &status); if (status != 220) return NULL; return current_news.rf; @@ -302,7 +304,7 @@ openNewsStream(ParsedURL *pu) } Str -readNewsgroup(ParsedURL *pu) +loadNewsgroup(ParsedURL *pu, char *code) { volatile Str page; Str tmp; @@ -312,11 +314,13 @@ readNewsgroup(ParsedURL *pu) char *volatile scheme, *volatile group, *volatile list; int status, i, first, last; volatile int flag = 0, start = 0, end = 0; - char code = '\0'; MySignalHandler(*volatile trap) (SIGNAL_ARG) = NULL; if (current_news.host == NULL || !pu->file || *pu->file == '\0') return NULL; +#ifdef JP_CHARSET + *code = DocumentCode; +#endif group = allocStr(pu->file, -1); if (pu->scheme == SCM_NNTP_GROUP) scheme = "/"; @@ -332,12 +336,15 @@ readNewsgroup(ParsedURL *pu) } qgroup = html_quote(group); group = file_unquote(group); - page = Sprintf("<title>Newsgroup: %s</title>\n\ -<h1>Newsgroup: %s</h1>\n<hr>\n", qgroup, qgroup); + page = Strnew_m_charp("<html>\n<head>\n<base href=\"", + parsedURL2Str(pu)->ptr, "\">\n<title>Newsgroup: ", + qgroup, "</title>\n</head>\n<body>\n<h1>Newsgroup: ", + qgroup, "</h1>\n<hr>\n", NULL); if (SETJMP(AbortLoading) != 0) { news_close(¤t_news); - Strcat_charp(page, "</table><p>Transfer Interrupted!\n"); + Strcat_charp(page, + "</table>\n<p>Transfer Interrupted!\n"); goto news_end; } trap = signal(SIGINT, KeyAbort); @@ -345,7 +352,7 @@ readNewsgroup(ParsedURL *pu) term_cbreak(); tmp = - news_command(¤t_news, Sprintf("GROUP %s", group)->ptr, &status); + news_command(¤t_news, "GROUP", group, &status); if (status != 211) goto news_list; if (sscanf(tmp->ptr, "%d %d %d %d", &status, &i, &first, &last) != 4) @@ -369,8 +376,11 @@ readNewsgroup(ParsedURL *pu) if (end - start > MaxNewsMessage - 1) start = end - MaxNewsMessage + 1; } - page = Sprintf("<title>Newsgroup: %s %d-%d</title>\n\ -<h1>Newsgroup: %s %d-%d</h1>\n<hr>\n", qgroup, start, end, qgroup, start, end); + page = Sprintf("<html>\n<head>\n<base href=\"%s\">\n\ +<title>Newsgroup: %s %d-%d</title>\n\ +</head>\n<body>\n<h1>Newsgroup: %s %d-%d</h1>\n<hr>\n", + parsedURL2Str(pu)->ptr, qgroup, start, end, qgroup, start, + end); if (start > first) { i = start - MaxNewsMessage; if (i < first) @@ -380,7 +390,7 @@ readNewsgroup(ParsedURL *pu) } Strcat_charp(page, "<table>\n"); - news_command(¤t_news, Sprintf("XOVER %d-%d", start, end)->ptr, + news_command(¤t_news, "XOVER", Sprintf("%d-%d", start, end)->ptr, &status); if (status == 224) { f.scheme = SCM_NEWS; @@ -407,8 +417,8 @@ readNewsgroup(ParsedURL *pu) if (!(q = strchr(p, '>')) && !(q = strchr(p, '\t'))) continue; *q = '\0'; - s = convertLine(&f, decodeMIME(s), &code, HEADER_MODE)->ptr; - n = convertLine(&f, decodeMIME(n), &code, HEADER_MODE)->ptr; + s = convertLine(&f, decodeMIME(s), code, HEADER_MODE)->ptr; + n = convertLine(&f, decodeMIME(n), code, HEADER_MODE)->ptr; add_news_message(page, i, t, n, s, p, scheme, pu->scheme == SCM_NNTP_GROUP ? qgroup : NULL); } @@ -417,7 +427,7 @@ readNewsgroup(ParsedURL *pu) init_stream(&f, SCM_NEWS, current_news.rf); buf = newBuffer(INIT_BUFFER_WIDTH); for (i = start; i <= end && i <= last; i++) { - news_command(¤t_news, Sprintf("HEAD %d", i)->ptr, &status); + news_command(¤t_news, "HEAD", Sprintf("%d", i)->ptr, &status); if (status != 221) continue; readHeader(&f, buf, FALSE, NULL); @@ -449,10 +459,10 @@ readNewsgroup(ParsedURL *pu) flag = 1; news_list: - tmp = Sprintf("LIST ACTIVE %s", group); + tmp = Sprintf("ACTIVE %s", group); if (!strchr(group, '*')) Strcat_charp(tmp, ".*"); - news_command(¤t_news, tmp->ptr, &status); + news_command(¤t_news, "LIST", tmp->ptr, &status); if (status != 215) goto news_end; while (1) { @@ -481,6 +491,7 @@ readNewsgroup(ParsedURL *pu) Strcat_charp(page, "</table>\n"); news_end: + Strcat_charp(page, "</body>\n</html>\n"); if (fmInitialized) term_raw(); signal(SIGINT, trap); @@ -488,6 +499,12 @@ readNewsgroup(ParsedURL *pu) } void +closeNews(void) +{ + news_close(¤t_news); +} + +void disconnectNews(void) { news_quit(¤t_news); |