1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
|
-- Prosody IM
-- Copyright (C) 2008-2010 Matthew Wild
-- Copyright (C) 2008-2010 Waqas Hussain
--
-- This project is MIT/X11 licensed. Please see the
-- COPYING file in the source package for more information.
--
local usermanager = require "prosody.core.usermanager";
local id = require "prosody.util.id";
local jid = require "prosody.util.jid";
local st = require "prosody.util.stanza";
local hosts = prosody.hosts;
function send_to_online(message, host)
host = host or module.host;
local sessions;
if host then
sessions = { [host] = hosts[host] };
else
sessions = hosts;
end
local c = 0;
for hostname, host_session in pairs(sessions) do
if host_session.sessions then
message.attr.from = hostname;
for username in pairs(host_session.sessions) do
c = c + 1;
message.attr.to = username.."@"..hostname;
module:send(message);
end
end
end
return c;
end
function send_to_all(message, host)
host = host or module.host;
local c = 0;
for username in usermanager.users(host) do
message.attr.to = username.."@"..host;
module:send(st.clone(message));
c = c + 1;
end
return c;
end
function send_to_role(message, role, host)
host = host or module.host;
local c = 0;
for _, recipient_jid in ipairs(usermanager.get_jids_with_role(role, host)) do
message.attr.to = recipient_jid;
module:send(st.clone(message));
c = c + 1;
end
return c;
end
module:default_permission("prosody:admin", ":send-announcement");
-- Old <message>-based jabberd-style announcement sending
function handle_announcement(event)
local stanza = event.stanza;
-- luacheck: ignore 211/node
local node, host, resource = jid.split(stanza.attr.to);
if resource ~= "announce/online" then
return; -- Not an announcement
end
if not module:may(":send-announcement", event) then
-- Not allowed!
module:log("warn", "Non-admin '%s' tried to send server announcement", stanza.attr.from);
return;
end
module:log("info", "Sending server announcement to all online users");
local message = st.clone(stanza);
message.attr.type = "headline";
message.attr.from = host;
local c = send_to_online(message, host);
module:log("info", "Announcement sent to %d online users", c);
return true;
end
module:hook("message/host", handle_announcement);
-- Ad-hoc command (XEP-0133)
local dataforms_new = require "prosody.util.dataforms".new;
local announce_layout = dataforms_new{
title = "Making an Announcement";
instructions = "Fill out this form to make an announcement to all\nactive users of this service.";
{ name = "FORM_TYPE", type = "hidden", value = "http://jabber.org/protocol/admin" };
{ name = "subject", type = "text-single", label = "Subject" };
{ name = "announcement", type = "text-multi", required = true, label = "Announcement" };
};
function announce_handler(_, data, state)
if state then
if data.action == "cancel" then
return { status = "canceled" };
end
local fields = announce_layout:data(data.form);
module:log("info", "Sending server announcement to all online users");
local message = st.message({type = "headline"}, fields.announcement):up();
if fields.subject and fields.subject ~= "" then
message:text_tag("subject", fields.subject);
end
local count = send_to_online(message, data.to);
module:log("info", "Announcement sent to %d online users", count);
return { status = "completed", info = ("Announcement sent to %d online users"):format(count) };
else
return { status = "executing", actions = {"next", "complete", default = "complete"}, form = announce_layout }, "executing";
end
end
module:depends "adhoc";
local adhoc_new = module:require "adhoc".new;
local announce_desc = adhoc_new("Send Announcement to Online Users", "http://jabber.org/protocol/admin#announce", announce_handler, "admin");
module:provides("adhoc", announce_desc);
module:add_item("shell-command", {
section = "announce";
section_desc = "Broadcast announcements to users";
name = "all";
desc = "Send announcement to all users on the host";
args = {
{ name = "host", type = "string" };
{ name = "text", type = "string" };
};
host_selector = "host";
handler = function(self, host, text) --luacheck: ignore 212/self
local msg = st.message({ from = host, id = id.short() })
:text_tag("body", text);
local count = send_to_all(msg, host);
return true, ("Announcement sent to %d users"):format(count);
end;
});
module:add_item("shell-command", {
section = "announce";
section_desc = "Broadcast announcements to users";
name = "online";
desc = "Send announcement to all online users on the host";
args = {
{ name = "host", type = "string" };
{ name = "text", type = "string" };
};
host_selector = "host";
handler = function(self, host, text) --luacheck: ignore 212/self
local msg = st.message({ from = host, id = id.short(), type = "headline" })
:text_tag("body", text);
local count = send_to_online(msg, host);
return true, ("Announcement sent to %d users"):format(count);
end;
});
module:add_item("shell-command", {
section = "announce";
section_desc = "Broadcast announcements to users";
name = "role";
desc = "Send announcement to users with a specific role on the host";
args = {
{ name = "host", type = "string" };
{ name = "role", type = "string" };
{ name = "text", type = "string" };
};
host_selector = "host";
handler = function(self, host, role, text) --luacheck: ignore 212/self
local msg = st.message({ from = host, id = id.short() })
:text_tag("body", text);
local count = send_to_role(msg, role, host);
return true, ("Announcement sent to %d users"):format(count);
end;
});
|
