![[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.