From cc5a2b65b59b21981df5aca051daadac09739efb Mon Sep 17 00:00:00 2001 From: AriWD40 <31068670+AriWD40@users.noreply.github.com> Date: Sat, 25 Jul 2020 17:56:17 +0000 Subject: [PATCH] Create SMTP-NodeCode --- SMTP-NodeCode | 289 ++++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 289 insertions(+) create mode 100644 SMTP-NodeCode diff --git a/SMTP-NodeCode b/SMTP-NodeCode new file mode 100644 index 0000000..63c4b40 --- /dev/null +++ b/SMTP-NodeCode @@ -0,0 +1,289 @@ +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("..")