![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to netmail.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 netmail.cpp CVS log | Up to [Synchronet] / sbbs / src / sbbs3 |
1.1 ! root 1: /* netmail.cpp */ ! 2: ! 3: /* Synchronet network mail-related functions */ ! 4: ! 5: /* $Id: netmail.cpp,v 1.34 2005/10/02 23:33:45 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 2005 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: /****************************************************************************/ ! 43: bool sbbs_t::inetmail(char *into, char *subj, long mode) ! 44: { ! 45: char str[256],str2[256],msgpath[256],title[256],name[256],ch ! 46: ,buf[SDT_BLOCK_LEN],*p,addr[256]; ! 47: char tmp[512]; ! 48: char your_addr[128]; ! 49: ushort xlat=XLAT_NONE,net=NET_INTERNET; ! 50: int i,j,x,file; ! 51: long l; ! 52: ulong length,offset; ! 53: FILE *instream; ! 54: smbmsg_t msg; ! 55: ! 56: if(useron.etoday>=cfg.level_emailperday[useron.level] && !SYSOP) { ! 57: bputs(text[TooManyEmailsToday]); ! 58: return(false); ! 59: } ! 60: ! 61: strcpy(name,into); ! 62: strcpy(addr,into); ! 63: strcpy(title,subj); ! 64: ! 65: if((!SYSOP && !(cfg.inetmail_misc&NMAIL_ALLOW)) || useron.rest&FLAG('M')) { ! 66: bputs(text[NoNetMailAllowed]); ! 67: return(false); } ! 68: ! 69: if(cfg.inetmail_cost && !(useron.exempt&FLAG('S'))) { ! 70: if(useron.cdt+useron.freecdt<cfg.inetmail_cost) { ! 71: bputs(text[NotEnoughCredits]); ! 72: return(false); } ! 73: sprintf(str,text[NetMailCostContinueQ],cfg.inetmail_cost); ! 74: if(noyes(str)) ! 75: return(false); } ! 76: ! 77: /* Get destination user name */ ! 78: p=strrchr(name,'@'); ! 79: if(!p) ! 80: p=strrchr(name,'!'); ! 81: if(p) { ! 82: *p=0; ! 83: truncsp(name); } ! 84: ! 85: /* Get this user's internet mailing address */ ! 86: usermailaddr(&cfg,your_addr ! 87: ,cfg.inetmail_misc&NMAIL_ALIAS ? useron.alias : useron.name); ! 88: ! 89: bprintf(text[InternetMailing],addr,your_addr); ! 90: action=NODE_SMAL; ! 91: nodesync(); ! 92: ! 93: sprintf(msgpath,"%snetmail.msg",cfg.node_dir); ! 94: if(!writemsg(msgpath,nulstr,title,mode,INVALID_SUB,into)) { ! 95: bputs(text[Aborted]); ! 96: return(false); } ! 97: ! 98: if(mode&WM_FILE) { ! 99: sprintf(str2,"%sfile/%04u.out",cfg.data_dir,useron.number); ! 100: MKDIR(str2); ! 101: sprintf(str2,"%sfile/%04u.out/%s",cfg.data_dir,useron.number,title); ! 102: if(fexistcase(str2)) { ! 103: bputs(text[FileAlreadyThere]); ! 104: remove(msgpath); ! 105: return(false); } ! 106: #if 0 /* no such thing as local logon */ ! 107: if(online==ON_LOCAL) { /* Local upload */ ! 108: bputs(text[EnterPath]); ! 109: if(!getstr(str,60,K_LINE|K_UPPER)) { ! 110: bputs(text[Aborted]); ! 111: remove(msgpath); ! 112: return(false); } ! 113: backslash(str); ! 114: strcat(str,title); ! 115: mv(str,str2,1); } ! 116: else ! 117: #endif ! 118: { /* Remote */ ! 119: xfer_prot_menu(XFER_UPLOAD); ! 120: mnemonics(text[ProtocolOrQuit]); ! 121: strcpy(str,"Q"); ! 122: for(x=0;x<cfg.total_prots;x++) ! 123: if(cfg.prot[x]->ulcmd[0] && chk_ar(cfg.prot[x]->ar,&useron)) { ! 124: sprintf(tmp,"%c",cfg.prot[x]->mnemonic); ! 125: strcat(str,tmp); } ! 126: ch=(char)getkeys(str,0); ! 127: if(ch=='Q' || sys_status&SS_ABORT) { ! 128: bputs(text[Aborted]); ! 129: remove(msgpath); ! 130: return(false); } ! 131: for(x=0;x<cfg.total_prots;x++) ! 132: if(cfg.prot[x]->ulcmd[0] && cfg.prot[x]->mnemonic==ch ! 133: && chk_ar(cfg.prot[x]->ar,&useron)) ! 134: break; ! 135: if(x<cfg.total_prots) /* This should be always */ ! 136: protocol(cfg.prot[x],XFER_UPLOAD,str2,nulstr,true); ! 137: } ! 138: sprintf(tmp,"%s%s",cfg.temp_dir,title); ! 139: if(!fexistcase(str2) && fexistcase(tmp)) ! 140: mv(tmp,str2,0); ! 141: l=flength(str2); ! 142: if(l>0) ! 143: bprintf(text[FileNBytesReceived],title,ultoac(l,tmp)); ! 144: else { ! 145: bprintf(text[FileNotReceived],title); ! 146: remove(msgpath); ! 147: return(false); } } ! 148: ! 149: if((i=smb_stack(&smb,SMB_STACK_PUSH))!=SMB_SUCCESS) { ! 150: errormsg(WHERE,ERR_OPEN,"MAIL",i); ! 151: return(false); } ! 152: sprintf(smb.file,"%smail",cfg.data_dir); ! 153: smb.retry_time=cfg.smb_retry_time; ! 154: smb.subnum=INVALID_SUB; ! 155: if((i=smb_open(&smb))!=SMB_SUCCESS) { ! 156: smb_stack(&smb,SMB_STACK_POP); ! 157: errormsg(WHERE,ERR_OPEN,smb.file,i,smb.last_error); ! 158: return(false); } ! 159: ! 160: if(filelength(fileno(smb.shd_fp))<1) { /* Create it if it doesn't exist */ ! 161: smb.status.max_crcs=cfg.mail_maxcrcs; ! 162: smb.status.max_age=cfg.mail_maxage; ! 163: smb.status.max_msgs=0; ! 164: smb.status.attr=SMB_EMAIL; ! 165: if((i=smb_create(&smb))!=SMB_SUCCESS) { ! 166: smb_close(&smb); ! 167: smb_stack(&smb,SMB_STACK_POP); ! 168: errormsg(WHERE,ERR_CREATE,smb.file,i); ! 169: return(false); } } ! 170: ! 171: if((i=smb_locksmbhdr(&smb))!=SMB_SUCCESS) { ! 172: smb_close(&smb); ! 173: smb_stack(&smb,SMB_STACK_POP); ! 174: errormsg(WHERE,ERR_LOCK,smb.file,i); ! 175: return(false); } ! 176: ! 177: length=flength(msgpath)+2; /* +2 for translation string */ ! 178: ! 179: if(length&0xfff00000UL) { ! 180: smb_unlocksmbhdr(&smb); ! 181: smb_close(&smb); ! 182: smb_stack(&smb,SMB_STACK_POP); ! 183: errormsg(WHERE,ERR_LEN,msgpath,length); ! 184: return(false); } ! 185: ! 186: if((i=smb_open_da(&smb))!=SMB_SUCCESS) { ! 187: smb_unlocksmbhdr(&smb); ! 188: smb_close(&smb); ! 189: smb_stack(&smb,SMB_STACK_POP); ! 190: errormsg(WHERE,ERR_OPEN,smb.file,i,smb.last_error); ! 191: return(false); } ! 192: if(cfg.sys_misc&SM_FASTMAIL) ! 193: offset=smb_fallocdat(&smb,length,1); ! 194: else ! 195: offset=smb_allocdat(&smb,length,1); ! 196: smb_close_da(&smb); ! 197: ! 198: if((file=open(msgpath,O_RDONLY|O_BINARY))==-1 ! 199: || (instream=fdopen(file,"rb"))==NULL) { ! 200: smb_freemsgdat(&smb,offset,length,1); ! 201: smb_unlocksmbhdr(&smb); ! 202: smb_close(&smb); ! 203: smb_stack(&smb,SMB_STACK_POP); ! 204: errormsg(WHERE,ERR_OPEN,msgpath,O_RDONLY|O_BINARY); ! 205: return(false); } ! 206: ! 207: setvbuf(instream,NULL,_IOFBF,2*1024); ! 208: fseek(smb.sdt_fp,offset,SEEK_SET); ! 209: xlat=XLAT_NONE; ! 210: fwrite(&xlat,2,1,smb.sdt_fp); ! 211: x=SDT_BLOCK_LEN-2; /* Don't read/write more than 255 */ ! 212: while(!feof(instream)) { ! 213: memset(buf,0,x); ! 214: j=fread(buf,1,x,instream); ! 215: if(j<1) ! 216: break; ! 217: if(j>1 && (j!=x || feof(instream)) && buf[j-1]==LF && buf[j-2]==CR) ! 218: buf[j-1]=buf[j-2]=0; ! 219: fwrite(buf,j,1,smb.sdt_fp); ! 220: x=SDT_BLOCK_LEN; } ! 221: fflush(smb.sdt_fp); ! 222: fclose(instream); ! 223: ! 224: memset(&msg,0,sizeof(smbmsg_t)); ! 225: msg.hdr.version=smb_ver(); ! 226: if(mode&WM_FILE) ! 227: msg.hdr.auxattr|=MSG_FILEATTACH; ! 228: msg.hdr.when_written.time=msg.hdr.when_imported.time=time(NULL); ! 229: msg.hdr.when_written.zone=msg.hdr.when_imported.zone=sys_timezone(&cfg); ! 230: ! 231: msg.hdr.offset=offset; ! 232: ! 233: net=NET_INTERNET; ! 234: smb_hfield_str(&msg,RECIPIENT,name); ! 235: smb_hfield(&msg,RECIPIENTNETTYPE,sizeof(net),&net); ! 236: smb_hfield_str(&msg,RECIPIENTNETADDR,addr); ! 237: ! 238: strcpy(str,cfg.inetmail_misc&NMAIL_ALIAS ? useron.alias : useron.name); ! 239: smb_hfield_str(&msg,SENDER,str); ! 240: ! 241: sprintf(str,"%u",useron.number); ! 242: smb_hfield_str(&msg,SENDEREXT,str); ! 243: ! 244: /* ! 245: smb_hfield(&msg,SENDERNETTYPE,sizeof(net),&net); ! 246: smb_hfield(&msg,SENDERNETADDR,strlen(sys_inetaddr),sys_inetaddr); ! 247: */ ! 248: ! 249: /* Security logging */ ! 250: msg_client_hfields(&msg,&client); ! 251: ! 252: smb_hfield_str(&msg,SUBJECT,title); ! 253: strcpy(str,title); ! 254: ! 255: smb_dfield(&msg,TEXT_BODY,length); ! 256: ! 257: i=smb_addmsghdr(&smb,&msg,SMB_SELFPACK); // calls smb_unlocksmbhdr() ! 258: smb_close(&smb); ! 259: smb_stack(&smb,SMB_STACK_POP); ! 260: ! 261: smb_freemsgmem(&msg); ! 262: if(i!=SMB_SUCCESS) { ! 263: errormsg(WHERE,ERR_WRITE,smb.file,i,smb.last_error); ! 264: smb_freemsgdat(&smb,offset,length,1); ! 265: return(false); ! 266: } ! 267: ! 268: if(mode&WM_FILE && online==ON_REMOTE) ! 269: autohangup(); ! 270: ! 271: if(cfg.inetmail_sem[0]) /* update semaphore file */ ! 272: ftouch(cmdstr(cfg.inetmail_sem,nulstr,nulstr,NULL)); ! 273: if(!(useron.exempt&FLAG('S'))) ! 274: subtract_cdt(&cfg,&useron,cfg.inetmail_cost); ! 275: ! 276: useron.emails++; ! 277: logon_emails++; ! 278: putuserrec(&cfg,useron.number,U_EMAILS,5,ultoa(useron.emails,tmp,10)); ! 279: useron.etoday++; ! 280: putuserrec(&cfg,useron.number,U_ETODAY,5,ultoa(useron.etoday,tmp,10)); ! 281: ! 282: sprintf(str,"%s sent Internet Mail to %s (%s)" ! 283: ,useron.alias ! 284: ,name,addr); ! 285: logline("EN",str); ! 286: return(true); ! 287: } ! 288: ! 289: bool sbbs_t::qnetmail(char *into, char *subj, long mode) ! 290: { ! 291: char str[256],msgpath[128],title[128],to[128],fulladdr[128] ! 292: ,buf[SDT_BLOCK_LEN],*addr; ! 293: char tmp[512]; ! 294: ushort xlat=XLAT_NONE,net=NET_QWK,touser; ! 295: int i,j,x,file; ! 296: ulong length,offset; ! 297: FILE *instream; ! 298: smbmsg_t msg; ! 299: ! 300: if(useron.etoday>=cfg.level_emailperday[useron.level] && !SYSOP) { ! 301: bputs(text[TooManyEmailsToday]); ! 302: return(false); ! 303: } ! 304: ! 305: strcpy(to,into); ! 306: strcpy(title,subj); ! 307: ! 308: if(useron.rest&FLAG('M')) { ! 309: bputs(text[NoNetMailAllowed]); ! 310: return(false); } ! 311: ! 312: addr=strrchr(to,'@'); ! 313: if(!addr) { ! 314: bputs(text[InvalidNetMailAddr]); ! 315: return(false); ! 316: } ! 317: *addr=0; ! 318: addr++; ! 319: strupr(addr); ! 320: truncsp(addr); ! 321: touser=qwk_route(addr,fulladdr); ! 322: if(!fulladdr[0]) { ! 323: bputs(text[InvalidNetMailAddr]); ! 324: return(false); ! 325: } ! 326: ! 327: truncsp(to); ! 328: if(!stricmp(to,"SBBS") && !SYSOP) { ! 329: bputs(text[InvalidNetMailAddr]); ! 330: return(false); ! 331: } ! 332: bprintf(text[NetMailing],to,fulladdr ! 333: ,useron.alias,cfg.sys_id); ! 334: action=NODE_SMAL; ! 335: nodesync(); ! 336: ! 337: sprintf(msgpath,"%snetmail.msg",cfg.node_dir); ! 338: if(!writemsg(msgpath,nulstr,title,mode|WM_QWKNET,INVALID_SUB,to)) { ! 339: bputs(text[Aborted]); ! 340: return(false); } ! 341: ! 342: if((i=smb_stack(&smb,SMB_STACK_PUSH))!=SMB_SUCCESS) { ! 343: errormsg(WHERE,ERR_OPEN,"MAIL",i); ! 344: return(false); } ! 345: sprintf(smb.file,"%smail",cfg.data_dir); ! 346: smb.retry_time=cfg.smb_retry_time; ! 347: smb.subnum=INVALID_SUB; ! 348: if((i=smb_open(&smb))!=SMB_SUCCESS) { ! 349: smb_stack(&smb,SMB_STACK_POP); ! 350: errormsg(WHERE,ERR_OPEN,smb.file,i,smb.last_error); ! 351: return(false); } ! 352: ! 353: if(filelength(fileno(smb.shd_fp))<1) { /* Create it if it doesn't exist */ ! 354: smb.status.max_crcs=cfg.mail_maxcrcs; ! 355: smb.status.max_msgs=0; ! 356: smb.status.max_age=cfg.mail_maxage; ! 357: smb.status.attr=SMB_EMAIL; ! 358: if((i=smb_create(&smb))!=SMB_SUCCESS) { ! 359: smb_close(&smb); ! 360: smb_stack(&smb,SMB_STACK_POP); ! 361: errormsg(WHERE,ERR_CREATE,smb.file,i,smb.last_error); ! 362: return(false); } } ! 363: ! 364: if((i=smb_locksmbhdr(&smb))!=SMB_SUCCESS) { ! 365: smb_close(&smb); ! 366: smb_stack(&smb,SMB_STACK_POP); ! 367: errormsg(WHERE,ERR_LOCK,smb.file,i,smb.last_error); ! 368: return(false); } ! 369: ! 370: length=flength(msgpath)+2; /* +2 for translation string */ ! 371: ! 372: if(length&0xfff00000UL) { ! 373: smb_unlocksmbhdr(&smb); ! 374: smb_close(&smb); ! 375: smb_stack(&smb,SMB_STACK_POP); ! 376: errormsg(WHERE,ERR_LEN,msgpath,length); ! 377: return(false); } ! 378: ! 379: if((i=smb_open_da(&smb))!=SMB_SUCCESS) { ! 380: smb_unlocksmbhdr(&smb); ! 381: smb_close(&smb); ! 382: smb_stack(&smb,SMB_STACK_POP); ! 383: errormsg(WHERE,ERR_OPEN,smb.file,i,smb.last_error); ! 384: return(false); } ! 385: if(cfg.sys_misc&SM_FASTMAIL) ! 386: offset=smb_fallocdat(&smb,length,1); ! 387: else ! 388: offset=smb_allocdat(&smb,length,1); ! 389: smb_close_da(&smb); ! 390: ! 391: if((file=open(msgpath,O_RDONLY|O_BINARY))==-1 ! 392: || (instream=fdopen(file,"rb"))==NULL) { ! 393: smb_freemsgdat(&smb,offset,length,1); ! 394: smb_unlocksmbhdr(&smb); ! 395: smb_close(&smb); ! 396: smb_stack(&smb,SMB_STACK_POP); ! 397: errormsg(WHERE,ERR_OPEN,msgpath,O_RDONLY|O_BINARY); ! 398: return(false); } ! 399: ! 400: setvbuf(instream,NULL,_IOFBF,2*1024); ! 401: fseek(smb.sdt_fp,offset,SEEK_SET); ! 402: xlat=XLAT_NONE; ! 403: fwrite(&xlat,2,1,smb.sdt_fp); ! 404: x=SDT_BLOCK_LEN-2; /* Don't read/write more than 255 */ ! 405: while(!feof(instream)) { ! 406: memset(buf,0,x); ! 407: j=fread(buf,1,x,instream); ! 408: if(j<1) ! 409: break; ! 410: if(j>1 && (j!=x || feof(instream)) && buf[j-1]==LF && buf[j-2]==CR) ! 411: buf[j-1]=buf[j-2]=0; ! 412: fwrite(buf,j,1,smb.sdt_fp); ! 413: x=SDT_BLOCK_LEN; } ! 414: fflush(smb.sdt_fp); ! 415: fclose(instream); ! 416: ! 417: memset(&msg,0,sizeof(smbmsg_t)); ! 418: msg.hdr.version=smb_ver(); ! 419: if(mode&WM_FILE) ! 420: msg.hdr.auxattr|=MSG_FILEATTACH; ! 421: msg.hdr.when_written.time=msg.hdr.when_imported.time=time(NULL); ! 422: msg.hdr.when_written.zone=msg.hdr.when_imported.zone=sys_timezone(&cfg); ! 423: ! 424: msg.hdr.offset=offset; ! 425: ! 426: net=NET_QWK; ! 427: smb_hfield_str(&msg,RECIPIENT,to); ! 428: sprintf(str,"%u",touser); ! 429: smb_hfield_str(&msg,RECIPIENTEXT,str); ! 430: smb_hfield(&msg,RECIPIENTNETTYPE,sizeof(net),&net); ! 431: smb_hfield_str(&msg,RECIPIENTNETADDR,fulladdr); ! 432: ! 433: smb_hfield_str(&msg,SENDER,useron.alias); ! 434: ! 435: sprintf(str,"%u",useron.number); ! 436: smb_hfield_str(&msg,SENDEREXT,str); ! 437: ! 438: /* Security logging */ ! 439: msg_client_hfields(&msg,&client); ! 440: ! 441: smb_hfield_str(&msg,SUBJECT,title); ! 442: ! 443: smb_dfield(&msg,TEXT_BODY,length); ! 444: ! 445: i=smb_addmsghdr(&smb,&msg,SMB_SELFPACK); // calls smb_unlocksmbhdr() ! 446: smb_close(&smb); ! 447: smb_stack(&smb,SMB_STACK_POP); ! 448: ! 449: smb_freemsgmem(&msg); ! 450: if(i!=SMB_SUCCESS) { ! 451: errormsg(WHERE,ERR_WRITE,smb.file,i,smb.last_error); ! 452: smb_freemsgdat(&smb,offset,length,1); ! 453: return(false); ! 454: } ! 455: ! 456: useron.emails++; ! 457: logon_emails++; ! 458: putuserrec(&cfg,useron.number,U_EMAILS,5,ultoa(useron.emails,tmp,10)); ! 459: useron.etoday++; ! 460: putuserrec(&cfg,useron.number,U_ETODAY,5,ultoa(useron.etoday,tmp,10)); ! 461: ! 462: sprintf(str,"%s sent QWK NetMail to %s (%s)" ! 463: ,useron.alias ! 464: ,to,fulladdr); ! 465: logline("EN",str); ! 466: return(true); ! 467: }
This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.