/*
    prot_nntp.* - nntp protocol handler
    Copyright (C) 1999-2004  Matthew Mueller <donut AT dakotacom.net>

    This program is free software; you can redistribute it and/or modify
    it under the terms of the GNU General Public License as published by
    the Free Software Foundation; either version 2 of the License, or
    (at your option) any later version.

    This program is distributed in the hope that it will be useful,
    but WITHOUT ANY WARRANTY; without even the implied warranty of
    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
    GNU General Public License for more details.

    You should have received a copy of the GNU General Public License
    along with this program; if not, write to the Free Software
    Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
*/

#ifdef HAVE_CONFIG_H
#include "config.h"
#endif
#include "prot_nntp.h"
#include <list>
#include <stdio.h>
#include <stdlib.h>
#include <ctype.h>

#include "misc.h"
#include "path.h"
#include "termstuff.h"
#include "strreps.h"
#include <stdlib.h>
#include <errno.h>
#include <string.h>
#include <time.h>
#include <unistd.h>
#include "log.h"
#include "file.h"
#include "nget.h"
#include "status.h"
#include "strtoker.h"
#include "par.h"
#include "decode.h"

extern SockPool sockpool;


static void printCommEx(const baseEx &e, const c_server::ptr &s, int redone, const nget_options &options) {
	if (e.isfatal())
		print_ex_with_message(e, "fatal error, won't try %s again", s->alias.c_str());
	else if (redone+1 < options.maxretry)
		print_ex_with_message(e, "error, will try %s again", s->alias.c_str());
	else //if this is the last retry, don't say that we will try it again.
		print_ex_with_message(e, "error, retries exhausted, won't try %s again", s->alias.c_str());
}

int c_prot_nntp::putline(int echo,const char * str,...){
	va_list ap;
	va_start(ap,str);
	int i=connection->doputline(echo,str,ap);
	va_end(ap);
	return i;
}
int c_prot_nntp::stdputline(int echo,const char * str,...){
	va_list ap;
	int i;
	va_start(ap,str);
	connection->doputline(echo,str,ap);
	va_end(ap);
	i=getreply(echo);
	if (i==450 || i==480) {
		nntp_auth();
		va_start(ap,str);
		connection->doputline(echo,str,ap);
		va_end(ap);
		i=getreply(echo);
	}
	return i;
}

int c_prot_nntp::chkreply(int reply) const {
//	int i=getreply(echo);
	if (reply==400) {
		// 400 response is used on connection for "Service temporarily unavailable" or during a session if the server has to terminate the connection for some reason.
		connection->close(1);
		throw ProtocolExError(Ex_INIT,"server says byebye: %s", cbuf);
	}
	if (reply/100!=2)
		throw ProtocolExFatal(Ex_INIT,"bad reply %i: %s",reply,cbuf);
	return reply;
}

int c_prot_nntp::chkreply_setok(int reply){
	//only set the server_ok flag if the command had a "normal" error status (like group not found, article expired, etc).  If the command sequence completes successfully, then the server_ok will be set before releasing the ConnectionHolder.
	if (reply/100==4 && reply!=400)
		connection->server_ok = true;
	return chkreply(reply);
}

int c_prot_nntp::getline(int echo){
	int r = connection->getline(echo);
	cbuf = connection->sock.rbufp();
	return r;
}

int c_prot_nntp::getreply(int echo){
	int code;
	if ((code=getline(echo))>=0)
		code=atoi(cbuf);
	return code;
}


class Progress {
	public:
		time_t lasttime, starttime, curt;
		bool needupdate(void) {
			time(&curt);
			return !quiet && curt>lasttime;
		};
		Progress(void) {
			lasttime = 0;
			starttime = time(NULL);
		};
};


class DumbProgress : public Progress {
	public:
		void print_retrieving(const char *what, ulong done, ulong bytes){
			time(&lasttime);
			time_t dtime=lasttime-starttime;
			long Bps=(dtime>0)?bytes/dtime:0;
			if (!quiet) clear_line_and_return();
			printf("Retrieving %s: %lu %liB/s %s",what,done,Bps,durationstr(dtime).c_str());

			fflush(stdout);//@@@@
		}
};

void c_prot_nntp::nntp_dogetgrouplist(void){
	ulong bytes=0, done=0;
	DumbProgress progress;
	while (1) {
		if (progress.needupdate())
			progress.print_retrieving("group list", done, bytes);
		bytes+=getline(debug>=DEBUG_ALL);
		if (cbuf[0]=='.' && cbuf[1]=='\0')break;
		char * p = strpbrk(cbuf, " \t");
		if (p)
			*p = '\0';
		//####do something with last/first/postingallowed info?

		glist->addgroup(connection->server->serverid, cbuf);
		done++;
	}
	if(quiet<2){
		progress.print_retrieving("group list", done, bytes);
		printf("\n");
	}
}
void c_prot_nntp::nntp_dogrouplist(void){
	c_nntp_grouplist_server_info::ptr servinfo = glist->getserverinfo(connection->server->serverid);
	string newdate;
	int r=stdputline(quiet<2,"DATE");
	if (r==111)
		newdate = cbuf+4;
	else {
		char tbuf[40];
		time_t t = time(NULL);
		tconv(tbuf, 40, &t, "%Y%m%d%H%M%S", 0);
		printf("bad DATE reply '%s', using local date %s\n", cbuf, tbuf);
		newdate = tbuf;
	}

	if (!servinfo->date.empty()) {
		int dsepn = servinfo->date.size()-6;
		chkreply(stdputline(quiet<2,"NEWGROUPS %s %s GMT",servinfo->date.substr(0,dsepn).c_str(), servinfo->date.substr(dsepn,6).c_str()));
	}
	if (servinfo->date.empty()) {
		chkreply(stdputline(quiet<2,"LIST"));
	}

	nntp_dogetgrouplist();
	servinfo->date = newdate;
}

void c_prot_nntp::nntp_dogrouplist(const char *wildmat){
	chkreply(stdputline(quiet<2,"LIST ACTIVE %s", wildmat));
	nntp_dogetgrouplist();
}

void c_prot_nntp::nntp_dogroupdescriptions(const char *wildmat){
	ulong bytes=0, done=0;
	int r;
	if (wildmat)
		r=stdputline(quiet<2,"LIST NEWSGROUPS %s", wildmat);
	else
		r=stdputline(quiet<2,"LIST NEWSGROUPS");
	if (r/100!=2) {
		// if server doesn't support LIST NEWSGROUPS, just ignore the error.
		return;
	}
	DumbProgress progress;
	while (1) {
		if (progress.needupdate())
			progress.print_retrieving("group descriptions", done, bytes);

		bytes+=getline(debug>=DEBUG_ALL);
		if (cbuf[0]=='.' && cbuf[1]=='\0')break;
		char * desc = strpbrk(cbuf, " \t");
		if (desc) {
			*desc = '\0';
			desc++;
			desc += strspn(desc, " \t");
		}

		glist->addgroupdesc(connection->server->serverid, cbuf, desc ? desc : "");
		done++;
	}
	if(quiet<2){
		progress.print_retrieving("group descriptions", done, bytes);
		printf("\n");
	}
}

