![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to un_qwk.cpp CVS log ![[TXT]](/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvsweb/icons/dir.gif){kind=icon}
Up to [Synchronet] / sbbs / src / sbbs3|
Return to un_qwk.cpp CVS log | Up to [Synchronet] / sbbs / src / sbbs3 |
1.1 ! root 1: /* un_qwk.cpp */ ! 2: ! 3: /* Synchronet QWK unpacking routine */ ! 4: ! 5: /* $Id: un_qwk.cpp,v 1.30 2006/05/08 17:02:29 deuce 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 2004 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 .QWK packet, hubnum is the number of the QWK net hub */ ! 43: /****************************************************************************/ ! 44: bool sbbs_t::unpack_qwk(char *packet,uint hubnum) ! 45: { ! 46: char str[MAX_PATH+1],fname[MAX_PATH+1]; ! 47: char tmp[512]; ! 48: char from[26]; ! 49: char to[26]; ! 50: char inbox[MAX_PATH+1]; ! 51: uchar block[QWK_BLOCK_LEN]; ! 52: int k,file; ! 53: uint i,j,n,lastsub=INVALID_SUB; ! 54: uint blocks; ! 55: long l,size,misc; ! 56: ulong t; ! 57: ulong msgs=0; ! 58: ulong tmsgs=0; ! 59: time_t start; ! 60: time_t startsub; ! 61: DIR* dir; ! 62: DIRENT* dirent; ! 63: FILE* qwk; ! 64: BOOL twit_list; ! 65: ! 66: sprintf(fname,"%stwitlist.cfg",cfg.ctrl_dir); ! 67: twit_list=fexist(fname); ! 68: ! 69: start=time(NULL); ! 70: if((l=flength(packet))<1) { ! 71: errormsg(WHERE,ERR_LEN,packet,l); ! 72: return(false); ! 73: } ! 74: i=external(cmdstr(cfg.qhub[hubnum]->unpack,packet,ALLFILES,NULL),EX_OFFLINE); ! 75: if(i) { ! 76: errormsg(WHERE,ERR_EXEC,cmdstr(cfg.qhub[hubnum]->unpack,packet,ALLFILES,NULL),i); ! 77: return(false); ! 78: } ! 79: sprintf(str,"%sMESSAGES.DAT",cfg.temp_dir); ! 80: if(!fexistcase(str)) { ! 81: sprintf(str,"%s doesn't contain MESSAGES.DAT (%s)",packet,str); ! 82: errorlog(str); ! 83: return(false); ! 84: } ! 85: if((qwk=fnopen(&file,str,O_RDONLY))==NULL) { ! 86: errormsg(WHERE,ERR_OPEN,str,O_RDONLY); ! 87: return(false); ! 88: } ! 89: size=filelength(file); ! 90: /********************/ ! 91: /* Process messages */ ! 92: /********************/ ! 93: eprintf(LOG_INFO,"Importing QWK Network Packet: %s",packet); ! 94: ! 95: for(l=QWK_BLOCK_LEN;l<size;l+=blocks*QWK_BLOCK_LEN) { ! 96: if(terminated) { ! 97: eprintf(LOG_NOTICE,"!Terminated"); ! 98: break; ! 99: } ! 100: fseek(qwk,l,SEEK_SET); ! 101: fread(block,QWK_BLOCK_LEN,1,qwk); ! 102: if(block[0]<' ' || block[0]&0x80) { ! 103: eprintf(LOG_NOTICE,"!Invalid message status (%02X) at offset %lu in %s" ! 104: ,block[0], l, packet); ! 105: blocks=1; ! 106: continue; ! 107: } ! 108: sprintf(tmp,"%.6s",block+116); ! 109: blocks=atoi(tmp); /* i = number of blocks */ ! 110: if(blocks<2) { ! 111: eprintf(LOG_NOTICE,"!Invalid number of blocks (%d) at offset %lu in %s" ! 112: ,blocks, l+116, packet); ! 113: blocks=1; ! 114: continue; ! 115: } ! 116: /*********************************/ ! 117: /* public message on a sub-board */ ! 118: /*********************************/ ! 119: n=(uint)block[123]|(((uint)block[124])<<8); /* conference number */ ! 120: ! 121: if(!n) { /* NETMAIL */ ! 122: sprintf(str,"%25.25s",block+21); ! 123: truncsp(str); ! 124: eprintf(LOG_INFO,"NetMail from %s to %s", cfg.qhub[hubnum]->id, str); ! 125: if(!stricmp(str,"NETMAIL")) { /* QWK to FidoNet NetMail */ ! 126: qwktonetmail(qwk,(char *)block,NULL,hubnum+1); ! 127: continue; ! 128: } ! 129: if(strchr(str,'@')) { ! 130: qwktonetmail(qwk,(char *)block,str,hubnum+1); ! 131: continue; ! 132: } ! 133: j=atoi(str); ! 134: if(j && j>lastuser(&cfg)) ! 135: j=0; ! 136: if(!j) ! 137: j=matchuser(&cfg,str,TRUE /* sysop_alias */); ! 138: if(!j) { ! 139: eprintf(LOG_NOTICE,"!NetMail from %s to UNKNOWN USER: %s", cfg.qhub[hubnum]->id, str); ! 140: continue; ! 141: } ! 142: ! 143: getuserrec(&cfg,j,U_MISC,8,str); ! 144: misc=ahtoul(str); ! 145: if(misc&NETMAIL && cfg.sys_misc&SM_FWDTONET) { ! 146: getuserrec(&cfg,j,U_NETMAIL,LEN_NETMAIL,str); ! 147: qwktonetmail(qwk,(char*)block,str,hubnum+1); ! 148: continue; ! 149: } ! 150: ! 151: smb_stack(&smb,SMB_STACK_PUSH); ! 152: sprintf(smb.file,"%smail",cfg.data_dir); ! 153: smb.retry_time=cfg.smb_retry_time; ! 154: smb.subnum=INVALID_SUB; ! 155: if((k=smb_open(&smb))!=0) { ! 156: errormsg(WHERE,ERR_OPEN,smb.file,k,smb.last_error); ! 157: smb_stack(&smb,SMB_STACK_POP); ! 158: continue; ! 159: } ! 160: if(!filelength(fileno(smb.shd_fp))) { ! 161: smb.status.max_crcs=cfg.mail_maxcrcs; ! 162: smb.status.max_msgs=0; ! 163: smb.status.max_age=cfg.mail_maxage; ! 164: smb.status.attr=SMB_EMAIL; ! 165: if((k=smb_create(&smb))!=0) { ! 166: smb_close(&smb); ! 167: errormsg(WHERE,ERR_CREATE,smb.file,k); ! 168: smb_stack(&smb,SMB_STACK_POP); ! 169: continue; ! 170: } ! 171: } ! 172: if((k=smb_locksmbhdr(&smb))!=0) { ! 173: smb_close(&smb); ! 174: errormsg(WHERE,ERR_LOCK,smb.file,k); ! 175: smb_stack(&smb,SMB_STACK_POP); ! 176: continue; ! 177: } ! 178: if((k=smb_getstatus(&smb))!=0) { ! 179: smb_close(&smb); ! 180: errormsg(WHERE,ERR_READ,smb.file,k); ! 181: smb_stack(&smb,SMB_STACK_POP); ! 182: continue; ! 183: } ! 184: smb_unlocksmbhdr(&smb); ! 185: if(qwktomsg(qwk,(char *)block,hubnum+1,INVALID_SUB,j)) { ! 186: sprintf(tmp,"%-25.25s",block+46); ! 187: truncsp(tmp); ! 188: sprintf(str,text[UserSentYouMail],tmp); ! 189: putsmsg(&cfg,j,str); ! 190: tmsgs++; ! 191: } ! 192: smb_close(&smb); ! 193: smb_stack(&smb,SMB_STACK_POP); ! 194: continue; ! 195: } ! 196: ! 197: for(j=0;j<cfg.qhub[hubnum]->subs;j++) ! 198: if(cfg.qhub[hubnum]->conf[j]==n) ! 199: break; ! 200: if(j>=cfg.qhub[hubnum]->subs) { /* ignore messages for subs not in config */ ! 201: eprintf(LOG_NOTICE,"!Message from %s on UNKNOWN CONFERENCE NUMBER: %u" ! 202: ,cfg.qhub[hubnum]->id, n); ! 203: continue; ! 204: } ! 205: ! 206: j=cfg.qhub[hubnum]->sub[j]; ! 207: ! 208: /* TWIT FILTER */ ! 209: if(twit_list) { ! 210: sprintf(fname,"%stwitlist.cfg",cfg.ctrl_dir); ! 211: ! 212: sprintf(from,"%25.25s",block+46); /* From user */ ! 213: truncsp(from); ! 214: sprintf(to,"%25.25s",block+21); /* To user */ ! 215: truncsp(to); ! 216: ! 217: if(findstr(from,fname) || findstr(to,fname)) { ! 218: eprintf(LOG_NOTICE,"!Filtering post from %s to %s on %s %s" ! 219: ,from ! 220: ,to ! 221: ,cfg.grp[cfg.sub[j]->grp]->sname,cfg.sub[j]->lname); ! 222: continue; ! 223: } ! 224: } ! 225: ! 226: if(j!=lastsub) { ! 227: ! 228: if(msgs) { ! 229: t=time(NULL)-startsub; ! 230: if(t<1) ! 231: t=1; ! 232: eprintf(LOG_INFO,"Imported %lu msgs in %lu seconds (%lu msgs/sec)", msgs,t,msgs/t); ! 233: } ! 234: msgs=0; ! 235: startsub=time(NULL); ! 236: ! 237: eprintf(LOG_INFO,"Importing messages from %s into %s %s" ! 238: ,cfg.qhub[hubnum]->id, cfg.grp[cfg.sub[j]->grp]->sname,cfg.sub[j]->lname); ! 239: ! 240: if(lastsub!=INVALID_SUB) ! 241: smb_close(&smb); ! 242: lastsub=INVALID_SUB; ! 243: sprintf(smb.file,"%s%s",cfg.sub[j]->data_dir,cfg.sub[j]->code); ! 244: smb.retry_time=cfg.smb_retry_time; ! 245: smb.subnum=j; ! 246: if((k=smb_open(&smb))!=0) { ! 247: errormsg(WHERE,ERR_OPEN,smb.file,k,smb.last_error); ! 248: continue; ! 249: } ! 250: if(!filelength(fileno(smb.shd_fp))) { ! 251: smb.status.max_crcs=cfg.sub[j]->maxcrcs; ! 252: smb.status.max_msgs=cfg.sub[j]->maxmsgs; ! 253: smb.status.max_age=cfg.sub[j]->maxage; ! 254: smb.status.attr=cfg.sub[j]->misc&SUB_HYPER ? SMB_HYPERALLOC :0; ! 255: if((k=smb_create(&smb))!=0) { ! 256: smb_close(&smb); ! 257: errormsg(WHERE,ERR_CREATE,smb.file,k); ! 258: continue; ! 259: } ! 260: } ! 261: if((k=smb_locksmbhdr(&smb))!=0) { ! 262: smb_close(&smb); ! 263: errormsg(WHERE,ERR_LOCK,smb.file,k); ! 264: continue; ! 265: } ! 266: if((k=smb_getstatus(&smb))!=0) { ! 267: smb_close(&smb); ! 268: errormsg(WHERE,ERR_READ,smb.file,k); ! 269: continue; ! 270: } ! 271: smb_unlocksmbhdr(&smb); ! 272: lastsub=j; ! 273: } ! 274: ! 275: if(!qwktomsg(qwk,(char *)block,hubnum+1,j,0)) { ! 276: // eprintf("!QWKTOMSG failed"); ! 277: continue; ! 278: } ! 279: ! 280: signal_sub_sem(&cfg,j); ! 281: /* ! 282: eprintf("Message from %s Posted on %s %s" ! 283: ,cfg.qhub[hubnum]->id,cfg.grp[cfg.sub[j]->grp]->sname,cfg.sub[j]->lname); ! 284: */ ! 285: msgs++; ! 286: tmsgs++; ! 287: } ! 288: ! 289: update_qwkroute(NULL); /* Write ROUTE.DAT */ ! 290: ! 291: fclose(qwk); ! 292: if(lastsub!=INVALID_SUB) ! 293: smb_close(&smb); ! 294: ! 295: delfiles(cfg.temp_dir,"*.NDX"); ! 296: sprintf(str,"%sMESSAGES.DAT",cfg.temp_dir); ! 297: remove(str); ! 298: sprintf(str,"%sDOOR.ID",cfg.temp_dir); ! 299: remove(str); ! 300: sprintf(str,"%sCONTROL.DAT",cfg.temp_dir); ! 301: remove(str); ! 302: sprintf(str,"%sNETFLAGS.DAT",cfg.temp_dir); ! 303: remove(str); ! 304: ! 305: dir=opendir(cfg.temp_dir); ! 306: while(dir!=NULL && (dirent=readdir(dir))!=NULL) { ! 307: sprintf(str,"%s%s",cfg.temp_dir,dirent->d_name); ! 308: if(isdir(str)) /* sub-dir */ ! 309: continue; ! 310: ! 311: // Create directory if necessary ! 312: sprintf(inbox,"%sqnet/%s.in",cfg.data_dir,cfg.qhub[hubnum]->id); ! 313: MKDIR(inbox); ! 314: ! 315: // Copy files ! 316: sprintf(fname,"%s/%s",inbox,dirent->d_name); ! 317: mv(str,fname,1 /* overwrite */); ! 318: sprintf(str,text[ReceivedFileViaQWK],dirent->d_name,cfg.qhub[hubnum]->id); ! 319: putsmsg(&cfg,1,str); ! 320: eprintf(LOG_INFO,"Received %s from %s", dirent->d_name, cfg.qhub[hubnum]->id); ! 321: } ! 322: if(dir!=NULL) ! 323: closedir(dir); ! 324: ! 325: t=time(NULL)-start; ! 326: if(tmsgs) { ! 327: if(t<1) ! 328: t=1; ! 329: eprintf(LOG_INFO,"Finished Importing QWK Network Packet from %s: " ! 330: "(%lu msgs) in %lu seconds (%lu msgs/sec)" ! 331: ,cfg.qhub[hubnum]->id, tmsgs, t, tmsgs/t); ! 332: } ! 333: delfiles(cfg.temp_dir,ALLFILES); ! 334: return(true); ! 335: }
This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.