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