![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to pack_qwk.cpp CVS log ![[TXT]](/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvsweb/icons/dir.gif){kind=icon}
Up to [Synchronet] / sbbs / sbbs3|
Return to pack_qwk.cpp CVS log | Up to [Synchronet] / sbbs / sbbs3 |
1.1 root 1: /* pack_qwk.cpp */
2:
3: /* Synchronet pack QWK packet routine */
4:
5: /* $Id: pack_qwk.cpp,v 1.8 2000/12/11 23:21:12 rswindell Exp $ */
6:
7: /****************************************************************************
8: * @format.tab-size 4 (Plain Text/Source Code File Header) *
9: * @format.use-tabs true (see http://www.synchro.net/ptsc_hdr.html) *
10: * *
11: * Copyright 2000 Rob Swindell - http://www.synchro.net/copyright.html *
12: * *
13: * This program is free software; you can redistribute it and/or *
14: * modify it under the terms of the GNU General Public License *
15: * as published by the Free Software Foundation; either version 2 *
16: * of the License, or (at your option) any later version. *
17: * See the GNU General Public License for more details: gpl.txt or *
18: * http://www.fsf.org/copyleft/gpl.html *
19: * *
20: * Anonymous FTP access to the most recent released source is available at *
21: * ftp://vert.synchro.net, ftp://cvs.synchro.net and ftp://ftp.synchro.net *
22: * *
23: * Anonymous CVS access to the development source and modification history *
24: * is available at cvs.synchro.net:/cvsroot/sbbs, example: *
25: * cvs -d :pserver:[email protected]:/cvsroot/sbbs login *
26: * (just hit return, no password is necessary) *
27: * cvs -d :pserver:[email protected]:/cvsroot/sbbs checkout src *
28: * *
29: * For Synchronet coding style and modification guidelines, see *
30: * http://www.synchro.net/source.html *
31: * *
32: * You are encouraged to submit any modifications (preferably in Unix diff *
33: * format) via e-mail to [email protected] *
34: * *
35: * Note: If this box doesn't appear square, then you need to fix your tabs. *
36: ****************************************************************************/
37:
38: #include "sbbs.h"
39: #include "qwk.h"
40: #include "post.h"
41:
42: /****************************************************************************/
43: /* Creates QWK packet, returning 1 if successful, 0 if not. */
44: /****************************************************************************/
45: bool sbbs_t::pack_qwk(char *packet, ulong *msgcnt, bool prepack)
46: {
47: char str[256],tmp2[256],ch,*p;
48: char tmp[512];
49: char* fname;
50: int file,mode;
51: uint i,j,k,conf;
52: long l,size,msgndx,posts,ex;
53: ulong mailmsgs=0;
54: ulong totalcdt,totaltime,lastmsg
55: ,files,submsgs,msgs,netfiles=0,preqwk=0;
56: float f; /* Sparky is responsible */
57: time_t start;
58: node_t node;
59: mail_t *mail;
60: post_t HUGE16 *post;
61: glob_t g;
62: FILE *stream,*qwk,*personal,*ndx;
63: DIR* dir;
64: DIRENT* dirent;
65: struct tm* tm;
66: smbmsg_t msg;
67:
68:
69: ex=EX_OUTL|EX_OUTR;
70: if(prepack)
71: ex|=EX_OFFLINE;
72:
73: delfiles(cfg.temp_dir,ALLFILES);
74: sprintf(str,"%sfile/%04u.qwk",cfg.data_dir,useron.number);
75: if(fexist(str)) {
76: for(k=0;k<cfg.total_fextrs;k++)
77: if(!stricmp(cfg.fextr[k]->ext,useron.tmpext)
78: && chk_ar(cfg.fextr[k]->ar,&useron))
79: break;
80: if(k>=cfg.total_fextrs)
81: k=0;
82: i=external(cmdstr(cfg.fextr[k]->cmd,str,ALLFILES,NULL),ex);
83: if(!i)
84: preqwk=1; }
85:
86: if(useron.rest&FLAG('Q') && useron.qwk&QWK_RETCTLA)
87: useron.qwk|=(QWK_NOINDEX|QWK_NOCTRL|QWK_VIA|QWK_TZ);
88:
89: if(useron.qwk&QWK_EXPCTLA)
90: mode=A_EXPAND;
91: else if(useron.qwk&QWK_RETCTLA)
92: mode=A_LEAVE;
93: else mode=0;
94: if(useron.qwk&QWK_TZ)
95: mode|=TZ;
96: if(useron.qwk&QWK_VIA)
97: mode|=VIA;
98: (*msgcnt)=0L;
99: if(/* !prepack && */ !(useron.qwk&QWK_NOCTRL)) {
100: /***************************/
101: /* Create CONTROL.DAT file */
102: /***************************/
103: sprintf(str,"%sCONTROL.DAT",cfg.temp_dir);
104: if((stream=fnopen(&file,str,O_WRONLY|O_CREAT|O_TRUNC))==NULL) {
105: errormsg(WHERE,ERR_OPEN,str,O_WRONLY|O_CREAT|O_TRUNC);
106: return(false); }
107:
108: now=time(NULL);
109: tm=gmtime(&now);
110: if(tm==NULL)
111: return(false);
112:
113: fprintf(stream,"%s\r\n%s\r\n%s\r\n%s, Sysop\r\n0000,%s\r\n"
114: "%02u-%02u-%u,%02u:%02u:%02u\r\n"
115: ,cfg.sys_name
116: ,cfg.sys_location
117: ,cfg.node_phone
118: ,cfg.sys_op
119: ,cfg.sys_id
120: ,tm->tm_mon+1,tm->tm_mday,tm->tm_year+1900
121: ,tm->tm_hour,tm->tm_min,tm->tm_sec);
122: k=0;
123: for(i=0;i<usrgrps;i++)
124: for(j=0;j<usrsubs[i];j++)
125: k++; /* k is how many subs */
126: fprintf(stream,"%s\r\n\r\n0\r\n0\r\n%u\r\n",useron.alias,k);
127: fprintf(stream,"0\r\nE-mail\r\n"); /* first conference is e-mail */
128: for(i=0;i<usrgrps;i++)
129: for(j=0;j<usrsubs[i];j++)
130: fprintf(stream,"%u\r\n%s\r\n"
131: ,cfg.sub[usrsub[i][j]]->qwkconf ? cfg.sub[usrsub[i][j]]->qwkconf
132: : ((i+1)*1000)+j+1,cfg.sub[usrsub[i][j]]->qwkname);
133: fprintf(stream,"HELLO\r\nBBSNEWS\r\nGOODBYE\r\n");
134: fclose(stream);
135: /***********************/
136: /* Create DOOR.ID File */
137: /***********************/
138: sprintf(str,"%sDOOR.ID",cfg.temp_dir);
139: if((stream=fnopen(&file,str,O_WRONLY|O_CREAT|O_TRUNC))==NULL) {
140: errormsg(WHERE,ERR_OPEN,str,O_WRONLY|O_CREAT|O_TRUNC);
141: return(false); }
142: p="CONTROLTYPE = ";
143: fprintf(stream,"DOOR = %s\r\nVERSION = %s\r\n"
144: "SYSTEM = %s v%s\r\n"
145: "CONTROLNAME = SBBS\r\n"
146: "%sADD\r\n"
147: "%sDROP\r\n"
148: "%sYOURS\r\n"
149: "%sRESET\r\n"
150: "%sRESETALL\r\n"
151: "%sFILES\r\n"
152: "%sATTACH\r\n"
153: "%sOWN\r\n"
154: "%smail\r\n"
155: "%sDELMAIL\r\n"
156: "%sCTRL-A\r\n"
157: "%sFREQ\r\n"
158: "%sNDX\r\n"
159: "%sTZ\r\n"
160: "%sVIA\r\n"
161: "%sCONTROL\r\n"
162: "MIXEDCASE = YES\r\n"
163: ,"Synchronet"
164: ,VERSION
165: ,"Synchronet"
166: ,VERSION
167: ,p,p,p,p
168: ,p,p,p,p
169: ,p,p,p,p
170: ,p,p,p,p
171: );
172: fclose(stream);
173: if(useron.rest&FLAG('Q')) {
174: /***********************/
175: /* Create NETFLAGS.DAT */
176: /***********************/
177: sprintf(str,"%sNETFLAGS.DAT",cfg.temp_dir);
178: if((stream=fnopen(&file,str,O_WRONLY|O_CREAT))==NULL) {
179: errormsg(WHERE,ERR_OPEN,str,O_WRONLY|O_CREAT);
180: return(false); }
181: ch=1; /* Net enabled */
182: if(usrgrps)
183: for(i=0;i<(usrgrps*1000)+usrsubs[usrgrps-1];i++)
184: fputc(ch,stream);
185: fclose(stream); }
186: } /* !prepack */
187:
188: /****************************************************/
189: /* Create MESSAGES.DAT, write header and leave open */
190: /****************************************************/
191: sprintf(str,"%sMESSAGES.DAT",cfg.temp_dir);
192: if((qwk=fnopen(&file,str,O_CREAT|O_WRONLY|O_TRUNC))==NULL) {
193: errormsg(WHERE,ERR_OPEN,str,O_CREAT|O_WRONLY|O_TRUNC);
194: return(false); }
195: l=filelength(file);
196: if(l<1) {
197: fprintf(qwk,"%-128s",QWK_HEADER);
198: msgndx=1; }
199: else
200: msgndx=l/128L;
201: fseek(qwk,0,SEEK_END);
202: sprintf(str,"%sNEWFILES.DAT",cfg.temp_dir);
203: remove(str);
204: if(!(useron.rest&FLAG('T')) && useron.qwk&QWK_FILES)
205: files=create_filelist("NEWFILES.DAT",FL_ULTIME);
206: else
207: files=0;
208:
209: start=time(NULL);
210:
211: if(useron.rest&FLAG('Q'))
212: useron.qwk|=(QWK_EMAIL|QWK_ALLMAIL|QWK_DELMAIL);
213:
214: if(!(useron.qwk&QWK_NOINDEX)) {
215: sprintf(str,"%sPERSONAL.NDX",cfg.temp_dir);
216: if((personal=fnopen(&file,str,O_CREAT|O_WRONLY|O_APPEND))==NULL) {
217: fclose(qwk);
218: errormsg(WHERE,ERR_OPEN,str,O_WRONLY|O_CREAT|O_APPEND);
219: return(false); }
220: fseek(personal,0L,SEEK_END); }
221: else
222: personal=NULL;
223:
224: if(useron.qwk&(QWK_EMAIL|QWK_ALLMAIL) /* && !prepack */) {
225: sprintf(smb.file,"%smail",cfg.data_dir);
226: smb.retry_time=cfg.smb_retry_time;
227: if((i=smb_open(&smb))!=0) {
228: fclose(qwk);
229: if(personal)
230: fclose(personal);
231: errormsg(WHERE,ERR_OPEN,smb.file,i,smb.last_error);
232: return(false); }
233:
234: /***********************/
235: /* Pack E-mail, if any */
236: /***********************/
237: qwkmail_time=time(NULL);
238: mail=loadmail(&smb,&mailmsgs,useron.number,0,useron.qwk&QWK_ALLMAIL ? 0
239: : LM_UNREAD);
240: if(mailmsgs && !(sys_status&SS_ABORT)) {
241: bputs(text[QWKPackingEmail]);
242: if(!(useron.qwk&QWK_NOINDEX)) {
243: sprintf(str,"%s000.NDX",cfg.temp_dir);
244: if((ndx=fnopen(&file,str,O_CREAT|O_WRONLY|O_APPEND))==NULL) {
245: fclose(qwk);
246: if(personal)
247: fclose(personal);
248: smb_close(&smb);
249: errormsg(WHERE,ERR_OPEN,str,O_WRONLY|O_CREAT|O_APPEND);
250: FREE(mail);
251: return(false); }
252: fseek(ndx,0L,SEEK_END); }
253: else
254: ndx=NULL;
255:
256: if(useron.rest&FLAG('Q'))
257: mode|=TO_QNET;
258: else
259: mode&=~TO_QNET;
260:
261: for(l=0;(ulong)l<mailmsgs;l++) {
262: bprintf("\b\b\b\b\b\b\b\b\b\b\b\b%4lu of %-4lu"
263: ,l+1,mailmsgs);
264:
265: msg.idx.offset=mail[l].offset;
266: if(!loadmsg(&msg,mail[l].number))
267: continue;
268:
269: if(msg.hdr.auxattr&MSG_FILEATTACH && useron.qwk&QWK_ATTACH) {
270: sprintf(str,"%sfile/%04u.in/%s"
271: ,cfg.data_dir,useron.number,msg.subj);
272: sprintf(tmp,"%s%s",cfg.temp_dir,msg.subj);
273: if(fexist(str) && !fexist(tmp))
274: mv(str,tmp,1); }
275:
276: size=msgtoqwk(&msg,qwk,mode,INVALID_SUB,0);
277: smb_unlockmsghdr(&smb,&msg);
278: smb_freemsgmem(&msg);
279: if(ndx) {
280: msgndx++;
281: f=ltomsbin(msgndx); /* Record number */
282: ch=0; /* Sub number, not used */
283: if(personal) {
284: fwrite(&f,4,1,personal);
285: fwrite(&ch,1,1,personal); }
286: fwrite(&f,4,1,ndx);
287: fwrite(&ch,1,1,ndx);
288: msgndx+=size/128L; } }
289: bprintf(text[QWKPackedEmail],mailmsgs);
290: if(ndx)
291: fclose(ndx); }
292: smb_close(&smb); /* Close the e-mail */
293: if(mailmsgs)
294: FREE(mail);
295: }
296:
297: /*********************/
298: /* Pack new messages */
299: /*********************/
300: for(i=0;i<usrgrps;i++) {
301: for(j=0;j<usrsubs[i] && !msgabort();j++)
302: if(sub_cfg[usrsub[i][j]]&SUB_CFG_NSCAN
303: || (!(useron.rest&FLAG('Q'))
304: && cfg.sub[usrsub[i][j]]->misc&SUB_FORCED)) {
305: if(!chk_ar(cfg.sub[usrsub[i][j]]->read_ar,&useron))
306: continue;
307: lncntr=0; /* defeat pause */
308: if(useron.rest&FLAG('Q') && !(cfg.sub[usrsub[i][j]]->misc&SUB_QNET))
309: continue; /* QWK Net Node and not QWK networked, so skip */
310:
311: msgs=getlastmsg(usrsub[i][j],&lastmsg,0);
312: if(!msgs || lastmsg<=sub_ptr[usrsub[i][j]]) { /* no msgs */
313: if(sub_ptr[usrsub[i][j]]>lastmsg) { /* corrupted ptr */
314: sub_ptr[usrsub[i][j]]=lastmsg; /* so fix automatically */
315: sub_last[usrsub[i][j]]=lastmsg; }
316: bprintf(text[NScanStatusFmt]
317: ,cfg.grp[cfg.sub[usrsub[i][j]]->grp]->sname
318: ,cfg.sub[usrsub[i][j]]->lname,0L,msgs);
319: continue; }
320:
321: sprintf(smb.file,"%s%s"
322: ,cfg.sub[usrsub[i][j]]->data_dir,cfg.sub[usrsub[i][j]]->code);
323: smb.retry_time=cfg.smb_retry_time;
324: if((k=smb_open(&smb))!=0) {
325: errormsg(WHERE,ERR_OPEN,smb.file,k,smb.last_error);
326: continue; }
327:
328: k=0;
329: if(useron.qwk&QWK_BYSELF)
330: k|=LP_BYSELF;
331: if(!(sub_cfg[usrsub[i][j]]&SUB_CFG_YSCAN))
332: k|=LP_OTHERS;
333: post=loadposts(&posts,usrsub[i][j],sub_ptr[usrsub[i][j]],k);
334:
335: bprintf(text[NScanStatusFmt]
336: ,cfg.grp[cfg.sub[usrsub[i][j]]->grp]->sname
337: ,cfg.sub[usrsub[i][j]]->lname,posts,msgs);
338: if(!posts) { /* no new messages */
339: smb_close(&smb);
340: continue; }
341: bputs(text[QWKPackingSubboard]);
342: submsgs=0;
343: conf=cfg.sub[usrsub[i][j]]->qwkconf;
344: if(!conf)
345: conf=((i+1)*1000)+j+1;
346:
347: if(!(useron.qwk&QWK_NOINDEX)) {
348: sprintf(str,"%s%u.NDX",cfg.temp_dir,conf);
349: if((ndx=fnopen(&file,str,O_CREAT|O_WRONLY|O_APPEND))==NULL) {
350: fclose(qwk);
351: if(personal)
352: fclose(personal);
353: smb_close(&smb);
354: errormsg(WHERE,ERR_OPEN,str,O_WRONLY|O_CREAT|O_APPEND);
355: LFREE(post);
356: return(false); }
357: fseek(ndx,0L,SEEK_END); }
358: else
359: ndx=NULL;
360:
361: for(l=0;l<posts && !msgabort();l++) {
362: bprintf("\b\b\b\b\b%-5lu",l+1);
363:
364: sub_ptr[usrsub[i][j]]=post[l].number; /* set ptr */
365: sub_last[usrsub[i][j]]=post[l].number; /* set last read */
366:
367: msg.idx.offset=post[l].offset;
368: if(!loadmsg(&msg,post[l].number))
369: continue;
370:
371: if(useron.rest&FLAG('Q')) {
372: if(msg.from_net.type && msg.from_net.type!=NET_QWK &&
373: !(cfg.sub[usrsub[i][j]]->misc&SUB_GATE)) { /* From other */
374: smb_freemsgmem(&msg); /* net, don't gate */
375: smb_unlockmsghdr(&smb,&msg);
376: continue; }
377: mode|=(TO_QNET|TAGLINE);
378: if(msg.from_net.type==NET_QWK) {
379: mode&=~TAGLINE;
380: if(route_circ((char *)msg.from_net.addr,useron.alias)
381: || !strnicmp(msg.subj,"NE:",3)) {
382: smb_freemsgmem(&msg);
383: smb_unlockmsghdr(&smb,&msg);
384: continue; } } }
385: else
386: mode&=~(TAGLINE|TO_QNET);
387:
388: size=msgtoqwk(&msg,qwk,mode,usrsub[i][j],conf);
389: smb_unlockmsghdr(&smb,&msg);
390:
391: if(ndx) {
392: msgndx++;
393: f=ltomsbin(msgndx); /* Record number */
394: ch=0; /* Sub number, not used */
395: if(personal
396: && (!stricmp(msg.to,useron.alias)
397: || !stricmp(msg.to,useron.name))) {
398: fwrite(&f,4,1,personal);
399: fwrite(&ch,1,1,personal); }
400: fwrite(&f,4,1,ndx);
401: fwrite(&ch,1,1,ndx);
402: msgndx+=size/128L; }
403:
404: smb_freemsgmem(&msg);
405: (*msgcnt)++;
406: submsgs++;
407: if(cfg.max_qwkmsgs
408: && !(useron.rest&FLAG('Q')) && (*msgcnt)>=cfg.max_qwkmsgs) {
409: bputs(text[QWKmsgLimitReached]);
410: break; } }
411: if(!(sys_status&SS_ABORT))
412: bprintf(text[QWKPackedSubboard],submsgs,(*msgcnt));
413: if(ndx) {
414: fclose(ndx);
415: sprintf(str,"%s%u.NDX",cfg.temp_dir,conf);
416: if(!flength(str))
417: remove(str); }
418: smb_close(&smb);
419: LFREE(post);
420: if(l<posts)
421: break; }
422: if(j<usrsubs[i]) /* if sub aborted, abort all */
423: break; }
424:
425: if((*msgcnt)+mailmsgs && time(NULL)-start) {
426: bprintf("\r\n\r\n\1n\1hPacked %lu messages in %lu seconds "
427: "(%lu messages/second)."
428: ,(*msgcnt)+mailmsgs,time(NULL)-start
429: ,((*msgcnt)+mailmsgs)/(time(NULL)-start));
430: lprintf("Packed %lu messages in %lu seconds (%lu msgs/sec)"
431: ,(*msgcnt)+mailmsgs,time(NULL)-start
432: ,((*msgcnt)+mailmsgs)/(time(NULL)-start));
433: }
434:
435: fclose(qwk); /* close MESSAGE.DAT */
436: if(personal) {
437: fclose(personal); /* close PERSONAL.NDX */
438: sprintf(str,"%sPERSONAL.NDX",cfg.temp_dir);
439: if(!flength(str))
440: remove(str); }
441: CRLF;
442:
443: if(!prepack && (sys_status&SS_ABORT || !online))
444: return(false);
445:
446: if(/*!prepack && */ useron.rest&FLAG('Q')) { /* If QWK Net node, check for files */
447: sprintf(str,"%sqnet/%s.out/",cfg.data_dir,useron.alias);
448: dir=opendir(str);
449: while((dirent=readdir(dir))!=NULL) { /* Move files into temp dir */
450: sprintf(str,"%sqnet/%s.out/%s",cfg.data_dir,useron.alias,dirent->d_name);
451: if(isdir(str))
452: continue;
453: sprintf(tmp2,"%s%s",cfg.temp_dir,dirent->d_name);
454: lncntr=0; /* Default pause */
455: lprintf("Including %s in packet",str);
456: bprintf(text[RetrievingFile],str);
457: if(!mv(str,tmp2,1))
458: netfiles++;
459: }
460: closedir(dir);
461: if(netfiles)
462: CRLF; }
463:
464: if(batdn_total) {
465: for(i=0,totalcdt=0;i<batdn_total;i++)
466: totalcdt+=batdn_cdt[i];
467: if(!(useron.exempt&FLAG('D'))
468: && totalcdt>useron.cdt+useron.freecdt) {
469: bprintf(text[YouOnlyHaveNCredits]
470: ,ultoac(useron.cdt+useron.freecdt,tmp)); }
471: else {
472: for(i=0,totaltime=0;i<batdn_total;i++) {
473: if(!(cfg.dir[batdn_dir[i]]->misc&DIR_TFREE) && cur_cps)
474: totaltime+=batdn_size[i]/(ulong)cur_cps; }
475: if(!(useron.exempt&FLAG('T')) && !SYSOP && totaltime>timeleft)
476: bputs(text[NotEnoughTimeToDl]);
477: else {
478: for(i=0;i<batdn_total;i++) {
479: lncntr=0;
480: unpadfname(batdn_name[i],tmp);
481: sprintf(tmp2,"%s%s",cfg.temp_dir,tmp);
482: if(!fexist(tmp2)) {
483: seqwait(cfg.dir[batdn_dir[i]]->seqdev);
484: bprintf(text[RetrievingFile],tmp);
485: sprintf(str,"%s%s"
486: ,batdn_alt[i]>0 && batdn_alt[i]<=cfg.altpaths
487: ? cfg.altpath[batdn_alt[i]-1]
488: : cfg.dir[batdn_dir[i]]->path
489: ,tmp);
490: mv(str,tmp2,1); /* copy the file to temp dir */
491: getnodedat(cfg.node_num,&thisnode,1);
492: thisnode.aux=0xfe;
493: putnodedat(cfg.node_num,&thisnode);
494: CRLF; } } } } }
495:
496: if(!(*msgcnt) && !mailmsgs && !files && !netfiles && !batdn_total
497: && (prepack || !preqwk)) {
498: bputs(text[QWKNoNewMessages]);
499: return(false); }
500:
501: if(!prepack && !(useron.rest&FLAG('Q'))) { /* Don't include in network */
502: /***********************/ /* packets */
503: /* Copy QWK Text files */
504: /***********************/
505: sprintf(str,"%sQWK/HELLO",cfg.text_dir);
506: if(fexist(str)) {
507: sprintf(tmp2,"%sHELLO",cfg.temp_dir);
508: mv(str,tmp2,1); }
509: sprintf(str,"%sQWK/BBSNEWS",cfg.text_dir);
510: if(fexist(str)) {
511: sprintf(tmp2,"%sBBSNEWS",cfg.temp_dir);
512: mv(str,tmp2,1); }
513: sprintf(str,"%sQWK/GOODBYE",cfg.text_dir);
514: if(fexist(str)) {
515: sprintf(tmp2,"%sGOODBYE",cfg.temp_dir);
516: mv(str,tmp2,1); }
517: sprintf(str,"%sQWK/BLT-*",cfg.text_dir);
518: glob(str,0,NULL,&g);
519: for(i=0;i<g.gl_pathc;i++) { /* Copy BLT-*.* files */
520: fname=getfname(g.gl_pathv[i]);
521: padfname(fname,str);
522: if(isdigit(str[4]) && isdigit(str[9])) {
523: sprintf(str,"%sQWK/%s",cfg.text_dir,fname);
524: sprintf(tmp2,"%s%s",cfg.temp_dir,fname);
525: mv(str,tmp2,1);
526: }
527: }
528: globfree(&g);
529: }
530:
531: if(prepack) {
532: for(i=1;i<=cfg.sys_nodes;i++) {
533: getnodedat(i,&node,0);
534: if((node.status==NODE_INUSE || node.status==NODE_QUIET
535: || node.status==NODE_LOGON) && node.useron==useron.number)
536: break; }
537: if(i<=cfg.sys_nodes) /* Don't pre-pack with user online */
538: return(false); }
539:
540: /*******************/
541: /* Compress Packet */
542: /*******************/
543: sprintf(tmp2,"%s%s",cfg.temp_dir,ALLFILES);
544: i=external(cmdstr(temp_cmd(),packet,tmp2,NULL),ex);
545: if(!fexist(packet)) {
546: bputs(text[QWKCompressionFailed]);
547: if(i)
548: errormsg(WHERE,ERR_EXEC,cmdstr(temp_cmd(),packet,tmp2,NULL),i);
549: else
550: errorlog("Couldn't compress QWK packet");
551: return(false); }
552:
553: if(prepack) /* Early return if pre-packing */
554: return(true);
555:
556: l=flength(packet);
557: sprintf(str,"%s.qwk",cfg.sys_id);
558: bprintf(text[FiFilename],str);
559: bprintf(text[FiFileSize],ultoac(l,tmp));
560: if(l>0L && cur_cps)
561: i=l/(ulong)cur_cps;
562: else
563: i=0;
564: bprintf(text[FiTransferTime],sectostr(i,tmp));
565: CRLF;
566: if(!(useron.exempt&FLAG('T')) && i>timeleft) {
567: bputs(text[NotEnoughTimeToDl]);
568: return(false);
569: }
570:
571: if(useron.rest&FLAG('Q')) {
572: sprintf(str,"%s.qwk",cfg.sys_id);
573: dir=opendir(cfg.temp_dir);
574: while((dirent=readdir(dir))!=NULL) {
575: if(!stricmp(str,dirent->d_name)) /* QWK packet */
576: continue;
577: sprintf(tmp,"%s%s",cfg.temp_dir,dirent->d_name);
578: if(!isdir(tmp))
579: remove(tmp);
580: }
581: closedir(dir);
582: }
583:
584: return(true);
585: }
This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.