![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to pack_qwk.c CVS log ![[TXT]](/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvsweb/icons/dir.gif){kind=icon}
Up to [Synchronet] / sbbs / sbbs2|
Return to pack_qwk.c CVS log | Up to [Synchronet] / sbbs / sbbs2 |
1.1 root 1: #line 1 "PACK_QWK.C"
2:
3: /* Developed 1990-1997 by Rob Swindell; PO Box 501, Yorba Linda, CA 92885 */
4:
5: #include "sbbs.h"
6: #include "qwk.h"
7: #include "post.h"
8: #include "etext.h"
9:
10: /****************************************************************************/
11: /* Creates QWK packet, returning 1 if successful, 0 if not. */
12: /****************************************************************************/
13: char pack_qwk(char *packet, ulong *msgcnt, int prepack)
14: {
15: uchar str[256],tmp2[256],ch,*p;
16: uchar HUGE16 *qwkbuf;
17: int file,mode;
18: uint i,j,k,n,conf;
19: long l,size,msgndx;
20: ulong totalcdt,totalsize,totaltime,lastmsg
21: ,mailmsgs=0,files,submsgs,msgs,posts,netfiles=0,preqwk=0;
22: float f; /* Sparky is responsible */
23: time_t start;
24: node_t node;
25: mail_t *mail;
26: post_t HUGE16 *post;
27: FILE *stream,*qwk,*personal,*ndx;
28: struct ffblk ff;
29: smbmsg_t msg;
30:
31: delfiles(temp_dir,"*.*");
32: sprintf(str,"%sFILE\\%04u.QWK",data_dir,useron.number);
33: if(fexist(str)) {
34: for(k=0;k<total_fextrs;k++)
35: if(!stricmp(fextr[k]->ext,useron.tmpext)
36: && chk_ar(fextr[k]->ar,useron))
37: break;
38: if(k>=total_fextrs)
39: k=0;
40: i=external(cmdstr(fextr[k]->cmd,str,"*.*",NULL),EX_OUTL|EX_OUTR);
41: if(!i)
42: preqwk=1; }
43:
44: if(useron.rest&FLAG('Q') && useron.qwk&QWK_RETCTLA)
45: useron.qwk|=(QWK_NOINDEX|QWK_NOCTRL|QWK_VIA|QWK_TZ);
46:
47: if(useron.qwk&QWK_EXPCTLA)
48: mode=A_EXPAND;
49: else if(useron.qwk&QWK_RETCTLA)
50: mode=A_LEAVE;
51: else mode=0;
52: if(useron.qwk&QWK_TZ)
53: mode|=TZ;
54: if(useron.qwk&QWK_VIA)
55: mode|=VIA;
56: (*msgcnt)=0L;
57: if(!prepack && !(useron.qwk&QWK_NOCTRL)) {
58: /***************************/
59: /* Create CONTROL.DAT file */
60: /***************************/
61: sprintf(str,"%sCONTROL.DAT",temp_dir);
62: if((stream=fnopen(&file,str,O_WRONLY|O_CREAT|O_TRUNC))==NULL) {
63: errormsg(WHERE,ERR_OPEN,str,O_WRONLY|O_CREAT|O_TRUNC);
64: return(0); }
65:
66: now=time(NULL);
67: unixtodos(now,&date,&curtime);
68:
69: fprintf(stream,"%s\r\n%s\r\n%s\r\n%s, Sysop\r\n0000,%s\r\n"
70: "%02u-%02u-%u,%02u:%02u:%02u\r\n"
71: ,sys_name
72: ,sys_location
73: ,node_phone
74: ,sys_op
75: ,sys_id
76: ,date.da_mon,date.da_day,date.da_year
77: ,curtime.ti_hour,curtime.ti_min,curtime.ti_sec);
78: k=0;
79: for(i=0;i<usrgrps;i++)
80: for(j=0;j<usrsubs[i];j++)
81: k++; /* k is how many subs */
82: fprintf(stream,"%s\r\n\r\n0\r\n0\r\n%u\r\n",useron.alias,k);
83: fprintf(stream,"0\r\nE-mail\r\n"); /* first conference is e-mail */
84: for(i=0;i<usrgrps;i++)
85: for(j=0;j<usrsubs[i];j++)
86: fprintf(stream,"%u\r\n%s\r\n"
87: ,sub[usrsub[i][j]]->qwkconf ? sub[usrsub[i][j]]->qwkconf
88: : ((i+1)*1000)+j+1,sub[usrsub[i][j]]->qwkname);
89: fprintf(stream,"HELLO\r\nBBSNEWS\r\nGOODBYE\r\n");
90: fclose(stream);
91: /***********************/
92: /* Create DOOR.ID File */
93: /***********************/
94: sprintf(str,"%sDOOR.ID",temp_dir);
95: if((stream=fnopen(&file,str,O_WRONLY|O_CREAT|O_TRUNC))==NULL) {
96: errormsg(WHERE,ERR_OPEN,str,O_WRONLY|O_CREAT|O_TRUNC);
97: return(0); }
98: p="CONTROLTYPE = ";
99: fprintf(stream,"DOOR = %s\r\nVERSION = %s\r\n"
100: "SYSTEM = %s v%s\r\n"
101: "CONTROLNAME = SBBS\r\n"
102: "%sADD\r\n"
103: "%sDROP\r\n"
104: "%sYOURS\r\n"
105: "%sRESET\r\n"
106: "%sRESETALL\r\n"
107: "%sFILES\r\n"
108: "%sATTACH\r\n"
109: "%sOWN\r\n"
110: "%sMAIL\r\n"
111: "%sDELMAIL\r\n"
112: "%sCTRL-A\r\n"
113: "%sFREQ\r\n"
114: "%sNDX\r\n"
115: "%sTZ\r\n"
116: "%sVIA\r\n"
117: "%sCONTROL\r\n"
118: "MIXEDCASE = YES\r\n"
119: ,decrypt(Synchronet,0)
120: ,VERSION
121: ,decrypt(Synchronet,0)
122: ,VERSION
123: ,p,p,p,p
124: ,p,p,p,p
125: ,p,p,p,p
126: ,p,p,p,p
127: );
128: fclose(stream);
129: if(useron.rest&FLAG('Q')) {
130: /***********************/
131: /* Create NETFLAGS.DAT */
132: /***********************/
133: sprintf(str,"%sNETFLAGS.DAT",temp_dir);
134: if((stream=fnopen(&file,str,O_WRONLY|O_CREAT))==NULL) {
135: errormsg(WHERE,ERR_OPEN,str,O_WRONLY|O_CREAT);
136: return(0); }
137: ch=1; /* Net enabled */
138: if(usrgrps)
139: for(i=0;i<(usrgrps*1000)+usrsubs[usrgrps-1];i++)
140: fputc(ch,stream);
141: fclose(stream); }
142: } /* !prepack */
143:
144: /****************************************************/
145: /* Create MESSAGES.DAT, write header and leave open */
146: /****************************************************/
147: sprintf(str,"%sMESSAGES.DAT",temp_dir);
148: if((qwk=fnopen(&file,str,O_CREAT|O_WRONLY|O_TRUNC))==NULL) {
149: errormsg(WHERE,ERR_OPEN,str,O_CREAT|O_WRONLY|O_TRUNC);
150: return(0); }
151: l=filelength(file);
152: if(!l) {
153: fprintf(qwk,"%-128s",decrypt(QWKheader,0));
154: msgndx=1; }
155: else
156: msgndx=l/128L;
157: fseek(qwk,0,SEEK_END);
158: sprintf(str,"%sNEWFILES.DAT",temp_dir);
159: remove(str);
160: if(!(useron.rest&FLAG('T')) && useron.qwk&QWK_FILES)
161: files=create_filelist("NEWFILES.DAT",FL_ULTIME);
162: else
163: files=0;
164:
165: start=time(NULL);
166:
167: if(useron.rest&FLAG('Q'))
168: useron.qwk|=(QWK_EMAIL|QWK_ALLMAIL|QWK_DELMAIL);
169:
170: if(!(useron.qwk&QWK_NOINDEX)) {
171: sprintf(str,"%sPERSONAL.NDX",temp_dir);
172: if((personal=fnopen(&file,str,O_CREAT|O_WRONLY|O_APPEND))==NULL) {
173: fclose(qwk);
174: errormsg(WHERE,ERR_OPEN,str,O_WRONLY|O_CREAT|O_APPEND);
175: return(0); }
176: fseek(personal,0L,SEEK_END); }
177: else
178: personal=NULL;
179:
180: if(useron.qwk&(QWK_EMAIL|QWK_ALLMAIL) && !prepack) {
181: sprintf(smb.file,"%sMAIL",data_dir);
182: smb.retry_time=smb_retry_time;
183: if((i=smb_open(&smb))!=0) {
184: fclose(qwk);
185: if(personal)
186: fclose(personal);
187: errormsg(WHERE,ERR_OPEN,smb.file,i);
188: return(0); }
189:
190: /***********************/
191: /* Pack E-mail, if any */
192: /***********************/
193: qwkmail_time=time(NULL);
194: mailmsgs=loadmail(&mail,useron.number,0,useron.qwk&QWK_ALLMAIL ? LM_QWK
195: : LM_UNREAD|LM_QWK);
196: if(mailmsgs && !(sys_status&SS_ABORT)) {
197: bputs(text[QWKPackingEmail]);
198: if(!(useron.qwk&QWK_NOINDEX)) {
199: sprintf(str,"%s000.NDX",temp_dir);
200: if((ndx=fnopen(&file,str,O_CREAT|O_WRONLY|O_APPEND))==NULL) {
201: fclose(qwk);
202: if(personal)
203: fclose(personal);
204: smb_close(&smb);
205: errormsg(WHERE,ERR_OPEN,str,O_WRONLY|O_CREAT|O_APPEND);
206: FREE(mail);
207: return(0); }
208: fseek(ndx,0L,SEEK_END); }
209: else
210: ndx=NULL;
211:
212: if(useron.rest&FLAG('Q'))
213: mode|=TO_QNET;
214: else
215: mode&=~TO_QNET;
216:
217: for(l=0;l<mailmsgs;l++) {
218: bprintf("\b\b\b\b\b\b\b\b\b\b\b\b%4lu of %-4lu"
219: ,l+1,mailmsgs);
220:
221: msg.idx.offset=mail[l].offset;
222: if(!loadmsg(&msg,mail[l].number))
223: continue;
224:
225: if(msg.hdr.auxattr&MSG_FILEATTACH && useron.qwk&QWK_ATTACH) {
226: sprintf(str,"%sFILE\\%04u.IN\\%s"
227: ,data_dir,useron.number,msg.subj);
228: sprintf(tmp,"%s%s",temp_dir,msg.subj);
229: if(fexist(str) && !fexist(tmp))
230: mv(str,tmp,1); }
231:
232: size=msgtoqwk(msg,qwk,mode,INVALID_SUB,0);
233: smb_unlockmsghdr(&smb,&msg);
234: smb_freemsgmem(&msg);
235: if(ndx) {
236: msgndx++;
237: f=ltomsbin(msgndx); /* Record number */
238: ch=0; /* Sub number, not used */
239: if(personal) {
240: fwrite(&f,4,1,personal);
241: fwrite(&ch,1,1,personal); }
242: fwrite(&f,4,1,ndx);
243: fwrite(&ch,1,1,ndx);
244: msgndx+=size/128L; } }
245: bprintf(text[QWKPackedEmail],mailmsgs);
246: if(ndx)
247: fclose(ndx); }
248: smb_close(&smb); /* Close the e-mail */
249: if(mailmsgs)
250: FREE(mail);
251: }
252:
253: /*********************/
254: /* Pack new messages */
255: /*********************/
256: for(i=0;i<usrgrps;i++) {
257: for(j=0;j<usrsubs[i] && !msgabort();j++)
258: if(sub[usrsub[i][j]]->misc&SUB_NSCAN
259: || (!(useron.rest&FLAG('Q'))
260: && sub[usrsub[i][j]]->misc&SUB_FORCED)) {
261: if(!chk_ar(sub[usrsub[i][j]]->read_ar,useron))
262: continue;
263: lncntr=0; /* defeat pause */
264: if(useron.rest&FLAG('Q') && !(sub[usrsub[i][j]]->misc&SUB_QNET))
265: continue; /* QWK Net Node and not QWK networked, so skip */
266:
267: msgs=getlastmsg(usrsub[i][j],&lastmsg,0);
268: if(!msgs || lastmsg<=sub[usrsub[i][j]]->ptr) { /* no msgs */
269: if(sub[usrsub[i][j]]->ptr>lastmsg) { /* corrupted ptr */
270: sub[usrsub[i][j]]->ptr=lastmsg; /* so fix automatically */
271: sub[usrsub[i][j]]->last=lastmsg; }
272: bprintf(text[NScanStatusFmt]
273: ,grp[sub[usrsub[i][j]]->grp]->sname
274: ,sub[usrsub[i][j]]->lname,0L,msgs);
275: continue; }
276:
277: sprintf(smb.file,"%s%s"
278: ,sub[usrsub[i][j]]->data_dir,sub[usrsub[i][j]]->code);
279: smb.retry_time=smb_retry_time;
280: if((k=smb_open(&smb))!=0) {
281: errormsg(WHERE,ERR_OPEN,smb.file,k);
282: continue; }
283:
284: k=0;
285: if(useron.qwk&QWK_BYSELF)
286: k|=LP_BYSELF;
287: if(!(sub[usrsub[i][j]]->misc&SUB_YSCAN))
288: k|=LP_OTHERS;
289: post=loadposts(&posts,usrsub[i][j],sub[usrsub[i][j]]->ptr,k);
290:
291: bprintf(text[NScanStatusFmt]
292: ,grp[sub[usrsub[i][j]]->grp]->sname
293: ,sub[usrsub[i][j]]->lname,posts,msgs);
294: if(!posts) { /* no new messages */
295: smb_close(&smb);
296: continue; }
297: bputs(text[QWKPackingSubboard]);
298: submsgs=0;
299: conf=sub[usrsub[i][j]]->qwkconf;
300: if(!conf)
301: conf=((i+1)*1000)+j+1;
302:
303: if(!(useron.qwk&QWK_NOINDEX)) {
304: sprintf(str,"%s%u.NDX",temp_dir,conf);
305: if((ndx=fnopen(&file,str,O_CREAT|O_WRONLY|O_APPEND))==NULL) {
306: fclose(qwk);
307: if(personal)
308: fclose(personal);
309: smb_close(&smb);
310: errormsg(WHERE,ERR_OPEN,str,O_WRONLY|O_CREAT|O_APPEND);
311: LFREE(post);
312: return(0); }
313: fseek(ndx,0L,SEEK_END); }
314: else
315: ndx=NULL;
316:
317: for(l=0;l<posts && !msgabort();l++) {
318: bprintf("\b\b\b\b\b%-5lu",l+1);
319:
320: sub[usrsub[i][j]]->ptr=post[l].number; /* set ptr */
321: sub[usrsub[i][j]]->last=post[l].number; /* set last read */
322:
323: msg.idx.offset=post[l].offset;
324: if(!loadmsg(&msg,post[l].number))
325: continue;
326:
327: if(useron.rest&FLAG('Q')) {
328: if(msg.from_net.type && msg.from_net.type!=NET_QWK &&
329: !(sub[usrsub[i][j]]->misc&SUB_GATE)) { /* From other */
330: smb_freemsgmem(&msg); /* net, don't gate */
331: smb_unlockmsghdr(&smb,&msg);
332: continue; }
333: mode|=(TO_QNET|TAGLINE);
334: if(msg.from_net.type==NET_QWK) {
335: mode&=~TAGLINE;
336: if(route_circ(msg.from_net.addr,useron.alias)
337: || !strnicmp(msg.subj,"NE:",3)) {
338: smb_freemsgmem(&msg);
339: smb_unlockmsghdr(&smb,&msg);
340: continue; } } }
341: else
342: mode&=~(TAGLINE|TO_QNET);
343:
344: size=msgtoqwk(msg,qwk,mode,usrsub[i][j],conf);
345: smb_unlockmsghdr(&smb,&msg);
346:
347: if(ndx) {
348: msgndx++;
349: f=ltomsbin(msgndx); /* Record number */
350: ch=0; /* Sub number, not used */
351: if(personal
352: && (!stricmp(msg.to,useron.alias)
353: || !stricmp(msg.to,useron.name))) {
354: fwrite(&f,4,1,personal);
355: fwrite(&ch,1,1,personal); }
356: fwrite(&f,4,1,ndx);
357: fwrite(&ch,1,1,ndx);
358: msgndx+=size/128L; }
359:
360: smb_freemsgmem(&msg);
361: (*msgcnt)++;
362: submsgs++;
363: if(max_qwkmsgs
364: && !(useron.rest&FLAG('Q')) && (*msgcnt)>=max_qwkmsgs) {
365: bputs(text[QWKmsgLimitReached]);
366: break; } }
367: if(!(sys_status&SS_ABORT))
368: bprintf(text[QWKPackedSubboard],submsgs,(*msgcnt));
369: if(ndx) {
370: fclose(ndx);
371: sprintf(str,"%s%u.NDX",temp_dir,conf);
372: if(!flength(str))
373: remove(str); }
374: smb_close(&smb);
375: LFREE(post);
376: if(l<posts)
377: break; }
378: if(j<usrsubs[i]) /* if sub aborted, abort all */
379: break; }
380:
381: if((*msgcnt)+mailmsgs && time(NULL)-start)
382: bprintf("\r\n\r\n\1n\1hPacked %lu messages in %lu seconds "
383: "(%lu messages/second)."
384: ,(*msgcnt)+mailmsgs,time(NULL)-start
385: ,((*msgcnt)+mailmsgs)/(time(NULL)-start));
386:
387: fclose(qwk); /* close MESSAGE.DAT */
388: if(personal) {
389: fclose(personal); /* close PERSONAL.NDX */
390: sprintf(str,"%sPERSONAL.NDX",temp_dir);
391: if(!flength(str))
392: remove(str); }
393: CRLF;
394:
395: if(!prepack && (sys_status&SS_ABORT || !online))
396: return(0);
397:
398: if(!prepack && useron.rest&FLAG('Q')) { /* If QWK Net node, check for files */
399: sprintf(str,"%sQNET\\%s.OUT\\*.*",data_dir,useron.alias);
400: i=findfirst(str,&ff,0);
401: while(!i) { /* Move files into temp dir */
402: sprintf(str,"%sQNET\\%s.OUT\\%s",data_dir,useron.alias,ff.ff_name);
403: strupr(str);
404: sprintf(tmp2,"%s%s",temp_dir,ff.ff_name);
405: lncntr=0; /* Default pause */
406: bprintf(text[RetrievingFile],str);
407: if(!mv(str,tmp2,1))
408: netfiles++;
409: i=findnext(&ff); }
410: if(netfiles)
411: CRLF; }
412:
413: if(batdn_total) {
414: for(i=0,totalcdt=0;i<batdn_total;i++)
415: totalcdt+=batdn_cdt[i];
416: if(!(useron.exempt&FLAG('D'))
417: && totalcdt>useron.cdt+useron.freecdt) {
418: bprintf(text[YouOnlyHaveNCredits]
419: ,ultoac(useron.cdt+useron.freecdt,tmp)); }
420: else {
421: for(i=0,totalsize=totaltime=0;i<batdn_total;i++) {
422: totalsize+=batdn_size[i];
423: if(!(dir[batdn_dir[i]]->misc&DIR_TFREE) && cur_cps)
424: totaltime+=batdn_size[i]/(ulong)cur_cps; }
425: if(!(useron.exempt&FLAG('T')) && !SYSOP && totaltime>timeleft)
426: bputs(text[NotEnoughTimeToDl]);
427: else {
428: for(i=0;i<batdn_total;i++) {
429: lncntr=0;
430: unpadfname(batdn_name[i],tmp);
431: sprintf(tmp2,"%s%s",temp_dir,tmp);
432: if(!fexist(tmp2)) {
433: seqwait(dir[batdn_dir[i]]->seqdev);
434: bprintf(text[RetrievingFile],tmp);
435: sprintf(str,"%s%s"
436: ,batdn_alt[i]>0 && batdn_alt[i]<=altpaths
437: ? altpath[batdn_alt[i]-1]
438: : dir[batdn_dir[i]]->path
439: ,tmp);
440: mv(str,tmp2,1); /* copy the file to temp dir */
441: getnodedat(node_num,&thisnode,1);
442: thisnode.aux=0xfe;
443: putnodedat(node_num,thisnode);
444: CRLF; } } } } }
445:
446: if(!(*msgcnt) && !mailmsgs && !files && !netfiles && !batdn_total
447: && (prepack || !preqwk)) {
448: bputs(text[QWKNoNewMessages]);
449: return(0); }
450:
451: if(!prepack && !(useron.rest&FLAG('Q'))) { /* Don't include in network */
452: /***********************/ /* packets */
453: /* Copy QWK Text files */
454: /***********************/
455: sprintf(str,"%sQWK\\HELLO",text_dir);
456: if(fexist(str)) {
457: sprintf(tmp2,"%sHELLO",temp_dir);
458: mv(str,tmp2,1); }
459: sprintf(str,"%sQWK\\BBSNEWS",text_dir);
460: if(fexist(str)) {
461: sprintf(tmp2,"%sBBSNEWS",temp_dir);
462: mv(str,tmp2,1); }
463: sprintf(str,"%sQWK\\GOODBYE",text_dir);
464: if(fexist(str)) {
465: sprintf(tmp2,"%sGOODBYE",temp_dir);
466: mv(str,tmp2,1); }
467: sprintf(str,"%sQWK\\BLT-*.*",text_dir);
468: i=findfirst(str,&ff,0);
469: while(!i) { /* Copy BLT-*.* files */
470: padfname(ff.ff_name,str);
471: if(isdigit(str[4]) && isdigit(str[9])) {
472: sprintf(str,"%sQWK\\%s",text_dir,ff.ff_name);
473: sprintf(tmp2,"%s%s",temp_dir,ff.ff_name);
474: mv(str,tmp2,1); }
475: i=findnext(&ff); } }
476:
477: if(prepack) {
478: for(i=1;i<=sys_nodes;i++) {
479: getnodedat(i,&node,0);
480: if((node.status==NODE_INUSE || node.status==NODE_QUIET
481: || node.status==NODE_LOGON) && node.useron==useron.number)
482: break; }
483: if(i<=sys_nodes) /* Don't pre-pack with user online */
484: return(0); }
485:
486: /*******************/
487: /* Compress Packet */
488: /*******************/
489: sprintf(tmp2,"%s*.*",temp_dir);
490: i=external(cmdstr(temp_cmd(),packet,tmp2,NULL),EX_OUTL|EX_OUTR);
491: if(!fexist(packet)) {
492: bputs(text[QWKCompressionFailed]);
493: if(i)
494: errormsg(WHERE,ERR_EXEC,cmdstr(temp_cmd(),packet,tmp2,NULL),i);
495: else
496: errorlog("Couldn't compress QWK packet");
497: return(0); }
498:
499: if(prepack) /* Early return if pre-packing */
500: return(1);
501:
502: l=flength(packet);
503: sprintf(str,"%s.QWK",sys_id);
504: bprintf(text[FiFilename],str);
505: bprintf(text[FiFileSize],ultoac(l,tmp));
506: if(l>0L && cur_cps)
507: i=l/(ulong)cur_cps;
508: else
509: i=0;
510: bprintf(text[FiTransferTime],sectostr(i,tmp));
511: CRLF;
512: if(!(useron.exempt&FLAG('T')) && i>timeleft) {
513: bputs(text[NotEnoughTimeToDl]);
514: return(0); }
515:
516: if(useron.rest&FLAG('Q')) {
517: sprintf(str,"%s.QWK",sys_id);
518: sprintf(tmp,"%s*.*",temp_dir);
519: i=findfirst(tmp,&ff,0);
520: while(!i) {
521: if(stricmp(str,ff.ff_name)) {
522: sprintf(tmp,"%s%s",temp_dir,ff.ff_name);
523: remove(tmp); }
524: i=findnext(&ff); } }
525:
526: return(1);
527: }
This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.