/usr/lib/python2.7/dist-packages/landscape/textmessage.py is in landscape-common 14.01-0ubuntu3.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
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 | """
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 LandscapeReactor
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.
"""
def got_session_id(session_id):
response = broker.send_message(message, session_id, True)
return response
message = {"type": "text-message", "message": text}
result = broker.get_session_id()
result.addCallback(got_session_id)
return result
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 = LandscapeReactor()
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 LandscapeReactor.stop method calls
# reactor.crash() instead of reactor.stop(), which doesn't work
# here. Maybe LandscapeReactor.stop should simply use reactor.stop().
result.addBoth(lambda ignored: reactor.call_later(
0, reactor._reactor.stop))
reactor.run()
return result
|