mod_admin_messageconsole.lua
author Mikael Berthe <mikael@lilotux.net>
Tue, 31 Jul 2012 18:46:54 +0200
branch0.8
changeset 2 e193f80521cc
parent 1 7265595dbc3b
permissions -rw-r--r--
Backport to Prosody 0.8
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
0
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
     1
-- Prosody IM
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
     2
--
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
     3
-- This module depends on Prosody's admin_telnet module
2
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
     4
-- and some code (redirect_output() and onincoming() from console_listener)
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
     5
-- is duplicated here...
0
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
     6
--
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
     7
-- Copyright (C) 2008-2010 Matthew Wild
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
     8
-- Copyright (C) 2008-2010 Waqas Hussain
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
     9
-- Copyright (C) 2012 Mikael Berthe
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
    10
--
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
    11
-- This project is MIT/X11 licensed. Please see the
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
    12
-- COPYING file in the source package for more information.
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
    13
--
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
    14
1
7265595dbc3b Cosmetics
Mikael Berthe <mikael@lilotux.net>
parents: 0
diff changeset
    15
local st = require "util.stanza";
0
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
    16
local um_is_admin = require "core.usermanager".is_admin;
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
    17
2
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
    18
local telnet_def_env;
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
    19
local default_env_mt;
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
    20
local telnet_commands;
0
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
    21
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
    22
local host = module.host;
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
    23
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
    24
-- Create our own session.  print() will store the results in a text
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
    25
-- string.  send(), quit(), disconnect() are no-op.
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
    26
local function new_session ()
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
    27
	local session = {
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
    28
			send	    = function ()  end;
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
    29
			quit	    = function ()  end;
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
    30
			disconnect  = function ()  end;
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
    31
			};
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
    32
2
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
    33
	-- Initialization
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
    34
	-- Hack for 0.8 - Let's get dependencies now as we're almost
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
    35
	-- certain the admin_telnet module has been loaded by now.
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
    36
	if not telnet_def_env then
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
    37
		local prosody = _G.prosody;
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
    38
		local console = prosody.console;
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
    39
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
    40
		telnet_def_env = console.env;
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
    41
		default_env_mt = { __index = telnet_def_env };
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
    42
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
    43
		telnet_commands = console.commands;
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
    44
	end
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
    45
0
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
    46
	session.print = function (...)
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
    47
		local t = {};
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
    48
		for i=1,select("#", ...) do
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
    49
			t[i] = tostring(select(i, ...));
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
    50
		end
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
    51
		local text = "| "..table.concat(t, "\t");
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
    52
		if session.fulltext then
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
    53
		    session.fulltext = session.fulltext .. "\n" .. text;
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
    54
		else
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
    55
		    session.fulltext = text;
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
    56
		end
1
7265595dbc3b Cosmetics
Mikael Berthe <mikael@lilotux.net>
parents: 0
diff changeset
    57
	end
0
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
    58
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
    59
	session.env = setmetatable({}, default_env_mt);
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
    60
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
    61
	-- Load up environment with helper objects
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
    62
	for name, t in pairs(telnet_def_env) do
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
    63
		if type(t) == "table" then
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
    64
			session.env[name] = setmetatable({ session = session },
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
    65
							 { __index = t });
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
    66
		end
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
    67
	end
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
    68
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
    69
	return session;
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
    70
end
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
    71
2
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
    72
-- This function is 100% duplicated from mod_admin_telnet.
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
    73
