![[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:
1.1.1.2 ! root 5: /* $Id: netmail.cpp,v 1.32 2004/10/21 08:58:25 rswindell Exp $ */
1.1 root 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: * *
1.1.1.2 ! root 11: * Copyright 2004 Rob Swindell - http://www.synchro.net/copyright.html *
1.1 root 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
1.1.1.2 ! root 46: ,buf[SDT_BLOCK_LEN],*p,addr[256];
1.1 root 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 */
1.1.1.2 ! root 86: usermailaddr(&cfg,your_addr
! 87: ,cfg.inetmail_misc&NMAIL_ALIAS ? useron.alias : useron.name);
1.1 root 88:
89: bprintf(text[InternetMailing],addr,your_addr);
90: action=NODE_SMAL;
91: nodesync();
92:
93: sprintf(msgpath,"%snetmail.msg",cfg.node_dir);
1.1.1.2 ! root 94: if(!writemsg(msgpath,nulstr,title,mode,INVALID_SUB,into)) {
1.1 root 95: bputs(text[Aborted]);
96: return(false); }
97:
98: if(mode&WM_FILE) {
99: sprintf(str2,"%sfile/%04u.out",cfg.data_dir,useron.number);
1.1.1.2 ! root 100: MKDIR(str2);
1.1 root 101: sprintf(str2,"%sfile/%04u.out/%s",cfg.data_dir,useron.number,title);
1.1.1.2 ! root 102: if(fexistcase(str2)) {
1.1 root 103: bputs(text[FileAlreadyThere]);
104: remove(msgpath);
105: return(false); }
106: if(online==ON_LOCAL) { /* Local upload */
107: bputs(text[EnterPath]);
108: if(!getstr(str,60,K_LINE|K_UPPER)) {
109: bputs(text[Aborted]);
110: remove(msgpath);
111: return(false); }
112: backslash(str);
113: strcat(str,title);
114: mv(str,str2,1); }
115: else { /* Remote */
1.1.1.2 ! root 116: xfer_prot_menu(XFER_UPLOAD);
1.1 root 117: mnemonics(text[ProtocolOrQuit]);
118: strcpy(str,"Q");
119: for(x=0;x<cfg.total_prots;x++)
120: if(cfg.prot[x]->ulcmd[0] && chk_ar(cfg.prot[x]->ar,&useron)) {
121: sprintf(tmp,"%c",cfg.prot[x]->mnemonic);
122: strcat(str,tmp); }
123: ch=(char)getkeys(str,0);
124: if(ch=='Q' || sys_status&SS_ABORT) {
125: bputs(text[Aborted]);
126: remove(msgpath);
127: return(false); }
128: for(x=0;x<cfg.total_prots;x++)
129: if(cfg.prot[x]->ulcmd[0] && cfg.prot[x]->mnemonic==ch
130: && chk_ar(cfg.prot[x]->ar,&useron))
131: break;
132: if(x<cfg.total_prots) /* This should be always */
1.1.1.2 ! root 133: protocol(cfg.prot[x],XFER_UPLOAD,str2,nulstr,true);
! 134: }
! 135: sprintf(tmp,"%s%s",cfg.temp_dir,title);
! 136: if(!fexistcase(str2) && fexistcase(tmp))
! 137: mv(tmp,str2,0);
1.1 root 138: l=flength(str2);
139: if(l>0)
140: bprintf(text[FileNBytesReceived],title,ultoac(l,tmp));
141: else {
142: bprintf(text[FileNotReceived],title);
143: remove(msgpath);
144: return(false); } }
145:
1.1.1.2 ! root 146: if((i=smb_stack(&smb,SMB_STACK_PUSH))!=SMB_SUCCESS) {
1.1 root 147: errormsg(WHERE,ERR_OPEN,"MAIL",i);
148: return(false); }
149: sprintf(smb.file,"%smail",cfg.data_dir);
150: smb.retry_time=cfg.smb_retry_time;
1.1.1.2 ! root 151: smb.subnum=INVALID_SUB;
! 152: if((i=smb_open(&smb))!=SMB_SUCCESS) {
1.1 root 153: smb_stack(&smb,SMB_STACK_POP);
154: errormsg(WHERE,ERR_OPEN,smb.file,i,smb.last_error);
155: return(false); }
156:
157: if(filelength(fileno(smb.shd_fp))<1) { /* Create it if it doesn't exist */
158: smb.status.max_crcs=cfg.mail_maxcrcs;
159: smb.status.max_age=cfg.mail_maxage;
1.1.1.2 ! root 160: smb.status.max_msgs=0;
1.1 root 161: smb.status.attr=SMB_EMAIL;
1.1.1.2 ! root 162: if((i=smb_create(&smb))!=SMB_SUCCESS) {
1.1 root 163: smb_close(&smb);
164: smb_stack(&smb,SMB_STACK_POP);
165: errormsg(WHERE,ERR_CREATE,smb.file,i);
166: return(false); } }
167:
1.1.1.2 ! root 168: if((i=smb_locksmbhdr(&smb))!=SMB_SUCCESS) {
1.1 root 169: smb_close(&smb);
170: smb_stack(&smb,SMB_STACK_POP);
171: errormsg(WHERE,ERR_LOCK,smb.file,i);
172: return(false); }
173:
174: length=flength(msgpath)+2; /* +2 for translation string */
175:
176: if(length&0xfff00000UL) {
177: smb_unlocksmbhdr(&smb);
178: smb_close(&smb);
179: smb_stack(&smb,SMB_STACK_POP);
180: errormsg(WHERE,ERR_LEN,msgpath,length);
181: return(false); }
182:
1.1.1.2 ! root 183: if((i=smb_open_da(&smb))!=SMB_SUCCESS) {
1.1 root 184: smb_unlocksmbhdr(&smb);
185: smb_close(&smb);
186: smb_stack(&smb,SMB_STACK_POP);
187: errormsg(WHERE,ERR_OPEN,smb.file,i,smb.last_error);
188: return(false); }
189: if(cfg.sys_misc&SM_FASTMAIL)
190: offset=smb_fallocdat(&smb,length,1);
191: else
192: offset=smb_allocdat(&smb,length,1);
193: smb_close_da(&smb);
194:
195: if((file=open(msgpath,O_RDONLY|O_BINARY))==-1
196: || (instream=fdopen(file,"rb"))==NULL) {
197: smb_freemsgdat(&smb,offset,length,1);
198: smb_unlocksmbhdr(&smb);
199: smb_close(&smb);
200: smb_stack(&smb,SMB_STACK_POP);
201: errormsg(WHERE,ERR_OPEN,msgpath,O_RDONLY|O_BINARY);
202: return(false); }
203:
204: setvbuf(instream,NULL,_IOFBF,2*1024);
205: fseek(smb.sdt_fp,offset,SEEK_SET);
206: xlat=XLAT_NONE;
207: fwrite(&xlat,2,1,smb.sdt_fp);
208: x=SDT_BLOCK_LEN-2; /* Don't read/write more than 255 */
209: while(!feof(instream)) {
210: memset(buf,0,x);
211: j=fread(buf,1,x,instream);
1.1.1.2 ! root 212: if(j<1)
! 213: break;
! 214: if(j>1 && (j!=x || feof(instream)) && buf[j-1]==LF && buf[j-2]==CR)
1.1 root 215: buf[j-1]=buf[j-2]=0;
216: fwrite(buf,j,1,smb.sdt_fp);
217: x=SDT_BLOCK_LEN; }
218: fflush(smb.sdt_fp);
219: fclose(instream);
220:
221: memset(&msg,0,sizeof(smbmsg_t));
222: msg.hdr.version=smb_ver();
223: if(mode&WM_FILE)
224: msg.hdr.auxattr|=MSG_FILEATTACH;
225: msg.hdr.when_written.time=msg.hdr.when_imported.time=time(NULL);
1.1.1.2 ! root 226: msg.hdr.when_written.zone=msg.hdr.when_imported.zone=sys_timezone(&cfg);
1.1 root 227:
228: msg.hdr.offset=offset;
229:
230: net=NET_INTERNET;
1.1.1.2 ! root 231: smb_hfield_str(&msg,RECIPIENT,name);
1.1 root 232: msg.idx.to=0; /* Out-bound NetMail set to 0 */
233: smb_hfield(&msg,RECIPIENTNETTYPE,sizeof(net),&net);
1.1.1.2 ! root 234: smb_hfield_str(&msg,RECIPIENTNETADDR,addr);
1.1 root 235:
236: strcpy(str,cfg.inetmail_misc&NMAIL_ALIAS ? useron.alias : useron.name);
1.1.1.2 ! root 237: smb_hfield_str(&msg,SENDER,str);
1.1 root 238:
239: sprintf(str,"%u",useron.number);
1.1.1.2 ! root 240: smb_hfield_str(&msg,SENDEREXT,str);
1.1 root 241: msg.idx.from=useron.number;
242:
243: /*
244: smb_hfield(&msg,SENDERNETTYPE,sizeof(net),&net);
245: smb_hfield(&msg,SENDERNETADDR,strlen(sys_inetaddr),sys_inetaddr);
246: */
247:
1.1.1.2 ! root 248: /* Security logging */
! 249: msg_client_hfields(&msg,&client);
! 250:
! 251: smb_hfield_str(&msg,SUBJECT,title);
1.1 root 252: strcpy(str,title);
1.1.1.2 ! root 253: msg.idx.subj=smb_subject_crc(str);
1.1 root 254:
255: smb_dfield(&msg,TEXT_BODY,length);
256:
1.1.1.2 ! root 257: i=smb_addmsghdr(&smb,&msg,SMB_SELFPACK); // calls smb_unlocksmbhdr()
1.1 root 258: smb_close(&smb);
259: smb_stack(&smb,SMB_STACK_POP);
260:
261: smb_freemsgmem(&msg);
1.1.1.2 ! root 262: if(i!=SMB_SUCCESS) {
1.1 root 263: errormsg(WHERE,ERR_WRITE,smb.file,i,smb.last_error);
1.1.1.2 ! root 264: smb_freemsgdat(&smb,offset,length,1);
! 265: return(false);
! 266: }
1.1 root 267:
268: if(mode&WM_FILE && online==ON_REMOTE)
269: autohangup();
270:
271: if(cfg.inetmail_sem[0]) /* update semaphore file */
1.1.1.2 ! root 272: ftouch(cmdstr(cfg.inetmail_sem,nulstr,nulstr,NULL));
1.1 root 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:
1.1.1.2 ! root 282: sprintf(str,"%s sent Internet Mail to %s (%s)"
! 283: ,useron.alias
! 284: ,name,addr);
1.1 root 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) {
1.1.1.2 ! root 314: bputs(text[InvalidNetMailAddr]);
! 315: return(false);
! 316: }
1.1 root 317: *addr=0;
318: addr++;
319: strupr(addr);
320: truncsp(addr);
321: touser=qwk_route(addr,fulladdr);
322: if(!fulladdr[0]) {
1.1.1.2 ! root 323: bputs(text[InvalidNetMailAddr]);
! 324: return(false);
! 325: }
1.1 root 326:
327: truncsp(to);
328: if(!stricmp(to,"SBBS") && !SYSOP) {
1.1.1.2 ! root 329: bputs(text[InvalidNetMailAddr]);
! 330: return(false);
! 331: }
1.1 root 332: bprintf(text[NetMailing],to,fulladdr
333: ,useron.alias,cfg.sys_id);
334: action=NODE_SMAL;
335: nodesync();
336:
1.1.1.2 ! root 337: sprintf(msgpath,"%snetmail.msg",cfg.node_dir);
! 338: if(!writemsg(msgpath,nulstr,title,mode|WM_QWKNET,INVALID_SUB,to)) {
1.1 root 339: bputs(text[Aborted]);
340: return(false); }
341:
1.1.1.2 ! root 342: if((i=smb_stack(&smb,SMB_STACK_PUSH))!=SMB_SUCCESS) {
1.1 root 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;
1.1.1.2 ! root 347: smb.subnum=INVALID_SUB;
! 348: if((i=smb_open(&smb))!=SMB_SUCCESS) {
1.1 root 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;
1.1.1.2 ! root 355: smb.status.max_msgs=0;
1.1 root 356: smb.status.max_age=cfg.mail_maxage;
357: smb.status.attr=SMB_EMAIL;
1.1.1.2 ! root 358: if((i=smb_create(&smb))!=SMB_SUCCESS) {
1.1 root 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:
1.1.1.2 ! root 364: if((i=smb_locksmbhdr(&smb))!=SMB_SUCCESS) {
1.1 root 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:
1.1.1.2 ! root 379: if((i=smb_open_da(&smb))!=SMB_SUCCESS) {
1.1 root 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);
1.1.1.2 ! root 408: if(j<1)
! 409: break;
! 410: if(j>1 && (j!=x || feof(instream)) && buf[j-1]==LF && buf[j-2]==CR)
1.1 root 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);
1.1.1.2 ! root 422: msg.hdr.when_written.zone=msg.hdr.when_imported.zone=sys_timezone(&cfg);
1.1 root 423:
424: msg.hdr.offset=offset;
425:
426: net=NET_QWK;
1.1.1.2 ! root 427: smb_hfield_str(&msg,RECIPIENT,to);
1.1 root 428: msg.idx.to=touser;
429: smb_hfield(&msg,RECIPIENTNETTYPE,sizeof(net),&net);
1.1.1.2 ! root 430: smb_hfield_str(&msg,RECIPIENTNETADDR,fulladdr);
1.1 root 431:
1.1.1.2 ! root 432: smb_hfield_str(&msg,SENDER,useron.alias);
1.1 root 433:
434: sprintf(str,"%u",useron.number);
1.1.1.2 ! root 435: smb_hfield_str(&msg,SENDEREXT,str);
1.1 root 436: msg.idx.from=useron.number;
437:
1.1.1.2 ! root 438: /* Security logging */
! 439: msg_client_hfields(&msg,&client);
! 440:
! 441: smb_hfield_str(&msg,SUBJECT,title);
! 442: msg.idx.subj=smb_subject_crc(title);
1.1 root 443:
444: smb_dfield(&msg,TEXT_BODY,length);
445:
1.1.1.2 ! root 446: i=smb_addmsghdr(&smb,&msg,SMB_SELFPACK); // calls smb_unlocksmbhdr()
1.1 root 447: smb_close(&smb);
448: smb_stack(&smb,SMB_STACK_POP);
449:
450: smb_freemsgmem(&msg);
1.1.1.2 ! root 451: if(i!=SMB_SUCCESS) {
1.1 root 452: errormsg(WHERE,ERR_WRITE,smb.file,i,smb.last_error);
1.1.1.2 ! root 453: smb_freemsgdat(&smb,offset,length,1);
! 454: return(false);
! 455: }
1.1 root 456:
457: useron.emails++;
458: logon_emails++;
459: putuserrec(&cfg,useron.number,U_EMAILS,5,ultoa(useron.emails,tmp,10));
460: useron.etoday++;
461: putuserrec(&cfg,useron.number,U_ETODAY,5,ultoa(useron.etoday,tmp,10));
462:
1.1.1.2 ! root 463: sprintf(str,"%s sent QWK NetMail to %s (%s)"
! 464: ,useron.alias
! 465: ,to,fulladdr);
1.1 root 466: logline("EN",str);
467: return(true);
468: }
This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.