Mercurial Hosting > luan

comparison src/luan/modules/mail/MailCon.java @ 1586:fcca0ddf5a4d

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
luan uses goodjava.mail
author Franklin Schmidt <fschmidt@gmail.com>
date Fri, 12 Mar 2021 20:12:43 -0700
parents
children fa1a9aceac3e
comparison
equal deleted inserted replaced
1585:c0ef8acf069d 1586:fcca0ddf5a4d
1 package luan.modules.mail;
2
3 import java.io.IOException;
4 import java.net.Socket;
5 import java.util.Map;
6 import java.util.LinkedHashMap;
7 import java.util.List;
8 import goodjava.mail.Message;
9 import goodjava.mail.Smtp;
10 import goodjava.mail.MailException;
11 import luan.Luan;
12 import luan.LuanTable;
13 import luan.LuanException;
14
15
16 public final class MailCon {
17 private final String host;
18 private final int port;
19 private final String username;
20 private final String password;
21
22 public MailCon(LuanTable paramsTbl) throws LuanException {
23 Map<Object,Object> params = paramsTbl.asMap();
24
25 String host = getString(params,"host");
26 if( host==null )
27 throw new LuanException( "parameter 'host' is required" );
28 this.host = host;
29
30 Object port = params.remove("port");
31 if( port==null )
32 throw new LuanException( "parameter 'port' is required" );
33 if( !(port instanceof Number) )
34 throw new LuanException( "parameter 'port' must be an integer" );
35 Integer i = Luan.asInteger(port);
36 if( i == null )
37 throw new LuanException( "parameter 'port' must be an integer" );
38 this.port = i;
39
40 this.username = getString(params,"username");
41 this.password = getString(params,"password");
42 if( this.username!=null && this.password==null )
43 throw new LuanException( "password required with username" );
44 if( this.username==null && this.password!=null )
45 throw new LuanException( "username required with password" );
46
47 if( !params.isEmpty() )
48 throw new LuanException( "unrecognized parameters: "+params );
49 }
50
51 private static String getString(Map<Object,Object> params,String key) throws LuanException {
52 Object val = params.remove(key);
53 if( val!=null && !(val instanceof String) )
54 throw new LuanException( "parameter '"+key+"' must be a string" );
55 return (String)val;
56 }
57
58 private static Message message(LuanTable mailTbl) throws LuanException {
59 Map<Object,Object> mailParams = mailTbl.asMap();
60 Object body = mailParams.remove("body");
61 if( body == null )
62 throw new LuanException( "parameter 'body' is required" );
63 if( body instanceof LuanTable ) {
64 LuanTable tbl = (LuanTable)body;
65 if( !tbl.isList() )
66 throw new LuanException( "body table must be a list" );
67 List list = tbl.asList();
68 Message[] msgs = new Message[list.size()];
69 for( int i=0; i<msgs.length; i++ ) {
70 Object obj = list.get(i);
71 if( !(obj instanceof LuanTable) )
72 throw new LuanException( "body table must be a list of part tables" );
73 msgs[i] = message((LuanTable)obj);
74 }
75 body = msgs;
76 }
77 Map<String,String> headers = new LinkedHashMap<String,String>();
78 boolean hasContentType = false;
79 for( Map.Entry<Object,Object> entry : mailParams.entrySet() ) {
80 Object key = entry.getKey();
81 Object value = entry.getValue();
82 if( !(key instanceof String) )
83 throw new LuanException( "keys must be strings" );
84 if( !(value instanceof String) )
85 throw new LuanException( "value for '"+key+"' must be string" );
86 String name = (String)key;
87 headers.put(name,(String)value);
88 if( name.equalsIgnoreCase("content-type") )
89 hasContentType = true;
90 }
91 if( !hasContentType && body instanceof String )
92 headers.put("Content-Type","text/plain; charset=utf-8");
93 return new Message(headers,body);
94 }
95
96 public void send(LuanTable mailTbl) throws LuanException, IOException, MailException {
97 Message msg = message(mailTbl);
98 Socket socket = new Socket(host,port);
99 Smtp smtp = new Smtp(socket);
100 if( username != null )
101 smtp.authenticate(username,password);
102 smtp.send(msg);
103 smtp.close();
104 }
105
106 }