void c_prot_nntp::nntp_grouplist(int update, const nget_options &options){
	if (!glist)
		glist = new c_nntp_grouplist(ngcachehome+"newsgroups");
	if (update) {
		c_server::ptr s;
		list<c_server::ptr> doservers;
		c_server_priority_grouping *priogroup;
		if (!(priogroup=nconfig.getpriogrouping("_grouplist")))
			priogroup=nconfig.getpriogrouping("default");
		nntp_simple_prioritize(priogroup, doservers);

		int redone=0, succeeded=0, attempted=doservers.size();
		while (!doservers.empty() && redone<options.maxretry) {
			if (redone){
				printf("nntp_grouplist: trying again. %i\n",redone);
				if (options.retrydelay)
					sleep(options.retrydelay);
			}
			list<c_server::ptr>::iterator dsi = doservers.begin();
			list<c_server::ptr>::iterator ds_erase_i;
			while (dsi != doservers.end()){
				s=(*dsi);
				assert(s);
				PDEBUG(DEBUG_MED,"nntp_grouplist: serv(%s) %f>=%f",s->alias.c_str(),priogroup->getserverpriority(s),priogroup->defglevel);
				try {
					ConnectionHolder holder(&sockpool, &connection, s);
					nntp_doopen();
					nntp_dogrouplist();
					nntp_dogroupdescriptions();//####make this a seperate option?
					succeeded++;
					connection->server_ok=true;
				} catch (baseCommEx &e) {
					printCommEx(e, s, redone, options);
					if (!e.isfatal()) {
						++dsi;
						continue;//don't remove server from list
					}
				}
				ds_erase_i = dsi;
				++dsi;
				doservers.erase(ds_erase_i);
			}
			redone++;
		}
		if (succeeded) {
			set_grouplist_warn_status(attempted - succeeded);
			set_grouplist_ok_status();
		}else {
			set_grouplist_error_status();
			printf("no servers queried successfully\n");
		}
	}
}

void c_prot_nntp::nntp_xgrouplist(const t_xpat_list &patinfos, const nget_options &options){
	glist = new c_nntp_grouplist();

	c_server::ptr s;
	list<c_server::ptr> doservers;
	c_server_priority_grouping *priogroup;
	if (!(priogroup=nconfig.getpriogrouping("_grouplist")))
		priogroup=nconfig.getpriogrouping("default");
	nntp_simple_prioritize(priogroup, doservers);

	int redone=0, succeeded=0, attempted=doservers.size();
	while (!doservers.empty() && redone<options.maxretry) {
		if (redone){
			printf("nntp_xgrouplist: trying again. %i\n",redone);
			if (options.retrydelay)
				sleep(options.retrydelay);
		}
		list<c_server::ptr>::iterator dsi = doservers.begin();
		list<c_server::ptr>::iterator ds_erase_i;
		while (dsi != doservers.end()){
			s=(*dsi);
			assert(s);
			PDEBUG(DEBUG_MED,"nntp_xgrouplist: serv(%s) %f>=%f",s->alias.c_str(),priogroup->getserverpriority(s),priogroup->defglevel);
			try {
				ConnectionHolder holder(&sockpool, &connection, s);
				nntp_doopen();
				for (t_xpat_list::const_iterator i = patinfos.begin(); i != patinfos.end(); ++i) {
					nntp_dogrouplist((*i)->wildmat.c_str());
					nntp_dogroupdescriptions((*i)->wildmat.c_str());//####make this a seperate option? //######handle (skip?) servers that ignore wildmat option to LIST NEWSGROUPS somehow?  .. not that its really possible to tell before hand whether the server will ignore it.
				}
				succeeded++;
				connection->server_ok=true;
			} catch (baseCommEx &e) {
				printCommEx(e, s, redone, options);
				if (!e.isfatal()) {
					++dsi;
					continue;//don't remove server from list
				}
			}
			ds_erase_i = dsi;
			++dsi;
			doservers.erase(ds_erase_i);
		}
		redone++;
	}
	if (succeeded) {
		set_grouplist_warn_status(attempted - succeeded);
		set_grouplist_ok_status();
	}else {
		set_grouplist_error_status();
		printf("no servers queried successfully\n");
	}
}

void c_prot_nntp::nntp_grouplist_search(const t_grouplist_getinfo_list &getinfos, const nget_options &options){
	if (glist) {
		glist->printinfos(getinfos);
		//####should we glist=NULL; here?
	} else {
		nntp_grouplist_printinfos(getinfos);
	}
}

void c_prot_nntp::nntp_grouplist_search(const t_grouplist_getinfo_list &getinfos, const t_xpat_list &patinfos, const nget_options &options){
	nntp_xgrouplist(patinfos, options);
	glist->printinfos(getinfos);
	//####should we glist=NULL; here?
}


