| 1 | #!/usr/bin/python |
|---|
| 2 | """ |
|---|
| 3 | |
|---|
| 4 | VM names on stdin. |
|---|
| 5 | """ |
|---|
| 6 | |
|---|
| 7 | import smtplib |
|---|
| 8 | import optparse |
|---|
| 9 | import sys |
|---|
| 10 | from email.mime.text import MIMEText |
|---|
| 11 | |
|---|
| 12 | from invirt import database |
|---|
| 13 | |
|---|
| 14 | def send_mail(smtp, opts, message, vm): |
|---|
| 15 | contact = database.Machine.query.filter_by(name=vm).first().contact |
|---|
| 16 | if '@' not in contact: |
|---|
| 17 | contact += '@mit.edu' |
|---|
| 18 | msg = MIMEText(message % vm) |
|---|
| 19 | msg['To'] = contact |
|---|
| 20 | msg['CC'] = 'XVM <xvm@mit.edu>' |
|---|
| 21 | msg['Reply-To'] = 'XVM <xvm@mit.edu>' |
|---|
| 22 | msg['From'] = opts.from_addr |
|---|
| 23 | msg['Subject'] = opts.subject % vm |
|---|
| 24 | smtp.sendmail(opts.from_addr, |
|---|
| 25 | [contact, 'xvm@mit.edu'], |
|---|
| 26 | msg.as_string()) |
|---|
| 27 | |
|---|
| 28 | def main(argv): |
|---|
| 29 | parser = optparse.OptionParser( |
|---|
| 30 | usage = '%prog {-m message, -f from} [options] <vm-list', |
|---|
| 31 | description = __doc__.strip()) |
|---|
| 32 | parser.add_option('-m', '--message', |
|---|
| 33 | type = 'string', |
|---|
| 34 | dest = 'message', |
|---|
| 35 | help = 'filename with body of message') |
|---|
| 36 | parser.add_option('-s', '--subject', |
|---|
| 37 | type = 'string', |
|---|
| 38 | dest = 'subject', |
|---|
| 39 | default = '[xvm] Unexpected reboot of your VM %s', |
|---|
| 40 | help = 'subject line of message; %s for VM name') |
|---|
| 41 | parser.add_option('-f', '--from', |
|---|
| 42 | type = 'string', |
|---|
| 43 | dest = 'from_addr', |
|---|
| 44 | help = 'for From: and envelope-from; first word is %(sig)s') |
|---|
| 45 | parser.add_option('--host', |
|---|
| 46 | type = 'string', |
|---|
| 47 | dest = 'host', |
|---|
| 48 | help = 'host that failed; %(host)s in message') |
|---|
| 49 | parser.add_option('--time', |
|---|
| 50 | type = 'string', |
|---|
| 51 | dest = 'time', |
|---|
| 52 | help = 'time of failure; %(time)s in message') |
|---|
| 53 | opts, args = parser.parse_args() |
|---|
| 54 | |
|---|
| 55 | if len(args) or not opts.message or not opts.from_addr: |
|---|
| 56 | parser.print_help(sys.stderr) |
|---|
| 57 | return 2 |
|---|
| 58 | |
|---|
| 59 | opts.sig = opts.from_addr.split()[0] |
|---|
| 60 | message = file(opts.message).read() % opts.__dict__ |
|---|
| 61 | |
|---|
| 62 | vms = sys.stdin.read().split() |
|---|
| 63 | |
|---|
| 64 | database.connect() |
|---|
| 65 | s = smtplib.SMTP() |
|---|
| 66 | s.connect() |
|---|
| 67 | |
|---|
| 68 | for vm in vms: |
|---|
| 69 | send_mail(s, opts, message, vm) |
|---|
| 70 | |
|---|
| 71 | s.close() |
|---|
| 72 | |
|---|
| 73 | if __name__ == '__main__': |
|---|
| 74 | sys.exit(main(sys.argv)) |
|---|