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