class XoverProgress : public Progress {
	public:
		void print_retrieving_headers(ulong low,ulong high,ulong done,ulong realtotal,ulong total,ulong bytes,int doneranges,int streamed,int totalranges){
			time(&lasttime);
			time_t dtime=lasttime-starttime;
			long Bps=(dtime>0)?bytes/dtime:0;
			long Bph=(done>0)?bytes/done:3;//if no headers have been retrieved yet, set the bytes per header to 3 just to get some sort of timeleft display.  (3=strlen(".\r\n"))
			if (!quiet) clear_line_and_return();
			printf("Retrieving headers %lu-%lu : %lu/%lu/%lu %3li%% %liB/s %s",low,high,done,realtotal,total,(realtotal!=0)?((done+(total-realtotal))*100/total):0,Bps,durationstr(realtotal==done?dtime:(Bps>0)?((realtotal-done)*Bph)/(Bps):0).c_str());
			if (totalranges>1)
				printf(" (%i/%i/%i)",doneranges,doneranges+streamed,totalranges);
			fflush(stdout);//@@@@
		};
};
/*
2019    Re: question    Katya Moon <MoonAngel@shadowrealm.com>  Wed, 17 Nov 1999 09:42:53 -0600 <xMwyOI+pJ=mVLqMociXeHexHGW92@4ax.com>      <3830CF31.D41E1511@tampabay.rr.com>     1145    9       Xref: rQdQ alt.chocobo:2019
2020    Re: well then!  Katya Moon <MoonAngel@shadowrealm.com>  Wed, 17 Nov 1999 09:44:37 -0600 <Fs0yOEVKaIamwKGBgE=82Fk21OcM@4ax.com>      <3831B98A.72815A01@tampabay.rr.com>     1209    10      Xref: rQdQ alt.chocobo:2020
2021    free me from this hideous thing!        Selah <sslanka@tampabay.rr.com> Wed, 17 Nov 1999 20:17:35 GMT   <38330E93.C8AC2671@tampabay.rr.com>         1142    8       Xref: rQdQ alt.chocobo:2021
.
0=articlenum
1=subject
2=author
3=date
4=message id
5=references (aka in-reply-to) (used for threading)
6=bytes
7=lines
... following are optional (and possibly different):
8=crossreferences

The sequence of fields must be in this order:
subject, author, date, message-id, references, byte count, and line count.
Other optional fields may follow line count. These fields are specified by
examining the response to the LIST OVERVIEW.FMT command. Where no data
exists, a null field must be provided
*/
void c_prot_nntp::doxover(const c_group_info::ptr &group, c_nrange *r){
	if (r->empty())
		return;
	XoverProgress progress;
	ulong lowest=r->rlist.begin()->second, highest=r->rlist.rbegin()->first;
	ulong bytes=0, realnum=0, realtotal=r->get_total(), last;
	ulong total=realtotal;
	assert(connection);

	t_rlist::iterator r_ri;
	t_rlist::iterator w_ri=r->rlist.begin();
	int streamed = 0, totalranges = r->num_ranges(), doneranges = 0;
	for (r_ri=r->rlist.begin();r_ri!=r->rlist.end();++r_ri, ++doneranges){
		if (progress.needupdate())
			progress.print_retrieving_headers(lowest,highest,realnum,realtotal,total,bytes,doneranges,streamed,totalranges);
		char *p;
		char *t[10];
		int i;
		while (w_ri!=r->rlist.end() && streamed<=connection->server->maxstreaming) { 
			ulong low=(*w_ri).second, high=(*w_ri).first;
			if (low==high)
				putline(debug>=DEBUG_MED,"XOVER %lu",low);//save a few bytes
			else
				putline(debug>=DEBUG_MED,"XOVER %lu-%lu",low,high);
			++w_ri;
			++streamed;
		}
		ulong low=(*r_ri).second, high=(*r_ri).first;
		last = low;
		chkreply_setok(getreply(debug>=DEBUG_MED));
		bytes+=strlen(cbuf)+2;//#### ugly.
		--streamed;
		unsigned long an=0;
		c_nntp_header nh;
		nh.group = group;
		char * tp;
		do {
			bytes+=getline(debug>=DEBUG_ALL);
			if (cbuf[0]=='.')break;
			p=cbuf;
			for(i=0;i<10;i++){
				if((t[i]=goodstrtok(&p,'\t'))==NULL){
					break;
				}
				// fields 0, 6, 7 must all be numeric
				// otherwise restart
				if (i==0 || i==6 || i==7){
					tp=t[i];
					while (*tp){
						if (!isdigit(*tp) && !isspace(*tp))
							break;
						tp++;
					}
					// did the test finish, and/or was it a blank field?
					if (*tp && tp!=t[i]){
						// no - get out and read the next line
						// Is this how we want to handle it? SMW
						printf("error retrieving xover (%i non-numeric)\n",i);
						break;
					}
				}
			}
			if (i<=1 && streamed) {
				if (atoul(cbuf)==224){//some servers (DNEWS) will drop data while doing xover streaming, but seeminly only the ends of the requests.  Then you get a 224 data follows message for the next range without getting the rest of the current range or the "." line.  Retrying starting from the current range would be better, but this is easier ;)
					connection->server->maxstreaming=0;
					connection->close(1);
					set_xover_warn_status();
					throw ProtocolExError(Ex_INIT, "XOVER streaming error: recieved start of next range without end of current.  Setting maxstreaming to 0. (You may wish to decrease or disable maxstreaming for this server in your ngetrc.)");
				}
			}
			if (i>7){
				//	c=new c_nntp_cache_item(atol(t[0]),	decode_textdate(t[3]), atol(t[6]), atol(t[7]),t[1],t[2]);
				//gcache->additem(c);
				an=atoul(t[0]);
				nh.set(t[1],t[2],an,decode_textdate(t[3]),atoul(t[6]),atoul(t[7]),t[4],t[5]);
				nh.serverid=connection->server->serverid;
				//gcache->additem(an, decode_textdate(t[3]), atol(t[6]), atol(t[7]),t[1],t[2]);
				gcache->additem(&nh);
				//delete nh;
				realnum++;
				if (an<low || an>high || an<last) {
					printf("weird: articlenum %lu not in range %lu-%lu (last=%lu)\n",an,low,high,last);
					set_xover_warn_status();
				} else {
#ifndef NDEBUG
					ulong ort=realtotal;
#endif
					realtotal -= an - last;
					assert(ort>=realtotal);
					last = an + 1;
				}
				if (progress.needupdate())
					progress.print_retrieving_headers(lowest,highest,realnum,realtotal,total,bytes,doneranges,streamed,totalranges);
			}else{
				set_xover_warn_status();
				printf("error retrieving xover (%i<=7): ",i);
				for (int j=0;j<=i;j++)
					if (t[j])
						printf("%i:%s ",j,t[j]);
				if (p)
					printf("*:%s",p);
				printf("\n");
			}
		}while(1);
#ifndef NDEBUG
		ulong ort=realtotal;
#endif
		realtotal -= high - last + 1;
		assert(ort>=realtotal);
	}
	if(quiet<2 /*&& an*/){
		progress.print_retrieving_headers(lowest,highest,realnum,realtotal,total,bytes,doneranges,streamed,totalranges);
		printf("\n");
	}
}
void c_prot_nntp::doxover(const c_group_info::ptr &group, ulong low, ulong high){
	c_nrange r;
	r.insert(low, high);
	doxover(group, &r);
}

class ListgroupProgress : public Progress {
	public:
		void print_retrieving_article_list(ulong low, ulong high, ulong done, ulong total, ulong bytes, bool finished=false){
			time(&lasttime);
			time_t dtime=lasttime-starttime;
			long Bps=(dtime>0)?bytes/dtime:0;
			long Bph=(done>0)?bytes/done:3;//if no headers have been retrieved yet, set the bytes per header to 3 just to get some sort of timeleft display.  (3=strlen(".\r\n"))
			if (!quiet) clear_line_and_return();
			printf("Retrieving article list %lu-%lu : %lu/%lu %3li%% %liB/s %s",low,high,done,total,(finished || total==0)?100:done*100/total,Bps,durationstr(finished?dtime:(Bps>0)?((total-done)*Bph)/(Bps):0).c_str());

			fflush(stdout);//@@@@
		}
};
void c_prot_nntp::dolistgroup(c_nrange &existing, ulong lowest, ulong highest, ulong total) {
	ListgroupProgress progress;
	chkreply(stdputline(debug>=DEBUG_MED,"LISTGROUP"));
	ulong bytes=0, count=0, an;
	char *eptr;
	do {
		if (progress.needupdate())
			progress.print_retrieving_article_list(lowest,highest,count,total,bytes);
		bytes+=getline(debug>=DEBUG_ALL);
		if (cbuf[0]=='.')break;
		an = strtoul(cbuf, &eptr, 10);
		if (*cbuf=='\0' || *eptr!='\0') {
			printf("error retrieving article number\n");
			continue;
		}
		existing.insert(an);
		count++;
	}while (1);
	if(quiet<2){
		progress.print_retrieving_article_list(lowest,highest,count,total,bytes,true);
		printf("\n");
	}
}

