Revision 54ae949d snf-app/synnefo/logic/callbacks.py
b/snf-app/synnefo/logic/callbacks.py | ||
---|---|---|
109 | 109 |
log.exception("Unexpected error, msg: %s", msg) |
110 | 110 |
|
111 | 111 |
|
112 |
def send_email(message): |
|
113 |
"""Process an email submission request""" |
|
114 |
msg = None |
|
115 |
try: |
|
116 |
msg = json.loads(message.body) |
|
117 |
|
|
118 |
sent = email_send.send(sender=msg['frm'], recipient = msg['to'], |
|
119 |
body=msg['body'], subject=msg['subject']) |
|
120 |
|
|
121 |
if not sent: |
|
122 |
log.warn("Failed to send email to %s", msg['to']) |
|
123 |
else: |
|
124 |
message.channel.basic_ack(message.delivery_tag) |
|
125 |
except KeyError: |
|
126 |
log.error("Malformed incoming JSON, missing attributes: %s", |
|
127 |
message.body) |
|
128 |
except socket.error as e: |
|
129 |
log.error("Cannot connect to SMTP server:%s\n", e) |
|
130 |
except Exception as e: |
|
131 |
log.exception("Unexpected error, msg: %s", msg) |
|
132 |
raise |
|
133 |
|
|
134 |
|
|
135 |
def update_credits(message): |
|
136 |
log.debug("Request to update credits") |
|
137 |
message.channel.basic_ack(message.delivery_tag) |
|
138 |
|
|
139 |
|
|
140 | 112 |
def update_build_progress(message): |
141 | 113 |
"""Process a create progress message""" |
142 | 114 |
log.debug("Processing ganeti-create-progress msg: %s", message.body) |
Also available in: Unified diff