![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to un_rep.cpp CVS log ![[TXT]](/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvsweb/icons/dir.gif){kind=icon}
Up to [Synchronet] / sbbs / sbbs3|
Return to un_rep.cpp CVS log | Up to [Synchronet] / sbbs / sbbs3 |
1.1 ! root 1: /* un_rep.cpp */ ! 2: ! 3: /* Synchronet QWK replay (REP) packet unpacking routine */ ! 4: ! 5: /* $Id: un_rep.cpp,v 1.9 2000/12/31 03:41:55 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 "qwk.h" ! 40: ! 41: /****************************************************************************/ ! 42: /* Unpacks .REP packet, 'repname' is the path and filename of the packet */ ! 43: /****************************************************************************/ ! 44: bool sbbs_t::unpack_rep(char* repfile) ! 45: { ! 46: char str[256],fname[128] ! 47: ,*AttemptedToUploadREPpacket="Attempted to upload REP packet"; ! 48: char tmp[512]; ! 49: char block[128]; ! 50: int file; ! 51: uint i,j,k,lastsub=INVALID_SUB; ! 52: long l,size,misc; ! 53: ulong n; ! 54: ulong ex; ! 55: node_t node; ! 56: FILE* rep; ! 57: DIR* dir; ! 58: DIRENT* dirent; ! 59: ! 60: if(repfile!=NULL) ! 61: strcpy(str,repfile); ! 62: else ! 63: sprintf(str,"%s%s.rep",cfg.temp_dir,cfg.sys_id); ! 64: if(!fexist(str)) { ! 65: bputs(text[QWKReplyNotReceived]); ! 66: logline("U!",AttemptedToUploadREPpacket); ! 67: logline(nulstr,"REP file not received"); ! 68: return(false); ! 69: } ! 70: for(k=0;k<cfg.total_fextrs;k++) ! 71: if(!stricmp(cfg.fextr[k]->ext,useron.tmpext) && chk_ar(cfg.fextr[k]->ar,&useron)) ! 72: break; ! 73: if(k>=cfg.total_fextrs) ! 74: k=0; ! 75: ex=EX_OUTL|EX_OUTR; ! 76: if(!online) ! 77: ex|=EX_OFFLINE; ! 78: i=external(cmdstr(cfg.fextr[k]->cmd,str,ALLFILES,NULL),ex); ! 79: if(i) { ! 80: bputs(text[QWKExtractionFailed]); ! 81: logline("U!",AttemptedToUploadREPpacket); ! 82: logline(nulstr,"Extraction failed"); ! 83: return(false); ! 84: } ! 85: sprintf(str,"%s%s.msg",cfg.temp_dir,cfg.sys_id); ! 86: if(!fexist(str)) { ! 87: bputs(text[QWKReplyNotReceived]); ! 88: logline("U!",AttemptedToUploadREPpacket); ! 89: logline(nulstr,"MSG file not received"); ! 90: return(false); ! 91: } ! 92: if((rep=fnopen(&file,str,O_RDONLY))==NULL) { ! 93: errormsg(WHERE,ERR_OPEN,str,O_RDONLY); ! 94: return(false); ! 95: } ! 96: size=filelength(file); ! 97: fread(block,128,1,rep); ! 98: if(strnicmp((char *)block,cfg.sys_id,strlen(cfg.sys_id))) { ! 99: fclose(rep); ! 100: bputs(text[QWKReplyNotReceived]); ! 101: logline("U!",AttemptedToUploadREPpacket); ! 102: logline(nulstr,"Incorrect BBSID"); ! 103: return(false); ! 104: } ! 105: logline("U+","Uploaded REP packet"); ! 106: /********************/ ! 107: /* Process messages */ ! 108: /********************/ ! 109: bputs(text[QWKUnpacking]); ! 110: ! 111: for(l=128;l<size;l+=i*128) { ! 112: lncntr=0; /* defeat pause */ ! 113: if(fseek(rep,l,SEEK_SET)!=0) { ! 114: sprintf(str,"%s.msg", cfg.sys_id); ! 115: errormsg(WHERE,ERR_SEEK,str,l); ! 116: break; ! 117: } ! 118: if(fread(block,1,128,rep)!=128) { ! 119: sprintf(str,"%s.msg", cfg.sys_id); ! 120: errormsg(WHERE,ERR_READ,str,ftell(rep)); ! 121: break; ! 122: } ! 123: sprintf(tmp,"%.6s",block+116); ! 124: i=atoi(tmp); /* i = number of 128 byte records */ ! 125: if(i<2) { ! 126: sprintf(str,"%s.msg blocks (read '%s' at offset %ld)", cfg.sys_id, tmp, l); ! 127: errormsg(WHERE,ERR_CHK,str,i); ! 128: i=1; ! 129: continue; } ! 130: if(atoi(block+1)==0) { /**********/ ! 131: if(useron.rest&FLAG('E')) { /* E-mail */ ! 132: bputs(text[R_Email]); /**********/ ! 133: continue; } ! 134: ! 135: sprintf(str,"%25.25s",block+21); ! 136: truncsp(str); ! 137: if(!stricmp(str,"NETMAIL")) { /* QWK to FidoNet NetMail */ ! 138: qwktonetmail(rep,block,NULL,0); ! 139: continue; } ! 140: if(strchr(str,'@')) { ! 141: qwktonetmail(rep,block,str,0); ! 142: continue; } ! 143: if(!stricmp(str,"SBBS")) { /* to SBBS, config stuff */ ! 144: qwkcfgline(block+71,INVALID_SUB); ! 145: continue; } ! 146: ! 147: if(useron.etoday>=cfg.level_emailperday[useron.level] ! 148: && !(useron.rest&FLAG('Q'))) { ! 149: bputs(text[TooManyEmailsToday]); ! 150: continue; } ! 151: j=atoi(str); ! 152: if(j && j>lastuser(&cfg)) ! 153: j=0; ! 154: if(!j && ! 155: (!stricmp(str,"SYSOP") ! 156: || !stricmp(str,cfg.sys_id) ! 157: || !stricmp(str,cfg.sys_op))) ! 158: j=1; ! 159: if(!j) ! 160: j=matchuser(&cfg,str); ! 161: if(!j) { ! 162: bputs(text[UnknownUser]); ! 163: continue; } ! 164: if(j==1 && useron.rest&FLAG('S')) { ! 165: bprintf(text[R_Feedback],cfg.sys_op); ! 166: continue; } ! 167: ! 168: getuserrec(&cfg,j,U_MISC,8,str); ! 169: misc=ahtoul(str); ! 170: if(misc&NETMAIL && cfg.sys_misc&SM_FWDTONET) { ! 171: getuserrec(&cfg,j,U_NETMAIL,LEN_NETMAIL,str); ! 172: qwktonetmail(rep,block,str,0); ! 173: continue; } ! 174: ! 175: sprintf(smb.file,"%smail",cfg.data_dir); ! 176: smb.retry_time=cfg.smb_retry_time; ! 177: ! 178: if(lastsub!=INVALID_SUB) { ! 179: smb_close(&smb); ! 180: lastsub=INVALID_SUB; } ! 181: ! 182: if((k=smb_open(&smb))!=0) { ! 183: errormsg(WHERE,ERR_OPEN,smb.file,k,smb.last_error); ! 184: continue; } ! 185: ! 186: if(!filelength(fileno(smb.shd_fp))) { ! 187: smb.status.max_crcs=cfg.mail_maxcrcs; ! 188: smb.status.max_msgs=MAX_SYSMAIL; ! 189: smb.status.max_age=cfg.mail_maxage; ! 190: smb.status.attr=SMB_EMAIL; ! 191: if((k=smb_create(&smb))!=0) { ! 192: smb_close(&smb); ! 193: errormsg(WHERE,ERR_CREATE,smb.file,k); ! 194: continue; } } ! 195: ! 196: if((k=smb_locksmbhdr(&smb))!=0) { ! 197: smb_close(&smb); ! 198: errormsg(WHERE,ERR_LOCK,smb.file,k); ! 199: continue; } ! 200: ! 201: if((k=smb_getstatus(&smb))!=0) { ! 202: smb_close(&smb); ! 203: errormsg(WHERE,ERR_READ,smb.file,k); ! 204: continue; } ! 205: ! 206: smb_unlocksmbhdr(&smb); ! 207: ! 208: if(!qwktomsg(rep,block,0,INVALID_SUB,j)) { ! 209: smb_close(&smb); ! 210: continue; } ! 211: smb_close(&smb); ! 212: ! 213: if(j==1) { ! 214: useron.fbacks++; ! 215: logon_fbacks++; ! 216: putuserrec(&cfg,useron.number,U_FBACKS,5 ! 217: ,ultoa(useron.fbacks,tmp,10)); } ! 218: else { ! 219: useron.emails++; ! 220: logon_emails++; ! 221: putuserrec(&cfg,useron.number,U_EMAILS,5 ! 222: ,ultoa(useron.emails,tmp,10)); } ! 223: useron.etoday++; ! 224: putuserrec(&cfg,useron.number,U_ETODAY,5 ! 225: ,ultoa(useron.etoday,tmp,10)); ! 226: bprintf(text[Emailed],username(&cfg,j,tmp),j); ! 227: sprintf(str,"E-mailed %s #%d",username(&cfg,j,tmp),j); ! 228: logline("E+",str); ! 229: if(useron.rest&FLAG('Q')) { ! 230: sprintf(tmp,"%-25.25s",block+46); ! 231: truncsp(tmp); } ! 232: else ! 233: strcpy(tmp,useron.alias); ! 234: for(k=1;k<=cfg.sys_nodes;k++) { /* Tell user, if online */ ! 235: getnodedat(k,&node,0); ! 236: if(node.useron==j && !(node.misc&NODE_POFF) ! 237: && (node.status==NODE_INUSE ! 238: || node.status==NODE_QUIET)) { ! 239: sprintf(str,text[EmailNodeMsg] ! 240: ,cfg.node_num,tmp); ! 241: putnmsg(k,str); ! 242: break; } } ! 243: if(k>cfg.sys_nodes) { ! 244: sprintf(str,text[UserSentYouMail],tmp); ! 245: putsmsg(&cfg,j,str); } } /* end of email */ ! 246: ! 247: /**************************/ ! 248: else { /* message on a sub-board */ ! 249: /**************************/ ! 250: n=atol((char *)block+1); /* conference number */ ! 251: for(j=0;j<usrgrps;j++) { ! 252: for(k=0;k<usrsubs[j];k++) ! 253: if(cfg.sub[usrsub[j][k]]->qwkconf==n) ! 254: break; ! 255: if(k<usrsubs[j]) ! 256: break; } ! 257: ! 258: if(j>=usrgrps) { ! 259: if(n<1000) { /* version 1 method, start at 101 */ ! 260: j=n/100; ! 261: k=n-(j*100); } ! 262: else { /* version 2 method, start at 1001 */ ! 263: j=n/1000; ! 264: k=n-(j*1000); } ! 265: j--; /* j is group */ ! 266: k--; /* k is sub */ ! 267: if(j>=usrgrps || k>=usrsubs[j] || cfg.sub[usrsub[j][k]]->qwkconf) { ! 268: bprintf(text[QWKInvalidConferenceN],n); ! 269: sprintf(str,"Invalid conference number %d",n); ! 270: logline("P!",str); ! 271: continue; } } ! 272: ! 273: n=usrsub[j][k]; ! 274: ! 275: /* if posting, add to new-scan config for QWKnet nodes automatically */ ! 276: if(useron.rest&FLAG('Q')) ! 277: sub_cfg[n]|=SUB_CFG_NSCAN; ! 278: ! 279: sprintf(str,"%-25.25s","SBBS"); ! 280: if(!strnicmp((char *)block+21,str,25)) { /* to SBBS, config stuff */ ! 281: qwkcfgline((char *)block+71,n); ! 282: continue; } ! 283: ! 284: if(!SYSOP && cfg.sub[n]->misc&SUB_QNET) { /* QWK Netted */ ! 285: sprintf(str,"%-25.25s","DROP"); /* Drop from new-scan? */ ! 286: if(!strnicmp((char *)block+71,str,25)) /* don't allow post */ ! 287: continue; ! 288: sprintf(str,"%-25.25s","ADD"); /* Add to new-scan? */ ! 289: if(!strnicmp((char *)block+71,str,25)) /* don't allow post */ ! 290: continue; } ! 291: ! 292: if(useron.rest&FLAG('Q') && !(cfg.sub[n]->misc&SUB_QNET)) { ! 293: bputs(text[CantPostOnSub]); ! 294: logline("P!","Attempted to post on non-QWKnet sub"); ! 295: continue; } ! 296: ! 297: if(useron.rest&FLAG('P')) { ! 298: bputs(text[R_Post]); ! 299: logline("P!","Post attempted"); ! 300: continue; } ! 301: ! 302: if(useron.ptoday>=cfg.level_postsperday[useron.level] ! 303: && !(useron.rest&FLAG('Q'))) { ! 304: bputs(text[TooManyPostsToday]); ! 305: continue; } ! 306: ! 307: if(useron.rest&FLAG('N') ! 308: && cfg.sub[n]->misc&(SUB_FIDO|SUB_PNET|SUB_QNET|SUB_INET)) { ! 309: bputs(text[CantPostOnSub]); ! 310: logline("P!","Networked post attempted"); ! 311: continue; } ! 312: ! 313: if(!chk_ar(cfg.sub[n]->post_ar,&useron)) { ! 314: bputs(text[CantPostOnSub]); ! 315: logline("P!","Post attempted"); ! 316: continue; } ! 317: ! 318: if((block[0]=='*' || block[0]=='+') ! 319: && !(cfg.sub[n]->misc&SUB_PRIV)) { ! 320: bputs(text[PrivatePostsNotAllowed]); ! 321: logline("P!","Private post attempt"); ! 322: continue; } ! 323: ! 324: if(block[0]=='*' || block[0]=='+' /* Private post */ ! 325: || cfg.sub[n]->misc&SUB_PONLY) { ! 326: sprintf(str,"%-25.25s",nulstr); ! 327: sprintf(tmp,"%-25.25s","ALL"); ! 328: if(!strnicmp((char *)block+21,str,25) ! 329: || !strnicmp((char *)block+21,tmp,25)) { /* to blank */ ! 330: bputs(text[NoToUser]); /* or all */ ! 331: continue; } } ! 332: ! 333: if(!SYSOP && !(useron.rest&FLAG('Q'))) { ! 334: sprintf(str,"%-25.25s","SYSOP"); ! 335: if(!strnicmp((char *)block+21,str,25)) { ! 336: sprintf(str,"%-25.25s",username(&cfg,1,tmp)); ! 337: memcpy((char *)block+21,str,25); } } /* change from sysop */ ! 338: /* to user name */ ! 339: ! 340: #if 0 /* TWIT FILTER */ ! 341: sprintf(str,"%25.25s",block+46); /* From user */ ! 342: truncsp(str); ! 343: ! 344: if(!stricmp(str,"Lee Matherne") ! 345: || !stricmp(str,"Big Joe") ! 346: ) { ! 347: bprintf(text[Posted],cfg.grp[cfg.sub[n]->grp]->sname ! 348: ,cfg.sub[n]->lname); ! 349: continue; } ! 350: #endif ! 351: ! 352: if(n!=lastsub) { ! 353: if(lastsub!=INVALID_SUB) ! 354: smb_close(&smb); ! 355: lastsub=INVALID_SUB; ! 356: sprintf(smb.file,"%s%s",cfg.sub[n]->data_dir,cfg.sub[n]->code); ! 357: smb.retry_time=cfg.smb_retry_time; ! 358: if((j=smb_open(&smb))!=0) { ! 359: errormsg(WHERE,ERR_OPEN,smb.file,j,smb.last_error); ! 360: continue; } ! 361: ! 362: if(!filelength(fileno(smb.shd_fp))) { ! 363: smb.status.max_crcs=cfg.sub[n]->maxcrcs; ! 364: smb.status.max_msgs=cfg.sub[n]->maxmsgs; ! 365: smb.status.max_age=cfg.sub[n]->maxage; ! 366: smb.status.attr=cfg.sub[n]->misc&SUB_HYPER ? SMB_HYPERALLOC:0; ! 367: if((j=smb_create(&smb))!=0) { ! 368: smb_close(&smb); ! 369: lastsub=INVALID_SUB; ! 370: errormsg(WHERE,ERR_CREATE,smb.file,j); ! 371: continue; } } ! 372: ! 373: if((j=smb_locksmbhdr(&smb))!=0) { ! 374: smb_close(&smb); ! 375: lastsub=INVALID_SUB; ! 376: errormsg(WHERE,ERR_LOCK,smb.file,j); ! 377: continue; } ! 378: if((j=smb_getstatus(&smb))!=0) { ! 379: smb_close(&smb); ! 380: lastsub=INVALID_SUB; ! 381: errormsg(WHERE,ERR_READ,smb.file,j); ! 382: continue; } ! 383: smb_unlocksmbhdr(&smb); ! 384: lastsub=n; } ! 385: ! 386: if(!qwktomsg(rep,block,0,n,0)) ! 387: continue; ! 388: ! 389: useron.ptoday++; ! 390: useron.posts++; ! 391: logon_posts++; ! 392: putuserrec(&cfg,useron.number,U_POSTS,5,ultoa(useron.posts,str,10)); ! 393: putuserrec(&cfg,useron.number,U_PTODAY,5,ultoa(useron.ptoday,str,10)); ! 394: bprintf(text[Posted],cfg.grp[cfg.sub[n]->grp]->sname ! 395: ,cfg.sub[n]->lname); ! 396: sprintf(str,"Posted on %s/%s",cfg.grp[cfg.sub[n]->grp]->sname ! 397: ,cfg.sub[n]->lname); ! 398: if(cfg.sub[n]->misc&SUB_FIDO && cfg.sub[n]->echomail_sem[0]) /* semaphore */ ! 399: if((file=nopen(cmdstr(cfg.sub[n]->echomail_sem,nulstr,nulstr,NULL) ! 400: ,O_WRONLY|O_CREAT|O_TRUNC))!=-1) ! 401: close(file); ! 402: logline("P+",str); } } /* end of public message */ ! 403: ! 404: update_qwkroute(NULL); /* Write ROUTE.DAT */ ! 405: ! 406: if(lastsub!=INVALID_SUB) ! 407: smb_close(&smb); ! 408: fclose(rep); ! 409: ! 410: if(useron.rest&FLAG('Q')) { /* QWK Net Node */ ! 411: sprintf(str,"%s%s.msg",cfg.temp_dir,cfg.sys_id); ! 412: remove(str); ! 413: sprintf(str,"%s%s.rep",cfg.temp_dir,cfg.sys_id); ! 414: remove(str); ! 415: ! 416: dir=opendir(cfg.temp_dir); ! 417: while((dirent=readdir(dir))!=NULL) { /* Extra files */ ! 418: // Create directory if necessary ! 419: sprintf(str,"%sqnet/%s.in",cfg.data_dir,useron.alias); ! 420: _mkdir(str); ! 421: // Move files ! 422: sprintf(str,"%s%s",cfg.temp_dir,dirent->d_name); ! 423: if(isdir(str)) ! 424: continue; ! 425: sprintf(fname,"%sqnet/%s.in/%s",cfg.data_dir,useron.alias,dirent->d_name); ! 426: mv(str,fname,1); ! 427: sprintf(str,text[ReceivedFileViaQWK],dirent->d_name,useron.alias); ! 428: putsmsg(&cfg,1,str); ! 429: } ! 430: closedir(dir); ! 431: sprintf(str,"%sqnet-rep.now",cfg.data_dir); ! 432: if((file=nopen(str,O_WRONLY|O_CREAT|O_TRUNC))!=-1) ! 433: close(file); ! 434: } ! 435: ! 436: bputs(text[QWKUnpacked]); ! 437: CRLF; ! 438: /**********************************************/ ! 439: /* Hang-up now if that's what the user wanted */ ! 440: /**********************************************/ ! 441: autohangup(); ! 442: ! 443: return(true); ! 444: }
This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.