void c_prot_nntp::nntp_dogroup(const c_group_info::ptr &group, ulong &num, ulong &low, ulong &high) {
	assert(connection);
	connection->curgroup=NULL; //unset curgroup, in case the group we asked for does not exist, some servers will keep us in the old group, whereas others will put us into the no group selected state.
	int reply = stdputline(quiet<2,"GROUP %s",group->group.c_str());
	if (reply/100==4) // if group doesn't exist, set ok flag.  Otherwise let XOVER/ARTICLE reply set it. (If we always set it here, failure of xover/article would never result in penalization.  But if we only set it after xover/article, then a host could be incorrectly penalized just because it didn't have the group (eg, if maxconnections=1 so it closed connection before any other commands could succeed and setok))
		chkreply_setok(reply);
	else
		chkreply(reply);
	connection->curgroup=group;

	char *p;
	p=strchr(cbuf,' ')+1;
	num=atoul(p);
	p=strchr(p,' ')+1;
	low=atoul(p);
	p=strchr(p,' ')+1;
	high=atoul(p);
	//printf("%i, %i, %i\n",num,low,high);
}

void c_prot_nntp::nntp_dogroup(const c_group_info::ptr &group, bool getheaders, int forcefullxover){
	ulong num,low,high;
	if (connection->curgroup!=group || getheaders){	
		nntp_dogroup(group, num,low,high);
	}

	if (getheaders){
		assert(gcache);
		const int fullxover = forcefullxover==-1 ? connection->server->fullxover : forcefullxover;

		c_nntp_server_info* servinfo=gcache->getserverinfo(connection->server->serverid);
		assert(servinfo);
		//shouldn't do fullxover2 on first update of group or if cached headers are ALL older than available headers
		if (servinfo->high!=0 && servinfo->high>=low && fullxover==2){
			c_nrange existing;
			dolistgroup(existing, low, high, num);

			c_nrange nonexistant;
			nonexistant.invert(existing);
			gcache->flush(servinfo,nonexistant,midinfo);
			servinfo->low=existing.empty()?low:existing.low();//####this ok?
			
			c_nrange r(existing);
			gcache->getxrange(servinfo,&r);//remove the article numbers we already have, leaving only the ones we still need to get.

			doxover(group, &r);	
		}else{
			if (low>servinfo->low)
				gcache->flushlow(servinfo,low,midinfo);
			if (fullxover){
				c_nrange r;
				gcache->getxrange(servinfo,low,high,&r);
				doxover(group, &r);
			}else{
				c_nrange r;

				if (servinfo->high==0)
					r.insert(low, high);
				else {
					if (servinfo->high<high)
						r.insert(servinfo->high+1, high);
					if (servinfo->low>low)
						r.insert(low, servinfo->low-1);
				}
				doxover(group, &r);
			}
		}
	}
};

void c_prot_nntp::nntp_simple_prioritize(c_server_priority_grouping *priogroup, list<c_server::ptr> &doservers){
	if (force_host){
		doservers.push_front(force_host);
	} else {
		t_server_list::iterator sli = nconfig.serv.begin();
		for (;sli!=nconfig.serv.end();++sli){
			c_server::ptr &s=(*sli).second;
			assert(s);
			if (priogroup->getserverpriority(s) >= priogroup->defglevel) {
				if (sockpool.is_connected(s)) //put current connected hosts at start of list
					doservers.push_front(s);
				else
					doservers.push_back(s);
			}
		}
	}
}


void c_prot_nntp::doxpat(c_nrange &r, c_xpat::ptr xpat, ulong total, ulong lowest, ulong highest) {
	assert(gcache);
	assert(connection);

	chkreply_setok(stdputline(debug>=DEBUG_MED,"XPAT %s %lu-%lu %s", xpat->field.c_str(), lowest, highest, xpat->wildmat.c_str()));
	
	ListgroupProgress progress;
	ulong bytes=0, realnum=0;
	ulong an;
	char *eptr;

	do {
		if (progress.needupdate())
			progress.print_retrieving_article_list(lowest,highest,realnum,total,bytes,false);
		bytes+=getline(debug>=DEBUG_ALL);
		if (cbuf[0]=='.')break;
		an = strtoul(cbuf, &eptr, 10);
		if (*cbuf=='\0' || !(*eptr==' ' || *eptr=='\t')) {
			printf("error retrieving article number\n");
			continue;
		}
		r.insert(an);
		realnum++;
		if (progress.needupdate())
			progress.print_retrieving_article_list(lowest,highest,realnum,total,bytes,false);
		
	}while (1);
	if(quiet<2 /*&& an*/){
		progress.print_retrieving_article_list(lowest,highest,realnum,total,bytes,true);
		printf("\n");
	}
}

void c_prot_nntp::nntp_xgroup(const c_group_info::ptr &group, const t_xpat_list &patinfos, const nget_options &options) {
	c_server::ptr s;
	list<c_server::ptr> doservers;
	nntp_simple_prioritize(group->priogrouping, doservers);

	int redone=0, succeeded=0, attempted=doservers.size();
	while (!doservers.empty() && redone<options.maxretry) {
		if (redone){
			printf("nntp_xgroup: trying again. %i\n",redone);
			if (options.retrydelay)
				sleep(options.retrydelay);
		}
		list<c_server::ptr>::iterator dsi = doservers.begin();
		list<c_server::ptr>::iterator ds_erase_i;
		while (dsi != doservers.end()){
			s=(*dsi);
			assert(s);
			PDEBUG(DEBUG_MED,"nntp_xgroup: serv(%s) %f>=%f",s->alias.c_str(),group->priogrouping->getserverpriority(s),group->priogrouping->defglevel);
			try {
				ConnectionHolder holder(&sockpool, &connection, s);
				nntp_doopen();
				ulong num,low,high;
				nntp_dogroup(group, num,low,high);
				c_nrange r;
				for (t_xpat_list::const_iterator i = patinfos.begin(); i != patinfos.end(); ++i)
					doxpat(r, *i, num, low, high);
				doxover(group, &r);
				succeeded++;
				connection->server_ok=true;
			} catch (baseCommEx &e) {
				printCommEx(e, s, redone, options);
				if (!e.isfatal()) {
					++dsi;
					continue;//don't remove server from list
				}
			}
			ds_erase_i = dsi;
			++dsi;
			doservers.erase(ds_erase_i);
		}
		redone++;
	}
	if (succeeded) {
		set_group_warn_status(attempted - succeeded);
		set_group_ok_status();
	}else {
		set_group_error_status();
		printf("no servers queried successfully\n");
	}

	gcache_ismultiserver = gcache->ismultiserver();
}

