![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to pack_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 pack_rep.cpp CVS log | Up to [Synchronet] / sbbs / sbbs3 |
1.1 ! root 1: /* pack_rep.cpp */ ! 2: ! 3: /* Synchronet QWK reply (REP) packet creation routine */ ! 4: ! 5: /* $Id: pack_rep.cpp,v 1.8 2000/12/11 23:21:12 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 "post.h" ! 40: #include "qwk.h" ! 41: ! 42: /****************************************************************************/ ! 43: /* Creates an REP packet for upload to QWK hub 'hubnum'. */ ! 44: /* Returns 1 if successful, 0 if not. */ ! 45: /****************************************************************************/ ! 46: bool sbbs_t::pack_rep(uint hubnum) ! 47: { ! 48: char str[256],tmp2[256]; ! 49: char tmp[512]; ! 50: int file,mode; ! 51: uint i,j,k; ! 52: long l,msgcnt,submsgs,posts,packedmail,netfiles=0,deleted; ! 53: ulong mailmsgs; ! 54: ulong last,msgs; ! 55: post_t HUGE16 *post; ! 56: mail_t *mail; ! 57: FILE* rep; ! 58: DIR* dir; ! 59: DIRENT* dirent; ! 60: smbmsg_t msg; ! 61: ! 62: msgcnt=0L; ! 63: delfiles(cfg.temp_dir,ALLFILES); ! 64: sprintf(str,"%s%s.rep",cfg.data_dir,cfg.qhub[hubnum]->id); ! 65: if(fexist(str)) { ! 66: lprintf("Updating %s", str); ! 67: external(cmdstr(cfg.qhub[hubnum]->unpack,str,ALLFILES,NULL),EX_OFFLINE); ! 68: } else ! 69: lprintf("Creating %s", str); ! 70: /*************************************************/ ! 71: /* Create SYSID.MSG, write header and leave open */ ! 72: /*************************************************/ ! 73: sprintf(str,"%s%s.msg",cfg.temp_dir,cfg.qhub[hubnum]->id); ! 74: if((rep=fnopen(&file,str,O_CREAT|O_WRONLY))==NULL) { ! 75: errormsg(WHERE,ERR_OPEN,str,O_CREAT|O_WRONLY); ! 76: return(false); } ! 77: if(filelength(file)<1) { /* New REP packet */ ! 78: sprintf(str,"%-128s",cfg.qhub[hubnum]->id); /* So write header */ ! 79: fwrite(str,128,1,rep); } ! 80: fseek(rep,0L,SEEK_END); ! 81: /*********************/ ! 82: /* Pack new messages */ ! 83: /*********************/ ! 84: console|=CON_L_ECHO; ! 85: ! 86: sprintf(smb.file,"%smail",cfg.data_dir); ! 87: smb.retry_time=cfg.smb_retry_time; ! 88: if((i=smb_open(&smb))!=0) { ! 89: fclose(rep); ! 90: errormsg(WHERE,ERR_OPEN,smb.file,i,smb.last_error); ! 91: return(false); } ! 92: ! 93: /***********************/ ! 94: /* Pack E-mail, if any */ ! 95: /***********************/ ! 96: qwkmail_time=time(NULL); ! 97: mail=loadmail(&smb,&mailmsgs,0,MAIL_YOUR,0); ! 98: packedmail=0; ! 99: if(mailmsgs) { ! 100: lprintf("Packing NetMail for %s", cfg.qhub[hubnum]->id); ! 101: for(l=0;(ulong)l<mailmsgs;l++) { ! 102: // bprintf("\b\b\b\b\b%-5lu",l+1); ! 103: ! 104: msg.idx.offset=mail[l].offset; ! 105: if(!loadmsg(&msg,mail[l].number)) ! 106: continue; ! 107: ! 108: sprintf(str,"%s/",cfg.qhub[hubnum]->id); ! 109: if(msg.to_net.type!=NET_QWK ! 110: || (strcmp((char *)msg.to_net.addr,cfg.qhub[hubnum]->id) ! 111: && strncmp((char *)msg.to_net.addr,str,strlen(str)))) { ! 112: smb_unlockmsghdr(&smb,&msg); ! 113: smb_freemsgmem(&msg); ! 114: continue; } ! 115: ! 116: msgtoqwk(&msg,rep,TO_QNET|REP|A_LEAVE,INVALID_SUB,0); ! 117: packedmail++; ! 118: smb_unlockmsghdr(&smb,&msg); ! 119: smb_freemsgmem(&msg); } ! 120: lprintf("Packed %d NetMail messages",packedmail); } ! 121: smb_close(&smb); /* Close the e-mail */ ! 122: if(mailmsgs) ! 123: FREE(mail); ! 124: ! 125: #if 0 ! 126: useron.number=1; ! 127: getuserdat(&useron); ! 128: #endif ! 129: for(i=0;i<cfg.qhub[hubnum]->subs;i++) { ! 130: j=cfg.qhub[hubnum]->sub[i]; /* j now equals the real sub num */ ! 131: msgs=getlastmsg(j,&last,0); ! 132: lncntr=0; /* defeat pause */ ! 133: if(!msgs || last<=sub_ptr[j]) { ! 134: if(sub_ptr[j]>last) { ! 135: sub_ptr[j]=last; ! 136: sub_last[j]=last; } ! 137: lprintf(remove_ctrl_a(text[NScanStatusFmt],tmp) ! 138: ,cfg.grp[cfg.sub[j]->grp]->sname ! 139: ,cfg.sub[j]->lname,0L,msgs); ! 140: continue; } ! 141: ! 142: sprintf(smb.file,"%s%s" ! 143: ,cfg.sub[j]->data_dir,cfg.sub[j]->code); ! 144: smb.retry_time=cfg.smb_retry_time; ! 145: if((k=smb_open(&smb))!=0) { ! 146: errormsg(WHERE,ERR_OPEN,smb.file,k,smb.last_error); ! 147: continue; } ! 148: ! 149: post=loadposts(&posts,j,sub_ptr[j],LP_BYSELF|LP_OTHERS|LP_PRIVATE|LP_REP); ! 150: lprintf(remove_ctrl_a(text[NScanStatusFmt],tmp) ! 151: ,cfg.grp[cfg.sub[j]->grp]->sname ! 152: ,cfg.sub[j]->lname,posts,msgs); ! 153: if(!posts) { /* no new messages */ ! 154: smb_close(&smb); ! 155: continue; } ! 156: ! 157: sub_ptr[j]=last; /* set pointer */ ! 158: lputs(remove_ctrl_a(text[QWKPackingSubboard],tmp)); /* ptr to last msg */ ! 159: submsgs=0; ! 160: for(l=0;l<posts;l++) { ! 161: // bprintf("\b\b\b\b\b%-5lu",l+1); ! 162: ! 163: msg.idx.offset=post[l].offset; ! 164: if(!loadmsg(&msg,post[l].number)) ! 165: continue; ! 166: ! 167: if(msg.from_net.type && msg.from_net.type!=NET_QWK && ! 168: !(cfg.sub[j]->misc&SUB_GATE)) { ! 169: smb_freemsgmem(&msg); ! 170: smb_unlockmsghdr(&smb,&msg); ! 171: continue; } ! 172: ! 173: if(!strnicmp(msg.subj,"NE:",3) || (msg.from_net.type==NET_QWK && ! 174: route_circ((char *)msg.from_net.addr,cfg.qhub[hubnum]->id))) { ! 175: smb_freemsgmem(&msg); ! 176: smb_unlockmsghdr(&smb,&msg); ! 177: continue; } ! 178: ! 179: mode=cfg.qhub[hubnum]->mode[i]|TO_QNET|REP; ! 180: if(mode&A_LEAVE) mode|=(VIA|TZ); ! 181: if(msg.from_net.type!=NET_QWK) ! 182: mode|=TAGLINE; ! 183: ! 184: msgtoqwk(&msg,rep,mode,j,cfg.qhub[hubnum]->conf[i]); ! 185: ! 186: smb_freemsgmem(&msg); ! 187: smb_unlockmsghdr(&smb,&msg); ! 188: msgcnt++; ! 189: submsgs++; } ! 190: lprintf(remove_ctrl_a(text[QWKPackedSubboard],tmp),submsgs,msgcnt); ! 191: LFREE(post); ! 192: smb_close(&smb); } ! 193: ! 194: fclose(rep); /* close MESSAGE.DAT */ ! 195: CRLF; ! 196: /* Look for extra files to send out */ ! 197: sprintf(str,"%sqnet/%s.out",cfg.data_dir,cfg.qhub[hubnum]->id); ! 198: strlwr(str); ! 199: dir=opendir(str); ! 200: while((dirent=readdir(dir))!=NULL) { ! 201: sprintf(str,"%sqnet/%s.out/%s",cfg.data_dir,cfg.qhub[hubnum]->id,dirent->d_name); ! 202: strlwr(str); ! 203: if(isdir(str)) ! 204: continue; ! 205: sprintf(tmp2,"%s%s",cfg.temp_dir,dirent->d_name); ! 206: lprintf(remove_ctrl_a(text[RetrievingFile],tmp),str); ! 207: if(!mv(str,tmp2,1)) ! 208: netfiles++; ! 209: } ! 210: closedir(dir); ! 211: if(netfiles) ! 212: CRLF; ! 213: ! 214: if(!msgcnt && !netfiles && !packedmail) { ! 215: lputs(remove_ctrl_a(text[QWKNoNewMessages],tmp)); ! 216: return(false); } ! 217: ! 218: /*******************/ ! 219: /* Compress Packet */ ! 220: /*******************/ ! 221: sprintf(str,"%s%s.rep",cfg.data_dir,cfg.qhub[hubnum]->id); ! 222: sprintf(tmp2,"%s%s",cfg.temp_dir,ALLFILES); ! 223: i=external(cmdstr(cfg.qhub[hubnum]->pack,str,tmp2,NULL),EX_OFFLINE); ! 224: if(!fexist(str)) { ! 225: lputs(remove_ctrl_a(text[QWKCompressionFailed],tmp)); ! 226: if(i) ! 227: errormsg(WHERE,ERR_EXEC,cmdstr(cfg.qhub[hubnum]->pack,str,tmp2,NULL),i); ! 228: else ! 229: errorlog("Couldn't compress REP packet"); ! 230: return(false); } ! 231: sprintf(str,"%sqnet/%s.out/",cfg.data_dir,cfg.qhub[hubnum]->id); ! 232: strlwr(str); ! 233: delfiles(str,ALLFILES); ! 234: ! 235: if(packedmail) { /* Delete NetMail */ ! 236: sprintf(smb.file,"%smail",cfg.data_dir); ! 237: smb.retry_time=cfg.smb_retry_time; ! 238: if((i=smb_open(&smb))!=0) { ! 239: errormsg(WHERE,ERR_OPEN,smb.file,i,smb.last_error); ! 240: return(true); } ! 241: ! 242: mail=loadmail(&smb,&mailmsgs,0,MAIL_YOUR,0); ! 243: ! 244: if((i=smb_locksmbhdr(&smb))!=0) { /* Lock the base, so nobody */ ! 245: if(mailmsgs) ! 246: FREE(mail); ! 247: smb_close(&smb); ! 248: errormsg(WHERE,ERR_LOCK,smb.file,i,smb.last_error); /* messes with the index */ ! 249: return(true); } ! 250: ! 251: if((i=smb_getstatus(&smb))!=0) { ! 252: if(mailmsgs) ! 253: FREE(mail); ! 254: smb_close(&smb); ! 255: errormsg(WHERE,ERR_READ,smb.file,i,smb.last_error); ! 256: return(true); } ! 257: ! 258: deleted=0; ! 259: /* Mark as READ and DELETE */ ! 260: for(l=0;(ulong)l<mailmsgs;l++) { ! 261: if(mail[l].time>qwkmail_time) ! 262: continue; ! 263: msg.idx.offset=0; ! 264: if(!loadmsg(&msg,mail[l].number)) ! 265: continue; ! 266: ! 267: sprintf(str,"%s/",cfg.qhub[hubnum]->id); ! 268: if(msg.to_net.type!=NET_QWK ! 269: || (strcmp((char *)msg.to_net.addr,cfg.qhub[hubnum]->id) ! 270: && strncmp((char *)msg.to_net.addr,str,strlen(str)))) { ! 271: smb_unlockmsghdr(&smb,&msg); ! 272: smb_freemsgmem(&msg); ! 273: continue; } ! 274: ! 275: msg.hdr.attr|=MSG_DELETE; ! 276: msg.idx.attr=msg.hdr.attr; ! 277: if((i=smb_putmsg(&smb,&msg))!=0) ! 278: errormsg(WHERE,ERR_WRITE,smb.file,i,smb.last_error); ! 279: else ! 280: deleted++; ! 281: smb_unlockmsghdr(&smb,&msg); ! 282: smb_freemsgmem(&msg); } ! 283: ! 284: if(deleted && cfg.sys_misc&SM_DELEMAIL) ! 285: delmail(0,MAIL_YOUR); ! 286: smb_close(&smb); ! 287: if(mailmsgs) ! 288: FREE(mail); } ! 289: ! 290: return(true); ! 291: }
This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.