|
40
|
1 local Luan = require "luan:Luan.luan"
|
|
|
2 local error = Luan.error
|
|
|
3 local ipairs = Luan.ipairs or error()
|
|
|
4 local pairs = Luan.pairs or error()
|
|
|
5 local stringify = Luan.stringify or error()
|
|
|
6 local Time = require "luan:Time.luan"
|
|
|
7 local time_now = Time.now or error()
|
|
|
8 local Thread = require "luan:Thread.luan"
|
|
|
9 local Http = require "luan:http/Http.luan"
|
|
|
10 local Chat = require "site:/lib/Chat.luan"
|
|
|
11 local User = require "site:/lib/User.luan"
|
|
|
12 local get_user_by_id = User.get_by_id or error()
|
|
|
13 local Db = require "site:/lib/Db.luan"
|
|
|
14 local run_in_transaction = Db.run_in_transaction or error()
|
|
|
15 local Shared = require "site:/lib/Shared.luan"
|
|
|
16 local send_mail = Shared.send_mail or error()
|
|
|
17 local Utils = require "site:/lib/Utils.luan"
|
|
|
18 local shallow_copy = Utils.shallow_copy or error()
|
|
|
19 local Logging = require "luan:logging/Logging.luan"
|
|
|
20 local logger = Logging.logger "Notify"
|
|
|
21
|
|
|
22
|
|
|
23 local Notify = {}
|
|
|
24
|
|
45
|
25 local base_url = Http.domain and "https://"..Http.domain or "http://localhost:8080"
|
|
40
|
26
|
|
|
27 local wait = Time.period{seconds=10}
|
|
|
28
|
|
|
29 local function set_notified(user,was_notified)
|
|
|
30 run_in_transaction( function()
|
|
|
31 user = user.reload()
|
|
|
32 user.was_notified = was_notified
|
|
|
33 user.save()
|
|
|
34 end )
|
|
|
35 end
|
|
|
36
|
|
|
37 local function init()
|
|
|
38 local users = {}
|
|
|
39 local fns = {}
|
|
|
40
|
|
|
41 function fns.add(user_ids)
|
|
|
42 local now = time_now()
|
|
|
43 for _, user_id in ipairs(user_ids) do
|
|
|
44 local user = get_user_by_id(user_id)
|
|
|
45 if users[user_id] == nil and user.notify_email ~= nil and (user.multi_notify or not user.was_notified) then
|
|
|
46 users[user_id] = now
|
|
41
|
47 -- logger.info("add "..user_id)
|
|
40
|
48 end
|
|
|
49 end
|
|
|
50 end
|
|
|
51
|
|
|
52 function fns.remove(user_id)
|
|
|
53 users[user_id] = nil
|
|
41
|
54 -- logger.info("remove "..user_id)
|
|
40
|
55 end
|
|
|
56
|
|
|
57 function fns.notify()
|
|
41
|
58 -- logger.info("notify")
|
|
40
|
59 local now = time_now()
|
|
|
60 for user_id, when in pairs(shallow_copy(users)) do
|
|
|
61 if now - when > wait then
|
|
|
62 local user = get_user_by_id(user_id)
|
|
87
|
63 local name = user.name
|
|
|
64 local you = name and name..", you" or "You"
|
|
41
|
65 -- logger.info("notify "..user.notify_email.." "..user_id)
|
|
40
|
66 send_mail {
|
|
|
67 To = user.notify_email
|
|
|
68 Subject = "New Messages"
|
|
|
69 body = `%>
|
|
87
|
70 <%=you%> have received new messages.
|
|
40
|
71
|
|
45
|
72 <%= base_url %>/
|
|
|
73
|
|
|
74 To unsubscribe:
|
|
|
75 <%= base_url %>/unsubscribe.html?user=<%=user_id%>&password=<%=user.password%>
|
|
40
|
76 <% `
|
|
|
77 }
|
|
|
78 users[user_id] = nil
|
|
|
79 set_notified(user,true)
|
|
|
80 end
|
|
|
81 end
|
|
|
82 end
|
|
|
83
|
|
|
84 return fns
|
|
|
85 end
|
|
|
86
|
|
|
87 local glob = Thread.global_callable("notify",init)
|
|
|
88
|
|
|
89 function Notify.add(chat)
|
|
|
90 Thread.run(function()
|
|
|
91 glob.add(chat.user_ids)
|
|
|
92 end)
|
|
|
93 end
|
|
|
94
|
|
|
95 function Notify.remove(user)
|
|
|
96 Thread.run(function()
|
|
|
97 glob.remove(user.id)
|
|
|
98 if user.was_notified then
|
|
|
99 set_notified(user,false)
|
|
|
100 end
|
|
|
101 end)
|
|
|
102 end
|
|
|
103
|
|
|
104 Thread.schedule( glob.notify, { repeating_delay=Time.period{seconds=10} } )
|
|
|
105
|
|
|
106 return Notify
|