void c_prot_nntp::nntp_group(const c_group_info::ptr &ngroup, bool getheaders, const nget_options &options){
	if (group == ngroup && gcache && !getheaders)
		return; // group is already selected, don't waste time reloading it

	assert(ngroup);
	group=ngroup;
//	if (gcache) delete gcache;
	cleanupcache();

	midinfo=new meta_mid_info(ngcachehome, ngroup); 
	//gcache=new c_nntp_cache(nghome,group->group + ",cache");
	gcache=new c_nntp_cache(ngcachehome, group, midinfo);
	if (getheaders){
		c_server::ptr s;
		list<c_server::ptr> doservers;
		nntp_simple_prioritize(group->priogrouping, doservers);

		int redone=0, succeeded=0, attempted=doservers.size();
		while (!doservers.empty() && redone<options.maxretry) {
			if (redone){
				printf("nntp_group: trying again. %i\n",redone);
				if (options.retrydelay)
					sleep(options.retrydelay);
			}
			list<c_server::ptr>::iterator dsi = doservers.begin();
			list<c_server::ptr>::iterator ds_erase_i;
			while (dsi != doservers.end()){
				s=(*dsi);
				assert(s);
				PDEBUG(DEBUG_MED,"nntp_group: serv(%s) %f>=%f",s->alias.c_str(),group->priogrouping->getserverpriority(s),group->priogrouping->defglevel);
				try {
					ConnectionHolder holder(&sockpool, &connection, s);
					nntp_doopen();
					nntp_dogroup(ngroup, getheaders, options.fullxover);
					succeeded++;
					connection->server_ok=true;
				} catch (baseCommEx &e) {
					printCommEx(e, s, redone, options);
					if (!e.isfatal()) {
						++dsi;
						continue;//don't remove server from list
					}
				}
				ds_erase_i = dsi;
				++dsi;
				doservers.erase(ds_erase_i);
			}
			redone++;
		}
		if (succeeded) {
			set_group_warn_status(attempted - succeeded);
			set_group_ok_status();
		}else {
			set_group_error_status();
			printf("no servers queried successfully\n");
		}
	}

	gcache_ismultiserver = gcache->ismultiserver();
}

inline void arinfo::print_retrieving_articles(time_t curtime, quinfo*tot){
	dtime=curtime-starttime;
	Bps=(dtime>0)?bytesdone/dtime:0;
	if (!quiet) clear_line_and_return();
	if (tot && tot->doarticle_show_multi!=NO_SHOW_MULTI)
		printf("%s ",server_name);
	printf("%lu (%i/%i): %li/%liL %li/%liB %3li%% %liB/s %s",
			anum,partnum,partreq,linesdone,linestot,bytesdone,bytestot,
			(linestot!=0)?(linesdone*100/linestot):0,Bps,
			durationstr((linesdone>=linestot)?dtime:((Bps>0)?(bytestot-bytesdone)/(Bps):-1)).c_str());
	if (tot)
		printf(" %li/%li %s",tot->filesdone,tot->filestot,
				//(tot->bytesdone>=tot->bytestot)?curtime-tot->starttime:((Bps>0)?(tot->bytestot-tot->bytesdone)/(Bps):-1));
//				(linesdone>=linestot)?curtime-tot->starttime:((Bps>0)?(tot->bytestot-tot->bytesdone)/(Bps):-1));
				durationstr((linesdone>=linestot)?curtime-tot->starttime:((Bps>0)?(tot->bytesleft-bytesdone)/(Bps):-1)).c_str());
	fflush(stdout);
}

//inline void c_prot_nntp::nntp_print_retrieving_articles(long nnn, long tot,long done,long btot,long bbb,unsigned long obtot,unsigned long obdone,long ototf,long odonef,time_t tstarttime){
//	time_t dtime=lasttime-starttime;
//	long Bps=(dtime>0)?bbb/dtime:0;
//	printf("\rRetrieving article %li: %li/%liL %li/%liB %3li%% %liB/s %lis %li/%li %lis",nnn,done,tot,bbb,btot,(tot!=0)?(done*100/tot):0,Bps,(done>=tot)?dtime:((Bps>0)?(btot-bbb)/(Bps):-1),odonef,ototf,(obdone>=obtot)?lasttime-tstarttime:((Bps>0)?(botot-obdone)/(Bps):-1));
//	fflush(stdout);//@@@@
//}

int c_prot_nntp::nntp_doarticle_prioritize(c_nntp_part *part,t_nntp_server_articles_prioritized &sap,bool docurservmult){
	t_nntp_server_articles::iterator sai;
	c_nntp_server_article *sa=NULL;
	float prio;
	for (sai = part->articles.begin(); sai != part->articles.end(); ++sai){
		sa=(*sai);
		assert(sa);
		for (t_server_list_range servers = nconfig.getservers(sa->serverid); servers.first!=servers.second; ++servers.first) {
			const c_server::ptr &s = servers.first->second;
			if (force_host && s!=force_host)
				continue;
			prio=sa->group->priogrouping->getserverpriority(s);
			if (docurservmult){
				if (sockpool.is_connected(s))
					prio*=nconfig.curservmult;
			}
			PDEBUG(DEBUG_MED,"prioritizing server %s(%lu) article %lu prio %f",s->alias.c_str(),sa->serverid,sa->articlenum,prio);
			sap.insert(t_nntp_server_articles_prioritized::value_type(prio,t_real_server_article(sa,s)));
		}
	}

	if (docurservmult && !sap.empty()) {
		int connected=0, nonconnected=0;
		t_nntp_server_articles_prioritized::iterator i;
		pair<t_nntp_server_articles_prioritized::iterator,t_nntp_server_articles_prioritized::iterator> firstrange = sap.equal_range(sap.rend()->first);
		for (i=firstrange.first; i!=firstrange.second; ++i)
			if (sockpool.is_connected(i->second.second))
				++connected;
			else
				++nonconnected;

		if (connected && nonconnected) { //if both connected and nonconnected servers have the (same) highest priority, reprioritize the connected ones a bit higher to avoid excessive reconnecting.
			t_nntp_server_articles_prioritized::iterator ci;
			for (i=firstrange.first; i!=firstrange.second;){
				ci = i;
				++i;
				if (sockpool.is_connected(ci->second.second)) {
					prio=(*ci).first;
					sa=(*ci).second.first;
					c_server::ptr s = (*ci).second.second;
					sap.erase(ci);
					prio*=1.001;
					sap.insert(t_nntp_server_articles_prioritized::value_type(prio,t_real_server_article(sa,s)));
					PDEBUG(DEBUG_MED,"server %s(%lu) article %lu reprioritized %f",s->alias.c_str(),sa->serverid,sa->articlenum,prio);
				}
			}
		}

	}
	return 0;
}