function onincoming(session, data)
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
    74
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
    75
	local commands = telnet_commands;
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
    76
	local partial = session.partial_data;
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
    77
	if partial then
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
    78
		data = partial..data;
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
    79
	end
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
    80
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
    81
	local function redirect_output(_G, session)
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
    82
		local env = setmetatable({ print = session.print },
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
    83
			     { __index = function (t, k) return rawget(_G, k); end });
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
    84
		env.dofile = function(name)
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
    85
			local f, err = loadfile(name);
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
    86
			if not f then return f, err; end
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
    87
			return setfenv(f, env)();
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
    88
		end;
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
    89
		return env;
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
    90
	end
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
    91
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
    92
	for line in data:gmatch("[^\n]*[\n\004]") do
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
    93
		-- Handle data (loop allows us to break to add \0 after response)
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
    94
		repeat
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
    95
			local useglobalenv;
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
    96
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
    97
			if line:match("^>") then
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
    98
				line = line:gsub("^>", "");
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
    99
				useglobalenv = true;
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   100
			elseif line == "\004" then
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   101
				commands["bye"](session, line);
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   102
				break;
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   103
			else
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   104
				local command = line:lower();
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   105
				command = line:match("^%w+") or line:match("%p");
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   106
				if commands[command] then
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   107
					commands[command](session, line);
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   108
					break;
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   109
				end
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   110
			end
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   111
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   112
			session.env._ = line;
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   113
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   114
			local chunkname = "=console";
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   115
			local chunk, err = loadstring("return "..line, chunkname);
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   116
			if not chunk then
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   117
				chunk, err = loadstring(line, chunkname);
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   118
				if not chunk then
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   119
					err = err:gsub("^%[string .-%]:%d+: ", "");
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   120
					err = err:gsub("^:%d+: ", "");
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   121
					err = err:gsub("'<eof>'", "the end of the line");
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   122
					session.print("Sorry, I couldn't understand that... "..err);
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   123
					break;
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   124
				end
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   125
			end
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   126
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   127
			setfenv(chunk, (useglobalenv and redirect_output(_G, session)) or session.env or nil);
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   128
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   129
			local ranok, taskok, message = pcall(chunk);
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   130
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   131
			if not (ranok or message or useglobalenv) and commands[line:lower()] then
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   132
				commands[line:lower()](session, line);
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   133
				break;
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   134
			end
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   135
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   136
			if not ranok then
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   137
				session.print("Fatal error while running command, it did not complete");
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   138
				session.print("Error: "..taskok);
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   139
				break;
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   140
			end
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   141
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   142
			if not message then
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   143
				session.print("Result: "..tostring(taskok));
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   144
				break;
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   145
			elseif (not taskok) and message then
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   146
				session.print("Command completed with a problem");
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   147
				session.print("Message: "..tostring(message));
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   148
				break;
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   149
			end
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   150
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   151
			session.print("OK: "..tostring(message));
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   152
		until true
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   153
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   154
		session.send(string.char(0));
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   155
	end
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   156
	session.partial_data = data:match("[^\n]+$");
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   157
end
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   158
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   159
function on_message(event)
0
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   160
	-- Check the type of the incoming stanza to avoid loops:
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   161
	if event.stanza.attr.type == "error" then
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   162
		return; -- We do not want to reply to these, so leave.
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   163
	end
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   164
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   165
	local userjid = event.stanza.attr.from;
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   166
	local bodytag = event.stanza:get_child("body");
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   167
	local body = bodytag and bodytag:get_text() or "";
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   168
	if not body or body == "" then
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   169
		-- We do not reply to empty messages (chatstates, etc.)
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   170
		return true;
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   171
	end
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   172
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   173
	-- Check the requester is an admin user
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   174
	if not um_is_admin(userjid, module.host) then
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   175
		module:log("info", "Ignored request from non-admin: %s",
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   176
			   userjid);
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   177
		return;
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   178
	end
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   179
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   180
	-- Create a session in order to use an admin_telnet-like environment
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   181
	local session = new_session();
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   182
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   183
	-- Process the message using admin_telnet's onincoming function
2
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   184
	onincoming(session, body.."\n");
0
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   185
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   186
	-- Strip trailing blank line
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   187
	session.fulltext = tostring(session.fulltext):gsub("\n\|%s*$", "")
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   188
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   189
	-- Send the reply stanza
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   190
	local reply_stanza = st.message({ from = host, to = userjid,
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   191
					type = "chat" });
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   192
	reply_stanza = reply_stanza:body(session.fulltext);
2
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   193
	core_post_stanza(hosts[module.host], reply_stanza);
0
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   194
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   195
	return true;
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   196
end
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   197
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   198
local function on_presence(event)
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   199
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   200
	local send_presence = false;
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   201
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   202
	local userjid = event.stanza.attr.from;
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   203
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   204
	-- Check the requester is an admin user
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   205
	if not um_is_admin(userjid, module.host) then
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   206
		module:log("info", "Ignored presence from non-admin: %s",
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   207
			   userjid);
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   208
		return;
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   209
	end
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   210
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   211
	if (event.stanza.attr.type == "subscribe") then
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   212
		module:log("info", "Subscription request from %s", userjid);
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   213
		send_presence = true;
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   214
		-- Send a subscription ack
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   215
		local presence_stanza = st.presence({ from = host,
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   216
					to = userjid, type = "subscribed",
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   217
					id = event.stanza.attr.id });
2
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   218
		core_post_stanza(hosts[module.host], presence_stanza);
0
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   219
	elseif (event.stanza.attr.type == "probe") then
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   220
		send_presence = true;
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   221
	elseif (event.stanza.attr.type == "unsubscribe") then
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   222
		-- For information only...
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   223
		module:log("info", "Unsubscription request from %s", userjid);
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   224
	end
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   225
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   226
	if (send_presence == true) then
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   227
		-- Send a presence stanza
2
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   228
		local presence_stanza = st.presence({ from = host,
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   229
						      to = userjid });
e193f80521cc Backport to Prosody 0.8
Mikael Berthe <mikael@lilotux.net>
parents: 1
diff changeset
   230
		core_post_stanza(hosts[module.host], presence_stanza);
0
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   231
	end
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   232
	return true;
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   233
end
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   234
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   235
module:hook("message/bare", on_message);
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   236
module:hook("presence/bare", on_presence);
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   237
dc4eb8fe8b94 mod_admin_messageconsole.lua, initial version
Mikael Berthe <mikael@lilotux.net>
parents:
diff changeset
   238
-- vim:set noet sts=8 sw=8: