extends Node ########################################################### # # ExtraSimple SMTP client # # 1 - import in your project # 2 - put values in var server, user, password, # mailto, mymail # 3 - call method Deliver(data) to send mail # ########################################################### ########################################################### # # # d: inner class for simple debug - begin # # ########################################################### var debug = true func display(data): if debug == true: print("debug: ",data) ########################################################### # # # d: inner class for simple debug - end # # ########################################################### export var server = "smtp.gmail.com" export var port = 465 # standard SSL port export var user = ""# # put userid for SMTP login export var password = "" # put password for SMTP login export var mymailto = "" # put destination address export var mymail = "mail.smtp.localhost" ########################################################### # # signals # ########################################################### signal SMTP_connecting signal SMTP_connected signal SMTP_working signal SMTP_disconnected_error signal SMTP_disconnected_ok ########################################################### # # method used to connect # ########################################################### enum channel {TCP,PACKET} export (channel) var com = channel.TCP ########################################################### # # storage area # ########################################################### var authloginbase64="" var authpassbase64="" var Socket = null var PacketSocket = null var PacketIn = "" var PacketOut = "" enum esi {OK,KO} enum stati {OK,WAITING,NO_RESPONSE,UNHANDLED_REPONSE} export (stati) var stato var MaxRetries = 30 var delayTime = 250 var thread = null func _ready(): if user != "": authloginbase64=Marshalls.raw_to_base64(user.to_ascii()) if password != "": authpassbase64=Marshalls.raw_to_base64(password.to_ascii()) func _process(delta): pass func Deliver(data): thread = Thread.new() thread.start(self,"ThreadDeliver",data) #If you want to debug the program, this is where you start func ThreadDeliver(data): var r_code r_code = OpenSocket() if r_code == OK: r_code =WaitAnswer() if r_code == OK: r_code = MAILhello() if r_code == OK: print("SMTP_working") r_code = MAILauth() if r_code == OK: r_code = MAILfrom(mymail) if r_code == OK: r_code = MAILto(mymailto) if r_code == OK: r_code = MAILdata(data,mymail,subject) if r_code == OK: print("process OK") if r_code == OK: r_code =MAILquit() CloseSocket() if r_code == OK: emit_signal("SMTP_disconnected_ok") else: emit_signal("SMTP_disconnected_error") display("ERROR") return r_code var Bocket = null # I added the variable Bocket, as a wrap around the Socket (originally called socket anyway), # it's an SSL wrapper for Streampeers, I don't know much about these things, # but you learn a lot by messing around with things. func OpenSocket(): var error if Bocket == null: Bocket=StreamPeerTCP.new() error=Bocket.connect_to_host(server,port ) Socket = StreamPeerSSL.new() Socket.connect_to_stream(Bocket, true, server) display(["connecting server...",server,error]) if error > 0: var ip=IP.resolve_hostname(server) error=Socket.connect_to_host(ip,port) display(["trying IP ...",ip,error]) for i in range(1,MaxRetries): print(Socket.get_status()) if Socket.get_status() == Socket.STATUS_CONNECTED: display("connection up") break OS.delay_msec(delayTime) return error func CloseSocket(): Bocket.disconnect_from_host() func send(data1,data2=null,data3=null): var error error = sendOnly(data1,data2,data3) return error func sendOnly(data1,data2=null,data3=null): var error = 0 PacketOut = data1 if data2 != null: PacketOut = PacketOut + " " + data2 if data3 != null: PacketOut = PacketOut + " " + data3 display(["send",PacketOut]) PacketOut = PacketOut + "\n" if com == channel.TCP: error=Socket.put_data(PacketOut.to_utf8()) if error == null: error = "NULL" display(["send","r_code",error]) return error func WaitAnswer(succesful=""): stato= stati.WAITING display(["waiting response from server..."]) if com == channel.TCP: PacketIn = "" OS.delay_msec(delayTime) for i in range(1,MaxRetries): Socket.poll() var bufLen = Socket.get_available_bytes() if bufLen > 0: display(["bytes buffered",String(bufLen)]) PacketIn=PacketIn + Socket.get_utf8_string(bufLen) display(["receive",PacketIn]) break else: OS.delay_msec(delayTime) if PacketIn != "": stato= stati.OK if ParsePacketIn(succesful) != OK: stato=stati.UNHANDLED_REPONSE else: stato = stati.NO_RESPONSE return stato else: return 99 func ParsePacketIn(strcompare): if strcompare == "": return OK if PacketIn.left(strcompare.length())==strcompare: return OK else: return FAILED func MAILhello(): var r_code=send("HELO", mymail) WaitAnswer() r_code= send("EHLO", mymail) r_code= WaitAnswer("250") return r_code func MAILauth(): var r_code=send("AUTH LOGIN") r_code=WaitAnswer("334") #print("MAILauth() , AUTH LOGIN ", r_code) # when debugging, add print statements everywhere you fail to progress. if r_code == OK: r_code=send(authloginbase64) r_code = WaitAnswer("334") #print("MAILauth() , username ", r_code) if r_code == OK: r_code=send(authpassbase64) r_code = WaitAnswer("235") #print("MAILauth() , password ", r_code) display(["r_code auth:", r_code]) return r_code func MAILfrom(data): var r_code=send("MAIL FROM:",bracket(data)) r_code = WaitAnswer("250") return r_code func MAILto(data): var r_code=send("RCPT TO:",bracket(data)) r_code = WaitAnswer("250") return r_code var corpo = "Hello World!" var subject = "New message from Godot" func MAILdata(data=null,from=null,subject=null): print(corpo) for i in data: corpo = corpo + i + "\r\n" var r_code=send("DATA") r_code=WaitAnswer("354") if r_code == OK and subject != null: r_code=send("SUBJECT: ",subject) if r_code == OK and data != null: r_code=send(corpo) r_code =WaitAnswer("250") return r_code func MAILquit(): return send("QUIT") func bracket(data): return "<"+data+">" func _on_Button_pressed() -> void: Deliver("..")