int c_prot_nntp::nntp_dowritelite_article(c_file &fw,c_nntp_part *part,char *fn){
	fw.putf("0\n%s\n%s\n",group?group->group.c_str():"",fn);

	c_server::ptr whost;
	c_nntp_server_article *sa=NULL;
	t_nntp_server_articles_prioritized sap;
	t_nntp_server_articles_prioritized::iterator sapi;
	nntp_doarticle_prioritize(part,sap,false);
	fw.putf("%lu\n",(ulong)sap.size());
	for (sapi = sap.begin(); sapi != sap.end(); ++sapi){
		sa=(*sapi).second.first;
		whost=(*sapi).second.second;
		fw.putf("%s\t%s\t%s\n",whost->addr.c_str(),whost->user.c_str(),whost->pass.c_str());
		if (group)
			fw.putf("%lu\n",sa->articlenum);
		else
			fw.putf("%s\n",part->messageid.c_str());
		fw.putf("%lu\n%lu\n",sa->bytes,sa->lines);
	}
	return 0;
}

void c_prot_nntp::nntp_dogetarticle(arinfo*ari,quinfo*toti,list<string> &buf){
	int header=1;
	time_t curt,lastt=0;
	char *lp;
	time(&ari->starttime);
	curt=starttime;
	long glr;
	do {
		glr=getline(debug>=DEBUG_ALL);
		if (cbuf[0]=='.'){
			if(cbuf[1]==0)
				break;
			lp=cbuf+1;
		}else
			lp=cbuf;
		ari->bytesdone+=glr;
		ari->linesdone++;
		if (header && lp[0]==0){
			//			printf("\ntoasted header statssssssss\n");
			header=0;
			ari->linesdone=0;
			time(&ari->starttime);//bytes=0;
		}
		time(&curt);
		if (!quiet && curt>lastt){
			//		nntp_print_retrieving_articles(num,ltotal,lines,btotal,bytes);
			ari->print_retrieving_articles(curt,toti);
			lastt=curt;
		}
		buf.push_back(lp);
	}while(1);
	if (quiet<2){
		//nntp_print_retrieving_articles(num,ltotal,lines,btotal,bytes);
		ari->print_retrieving_articles(curt,toti);
		printf("\n");
	}

	//some servers report # of bytes a bit off of what we expect.
	if (!((ari->bytesdone <= ari->bytestot+3 && ari->bytesdone >= ari->bytestot-3) ||
			//some servers also report # of bytes counted with LF endings, then send with CRLF
			(ari->bytesdone <= ari->bytestot+3+ari->linesdone || ari->bytesdone >= ari->bytestot-3+ari->linesdone)) ||
			ari->linesdone!=ari->linestot){
		printf("doarticle %lu: %lu!=%lu || %lu!=%lu\n",ari->anum,ari->bytesdone,ari->bytestot,ari->linesdone,ari->linestot);
	}
	c_server::ptr host = connection->server;
	if (!(ari->linesdone>=ari->linestot+host->lineleniencelow && ari->linesdone<=ari->linestot+host->lineleniencehigh)){
		printf("unequal line count %lu should equal %lu",ari->linesdone,ari->linestot);
		if (host->lineleniencelow||host->lineleniencehigh){
			if (host->lineleniencelow==-host->lineleniencehigh)
				printf("(+/- %i)",host->lineleniencehigh);
			else
				printf("(%+i/%+i)",host->lineleniencelow,host->lineleniencehigh);
		}
		printf("\n");
		if (nconfig.unequal_line_error)
			throw TransportExFatal(Ex_INIT, "unequal line count and unequal_line_error is true");
		set_unequal_line_count_warn_status();
	}
}

int c_prot_nntp::nntp_doarticle(c_nntp_part *part,arinfo*ari,quinfo*toti,char *fn, const nget_options &options){
	c_nntp_server_article *sa=NULL;
	t_nntp_server_articles_prioritized sap;
	t_nntp_server_articles_prioritized::iterator sapi;
	t_nntp_server_articles_prioritized::iterator sap_erase_i;
	nntp_doarticle_prioritize(part,sap,true);
	int redone=0, attempted=sap.size();
	while (!sap.empty() && redone<options.maxretry) {
		if (redone){
			printf("nntp_doarticle: trying again. %i\n",redone);
			if (options.retrydelay)
				sleep(options.retrydelay);
		}
		for (sapi = sap.begin(); sapi != sap.end();){
			sa=(*sapi).second.first;
			const c_server::ptr &s = (*sapi).second.second;
			assert(sa);
			ari->partnum=part->partnum;
			ari->anum=sa->articlenum;
			ari->bytestot=sa->bytes;
			ari->linestot=sa->lines;
			ari->linesdone=0;
			ari->bytesdone=0;
			PDEBUG(DEBUG_MED,"trying server %s(%lu) article %lu",s->alias.c_str(),sa->serverid,sa->articlenum);
			list<string> buf;//use a list of strings instead of char *.  Easier and it cleans up after itself too.
			try {
				ConnectionHolder holder(&sockpool, &connection, s);
				nntp_doopen();
				if (toti->doarticle_show_multi==SHOW_MULTI_SHORT)
					ari->server_name=connection->server->shortname.c_str();
				else if (toti->doarticle_show_multi==SHOW_MULTI_LONG)
					ari->server_name=connection->server->alias.c_str();
				nntp_dogroup(sa->group, false);
				chkreply_setok(stdputline(debug>=DEBUG_MED,"ARTICLE %lu",sa->articlenum));
				nntp_dogetarticle(ari,toti,buf);
				connection->server_ok=true;
			} catch (baseCommEx &e) {
				printCommEx(e, s, redone, options);
				if (e.isfatal()) {
					sap_erase_i = sapi;
					++sapi;
					sap.erase(sap_erase_i);
				}else{
					++sapi;
				}
				continue;
			}
			c_file_fd f(fn, O_CREAT|O_WRONLY|O_TRUNC, PRIVMODE);
			list<string>::iterator curb;
			try {
				for(curb = buf.begin();curb!=buf.end();++curb){
					f.putf("%s\n",(*curb).c_str());
				}
				f.close();
			}catch(FileEx &e){
				//if the drive is full or other error occurs, then the temp file will be cutoff and useless, so delete it.
				if (unlink(fn))
					perror("unlink:");
				throw;
			}
			set_retrieve_warn_status(attempted - sap.size());
			return 0; //article successfully retrieved, return.
		}
		redone++;
	}
	printf("couldn't get %s from anywhere\n",part->messageid.c_str());
	set_retrieve_error_status();
	return -1;
}

