BastliBridge

mail.d (1424B)

---

 module bastlibridge.interfaces.mail;
 import bastlibridge.base;
 import std.process;
 import std.format;
 import std.algorithm;
 import std.concurrency;
 
 
 final class Mail: Endpoint{
 	string shellcmd;
 	__gshared Tid tid;
 	
 	this(Manager m, string args){
 		super(m,args);
 		shellcmd=args.idup;
 	}
 	
 	override void open(){
 		
 	}
 	
 	override Channel join(string c){
 		return new MailAddress();
 	}
 	
 	override void part(Channel c){
 		
 	}
 	
 	override void sendMessage(Message m, Channel c){
 		auto msg=m.getMessage();
 		if(msg.length==0){
 			info("Dropping empty message from mail endpoint");
 			return;
 		}
 		trace("Sending mail to ", c._name, " with command \"", shellcmd, `"`);
 		auto pipe=pipeShell(shellcmd);
 		trace("Process ", pipe.pid, " opened");
 		formattedWrite(pipe.stdin.lockingTextWriter, "Content-Type: text/plain; charset=utf-8\nTo: %s\nSubject: New message on %s\n\n%s\nAuthor: %s", c._name, m.getChannelName, m.getMessage(), m.userName());
 		trace("Text written to stdin");
 		pipe.stdin.close();
 		pipe.stdout.close();
 		trace("Closed pipes, waiting for termination of ", pipe.pid);
 		if(pipe.pid.wait()!=0){
 			warning("Sending mail failed");
 		}
 		else{
 			trace("Mail successfully sent");
 		}
 	}
 	
 	override void run(){
 		synchronized(this){
 			tid=thisTid();
 		}
 		while(!receiveOnly!bool()){}
 	}
 
 	override void stop(){
 		synchronized(this){
 			send(tid, true);
 		}
 	}
 }
 
 final class MailAddress : Channel{
 	
 }