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