void print_nntp_file_info(c_nntp_file::ptr f, t_show_multiserver show_multi) {
	char tconvbuf[TCONV_DEF_BUF_LEN];
	c_nntp_part *p=(*f->parts.begin());
	tconv(tconvbuf,TCONV_DEF_BUF_LEN,&p->date);
	if (f->iscomplete())
		printf("%i",f->have);
	else
		printf("%i/%i",f->have,f->req);
	if (show_multi!=NO_SHOW_MULTI){
		t_server_have_map have_map;
		f->get_server_have_map(have_map);
		if (show_multi==SHOW_MULTI_SHORT)
			printf(" ");
		
		for (t_server_have_map::iterator i=have_map.begin(); i!=have_map.end(); ++i){
			for (t_server_list_range servers = nconfig.getservers(i->first); servers.first!=servers.second; ++servers.first) {
				c_server::ptr s=servers.first->second;
				if (show_multi==SHOW_MULTI_LONG){
					printf(" %s", s->alias.c_str());
					if (i->second<f->have)
						printf(":%i", i->second);
				}
				else{
					if (i->second<f->have){
						for (string::size_type j=0; j<s->shortname.size(); j++)
							printf("%c", toupper(s->shortname[j]));
					}
					else
						printf("%s", s->shortname.c_str());
				}
			}
		}
	}
	printf("\t%lil\t%s\t%s\t%s\t%s\n",f->lines(),tconvbuf,f->subject.c_str(),f->author.c_str(),p->messageid.c_str());
}

void c_prot_nntp::nntp_retrieve(const vector<c_group_info::ptr> &rgroups, const t_nntp_getinfo_list &getinfos, const t_xpat_list &patinfos, const nget_options &options) {
	c_nntp_files_u filec;
	ParHandler parhandler;
	if (rgroups.size()!=1) {
		cleanupcache();
		group = NULL;
		midinfo=new meta_mid_info(ngcachehome, rgroups);
	} else {
		if (rgroups.front() != group) {
			cleanupcache();
			group = rgroups.front();
		}
		if (!midinfo) {
			midinfo=new meta_mid_info(ngcachehome, group);
		}
	}
	gcache=new c_nntp_cache();

	for (vector<c_group_info::ptr>::const_iterator gi=rgroups.begin(); gi!=rgroups.end(); gi++)
		nntp_xgroup(*gi, patinfos, options);

	gcache->getfiles(&filec, &parhandler, midinfo, getinfos);

	gcache=NULL;
	
	nntp_doretrieve(filec, parhandler, options);
}

void c_prot_nntp::nntp_retrieve(const vector<c_group_info::ptr> &rgroups, const t_nntp_getinfo_list &getinfos, const nget_options &options){
	c_nntp_files_u filec;
	ParHandler parhandler;
	if (rgroups.size()!=1) {
		cleanupcache();
		group = NULL;
		midinfo=new meta_mid_info(ngcachehome, rgroups);
		nntp_cache_getfiles(&filec, &parhandler, &gcache_ismultiserver, ngcachehome, rgroups, midinfo, getinfos);
	} else {
		assert(rgroups.front());
		if (gcache) {
			assert(group == rgroups.front());
			gcache->getfiles(&filec, &parhandler, midinfo, getinfos);
			//attempt to free up some mem since all the data we need is now in filec, we don't need the whole cache.  Unfortunatly due to STL's memory allocators this doesn't really return the memory to the OS, but at least its available for any further STL allocations while retrieving.
			gcache=NULL;
		} else {
			if (rgroups.front() != group) {
				cleanupcache();
				group = rgroups.front();
			}
			if (!midinfo) {
				midinfo=new meta_mid_info(ngcachehome, rgroups);
			}

			nntp_cache_getfiles(&filec, &parhandler, &gcache_ismultiserver, ngcachehome, group, midinfo, getinfos);
		}
	}
	nntp_doretrieve(filec, parhandler, options);
}


