![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to 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 qwk.cpp CVS log | Up to [Synchronet] / sbbs / sbbs3 |
1.1 root 1: /* qwk.cpp */
2:
3: /* Synchronet QWK packet-related functions */
4:
5: /* $Id: qwk.cpp,v 1.6 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 "post.h"
40: #include "qwk.h"
41:
42: /****************************************************************************/
43: /* Removes ctrl-a codes from the string 'instr' */
44: /****************************************************************************/
45: char* remove_ctrl_a(char *instr, char *outstr)
46: {
47: char str[512],*p;
48: uint i,j,k;
49:
50: j=strlen(instr);
51: for(k=i=0;i<j;i++) {
52: if(instr[i]==1)
53: i++;
54: else str[k++]=instr[i]; }
55: str[k]=0;
56: if(outstr!=NULL)
57: p=outstr;
58: else
59: p=instr;
60: strcpy(p,str);
61: return(p);
62: }
63:
64:
65: /****************************************************************************/
66: /* Converts a long to an msbin real number. required for QWK NDX file */
67: /****************************************************************************/
68: float ltomsbin(long val)
69: {
70: converter t;
71: int sign, exp; /* sign and exponent */
72:
73: t.f[0]=(float)val;
74: sign=t.uc[3]/0x80;
75: exp=((t.ui[1]>>7)-0x7f+0x81)&0xff;
76: t.ui[1]=(t.ui[1]&0x7f)|(sign<<7)|(exp<<8);
77: return(t.f[0]);
78: }
79:
80: bool route_circ(char *via, char *id)
81: {
82: char str[256],*p,*sp;
83:
84: strcpy(str,via);
85: p=str;
86: while(*p && *p<=SP)
87: p++;
88: while(*p) {
89: sp=strchr(p,'/');
90: if(sp) *sp=0;
91: if(!stricmp(p,id))
92: return(true);
93: if(!sp)
94: break;
95: p=sp+1; }
96: return(false);
97: }
98:
99: int sbbs_t::qwk_route(char *inaddr, char *fulladdr)
100: {
101: char node[10],str[256],*p;
102: int file,i;
103: FILE *stream;
104:
105: fulladdr[0]=0;
106: sprintf(str,"%.255s",inaddr);
107: p=strrchr(str,'/');
108: if(p) p++;
109: else p=str;
110: sprintf(node,"%.8s",p); /* node = destination node */
111: truncsp(node);
112:
113: for(i=0;i<cfg.total_qhubs;i++) /* Check if destination is our hub */
114: if(!stricmp(cfg.qhub[i]->id,node))
115: break;
116: if(i<cfg.total_qhubs) {
117: strcpy(fulladdr,node);
118: return(0); }
119:
120: i=matchuser(&cfg,node); /* Check if destination is a node */
121: if(i) {
122: getuserrec(&cfg,i,U_REST,8,str);
123: if(ahtoul(str)&FLAG('Q')) {
124: strcpy(fulladdr,node);
125: return(i); } }
126:
127: sprintf(node,"%.8s",inaddr); /* node = next hop */
128: p=strchr(node,'/');
129: if(p) *p=0;
130: truncsp(node);
131:
132: if(strchr(inaddr,'/')) { /* Multiple hops */
133:
134: for(i=0;i<cfg.total_qhubs;i++) /* Check if next hop is our hub */
135: if(!stricmp(cfg.qhub[i]->id,node))
136: break;
137: if(i<cfg.total_qhubs) {
138: strcpy(fulladdr,inaddr);
139: return(0); }
140:
141: i=matchuser(&cfg,node); /* Check if next hop is a node */
142: if(i) {
143: getuserrec(&cfg,i,U_REST,8,str);
144: if(ahtoul(str)&FLAG('Q')) {
145: strcpy(fulladdr,inaddr);
146: return(i); } } }
147:
148: p=strchr(node,SP);
149: if(p) *p=0;
150:
151: sprintf(str,"%sqnet/route.dat",cfg.data_dir);
152: if((stream=fnopen(&file,str,O_RDONLY))==NULL)
153: return(0);
154:
155: strcat(node,":");
156: fulladdr[0]=0;
157: while(!feof(stream)) {
158: if(!fgets(str,256,stream))
159: break;
160: if(!strnicmp(str+9,node,strlen(node))) {
161: fclose(stream);
162: truncsp(str);
163: sprintf(fulladdr,"%s/%s",str+9+strlen(node),inaddr);
164: break; } }
165:
166: fclose(stream);
167: if(!fulladdr[0]) /* First hop not found in ROUTE.DAT */
168: return(0);
169:
170: sprintf(node,"%.8s",fulladdr);
171: p=strchr(node,'/');
172: if(p) *p=0;
173: truncsp(node);
174:
175: for(i=0;i<cfg.total_qhubs;i++) /* Check if first hop is our hub */
176: if(!stricmp(cfg.qhub[i]->id,node))
177: break;
178: if(i<cfg.total_qhubs)
179: return(0);
180:
181: i=matchuser(&cfg,node); /* Check if first hop is a node */
182: if(i) {
183: getuserrec(&cfg,i,U_REST,8,str);
184: if(ahtoul(str)&FLAG('Q'))
185: return(i); }
186: fulladdr[0]=0;
187: return(0);
188: }
189:
190:
191: /* Via is in format: NODE/NODE/... */
192: void sbbs_t::update_qwkroute(char *via)
193: {
194: static uint total_nodes;
195: static char **qwk_node;
196: static char **qwk_path;
197: static time_t *qwk_time;
198: char str[256],*p,*tp,node[9];
199: uint i;
200: int file;
201: time_t t;
202: FILE * stream;
203:
204: if(via==NULL) {
205: if(!total_nodes)
206: return;
207: sprintf(str,"%sqnet/route.dat",cfg.data_dir);
208: if((stream=fnopen(&file,str,O_WRONLY|O_CREAT|O_TRUNC))!=NULL) {
209: t=time(NULL);
210: t-=(90L*24L*60L*60L);
211: for(i=0;i<total_nodes;i++)
212: if(qwk_time[i]>t)
213: fprintf(stream,"%s %s:%s\r\n"
214: ,unixtodstr(&cfg,qwk_time[i],str),qwk_node[i],qwk_path[i]);
215: fclose(stream); }
216: else
217: errormsg(WHERE,ERR_OPEN,str,O_WRONLY|O_CREAT|O_TRUNC);
218: for(i=0;i<total_nodes;i++) {
219: FREE(qwk_node[i]);
220: FREE(qwk_path[i]); }
221: if(qwk_node) {
222: FREE(qwk_node);
223: qwk_node=NULL; }
224: if(qwk_path) {
225: FREE(qwk_path);
226: qwk_path=NULL; }
227: if(qwk_time) {
228: FREE(qwk_time);
229: qwk_time=NULL; }
230: total_nodes=0;
231: return; }
232:
233: if(!total_nodes) {
234: sprintf(str,"%sqnet/route.dat",cfg.data_dir);
235: if((stream=fnopen(&file,str,O_RDONLY))!=NULL) {
236: while(!feof(stream)) {
237: if(!fgets(str,255,stream))
238: break;
239: truncsp(str);
240: t=dstrtounix(&cfg,str);
241: p=strchr(str,':');
242: if(!p) continue;
243: *p=0;
244: sprintf(node,"%.8s",str+9);
245: tp=strchr(node,SP); /* change "node bbs:" to "node:" */
246: if(tp) *tp=0;
247: for(i=0;i<total_nodes;i++)
248: if(!stricmp(qwk_node[i],node))
249: break;
250: if(i<total_nodes && qwk_time[i]>t)
251: continue;
252: if(i==total_nodes) {
253: if((qwk_node=(char **)REALLOC(qwk_node,sizeof(char *)*(i+1)))==NULL) {
254: errormsg(WHERE,ERR_ALLOC,str,9*(i+1));
255: break; }
256: if((qwk_path=(char **)REALLOC(qwk_path,sizeof(char *)*(i+1)))==NULL) {
257: errormsg(WHERE,ERR_ALLOC,str,128*(i+1));
258: break; }
259: if((qwk_time=(time_t *)REALLOC(qwk_time,sizeof(time_t)*(i+1)))==NULL) {
260: errormsg(WHERE,ERR_ALLOC,str,sizeof(time_t)*(i+1));
261: break; }
262: if((qwk_node[i]=(char *)MALLOC(9))==NULL) {
263: errormsg(WHERE,ERR_ALLOC,str,9);
264: break; }
265: if((qwk_path[i]=(char *)MALLOC(128))==NULL) {
266: errormsg(WHERE,ERR_ALLOC,str,128);
267: break; }
268: total_nodes++; }
269: strcpy(qwk_node[i],node);
270: p++;
271: while(*p && *p<=SP) p++;
272: sprintf(qwk_path[i],"%.127s",p);
273: qwk_time[i]=t; }
274: fclose(stream); } }
275:
276: strupr(via);
277: p=strchr(via,'/'); /* Skip uplink */
278:
279: while(p && *p) {
280: p++;
281: sprintf(node,"%.8s",p);
282: tp=strchr(node,'/');
283: if(tp) *tp=0;
284: tp=strchr(node,SP); /* no spaces allowed */
285: if(tp) *tp=0;
286: truncsp(node);
287: for(i=0;i<total_nodes;i++)
288: if(!stricmp(qwk_node[i],node))
289: break;
290: if(i==total_nodes) { /* Not in list */
291: if((qwk_node=(char **)REALLOC(qwk_node,sizeof(char *)*(total_nodes+1)))==NULL) {
292: errormsg(WHERE,ERR_ALLOC,str,9*(total_nodes+1));
293: break; }
294: if((qwk_path=(char **)REALLOC(qwk_path,sizeof(char *)*(total_nodes+1)))==NULL) {
295: errormsg(WHERE,ERR_ALLOC,str,128*(total_nodes+1));
296: break; }
297: if((qwk_time=(time_t *)REALLOC(qwk_time,sizeof(time_t)*(total_nodes+1)))
298: ==NULL) {
299: errormsg(WHERE,ERR_ALLOC,str,sizeof(time_t)*(total_nodes+1));
300: break; }
301: if((qwk_node[total_nodes]=(char *)MALLOC(9))==NULL) {
302: errormsg(WHERE,ERR_ALLOC,str,9);
303: break; }
304: if((qwk_path[total_nodes]=(char *)MALLOC(128))==NULL) {
305: errormsg(WHERE,ERR_ALLOC,str,128);
306: break; }
307: total_nodes++; }
308: sprintf(qwk_node[i],"%.8s",node);
309: sprintf(qwk_path[i],"%.*s",(uint)((p-1)-via),via);
310: qwk_time[i]=time(NULL);
311: p=strchr(p,'/'); }
312: }
313:
314: /****************************************************************************/
315: /* Successful download of QWK packet */
316: /****************************************************************************/
317: void sbbs_t::qwk_success(ulong msgcnt, char bi, char prepack)
318: {
319: char str[128];
320: int i;
321: ulong l,msgs,deleted=0;
322: mail_t *mail;
323: smbmsg_t msg;
324:
325: if(useron.rest&FLAG('Q')) { // Was if(!prepack) only
326: sprintf(str,"%sqnet/%.8s.out/",cfg.data_dir,useron.alias);
327: strlwr(str);
328: delfiles(str,ALLFILES);
329: }
330:
331: if(!prepack) {
332: logline("D-","Downloaded QWK packet");
333: posts_read+=msgcnt;
334:
335: sprintf(str,"%sfile/%04u.qwk",cfg.data_dir,useron.number);
336: remove(str);
337:
338: if(!bi) {
339: batch_download(-1);
340: delfiles(cfg.temp_dir,ALLFILES); } }
341:
342: if(useron.rest&FLAG('Q'))
343: useron.qwk|=(QWK_EMAIL|QWK_ALLMAIL|QWK_DELMAIL);
344: if(useron.qwk&(QWK_EMAIL|QWK_ALLMAIL)) {
345: sprintf(smb.file,"%smail",cfg.data_dir);
346: smb.retry_time=cfg.smb_retry_time;
347: if((i=smb_open(&smb))!=0) {
348: errormsg(WHERE,ERR_OPEN,smb.file,i,smb.last_error);
349: return; }
350:
351: mail=loadmail(&smb,&msgs,useron.number,0
352: ,useron.qwk&QWK_ALLMAIL ? 0 : LM_UNREAD);
353:
354: if((i=smb_locksmbhdr(&smb))!=0) { /* Lock the base, so nobody */
355: if(msgs)
356: FREE(mail);
357: smb_close(&smb);
358: errormsg(WHERE,ERR_LOCK,smb.file,i); /* messes with the index */
359: return; }
360:
361: if((i=smb_getstatus(&smb))!=0) {
362: if(msgs)
363: FREE(mail);
364: smb_close(&smb);
365: errormsg(WHERE,ERR_READ,smb.file,i);
366: return; }
367:
368: /* Mark as READ and DELETE */
369: for(l=0;l<msgs;l++) {
370: if(mail[l].time>qwkmail_time)
371: continue;
372: msg.idx.offset=0;
373: if(!loadmsg(&msg,mail[l].number))
374: continue;
375: if(!(msg.hdr.attr&MSG_READ)) {
376: if(thisnode.status==NODE_INUSE)
377: telluser(&msg);
378: msg.hdr.attr|=MSG_READ;
379: msg.idx.attr=msg.hdr.attr;
380: smb_putmsg(&smb,&msg); }
381: if(!(msg.hdr.attr&MSG_PERMANENT)
382: && ((msg.hdr.attr&MSG_KILLREAD && msg.hdr.attr&MSG_READ)
383: || (useron.qwk&QWK_DELMAIL))) {
384: msg.hdr.attr|=MSG_DELETE;
385: msg.idx.attr=msg.hdr.attr;
386: if((i=smb_putmsg(&smb,&msg))!=0)
387: errormsg(WHERE,ERR_WRITE,smb.file,i);
388: else
389: deleted++; }
390: smb_freemsgmem(&msg);
391: smb_unlockmsghdr(&smb,&msg); }
392:
393: if(deleted && cfg.sys_misc&SM_DELEMAIL)
394: delmail(useron.number,MAIL_YOUR);
395: smb_close(&smb);
396: if(msgs)
397: FREE(mail); }
398:
399: }
400:
401: /****************************************************************************/
402: /* QWK mail packet section */
403: /****************************************************************************/
404: void sbbs_t::qwk_sec()
405: {
406: char str[256],tmp2[256],ch,bi=0
407: ,*AttemptedToDownloadQWKpacket="Attempted to download QWK packet";
408: char tmp[512];
409: int s;
410: uint i,j,k;
411: ulong msgcnt;
412: time_t *sav_ptr;
413: file_t fd;
414:
415: getusrdirs();
416: fd.dir=cfg.total_dirs;
417: if((sav_ptr=(time_t *)MALLOC(sizeof(time_t)*cfg.total_subs))==NULL) {
418: errormsg(WHERE,ERR_ALLOC,nulstr,sizeof(time_t)*cfg.total_subs);
419: return; }
420: for(i=0;i<cfg.total_subs;i++)
421: sav_ptr[i]=sub_ptr[i];
422: for(i=0;i<cfg.total_prots;i++)
423: if(cfg.prot[i]->bicmd[0] && chk_ar(cfg.prot[i]->ar,&useron))
424: bi++; /* number of bidirectional protocols configured */
425: if(useron.rest&FLAG('Q'))
426: getusrsubs();
427: delfiles(cfg.temp_dir,ALLFILES);
428: while(online) {
429: if((useron.misc&(WIP|RIP) || !(useron.misc&EXPERT))
430: && (useron.logons<2 || !(useron.rest&FLAG('Q'))))
431: menu("qwk");
432: action=NODE_TQWK;
433: ASYNC;
434: bputs(text[QWKPrompt]);
435: strcpy(str,"?UDCSPQ\r");
436: if(bi)
437: strcat(str,"B");
438: ch=(char)getkeys(str,0);
439: if(ch>SP)
440: logch(ch,0);
441: if(sys_status&SS_ABORT || ch=='Q' || ch==CR)
442: break;
443: if(ch=='?') {
444: if((useron.misc&(WIP|RIP) || !(useron.misc&EXPERT))
445: && !(useron.rest&FLAG('Q')))
446: continue;
447: menu("qwk");
448: continue; }
449: if(ch=='S') {
450: new_scan_cfg(SUB_CFG_NSCAN);
451: delfiles(cfg.temp_dir,ALLFILES);
452: continue; }
453: if(ch=='P') {
454: new_scan_ptr_cfg();
455: for(i=0;i<cfg.total_subs;i++)
456: sav_ptr[i]=sub_ptr[i];
457: delfiles(cfg.temp_dir,ALLFILES);
458: continue; }
459: if(ch=='C') {
460: while(online) {
461: CLS;
462: bputs("\1n\1gQWK Settings:\1n\r\n\r\n");
463: bprintf("A) %-30s: %s\r\n"
464: ,"Ctrl-A Color Codes"
465: ,useron.qwk&QWK_EXPCTLA
466: ? "Expand to ANSI" : useron.qwk&QWK_RETCTLA ? "Leave in"
467: : "Strip");
468: bprintf("T) %-30s: %s\r\n"
469: ,"Archive Type"
470: ,useron.tmpext);
471: bprintf("E) %-30s: %s\r\n"
472: ,"Include E-mail Messages"
473: ,useron.qwk&QWK_EMAIL ? "Un-read Only"
474: : useron.qwk&QWK_ALLMAIL ? text[Yes] : text[No]);
475: bprintf("I) %-30s: %s\r\n"
476: ,"Include File Attachments"
477: ,useron.qwk&QWK_ATTACH ? text[Yes] : text[No]);
478: bprintf("D) %-30s: %s\r\n"
479: ,"Delete E-mail Automatically"
480: ,useron.qwk&QWK_DELMAIL ? text[Yes]:text[No]);
481: bprintf("F) %-30s: %s\r\n"
482: ,"Include New Files List"
483: ,useron.qwk&QWK_FILES ? text[Yes]:text[No]);
484: bprintf("N) %-30s: %s\r\n"
485: ,"Include Index Files"
486: ,useron.qwk&QWK_NOINDEX ? text[No]:text[Yes]);
487: bprintf("C) %-30s: %s\r\n"
488: ,"Include Control Files"
489: ,useron.qwk&QWK_NOCTRL ? text[No]:text[Yes]);
490: bprintf("Y) %-30s: %s\r\n"
491: ,"Include Messages from You"
492: ,useron.qwk&QWK_BYSELF ? text[Yes]:text[No]);
493: bprintf("Z) %-30s: %s\r\n"
494: ,"Include Time Zone (TZ)"
495: ,useron.qwk&QWK_TZ ? text[Yes]:text[No]);
496: bprintf("V) %-30s: %s\r\n"
497: ,"Include Message Path (VIA)"
498: ,useron.qwk&QWK_VIA ? text[Yes]:text[No]);
499: //bprintf("Q) Quit\r\n\r\n");
500: bputs(text[UserDefaultsWhich]);
501: ch=(char)getkeys("AQEDFIOQTYNCZV",0);
502: if(sys_status&SS_ABORT || !ch || ch=='Q')
503: break;
504: switch(ch) {
505: case 'A':
506: if(!(useron.qwk&(QWK_EXPCTLA|QWK_RETCTLA)))
507: useron.qwk|=QWK_EXPCTLA;
508: else if(useron.qwk&QWK_EXPCTLA) {
509: useron.qwk&=~QWK_EXPCTLA;
510: useron.qwk|=QWK_RETCTLA; }
511: else
512: useron.qwk&=~(QWK_EXPCTLA|QWK_RETCTLA);
513: break;
514: case 'T':
515: for(i=0;i<cfg.total_fcomps;i++)
516: uselect(1,i,"Archive Types",cfg.fcomp[i]->ext,cfg.fcomp[i]->ar);
517: s=uselect(0,0,0,0,0);
518: if(s>=0) {
519: strcpy(useron.tmpext,cfg.fcomp[s]->ext);
520: putuserrec(&cfg,useron.number,U_TMPEXT,3,useron.tmpext); }
521: break;
522: case 'E':
523: if(!(useron.qwk&(QWK_EMAIL|QWK_ALLMAIL)))
524: useron.qwk|=QWK_EMAIL;
525: else if(useron.qwk&QWK_EMAIL) {
526: useron.qwk&=~QWK_EMAIL;
527: useron.qwk|=QWK_ALLMAIL; }
528: else
529: useron.qwk&=~(QWK_EMAIL|QWK_ALLMAIL);
530: break;
531: case 'I':
532: useron.qwk^=QWK_ATTACH;
533: break;
534: case 'D':
535: useron.qwk^=QWK_DELMAIL;
536: break;
537: case 'F':
538: useron.qwk^=QWK_FILES;
539: break;
540: case 'N': /* NO IDX files */
541: useron.qwk^=QWK_NOINDEX;
542: break;
543: case 'C':
544: useron.qwk^=QWK_NOCTRL;
545: break;
546: case 'Z':
547: useron.qwk^=QWK_TZ;
548: break;
549: case 'V':
550: useron.qwk^=QWK_VIA;
551: break;
552: case 'Y': /* Yourself */
553: useron.qwk^=QWK_BYSELF;
554: break; }
555: putuserrec(&cfg,useron.number,U_QWK,8,ultoa(useron.qwk,str,16)); }
556: delfiles(cfg.temp_dir,ALLFILES);
557: continue; }
558:
559:
560: if(ch=='B') { /* Bidirectional QWK and REP packet transfer */
561: sprintf(str,"%s%s.qwk",cfg.temp_dir,cfg.sys_id);
562: if(!fexist(str) && !pack_qwk(str,&msgcnt,0)) {
563: for(i=0;i<cfg.total_subs;i++)
564: sub_ptr[i]=sav_ptr[i];
565: remove(str);
566: last_ns_time=ns_time;
567: continue; }
568: bprintf(text[UploadingREP],cfg.sys_id);
569: menu("biprot");
570: mnemonics(text[ProtocolOrQuit]);
571: strcpy(tmp2,"Q");
572: for(i=0;i<cfg.total_prots;i++)
573: if(cfg.prot[i]->bicmd[0] && chk_ar(cfg.prot[i]->ar,&useron)) {
574: sprintf(tmp,"%c",cfg.prot[i]->mnemonic);
575: strcat(tmp2,tmp); }
576: ch=(char)getkeys(tmp2,0);
577: if(ch=='Q' || sys_status&SS_ABORT) {
578: for(i=0;i<cfg.total_subs;i++)
579: sub_ptr[i]=sav_ptr[i]; /* re-load saved pointers */
580: last_ns_time=ns_time;
581: continue; }
582: for(i=0;i<cfg.total_prots;i++)
583: if(cfg.prot[i]->bicmd[0] && cfg.prot[i]->mnemonic==ch
584: && chk_ar(cfg.prot[i]->ar,&useron))
585: break;
586: if(i<cfg.total_prots) {
587: batup_total=1;
588: batup_dir[0]=cfg.total_dirs;
589: sprintf(batup_name[0],"%s.rep",cfg.sys_id);
590: batdn_total=1;
591: batdn_dir[0]=cfg.total_dirs;
592: sprintf(batdn_name[0],"%s.qwk",cfg.sys_id);
593: if(!create_batchdn_lst() || !create_batchup_lst()
594: || !create_bimodem_pth()) {
595: batup_total=batdn_total=0;
596: continue; }
597: sprintf(str,"%s%s.qwk",cfg.temp_dir,cfg.sys_id);
598: sprintf(tmp2,"%s.qwk",cfg.sys_id);
599: padfname(tmp2,fd.name);
600: sprintf(str,"%sBATCHDN.LST",cfg.node_dir);
601: sprintf(tmp2,"%sBATCHUP.LST",cfg.node_dir);
602: j=protocol(cmdstr(cfg.prot[i]->bicmd,str,tmp2,NULL),0);
603: batdn_total=batup_total=0;
604: if(cfg.prot[i]->misc&PROT_DSZLOG) {
605: if(!checkprotlog(&fd)) {
606: logline("D!",AttemptedToDownloadQWKpacket);
607: last_ns_time=ns_time;
608: for(i=0;i<cfg.total_subs;i++)
609: sub_ptr[i]=sav_ptr[i]; } /* re-load saved pointers */
610: else {
611: qwk_success(msgcnt,1,0);
612: for(i=0;i<cfg.total_subs;i++)
613: sav_ptr[i]=sub_ptr[i]; } }
614: else if(j) {
615: logline("D!",AttemptedToDownloadQWKpacket);
616: last_ns_time=ns_time;
617: for(i=0;i<cfg.total_subs;i++)
618: sub_ptr[i]=sav_ptr[i]; }
619: else {
620: qwk_success(msgcnt,1,0);
621: for(i=0;i<cfg.total_subs;i++)
622: sav_ptr[i]=sub_ptr[i]; }
623: sprintf(str,"%s%s.qwk",cfg.temp_dir,cfg.sys_id);
624: remove(str);
625: unpack_rep();
626: delfiles(cfg.temp_dir,ALLFILES);
627: //autohangup();
628: }
629: else {
630: last_ns_time=ns_time;
631: for(i=0;i<cfg.total_subs;i++)
632: sub_ptr[i]=sav_ptr[i]; } }
633:
634: else if(ch=='D') { /* Download QWK Packet of new messages */
635: sprintf(str,"%s%s.qwk",cfg.temp_dir,cfg.sys_id);
636: if(!fexist(str) && !pack_qwk(str,&msgcnt,0)) {
637: for(i=0;i<cfg.total_subs;i++)
638: sub_ptr[i]=sav_ptr[i];
639: last_ns_time=ns_time;
640: remove(str);
641: continue; }
642: if(online==ON_LOCAL) { /* Local QWK packet creation */
643: bputs(text[EnterPath]);
644: if(!getstr(str,60,K_LINE|K_UPPER)) {
645: for(i=0;i<cfg.total_subs;i++)
646: sub_ptr[i]=sav_ptr[i]; /* re-load saved pointers */
647: last_ns_time=ns_time;
648: continue; }
649: backslashcolon(str);
650: sprintf(tmp2,"%s%s.qwk",str,cfg.sys_id);
651: if(fexist(tmp2)) {
652: for(i=0;i<10;i++) {
653: sprintf(tmp2,"%s%s.QW%d",str,cfg.sys_id,i);
654: if(!fexist(tmp2))
655: break; }
656: if(i==10) {
657: bputs(text[FileAlreadyThere]);
658: last_ns_time=ns_time;
659: for(i=0;i<cfg.total_subs;i++)
660: sub_ptr[i]=sav_ptr[i];
661: continue; } }
662: sprintf(tmp,"%s%s.qwk",cfg.temp_dir,cfg.sys_id);
663: if(mv(tmp,tmp2,0)) { /* unsuccessful */
664: for(i=0;i<cfg.total_subs;i++)
665: sub_ptr[i]=sav_ptr[i];
666: last_ns_time=ns_time; }
667: else {
668: bprintf(text[FileNBytesSent],tmp2,ultoac(flength(tmp2),tmp));
669: qwk_success(msgcnt,0,0);
670: for(i=0;i<cfg.total_subs;i++)
671: sav_ptr[i]=sub_ptr[i]; }
672: continue; }
673:
674: /***************/
675: /* Send Packet */
676: /***************/
677: menu("dlprot");
678: mnemonics(text[ProtocolOrQuit]);
679: strcpy(tmp2,"Q");
680: for(i=0;i<cfg.total_prots;i++)
681: if(cfg.prot[i]->dlcmd[0] && chk_ar(cfg.prot[i]->ar,&useron)) {
682: sprintf(tmp,"%c",cfg.prot[i]->mnemonic);
683: strcat(tmp2,tmp); }
684: ungetkey(useron.prot);
685: ch=(char)getkeys(tmp2,0);
686: if(ch=='Q' || sys_status&SS_ABORT) {
687: for(i=0;i<cfg.total_subs;i++)
688: sub_ptr[i]=sav_ptr[i]; /* re-load saved pointers */
689: last_ns_time=ns_time;
690: continue; }
691: for(i=0;i<cfg.total_prots;i++)
692: if(cfg.prot[i]->dlcmd[0] && cfg.prot[i]->mnemonic==ch
693: && chk_ar(cfg.prot[i]->ar,&useron))
694: break;
695: if(i<cfg.total_prots) {
696: sprintf(str,"%s%s.qwk",cfg.temp_dir,cfg.sys_id);
697: sprintf(tmp2,"%s.qwk",cfg.sys_id);
698: padfname(tmp2,fd.name);
699: j=protocol(cmdstr(cfg.prot[i]->dlcmd,str,nulstr,NULL),0);
700: if(cfg.prot[i]->misc&PROT_DSZLOG) {
701: if(!checkprotlog(&fd)) {
702: last_ns_time=ns_time;
703: for(i=0;i<cfg.total_subs;i++)
704: sub_ptr[i]=sav_ptr[i]; } /* re-load saved pointers */
705: else {
706: qwk_success(msgcnt,0,0);
707: for(i=0;i<cfg.total_subs;i++)
708: sav_ptr[i]=sub_ptr[i]; } }
709: else if(j) {
710: logline("D!",AttemptedToDownloadQWKpacket);
711: last_ns_time=ns_time;
712: for(i=0;i<cfg.total_subs;i++)
713: sub_ptr[i]=sav_ptr[i]; }
714: else {
715: qwk_success(msgcnt,0,0);
716: for(i=0;i<cfg.total_subs;i++)
717: sav_ptr[i]=sub_ptr[i]; }
718: autohangup(); }
719: else { /* if not valid protocol (hungup?) */
720: for(i=0;i<cfg.total_subs;i++)
721: sub_ptr[i]=sav_ptr[i];
722: last_ns_time=ns_time; } }
723:
724: else if(ch=='U') { /* Upload REP Packet */
725: /*
726: if(useron.rest&FLAG('Q') && useron.rest&FLAG('P')) {
727: bputs(text[R_Post]);
728: continue; }
729: */
730:
731: delfiles(cfg.temp_dir,ALLFILES);
732: bprintf(text[UploadingREP],cfg.sys_id);
733: for(k=0;k<cfg.total_fextrs;k++)
734: if(!stricmp(cfg.fextr[k]->ext,useron.tmpext)
735: && chk_ar(cfg.fextr[k]->ar,&useron))
736: break;
737: if(k>=cfg.total_fextrs) {
738: bputs(text[QWKExtractionFailed]);
739: errorlog("Couldn't extract REP packet - configuration error");
740: continue; }
741:
742: if(online==ON_LOCAL) { /* Local upload of rep packet */
743: bputs(text[EnterPath]);
744: if(!getstr(str,60,K_LINE|K_UPPER))
745: continue;
746: backslashcolon(str);
747: sprintf(tmp,"%s.rep",cfg.sys_id);
748: strcat(str,tmp);
749: sprintf(tmp,"%s%s.rep",cfg.temp_dir,cfg.sys_id);
750: if(!mv(str,tmp,0))
751: unpack_rep();
752: delfiles(cfg.temp_dir,ALLFILES);
753: continue; }
754:
755: /******************/
756: /* Receive Packet */
757: /******************/
758: menu("ulprot");
759: mnemonics(text[ProtocolOrQuit]);
760: strcpy(tmp2,"Q");
761: for(i=0;i<cfg.total_prots;i++)
762: if(cfg.prot[i]->ulcmd[0] && chk_ar(cfg.prot[i]->ar,&useron)) {
763: sprintf(tmp,"%c",cfg.prot[i]->mnemonic);
764: strcat(tmp2,tmp); }
765: ch=(char)getkeys(tmp2,0);
766: if(ch=='Q' || sys_status&SS_ABORT)
767: continue;
768: for(i=0;i<cfg.total_prots;i++)
769: if(cfg.prot[i]->ulcmd[0] && cfg.prot[i]->mnemonic==ch
770: && chk_ar(cfg.prot[i]->ar,&useron))
771: break;
772: if(i>=cfg.total_prots) /* This shouldn't happen */
773: continue;
774: sprintf(str,"%s%s.rep",cfg.temp_dir,cfg.sys_id);
775: protocol(cmdstr(cfg.prot[i]->ulcmd,str,nulstr,NULL),0);
776: unpack_rep();
777: delfiles(cfg.temp_dir,ALLFILES);
778: //autohangup();
779: } }
780: delfiles(cfg.temp_dir,ALLFILES);
781: FREE(sav_ptr);
782: }
783:
784: void sbbs_t::qwksetptr(uint subnum, char *buf, int reset)
785: {
786: long l;
787: ulong last;
788:
789: if(buf[2]=='/' && buf[5]=='/') { /* date specified */
790: l=dstrtounix(&cfg,buf);
791: sub_ptr[subnum]=getmsgnum(subnum,l);
792: return; }
793: l=atol(buf);
794: if(l>=0) /* ptr specified */
795: sub_ptr[subnum]=l;
796: else if(l) { /* relative ptr specified */
797: getlastmsg(subnum,&last,0);
798: if(-l>(long)last)
799: sub_ptr[subnum]=0;
800: else
801: sub_ptr[subnum]=last+l; }
802: else if(reset)
803: getlastmsg(subnum,&sub_ptr[subnum],0);
804: }
805:
806:
807: /****************************************************************************/
808: /* Process a QWK Config line */
809: /****************************************************************************/
810: void sbbs_t::qwkcfgline(char *buf,uint subnum)
811: {
812: char str[128];
813: char tmp[512];
814: uint x,y;
815: long l;
816: ulong qwk=useron.qwk;
817: file_t f;
818:
819: sprintf(str,"%.25s",buf);
820: strupr(str);
821: bprintf("\1n\r\n\1b\1hQWK Control [\1c%s\1b]: \1g%s\r\n"
822: ,subnum==INVALID_SUB ? "Mail":cfg.sub[subnum]->qwkname,str);
823:
824: if(subnum!=INVALID_SUB) { /* Only valid in sub-boards */
825:
826: if(!strncmp(str,"DROP ",5)) { /* Drop from new-scan */
827: l=atol(str+5);
828: if(!l)
829: sub_cfg[subnum]&=~SUB_CFG_NSCAN;
830: else {
831: x=l/1000;
832: y=l-(x*1000);
833: if(x>=usrgrps || y>=usrsubs[x]) {
834: bprintf(text[QWKInvalidConferenceN],l);
835: sprintf(str,"Invalid conference number %lu",l);
836: logline("Q!",str); }
837: else
838: sub_cfg[usrsub[x][y]]&=~SUB_CFG_NSCAN; }
839: return; }
840:
841: if(!strncmp(str,"ADD YOURS ",10)) { /* Add to new-scan */
842: sub_cfg[subnum]|=(SUB_CFG_NSCAN|SUB_CFG_YSCAN);
843: qwksetptr(subnum,str+10,0);
844: return; }
845:
846: else if(!strncmp(str,"YOURS ",6)) {
847: sub_cfg[subnum]|=(SUB_CFG_NSCAN|SUB_CFG_YSCAN);
848: qwksetptr(subnum,str+6,0);
849: return; }
850:
851: else if(!strncmp(str,"ADD ",4)) { /* Add to new-scan */
852: sub_cfg[subnum]|=SUB_CFG_NSCAN;
853: sub_cfg[subnum]&=~SUB_CFG_YSCAN;
854: qwksetptr(subnum,str+4,0);
855: return; }
856:
857: if(!strncmp(str,"RESET ",6)) { /* set msgptr */
858: qwksetptr(subnum,str+6,1);
859: return; }
860:
861: if(!strncmp(str,"SUBPTR ",7)) {
862: qwksetptr(subnum,str+7,1);
863: return; }
864: }
865:
866: if(!strncmp(str,"RESETALL ",9)) { /* set all ptrs */
867: for(x=0;x<usrgrps;x++)
868: for(y=0;y<usrsubs[x];y++)
869: if(sub_cfg[usrsub[x][y]]&SUB_CFG_NSCAN)
870: qwksetptr(usrsub[x][y],str+9,1); }
871:
872: else if(!strncmp(str,"ALLPTR ",7)) { /* set all ptrs */
873: for(x=0;x<usrgrps;x++)
874: for(y=0;y<usrsubs[x];y++)
875: if(sub_cfg[usrsub[x][y]]&SUB_CFG_NSCAN)
876: qwksetptr(usrsub[x][y],str+7,1); }
877:
878: else if(!strncmp(str,"FILES ",6)) { /* files list */
879: if(!strncmp(str+6,"ON ",3))
880: useron.qwk|=QWK_FILES;
881: else if(str[8]=='/' && str[11]=='/') { /* set scan date */
882: useron.qwk|=QWK_FILES;
883: ns_time=dstrtounix(&cfg,str+6); }
884: else
885: useron.qwk&=~QWK_FILES; }
886:
887: else if(!strncmp(str,"OWN ",4)) { /* message from you */
888: if(!strncmp(str+4,"ON ",3))
889: useron.qwk|=QWK_BYSELF;
890: else
891: useron.qwk&=~QWK_BYSELF;
892: return; }
893:
894: else if(!strncmp(str,"NDX ",4)) { /* include indexes */
895: if(!strncmp(str+4,"OFF ",4))
896: useron.qwk|=QWK_NOINDEX;
897: else
898: useron.qwk&=~QWK_NOINDEX; }
899:
900: else if(!strncmp(str,"CONTROL ",8)) { /* exclude ctrl files */
901: if(!strncmp(str+8,"OFF ",4))
902: useron.qwk|=QWK_NOCTRL;
903: else
904: useron.qwk&=~QWK_NOCTRL; }
905:
906: else if(!strncmp(str,"VIA ",4)) { /* include @VIA: */
907: if(!strncmp(str+4,"ON ",3))
908: useron.qwk|=QWK_VIA;
909: else
910: useron.qwk&=~QWK_VIA; }
911:
912: else if(!strncmp(str,"TZ ",3)) { /* include @TZ: */
913: if(!strncmp(str+3,"ON ",3))
914: useron.qwk|=QWK_TZ;
915: else
916: useron.qwk&=~QWK_TZ; }
917:
918: else if(!strncmp(str,"ATTACH ",7)) { /* file attachments */
919: if(!strncmp(str+7,"ON ",3))
920: useron.qwk|=QWK_ATTACH;
921: else
922: useron.qwk&=~QWK_ATTACH; }
923:
924: else if(!strncmp(str,"DELMAIL ",8)) { /* delete mail */
925: if(!strncmp(str+8,"ON ",3))
926: useron.qwk|=QWK_DELMAIL;
927: else
928: useron.qwk&=~QWK_DELMAIL; }
929:
930: else if(!strncmp(str,"CTRL-A ",7)) { /* Ctrl-a codes */
931: if(!strncmp(str+7,"KEEP ",5)) {
932: useron.qwk|=QWK_RETCTLA;
933: useron.qwk&=~QWK_EXPCTLA; }
934: else if(!strncmp(str+7,"EXPAND ",7)) {
935: useron.qwk|=QWK_EXPCTLA;
936: useron.qwk&=~QWK_RETCTLA; }
937: else
938: useron.qwk&=~(QWK_EXPCTLA|QWK_RETCTLA); }
939:
940: else if(!strncmp(str,"MAIL ",5)) { /* include e-mail */
941: if(!strncmp(str+5,"ALL ",4)) {
942: useron.qwk|=QWK_ALLMAIL;
943: useron.qwk&=~QWK_EMAIL; }
944: else if(!strncmp(str+5,"ON ",3)) {
945: useron.qwk|=QWK_EMAIL;
946: useron.qwk&=~QWK_ALLMAIL; }
947: else
948: useron.qwk&=~(QWK_ALLMAIL|QWK_EMAIL); }
949:
950: else if(!strncmp(str,"FREQ ",5)) { /* file request */
951: padfname(str+5,f.name);
952: strupr(f.name);
953: for(x=0;x<usrlibs;x++) {
954: for(y=0;y<usrdirs[x];y++)
955: if(findfile(&cfg,usrdir[x][y],f.name))
956: break;
957: if(y<usrdirs[x])
958: break; }
959: if(x>=usrlibs) {
960: bprintf("\r\n%s",f.name);
961: bputs(text[FileNotFound]); }
962: else {
963: f.dir=usrdir[x][y];
964: getfileixb(&cfg,&f);
965: f.size=0;
966: getfiledat(&cfg,&f);
967: if(f.size==-1L)
968: bprintf(text[FileIsNotOnline],f.name);
969: else
970: addtobatdl(&f); } }
971:
972: else bputs("\1r\1h\1iUnrecognized Control Command!\1n\r\n");
973:
974: if(qwk!=useron.qwk)
975: putuserrec(&cfg,useron.number,U_QWK,8,ultoa(useron.qwk,tmp,16));
976: }
977:
978:
This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.