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