void c_prot_nntp::nntp_doretrieve(c_nntp_files_u &filec, ParHandler &parhandler, const nget_options &options) {
	int optionflags = options.gflags;
	if (!(optionflags&GETFILES_AUTOPAR_DISABLING_FLAGS)) {
		parhandler.get_initial_pars(filec);
	}
	
	if (filec.files.empty())
		return;

	t_nntp_files_u::iterator curf;
	//c_nntp_file *f;
	c_nntp_file::ptr f;
	c_nntp_file_retr::ptr fr;

	if (optionflags & GETFILES_UNMARK) {
		ulong nbytes=0;
		unsigned int nfiles=0;
		for(curf = filec.files.begin();curf!=filec.files.end();++curf){
			fr=(*curf).second;
			f=fr->file;
			if (optionflags & GETFILES_TESTMODE) {
				if (midinfo->check(f->bamid())){
					print_nntp_file_info(f,options.test_multi);
					nbytes+=f->bytes();
					nfiles++;
				}
			} else
				midinfo->remove(f->bamid());
		}
		if (optionflags & GETFILES_TESTMODE)
			printf("Would unmark %lu bytes in %u files\n",nbytes,nfiles);
	} else if (optionflags & GETFILES_TESTMODE){
		for(curf = filec.files.begin();curf!=filec.files.end();++curf){
			fr=(*curf).second;
			print_nntp_file_info(fr->file,options.test_multi);
		}
		if (optionflags & GETFILES_MARK)
			printf("Would mark ");
		printf("%"PRIuFAST64" bytes in %lu files\n",filec.bytes,(ulong)filec.files.size());
	} else if (optionflags & GETFILES_MARK) {
		for(curf = filec.files.begin();curf!=filec.files.end();++curf){
			fr=(*curf).second;
			f=fr->file;
			midinfo->insert(f);
		}
	} else {
		quinfo qtotinfo;
		arinfo ainfo;
		time(&qtotinfo.starttime);
		qtotinfo.filesdone=0;
//		qtotinfo.linestot=filec.lines;
		qtotinfo.filestot=filec.files.size();
		qtotinfo.bytesleft=filec.bytes;
		qtotinfo.doarticle_show_multi=gcache_ismultiserver?SHOW_MULTI_SHORT:NO_SHOW_MULTI;
		c_nntp_part *p;
//		s_part_u *bp;
		c_nntp_file_parts::iterator curp;
		char *fn;
		if (!options.writelite.empty())
			optionflags |= GETFILES_NODECODE;
		curf=filec.files.end();
		while (1){
			if (curf!=filec.files.end()){
//				delete (*lastf).second;//new cache implementation uses pointers to the same data
				filec.files.erase(curf);
				qtotinfo.filesdone++;
				filec.bytes=qtotinfo.bytesleft;//update bytes in case we have an exception and need to restart.

				if (!(optionflags&GETFILES_AUTOPAR_DISABLING_FLAGS)) {
					//check if this was the last file to be downloaded to its path, and if so do autoparhandling
					int path_files_left=0;
					for (t_nntp_files_u::iterator dfi = filec.files.begin(); dfi!=filec.files.end(); ++dfi){
						const c_nntp_file_retr::ptr &dfr = (*dfi).second;
						if (dfr->path == fr->path)//fr will still be set to the just erased file_retr, here
							path_files_left++;
					}
					if (path_files_left==0) {
						long old_files_size = filec.files.size();
						parhandler.maybe_get_pxxs(fr->path, filec);
						//update status line information for any new pars that have been added
						qtotinfo.bytesleft = filec.bytes;
						qtotinfo.filestot += filec.files.size() - old_files_size;
					}
				}
			}
			if (filec.files.empty())
				break;
			curf = filec.files.begin();
			fr=(*curf).second;
			f=fr->file;
			printf("Retrieving: ");
			print_nntp_file_info(f, options.retr_show_multi);
//			bp=f->parts.begin()->second;
			int dlerr=0;
			Decoder decoder;
			for(curp = f->parts.begin();curp!=f->parts.end();++curp){
				//asprintf(&fn,"%s/%s-%s-%li-%li-%li",nghome.c_str(),host.c_str(),group.c_str(),fgnum,part,num);
				p=(*curp);
				if (dlerr){
					qtotinfo.bytesleft-=p->bytes();
					continue;
				}
				{
					const char *usepath;
					if (!options.writelite.empty())
						usepath="";
					else usepath=fr->temppath.c_str();
					if (optionflags & GETFILES_TEMPSHORTNAMES)
						asprintf(&fn,"%s%lx.%03i",usepath,f->getfileid(),p->partnum);
					else
						asprintf(&fn,"%sngettemp-%lx.%03i",usepath,f->getfileid(),p->partnum);
				}
				if (!fexists(fn)){
					ainfo.partreq = f->req;
//					ainfo.anum=p->articlenum;//set in doarticle now.
//					ainfo.linesdone=0;
//					ainfo.bytesdone=0;
//					ainfo.linestot=p->lines;
//					ainfo.bytestot=p->bytes;
					if (!options.writelite.empty()){
						c_file_fd fw(options.writelite.c_str(), O_WRONLY|O_CREAT|O_APPEND, PRIVMODE);
						nntp_dowritelite_article(fw,p,fn);
						fw.close();
						free(fn);
						qtotinfo.bytesleft-=p->bytes();
//						uustatus.derr=-1;//skip this file..
						continue;
					}
					if ((optionflags & GETFILES_NOCONNECT) || nntp_doarticle(p,&ainfo,&qtotinfo,fn,options)){
						free(fn);
						fn=NULL;
						if (!(optionflags & GETFILES_GETINCOMPLETE)) {
							qtotinfo.bytesleft-=p->bytes();
							dlerr=-1;//skip this file..
							continue;
						}
					}
				}else{
//					qtotinfo.bytestot-=p->bytes;
					if (quiet<2) printf("already have article %s (%s)\n",p->messageid.c_str(),fn);
				}
				qtotinfo.bytesleft-=p->bytes();
				if (fn)
					decoder.addpart(p->partnum,fn); //decoder will free fn when done.
			}

			if (dlerr) 
				printf("download error occured, keeping temp files.\n");
			else if (optionflags&GETFILES_NODECODE) {
				set_total_ok_status();
				if (quiet<2)
					printf("not decoding, keeping temp files.\n");
			}
			else {
				dupe_file_checker flist;
				if (!decoder.decode(options, fr, flist)) {
					midinfo->insert(f);
					if (!flist.empty()) {
						//check all remaining files against what we just decoded, and remove any dupes.
						t_nntp_files_u::iterator dfi = curf; ++dfi; //skip the current one
						t_nntp_files_u::iterator del_fi;
						c_nntp_file_retr::ptr dfr;
						while(dfi!=filec.files.end()){
							dfr = (*dfi).second;
							//only check files that are being downloaded to the same path
							if (dfr->dupecheck && dfr->path == fr->path) {
								c_nntp_file::ptr df = dfr->file;
								if (flist.checkhavefile(df->subject.c_str(), df->bamid(), df->bytes())) {
									set_skipped_ok_status();
									del_fi=dfi;
									++dfi;
									filec.files.erase(del_fi);
									qtotinfo.filestot--;
									qtotinfo.bytesleft-=df->bytes();
									filec.bytes=qtotinfo.bytesleft;//update bytes in case we have an exception and need to restart.
									continue;
								}
							}
							++dfi;
						}
					}
				}
			}
		}
	}
	//delete filec;filec=NULL;
	cleanupcache();
}
void c_prot_nntp::nntp_auth(void){
	nntp_doauth(connection->server->user.c_str(),connection->server->pass.c_str());
}
void c_prot_nntp::nntp_doauth(const char *user, const char *pass){
	int i;

	if(!user || !*user){
		throw TransportExFatal(Ex_INIT,"nntp_doauth: no authorization info known");
	}
	putline(quiet<2,"AUTHINFO USER %s",user);
	i=getreply(quiet<2);
	if (i==350 || i==381){
		if(!pass || !*pass){
			throw TransportExFatal(Ex_INIT,"nntp_doauth: no password known");
		}
		if (quiet<2)
			printf("%s << AUTHINFO PASS *\n", connection->server->shortname.c_str());
		putline(0,"AUTHINFO PASS %s",pass);
		i=getreply(quiet<2);
	}
	chkreply(i);
}

void c_prot_nntp::nntp_open(c_server::ptr h){
	if (h)
		force_host=h;
	else
		force_host=NULL;
}

void c_prot_nntp::nntp_doopen(void){
	assert(connection);
	if (connection->freshconnect){
		chkreply(getreply(quiet<2));
		putline(debug>=DEBUG_MED,"MODE READER");
		getline(debug>=DEBUG_MED);
		connection->freshconnect=false;
	}
}

void c_prot_nntp::cleanupcache(void){
//	if(gcache){gcache->dec_rcount();/*delete gcache;*/gcache=NULL;}
	gcache=NULL;//ref counted.
	if (midinfo){
		meta_mid_info *mi = midinfo; //store midinfo in temp pointer and NULL out real pointer, to prevent a second deletion attempt if the destructor aborts and the atexit calls the cleanup again.
		midinfo=NULL;
		delete mi;
	}
}
void c_prot_nntp::cleanup(void){
	cleanupcache();
}

void c_prot_nntp::initready(void){
//	midinfo=new c_mid_info((nghome + ".midinfo"));
}
c_prot_nntp::c_prot_nntp(void){
//	cbuf=new char[4096];
//	cbuf_size=4096;
	gcache=NULL;
//	ch=-1;
	connection=NULL;
	midinfo=NULL;
	force_host=NULL;
}
c_prot_nntp::~c_prot_nntp(void){
//	printf("nntp destructing\n");
//	if (midinfo)delete midinfo;
	cleanup();
}