'''
Manage client ssh components
'''

import os


def _refine_enc(enc):
    '''
    Return the properly formatted ssh value for the authorized encryption key
    type. If the type is not found, return ssh-rsa, the ssh default.
    '''
    rsa = ['r', 'rsa', 'ssh-rsa']
    dss = ['d', 'dsa', 'dss', 'ssh-dss']
    if enc in rsa:
        return 'ssh-rsa'
    elif enc in dss:
        return 'ssh-dss'
    else:
        return 'ssh-rsa'


def _format_auth_line(
        key,
        enc,
        comment,
        options):
    '''
    Properly format user input.
    '''
    line = ''
    if options:
        line += '{0} '.format(','.join(options))
    line += '{0} {1} {2}'.format(enc, key, comment)
    return line


def _replace_auth_key(
        user,
        key,
        enc='ssh-rsa',
        comment='',
        options=[],
        config='.ssh/authorized_keys'):
    '''
    Replace an existing key
    '''
    auth_line = _format_auth_line(
                key,
                enc,
                comment,
                options)
    lines = []
    uinfo = __salt__['user.info'](user)
    full = os.path.join(uinfo['home'], config)
    for line in open(full, 'r').readlines():
        if line.startswith('#'):
            # Commented Line
            lines.append(line)
            continue
        comps = line.split()
        if len(comps) < 2:
            # Not a valid line
            lines.append(line)
            continue
        key_ind = 1
        if not comps[0].startswith('ssh-'):
            key_ind = 2
        if comps[key_ind] == key:
            lines.append(auth_line)
        else:
            lines.append(line)
    open(full, 'w+').writelines(lines)


def host_keys(keydir=None):
    '''
    Return the minion's host keys

    CLI Example::

        salt '*' ssh.host_keys
    '''
    # Set up the default keydir - needs to support sshd_config parsing in the
    # future
    if not keydir:
        if __grains__['kernel'] == 'Linux':
            keydir = '/etc/ssh'
    keys = {}
    for fn_ in os.listdir(keydir):
        if fn_.startswith('ssh_host_'):
            top = fn_.split('.')
            comps = fn_.split('_')
            kname = comps[2]
            if len(top) > 1:
                kname += '.{0}'.format(top[1])
            try:
                keys[kname] = open(os.path.join(keydir, fn_), 'r').read()
            except:
                keys[kname] = ''
    return keys


def auth_keys(user, config='.ssh/authorized_keys'):
    '''
    Return the authorized keys for the specified user

    CLI Example::

        salt '*' ssh.auth_keys root
    '''
    ret = {}
    uinfo = __salt__['user.info'](user)
    full = os.path.join(uinfo['home'], config)
    if not os.path.isfile(full):
        return {}
    for line in open(full, 'r').readlines():
        if line.startswith('#'):
            # Commented Line
            continue
        comps = line.split()
        if len(comps) < 2:
            # Not a valid line
            continue
        if not comps[0].startswith('ssh-'):
            # It has options, grab them
            options = comps[0].split(',')
        else:
            options = []
        if not options:
            enc = comps[0]
            key = comps[1]
            comment = ' '.join(comps[2:])
        else:
            enc = comps[1]
            key = comps[2]
            comment = ' '.join(comps[3:])
        ret[key] = {'enc': enc,
                    'comment': comment,
                    'options': options}

    return ret


def rm_auth_key(user, key, config='.ssh/authorized_keys'):
    '''
    Remove an authorized key from the specified user's authorized key file

    CLI Example::

        salt '*' ssh.rm_auth_key <user> <key>
    '''
    current = auth_keys(user, config)
    if key in current:
        # Remove the key
        uinfo = __salt__['user.info'](user)
        full = os.path.join(uinfo['home'], config)
        if not os.path.isfile(full):
            return 'User authorized keys file not present'
        lines = []
        for line in open(full, 'r').readlines():
            if line.startswith('#'):
                # Commented Line
                lines.append(line)
                continue
            comps = line.split()
            if len(comps) < 2:
                # Not a valid line
                lines.append(line)
                continue
            if not comps[0].startswith('ssh-'):
                # It has options, grab them
                options = comps[0].split(',')
            else:
                options = []
            if not options:
                pkey = comps[1]
            else:
                pkey = comps[2]
            if pkey == key:
                continue
            else:
                lines.append(line)
        open(full, 'w+').writelines(lines)
        return 'Key removed'
    return 'Key not present'


def set_auth_key(
        user,
        key,
        enc='ssh-rsa',
        comment='',
        options=[],
        config='.ssh/authorized_keys'):
    '''
    Add a key to the authorized_keys file

    CLI Example::

        salt '*' ssh.set_auth_key <user> <key> dsa '[]' .ssh/authorized_keys
    '''
    enc = _refine_enc(enc)
    replace = False
    uinfo = __salt__['user.info'](user)
    current = auth_keys(user, config)
    if key in current:
        if not set(current[key]['options']) == set(options):
            replace = True
        if not current[key]['enc'] == enc:
            replace = True
        if not current[key]['comment'] == comment:
            if comment:
                replace = True
        if replace:
            _replace_auth_key(
                    user,
                    key,
                    enc,
                    comment,
                    options,
                    config)
            return 'replace'
        else:
            return 'no change'
    else:
        auth_line = _format_auth_line(
                    key,
                    enc,
                    comment,
                    options)
        fconfig = os.path.join(uinfo['home'], config)
        if not os.path.isdir(os.path.dirname(fconfig)):
            dpath = os.path.dirname(fconfig)
            os.makedirs(dpath)
            os.chown(dpath, uinfo['uid'], uinfo['gid'])
            os.chmod(dpath, 448)
            
        if not os.path.isfile(fconfig):
            open(fconfig, 'a+').write('\n{0}'.format(auth_line))
            os.chown(fconfig, uinfo['uid'], uinfo['gid'])
        else:
            open(fconfig, 'a+').write('\n{0}'.format(auth_line))
        return 'new'

@@ -6464,32 +6464,67 @@
 , uinfo%5B'gid'%5D)%0A
+            os.chmod(fconfig, 384)%0A
         else:%0A  

set authorized_keys file to 0600 when it is made with Salt