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