import os
import logging

TWITTER_KEYS = '~/.ssh/twitter'
EMAIL_SERVER = 'localhost'
EMAIL_SENDER = 'bumps@reflectometry.org'

def notify(user, msg, body="No body", level=1):
    """
    Send a notfication message to the user regarding the job status.
    """

    if not user:
        pass
    elif user.startswith('@'):
        tweet(user, msg)
    elif '@' in user:
        email(EMAIL_SENDER, [user], body, subject=msg, server=EMAIL_SERVER)
    else:
        logging.debug("%s : %s"%(user, msg))

twitter = None
def tweet(user, msg):
    global twitter
    if twitter is None: twitter = open_twitter(TWITTER_KEYS)
    twitter.direct_messages.new(user=user, text=msg)

def open_twitter(authfile):
    from twitter import Twitter, OAuth #@UnresolvedImport twitter is optional
    # Load credentials from authfile
    for line in open(os.path.expanduser(authfile)).readlines():
        exec(line)
    auth = OAuth(access_token, access_secret, consumer_key, consumer_secret) #@UndefinedVariable comes from authfile
    return Twitter(auth=auth)


def email(sender, receivers, message, subject='no subject', server='localhost'):
    """
    Send an email message to a group of receivers
    """
    import smtplib

    if ':' in server:
        host,port = server.split(':')
        port = int(port)
    else:
        host,port = server,25
    header="From: %s\r\nTo: %s\r\nSubject: %s\r\n\r\n"
    header %= sender,", ".join(receivers),subject
    #print "Sending the following mail message:\n"+header+message
    #print "Trying to connect to",host,port
    smtp = smtplib.SMTP(host,port)
    #print "Connection established"
    smtp.sendmail(sender,receivers,header+message)
    #print "Mail sent from",sender,"to",", ".join(receivers)
    smtp.quit()


if __name__ == "__main__":
    msg = 'test notification'
    body = 'See http://reflectometry.org for details.'
    #notify('@pkienzle', msg, body)
    notify('paknist@gmail.com', msg, body)