|
|
| System | : | Linux MiraNet 3.0.0-14-generic-pae #23-Ubuntu SMP Mon Nov 21 22:07:10 UTC 2011 i686 |
|---|
| Software | : | Apache. PHP/5.3.6-13ubuntu3.10 |
|---|
| ID | : | uid=65534(nobody) gid=65534(nogroup) groups=65534(nogroup)
|
|---|
|
| Safe Mode | : | OFF |
|---|
| Open_Basedir | : | OFF |
|---|
| Freespace | : | 23.08 GB of 70.42 GB (32.77%) |
|---|
|
|
MySQL: ON MSSQL: OFF Oracle: OFF PostgreSQL: OFF Curl: OFF Sockets: ON Fetch: OFF Wget: ON Perl: ON |
|
Disabled Functions: pcntl_alarm,pcntl_fork,pcntl_waitpid,pcntl_wait,pcntl_wifexited,pcntl_wifstopped,pcntl_wifsignaled,pcntl_wexitstatus,pcntl_wtermsig,pcntl_wstopsig,pcntl_signal,pcntl_signal_dispatch,pcntl_get_last_error,pcntl_strerror,pcntl_sigprocmask,pcntl_sigwaitinfo,pcntl_sigtimedwait,pcntl_exec,pcntl_getpriority,pcntl_setpriority,
|
[ System Info ]
[ Processes ]
[ SQL Manager ]
[ Eval ]
[ Encoder ]
[ Mailer ]
[ Back Connection ]
[ Backdoor Server ]
[ Kernel Exploit Search ]
[ MD5 Decrypter ]
[ Reverse IP ]
[ Kill Shell ]
[ FTP Brute-Force ]
|
|
/
usr/
lib/
python2.7/
dist-packages/
landscape/
- drwxr-xr-x
|
Viewing file:  textmessage.py (2.87 KB) -rw-r--r--Select action/file-type:  ( +) |  ( +) |  ( +) | Code ( +) | Session ( +) |  ( +) | SDB ( +) |  ( +) |  ( +) |  ( +) |  ( +) |  ( +) |
"""
Support code for the C{landscape-message} utility, which sends a text
message to the Landscape web UI via the landscape-client's dbus
messaging service (see L{landscape.plugins.dbus_message}).
"""
import sys
from landscape.lib.log import log_failure
from landscape.reactor import TwistedReactor
from landscape.broker.amp import RemoteBrokerConnector
from landscape.deployment import Configuration
class AcceptedTypeError(Exception):
"""
Raised when a message is sent without 'text-message' being an
accepted type.
"""
class EmptyMessageError(Exception):
"""Raised when an empty message is provied."""
def send_message(text, broker):
"""Add a message to the queue via a remote broker.
The message is of type C{text-message}.
@param broker: A connected L{RemoteBroker} object to use to send
the message.
@return: A L{Deferred} which will fire with the result of the send.
"""
message = {"type": "text-message", "message": text}
response = broker.send_message(message, True)
return response
def got_result(result):
print u"Message sent."
def get_message(args):
encoding = sys.stdin.encoding or "UTF-8"
if len(args) < 2:
print ("Please enter your message, and send EOF (Control + D after "
"newline) when done.")
message = sys.stdin.read().decode(encoding)
else:
message = u" ".join([x.decode(encoding) for x in args[1:]])
if not message:
raise EmptyMessageError("Text messages may not be empty.")
return message
def got_accepted_types(accepted_types, broker, args):
if not "text-message" in accepted_types:
raise AcceptedTypeError("Text messages may not be created. Is "
"Landscape Client registered with the server?")
message = get_message(args)
d = send_message(message, broker)
d.addCallback(got_result)
return d
def run(args=sys.argv):
"""Send a message to Landscape.
This function runs a Twisted reactor, prints various status
messages, and exits the process.
"""
reactor = TwistedReactor()
config = Configuration()
config.load(args)
def got_connection(broker):
result = broker.get_accepted_message_types()
return result.addCallback(got_accepted_types, broker, args)
def got_error(failure):
log_failure(failure)
connector = RemoteBrokerConnector(reactor, config)
result = connector.connect()
result.addCallback(got_connection)
result.addErrback(got_error)
result.addBoth(lambda x: connector.disconnect())
# For some obscure reason our TwistedReactor.stop method calls
# reactor.crash() instead of reactor.stop(), which doesn't work
# here. Maybe TwistedReactor.stop should simply use reactor.stop().
result.addBoth(lambda ignored: reactor.call_later(
0, reactor._reactor.stop))
reactor.run()
return result
|
