Synnefo

def send_email(message):

    """Process an email submission request"""

    msg = None

    try:

        msg = json.loads(message.body)

        sent = email_send.send(sender=msg['frm'], recipient = msg['to'],

                        body=msg['body'], subject=msg['subject'])

        if not sent:

            log.warn("Failed to send email to %s", msg['to'])

        else:

            message.channel.basic_ack(message.delivery_tag)

    except KeyError:

        log.error("Malformed incoming JSON, missing attributes: %s",

                      message.body)

    except socket.error as e:

        log.error("Cannot connect to SMTP server:%s\n", e)

    except Exception as e:

        log.exception("Unexpected error, msg: %s", msg)

        raise

def update_credits(message):

    log.debug("Request to update credits")

    message.channel.basic_ack(message.delivery_tag)