Module: Messaging

Included in:
DrbDb
Defined in:
lib/DrbDB/Messaging.rb

Overview

this file is part of manqod manqod is distributed under the CDDL licence the owner of manqod is Dobai-Pataky Balint([email protected])

Instance Method Summary collapse

Instance Method Details

#delete_message(message_id, nick) ⇒ Object 



70
71
72
73
 
# File 'lib/DrbDB/Messaging.rb', line 70

def delete_message(message_id,nick)
	admin.query("update messages set `state`='d' where id='#{message_id}'")
	send_check_messages(nick)
end

#messages(nick) ⇒ Object 



66
67
68
 
# File 'lib/DrbDB/Messaging.rb', line 66

def messages(nick)
	admin.rows("select * from messages where recipient='#{nick}' and `state`!='d'")
end

#send_check_messages(nick) ⇒ Object 



17
18
19
20
21
22
23
24
25
26
 
# File 'lib/DrbDB/Messaging.rb', line 17

def send_check_messages(nick)
		main_server.connected_clients.each_key{|client| 
			begin
				c=String.new(client.to_s).split(/\@/)[0]
				client.rpc("Messaging.instance.check_messages") if c == nick
			rescue =>err
				eerror(err)
			end
		}
end

#send_message(nick, subject, body, sender = nil, sendmail = true) ⇒ Object 



6
7
8
9
10
11
12
13
14
15
 
# File 'lib/DrbDB/Messaging.rb', line 6

def send_message(nick,subject,body,sender=nil,sendmail=true)
	nick=[nick] unless nick.class == Array
	Thread.new{
		nick.each{|n|
			admin.query("insert into messages (sender,recipient,subject,body,state,`date`) values('#{sender || "system"}','#{n}','#{admin.escape_string(subject)}','#{admin.escape_string(body)}','n',now())")
			send_check_messages(n)
		}
	}
	sendmail_to_nick(nick,subject,body) if sendmail
end

#sendmail_to_nick(nick, subject, body) ⇒ Object 



28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
 
# File 'lib/DrbDB/Messaging.rb', line 28

def sendmail_to_nick(nick,subject,body)
	Thread.new{
		nick=[nick] unless nick.class == Array
		sent=0
		@users.each{|uid|
			user=@users.get_user(uid)
			nick.each{|n|
				if n.to_s == user["nick"].to_s && user["email"].to_s.length>3
					begin
						msg="From: manqod@#{Socket.gethostbyname(Socket.gethostname).first}\nTo: #{user['email']}\nContent-Type: text/plain; charset=UTF-8\nSubject: #{subject}\n#{body}"
						Net::SMTP.start('localhost'){ |smtp|
							smtp.send_message(msg, "manqod_server", user["email"])
							einfo("mail to #{user['email']} sent: #{subject}")
						}
						sent+=1
					rescue => err
						eerror("can't send error report via SMTP")
					end
				end
			}
		}
		einfo("sent total #{sent} emails to #{nick.inspect}")
	}
end

#set_message_read(message_id, nick) ⇒ Object 



61
62
63
64
 
# File 'lib/DrbDB/Messaging.rb', line 61

def set_message_read(message_id,nick)
	admin.query("update messages set `state`='c' where id='#{message_id}'")
	send_check_messages(nick)
end

#unread_messages(nick) ⇒ Object 



53
54
55
56
57
58
59
 
# File 'lib/DrbDB/Messaging.rb', line 53

def unread_messages(nick)
	um=0
	if r=admin.qrow("select count(id) as cnt from messages where `state`='n' and recipient='#{nick}'")
		um=r["cnt"]
	end
	um
end