#!/usr/bin/python
# -*- coding: utf-8 -*-
from __future__ import print_function
 
import os
import pwd
import sys
import optparse
import requests
 
from getpass import getpass
 
from centos import CentOSUserCert
from centos import defaults
 
try:
    import urlparse
except ImportError:
    import urllib.parse as urlparse
 
 
def download_cert(username, password, topurl=None):
    if not topurl:
        topurl = defaults.FAS_TOPURL
 
    splittopurl = urlparse.urlsplit(topurl)
 
    usercertpath = os.path.join(splittopurl.path, 'user/dogencert')
    params = {'user_name': username, 'password': password, 'login': 'Login'}
 
    userspliturl = urlparse.SplitResult(splittopurl.scheme,
                                        splittopurl.netloc,
                                        usercertpath,
                                        None,
                                        None)
 
    servercapath = os.path.join(splittopurl.path, 'ca/ca-cert.pem')
    servercaspliturl = urlparse.SplitResult(splittopurl.scheme,
                                            splittopurl.netloc,
                                            servercapath,
                                            None,
                                            None)
 
    userurl = urlparse.urlunsplit(userspliturl)
    servercaurl = urlparse.urlunsplit(servercaspliturl)
 
    certfile = os.path.expanduser(defaults.USER_CERT_FILE)
    if os.path.exists(certfile):
        # Delete file in case we are changing its mode
        os.unlink(certfile)
    flags = os.O_WRONLY | os.O_CREAT
    mode = 0o600
    with os.fdopen(os.open(certfile, flags, mode), 'w') as usercertfile:
        r = requests.post(userurl, params=params)
        try:
            r.raise_for_status()
        except requests.exceptions.HTTPError as e:
            print("""Could not generate certificate!
Response Code: {0}
Message: {1}""".format(e.response.status_code, e.response.reason).strip())
            sys.exit(1)
 
        response = r.text
        usercertfile.write(response)
 
    with open(os.path.expanduser(defaults.SERVER_CA_CERT_FILE), 'w') as servercacertfile:
        r = requests.get(servercaurl)
        try:
            r.raise_for_status()
        except requests.exceptions.HTTPError as e:
            print("""Could not download CA Certificate!
Response Code: {0}
Message: {1}""".format(e.response.status_code, e.response.reason).strip())
            sys.exit(1)
 
        response = r.text
        servercacertfile.write(response)
 
    # for now upload-ca.cert is the same as the server-ca cert. let's link them here
    if os.path.exists(os.path.expanduser(defaults.UPLOAD_CA_CERT_FILE)):
        os.unlink(os.path.expanduser(defaults.UPLOAD_CA_CERT_FILE))
 
    os.symlink(os.path.expanduser(defaults.SERVER_CA_CERT_FILE),
               os.path.expanduser(defaults.UPLOAD_CA_CERT_FILE))
 
 
def main(opts):
 
    if not opts.certfile:
        certfile = defaults.USER_CERT_FILE
    else:
        certfile = opts.certfile
 
    if opts.username and not opts.verifycert:
        username = opts.username
    else:
        try:
            cert = CentOSUserCert(certfile)
            username = cert.CN
        except IOError as e:
            if opts.verifycert:
                print("{0}: {1}".format(os.path.expanduser(certfile), e.strerror))
                exit(1)
            username = pwd.getpwuid(os.geteuid())[0]
 
    if opts.verifycert:
        if not cert.valid:
            print("Your certificate is not valid")
            sys.exit(1)
        else:
            print("Your certificate is valid")
            sys.exit(0)
 
    if opts.newcert:
        password = getpass('ACO Password: ')
        download_cert(username, password)
 
 
if __name__ == '__main__':
    parser = optparse.OptionParser(usage="%prog [OPTIONS] ")
    parser.add_option('-u', '--username', action='store', dest='username',
                      default=False, help="ACO Username.")
    parser.add_option('-n', '--new-cert', action='store_true', dest='newcert',
                      default=False, help="Generate a new User Certificate.")
    parser.add_option('-f', '--file', action='store', dest='certfile',
                      default=None, help="User Certificate.")
    parser.add_option('-v', '--verify-cert', action='store_true', dest='verifycert',
                      default=False, help="Verify Certificate.")
    opts, args = parser.parse_args()
 
    if not opts.newcert and not opts.verifycert:
        print("Must specify one of arguments: -v or -n")
        parser.print_help()
        sys.exit(1)
 
    main(opts)