![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to email.cpp CVS log ![[TXT]](/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvsweb/icons/dir.gif){kind=icon}
Up to [Synchronet] / sbbs / sbbs3|
Return to email.cpp CVS log | Up to [Synchronet] / sbbs / sbbs3 |
1.1 root 1: /* email.cpp */
2:
3: /* Synchronet email function - for sending private e-mail */
4:
5: /* $Id: email.cpp,v 1.4 2000/12/11 23:21:11 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 "cmdshell.h"
40:
41: /****************************************************************************/
42: /* Mails a message to usernumber. 'top' is a buffer to place at beginning */
43: /* of message. */
44: /* Called from functions main_sec, newuser, readmail and scanposts */
45: /****************************************************************************/
46: bool sbbs_t::email(int usernumber, char *top, char *subj, long mode)
47: {
48: char str[256],str2[256],msgpath[256],title[LEN_TITLE+1],ch
49: ,buf[SDT_BLOCK_LEN];
50: char tmp[512];
51: ushort xlat=XLAT_NONE,msgattr=0;
52: int i,j,x,file;
53: long l;
54: ulong length,offset,crc=0xffffffffUL;
55: FILE *instream;
56: node_t node;
57: smbmsg_t msg;
58:
59: sprintf(title,"%.*s",LEN_TITLE,subj);
60:
61: if(useron.etoday>=cfg.level_emailperday[useron.level] && !SYSOP) {
62: bputs(text[TooManyEmailsToday]);
63: return(false); }
64:
65: if(usernumber==1 && useron.rest&FLAG('S')
66: && (cfg.node_valuser!=1 || useron.fbacks || useron.emails)) { /* ! val fback */
67: bprintf(text[R_Feedback],cfg.sys_op);
68: return(false); }
69: if(usernumber!=1 && useron.rest&FLAG('E')
70: && (cfg.node_valuser!=usernumber || useron.fbacks || useron.emails)) {
71: bputs(text[R_Email]);
72: return(false); }
73: if(!usernumber) {
74: bputs(text[UnknownUser]);
75: return(false); }
76: getuserrec(&cfg,usernumber,U_MISC,8,str);
77: l=ahtoul(str);
78: if(l&(DELETED|INACTIVE)) { /* Deleted or Inactive User */
79: bputs(text[UnknownUser]);
80: return(false); }
81: if(l&NETMAIL && cfg.sys_misc&SM_FWDTONET
82: && yesno(text[ForwardMailQ])) { /* Forward to netmail address */
83: getuserrec(&cfg,usernumber,U_NETMAIL,LEN_NETMAIL,str);
84: netmail(str,subj,mode);
85: return(false); }
86: bprintf(text[Emailing],username(&cfg,usernumber,tmp),usernumber);
87: action=NODE_SMAL;
88: nodesync();
89:
90: sprintf(str,"%sFEEDBACK.BIN", cfg.exec_dir);
91: if(usernumber==1 && useron.fbacks && fexist(str)) {
92: exec_bin("FEEDBACK",&main_csi);
93: if(main_csi.logic!=LOGIC_TRUE)
94: return(false); }
95:
96: if(cfg.sys_misc&SM_ANON_EM && useron.exempt&FLAG('A')
97: && !noyes(text[AnonymousQ]))
98: msgattr|=MSG_ANONYMOUS;
99:
100: if(cfg.sys_misc&SM_DELREADM)
101: msgattr|=MSG_KILLREAD;
102:
103: sprintf(msgpath,"%sINPUT.MSG", cfg.node_dir);
104: #if 0 // Removed 01/06/00 (for external editor information)
105: sprintf(str2,"%s #%u",username(&cfg,usernumber,tmp),usernumber);
106: #else
107: username(&cfg,usernumber,str2);
108: #endif
109: if(!writemsg(msgpath,top,title,mode,0,str2)) {
110: bputs(text[Aborted]);
111: return(false); }
112:
113: if(mode&WM_FILE) {
114: sprintf(str2,"%sfile/%04u.in", cfg.data_dir,usernumber);
115: _mkdir(str2);
116: sprintf(str2,"%sfile/%04u.in/%s", cfg.data_dir,usernumber,title);
117: if(fexist(str2)) {
118: bputs(text[FileAlreadyThere]);
119: remove(msgpath);
120: return(false); }
121: if(online==ON_LOCAL) { /* Local upload */
122: bputs(text[EnterPath]);
123: if(!getstr(str,60,K_LINE|K_UPPER)) {
124: bputs(text[Aborted]);
125: remove(msgpath);
126: return(false); }
127: backslash(str);
128: strcat(str,title);
129: mv(str,str2,1); }
130: else { /* Remote */
131: menu("ulprot");
132: mnemonics(text[ProtocolOrQuit]);
133: strcpy(str,"Q");
134: for(x=0;x<cfg.total_prots;x++)
135: if(cfg.prot[x]->ulcmd[0] && chk_ar(cfg.prot[x]->ar,&useron)) {
136: sprintf(tmp,"%c",cfg.prot[x]->mnemonic);
137: strcat(str,tmp); }
138: ch=(char)getkeys(str,0);
139: if(ch=='Q' || sys_status&SS_ABORT) {
140: bputs(text[Aborted]);
141: remove(msgpath);
142: return(false); }
143: for(x=0;x<cfg.total_prots;x++)
144: if(cfg.prot[x]->ulcmd[0] && cfg.prot[x]->mnemonic==ch
145: && chk_ar(cfg.prot[x]->ar,&useron))
146: break;
147: if(x<cfg.total_prots) /* This should be always */
148: protocol(cmdstr(cfg.prot[x]->ulcmd,str2,nulstr,NULL),0); }
149: l=flength(str2);
150: if(l>0)
151: bprintf(text[FileNBytesReceived],title,ultoac(l,tmp));
152: else {
153: bprintf(text[FileNotReceived],title);
154: remove(msgpath);
155: return(false); } }
156:
157: bputs(text[WritingIndx]);
158:
159: if((i=smb_stack(&smb,SMB_STACK_PUSH))!=0) {
160: errormsg(WHERE,ERR_OPEN,"MAIL",i);
161: return(false); }
162: sprintf(smb.file,"%smail", cfg.data_dir);
163: smb.retry_time=cfg.smb_retry_time;
164: if((i=smb_open(&smb))!=0) {
165: smb_stack(&smb,SMB_STACK_POP);
166: errormsg(WHERE,ERR_OPEN,smb.file,i,smb.last_error);
167: return(false); }
168:
169: if(smb_fgetlength(smb.shd_fp)<1) { /* Create it if it doesn't exist */
170: smb.status.max_crcs=cfg.mail_maxcrcs;
171: smb.status.max_age=cfg.mail_maxage;
172: smb.status.max_msgs=MAX_SYSMAIL;
173: smb.status.attr=SMB_EMAIL;
174: if((i=smb_create(&smb))!=0) {
175: smb_close(&smb);
176: smb_stack(&smb,SMB_STACK_POP);
177: errormsg(WHERE,ERR_CREATE,smb.file,i,smb.last_error);
178: return(false); } }
179:
180: if((i=smb_locksmbhdr(&smb))!=0) {
181: smb_close(&smb);
182: smb_stack(&smb,SMB_STACK_POP);
183: errormsg(WHERE,ERR_LOCK,smb.file,i,smb.last_error);
184: return(false); }
185:
186: length=flength(msgpath)+2; /* +2 for translation string */
187:
188: if(length&0xfff00000UL) {
189: smb_unlocksmbhdr(&smb);
190: smb_close(&smb);
191: smb_stack(&smb,SMB_STACK_POP);
192: errormsg(WHERE,ERR_LEN,msgpath,length);
193: return(false); }
194:
195: if((i=smb_open_da(&smb))!=0) {
196: smb_unlocksmbhdr(&smb);
197: smb_close(&smb);
198: smb_stack(&smb,SMB_STACK_POP);
199: errormsg(WHERE,ERR_OPEN,smb.file,i,smb.last_error);
200: return(false); }
201: if(cfg.sys_misc&SM_FASTMAIL)
202: offset=smb_fallocdat(&smb,length,1);
203: else
204: offset=smb_allocdat(&smb,length,1);
205: smb_close_da(&smb);
206:
207: if((file=open(msgpath,O_RDONLY|O_BINARY))==-1
208: || (instream=fdopen(file,"rb"))==NULL) {
209: smb_freemsgdat(&smb,offset,length,1);
210: smb_unlocksmbhdr(&smb);
211: smb_close(&smb);
212: smb_stack(&smb,SMB_STACK_POP);
213: errormsg(WHERE,ERR_OPEN,msgpath,O_RDONLY|O_BINARY);
214: return(false); }
215:
216: setvbuf(instream,NULL,_IOFBF,2*1024);
217: smb_fseek(smb.sdt_fp,offset,SEEK_SET);
218: xlat=XLAT_NONE;
219: smb_fwrite(&xlat,2,smb.sdt_fp);
220: x=SDT_BLOCK_LEN-2; /* Don't read/write more than 255 */
221: while(!feof(instream)) {
222: memset(buf,0,x);
223: j=fread(buf,1,x,instream);
224: if((j!=x || feof(instream)) && buf[j-1]==LF && buf[j-2]==CR)
225: buf[j-1]=buf[j-2]=0;
226: if(cfg.mail_maxcrcs) {
227: for(i=0;i<j;i++)
228: crc=ucrc32(buf[i],crc); }
229: smb_fwrite(buf,j,smb.sdt_fp);
230: x=SDT_BLOCK_LEN; }
231: smb_fflush(smb.sdt_fp);
232: fclose(instream);
233: crc=~crc;
234:
235: memset(&msg,0,sizeof(smbmsg_t));
236: memcpy(msg.hdr.id,"SHD\x1a",4);
237: msg.hdr.version=smb_ver();
238: msg.hdr.attr=msg.idx.attr=msgattr;
239: if(mode&WM_FILE)
240: msg.hdr.auxattr|=MSG_FILEATTACH;
241: msg.hdr.when_written.time=msg.hdr.when_imported.time=time(NULL);
242: msg.hdr.when_written.zone=msg.hdr.when_imported.zone=cfg.sys_timezone;
243:
244: if(cfg.mail_maxcrcs) {
245: i=smb_addcrc(&smb,crc);
246: if(i) {
247: smb_freemsgdat(&smb,offset,length,1);
248: smb_unlocksmbhdr(&smb);
249: smb_close(&smb);
250: smb_stack(&smb,SMB_STACK_POP);
251: bputs("\1r\1h\1iDuplicate message!\r\n");
252: return(false); } }
253:
254: msg.hdr.offset=offset;
255:
256: username(&cfg,usernumber,str);
257: smb_hfield(&msg,RECIPIENT,strlen(str),str);
258:
259: sprintf(str,"%u",usernumber);
260: smb_hfield(&msg,RECIPIENTEXT,strlen(str),str);
261: msg.idx.to=usernumber;
262:
263: strcpy(str,useron.alias);
264: smb_hfield(&msg,SENDER,strlen(str),str);
265:
266: sprintf(str,"%u",useron.number);
267: smb_hfield(&msg,SENDEREXT,strlen(str),str);
268: msg.idx.from=useron.number;
269:
270: smb_hfield(&msg,SUBJECT,strlen(title),title);
271: strlwr(title);
272: msg.idx.subj=crc16(title);
273:
274: smb_dfield(&msg,TEXT_BODY,length);
275:
276: smb_unlocksmbhdr(&smb);
277: i=smb_addmsghdr(&smb,&msg,SMB_SELFPACK);
278: smb_close(&smb);
279: smb_stack(&smb,SMB_STACK_POP);
280:
281: smb_freemsgmem(&msg);
282: if(i) {
283: smb_freemsgdat(&smb,offset,length,1);
284: errormsg(WHERE,ERR_WRITE,smb.file,i,smb.last_error);
285: return(false); }
286:
287: if(usernumber==1) {
288: useron.fbacks++;
289: logon_fbacks++;
290: putuserrec(&cfg,useron.number,U_FBACKS,5,ultoa(useron.fbacks,tmp,10)); }
291: else {
292: useron.emails++;
293: logon_emails++;
294: putuserrec(&cfg,useron.number,U_EMAILS,5,ultoa(useron.emails,tmp,10)); }
295: useron.etoday++;
296: putuserrec(&cfg,useron.number,U_ETODAY,5,ultoa(useron.etoday,tmp,10));
297: bprintf(text[Emailed],username(&cfg,usernumber,tmp),usernumber);
298: sprintf(str,"E-mailed %s #%d",username(&cfg,usernumber,tmp),usernumber);
299: logline("E+",str);
300: if(mode&WM_FILE && online==ON_REMOTE)
301: autohangup();
302: if(msgattr&MSG_ANONYMOUS) /* Don't tell user if anonymous */
303: return(true);
304: for(i=1;i<=cfg.sys_nodes;i++) { /* Tell user, if online */
305: getnodedat(i,&node,0);
306: if(node.useron==usernumber && !(node.misc&NODE_POFF)
307: && (node.status==NODE_INUSE || node.status==NODE_QUIET)) {
308: sprintf(str,text[EmailNodeMsg],cfg.node_num,useron.alias);
309: putnmsg(i,str);
310: break; } }
311: if(i>cfg.sys_nodes) { /* User wasn't online, so leave short msg */
312: sprintf(str,text[UserSentYouMail],useron.alias);
313: putsmsg(&cfg,usernumber,str); }
314: return(true);
315: }
This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.