![[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 / sbbs3|
Return to un_qwk.cpp CVS log | Up to [Synchronet] / sbbs / sbbs3 |
1.1 ! root 1: /* un_qwk.cpp */ ! 2: ! 3: /* Synchronet QWK unpacking routine */ ! 4: ! 5: /* $Id: un_qwk.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 .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[256],fname[128]; ! 47: char tmp[512]; ! 48: uchar block[128]; ! 49: int k,file; ! 50: uint i,j,n,lastsub=INVALID_SUB; ! 51: uint blocks; ! 52: long l,size,misc; ! 53: DIR* dir; ! 54: DIRENT* dirent; ! 55: FILE* qwk; ! 56: ! 57: if((l=flength(packet))<1) { ! 58: errormsg(WHERE,ERR_LEN,packet,l); ! 59: return(false); ! 60: } ! 61: i=external(cmdstr(cfg.qhub[hubnum]->unpack,packet,ALLFILES,NULL),EX_OFFLINE); ! 62: if(i) { ! 63: errormsg(WHERE,ERR_EXEC,cmdstr(cfg.qhub[hubnum]->unpack,packet,ALLFILES,NULL),i); ! 64: return(false); ! 65: } ! 66: sprintf(str,"%sMESSAGES.DAT",cfg.temp_dir); ! 67: if(!fexist(str)) { ! 68: sprintf(str,"%s doesn't contain MESSAGES.DAT",packet); ! 69: errorlog(str); ! 70: return(false); ! 71: } ! 72: if((qwk=fnopen(&file,str,O_RDONLY))==NULL) { ! 73: errormsg(WHERE,ERR_OPEN,str,O_RDONLY); ! 74: return(false); ! 75: } ! 76: size=filelength(file); ! 77: /********************/ ! 78: /* Process messages */ ! 79: /********************/ ! 80: lprintf("Importing QWK Network Packet: %s",packet); ! 81: ! 82: for(l=128;l<size;l+=blocks*128) { ! 83: fseek(qwk,l,SEEK_SET); ! 84: fread(block,128,1,qwk); ! 85: if(block[0]<' ' || block[0]&0x80) { ! 86: lprintf("!Invalid message status (%02X) at offset %lu in %s" ! 87: ,block[0], l, packet); ! 88: blocks=1; ! 89: continue; ! 90: } ! 91: sprintf(tmp,"%.6s",block+116); ! 92: blocks=atoi(tmp); /* i = number of 128 byte records */ ! 93: if(blocks<2) { ! 94: lprintf("!Invalid number of blocks (%d) at offset %lu in %s" ! 95: ,blocks, l+116, packet); ! 96: blocks=1; ! 97: continue; ! 98: } ! 99: /*********************************/ ! 100: /* public message on a sub-board */ ! 101: /*********************************/ ! 102: n=(uint)block[123]|(((uint)block[124])<<8); /* conference number */ ! 103: ! 104: if(!n) { /* NETMAIL */ ! 105: sprintf(str,"%25.25s",block+21); ! 106: truncsp(str); ! 107: lprintf("NetMail from %s to %s", cfg.qhub[hubnum]->id, str); ! 108: if(!stricmp(str,"NETMAIL")) { /* QWK to FidoNet NetMail */ ! 109: qwktonetmail(qwk,(char *)block,NULL,hubnum+1); ! 110: continue; ! 111: } ! 112: if(strchr(str,'@')) { ! 113: qwktonetmail(qwk,(char *)block,str,hubnum+1); ! 114: continue; ! 115: } ! 116: j=atoi(str); ! 117: if(j && j>lastuser(&cfg)) ! 118: j=0; ! 119: if(!j && !stricmp(str,"SYSOP")) ! 120: j=1; ! 121: if(!j) ! 122: j=matchuser(&cfg,str); ! 123: if(!j && !stricmp(str,cfg.sys_id)) ! 124: j=1; ! 125: if(!j) { ! 126: lprintf("!NetMail from %s to UNKNOWN USER: %s", cfg.qhub[hubnum]->id, str); ! 127: continue; ! 128: } ! 129: ! 130: getuserrec(&cfg,j,U_MISC,8,str); ! 131: misc=ahtoul(str); ! 132: if(misc&NETMAIL && cfg.sys_misc&SM_FWDTONET) { ! 133: getuserrec(&cfg,j,U_NETMAIL,LEN_NETMAIL,str); ! 134: qwktonetmail(qwk,(char*)block,str,hubnum+1); ! 135: continue; ! 136: } ! 137: ! 138: smb_stack(&smb,SMB_STACK_PUSH); ! 139: sprintf(smb.file,"%smail",cfg.data_dir); ! 140: smb.retry_time=cfg.smb_retry_time; ! 141: if((k=smb_open(&smb))!=0) { ! 142: errormsg(WHERE,ERR_OPEN,smb.file,k,smb.last_error); ! 143: smb_stack(&smb,SMB_STACK_POP); ! 144: continue; ! 145: } ! 146: if(!filelength(fileno(smb.shd_fp))) { ! 147: smb.status.max_crcs=cfg.mail_maxcrcs; ! 148: smb.status.max_msgs=MAX_SYSMAIL; ! 149: smb.status.max_age=cfg.mail_maxage; ! 150: smb.status.attr=SMB_EMAIL; ! 151: if((k=smb_create(&smb))!=0) { ! 152: smb_close(&smb); ! 153: errormsg(WHERE,ERR_CREATE,smb.file,k); ! 154: smb_stack(&smb,SMB_STACK_POP); ! 155: continue; ! 156: } ! 157: } ! 158: if((k=smb_locksmbhdr(&smb))!=0) { ! 159: smb_close(&smb); ! 160: errormsg(WHERE,ERR_LOCK,smb.file,k); ! 161: smb_stack(&smb,SMB_STACK_POP); ! 162: continue; ! 163: } ! 164: if((k=smb_getstatus(&smb))!=0) { ! 165: smb_close(&smb); ! 166: errormsg(WHERE,ERR_READ,smb.file,k); ! 167: smb_stack(&smb,SMB_STACK_POP); ! 168: continue; ! 169: } ! 170: smb_unlocksmbhdr(&smb); ! 171: qwktomsg(qwk,(char *)block,hubnum+1,INVALID_SUB,j); ! 172: smb_close(&smb); ! 173: smb_stack(&smb,SMB_STACK_POP); ! 174: sprintf(tmp,"%-25.25s",block+46); ! 175: truncsp(tmp); ! 176: sprintf(str,text[UserSentYouMail],tmp); ! 177: putsmsg(&cfg,j,str); ! 178: continue; ! 179: } ! 180: ! 181: for(j=0;j<cfg.qhub[hubnum]->subs;j++) ! 182: if(cfg.qhub[hubnum]->conf[j]==n) ! 183: break; ! 184: if(j>=cfg.qhub[hubnum]->subs) { /* ignore messages for subs not in config */ ! 185: lprintf("!Message from %s on UNKNOWN CONFERENCE NUMBER: %u" ! 186: ,cfg.qhub[hubnum]->id, n); ! 187: continue; ! 188: } ! 189: ! 190: j=cfg.qhub[hubnum]->sub[j]; ! 191: ! 192: if(j!=lastsub) { ! 193: if(lastsub!=INVALID_SUB) ! 194: smb_close(&smb); ! 195: lastsub=INVALID_SUB; ! 196: sprintf(smb.file,"%s%s",cfg.sub[j]->data_dir,cfg.sub[j]->code); ! 197: smb.retry_time=cfg.smb_retry_time; ! 198: if((k=smb_open(&smb))!=0) { ! 199: errormsg(WHERE,ERR_OPEN,smb.file,k,smb.last_error); ! 200: continue; ! 201: } ! 202: if(!filelength(fileno(smb.shd_fp))) { ! 203: smb.status.max_crcs=cfg.sub[j]->maxcrcs; ! 204: smb.status.max_msgs=cfg.sub[j]->maxmsgs; ! 205: smb.status.max_age=cfg.sub[j]->maxage; ! 206: smb.status.attr=cfg.sub[j]->misc&SUB_HYPER ? SMB_HYPERALLOC :0; ! 207: if((k=smb_create(&smb))!=0) { ! 208: smb_close(&smb); ! 209: errormsg(WHERE,ERR_CREATE,smb.file,k); ! 210: continue; ! 211: } ! 212: } ! 213: if((k=smb_locksmbhdr(&smb))!=0) { ! 214: smb_close(&smb); ! 215: errormsg(WHERE,ERR_LOCK,smb.file,k); ! 216: continue; ! 217: } ! 218: if((k=smb_getstatus(&smb))!=0) { ! 219: smb_close(&smb); ! 220: errormsg(WHERE,ERR_READ,smb.file,k); ! 221: continue; ! 222: } ! 223: smb_unlocksmbhdr(&smb); ! 224: lastsub=j; ! 225: } ! 226: ! 227: lprintf("Importing message from %s on %s %s" ! 228: ,cfg.qhub[hubnum]->id, cfg.grp[cfg.sub[j]->grp]->sname,cfg.sub[j]->lname); ! 229: if(!qwktomsg(qwk,(char *)block,hubnum+1,j,0)) { ! 230: lprintf("!QWKTOMSG failed"); ! 231: continue; ! 232: } ! 233: ! 234: if(cfg.sub[j]->misc&SUB_FIDO && cfg.sub[j]->echomail_sem[0]) /* update semaphore */ ! 235: if((file=nopen(cmdstr(cfg.sub[j]->echomail_sem,nulstr,nulstr,NULL) ! 236: ,O_WRONLY|O_CREAT|O_TRUNC))!=-1) ! 237: close(file); ! 238: lprintf("Message from %s Posted on %s %s" ! 239: ,cfg.qhub[hubnum]->id,cfg.grp[cfg.sub[j]->grp]->sname,cfg.sub[j]->lname); ! 240: } ! 241: ! 242: update_qwkroute(NULL); /* Write ROUTE.DAT */ ! 243: ! 244: fclose(qwk); ! 245: if(lastsub!=INVALID_SUB) ! 246: smb_close(&smb); ! 247: ! 248: delfiles(cfg.temp_dir,"*.NDX"); ! 249: sprintf(str,"%sMESSAGES.DAT",cfg.temp_dir); ! 250: remove(str); ! 251: sprintf(str,"%sDOOR.ID",cfg.temp_dir); ! 252: remove(str); ! 253: sprintf(str,"%sCONTROL.DAT",cfg.temp_dir); ! 254: remove(str); ! 255: sprintf(str,"%sNETFLAGS.DAT",cfg.temp_dir); ! 256: remove(str); ! 257: ! 258: dir=opendir(cfg.temp_dir); ! 259: while((dirent=readdir(dir))!=NULL) { ! 260: // Create directory if necessary ! 261: sprintf(str,"%sqnet/%s.in",cfg.data_dir,cfg.qhub[hubnum]->id); ! 262: _mkdir(str); ! 263: sprintf(str,"%s%s",cfg.temp_dir,dirent->d_name); ! 264: if(isdir(str)) /* sub-dir */ ! 265: continue; ! 266: // Copy files ! 267: sprintf(fname,"%sqnet/%s.in/%s",cfg.data_dir,cfg.qhub[hubnum]->id,dirent->d_name); ! 268: mv(str,fname,1 /* overwrite */); ! 269: sprintf(str,text[ReceivedFileViaQWK],dirent->d_name,cfg.qhub[hubnum]->id); ! 270: putsmsg(&cfg,1,str); ! 271: lprintf("Received %s from %s", dirent->d_name, cfg.qhub[hubnum]->id); ! 272: } ! 273: closedir(dir); ! 274: ! 275: lprintf("Finished Importing QWK Network Packet: %s",packet); ! 276: delfiles(cfg.temp_dir,ALLFILES); ! 277: return(true); ! 278: }
This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.