wireguard-formula/_states/wireguard.py

__virtualname__ = 'wg'

def __virtual__():
    if 'wg.show' in __salt__:
        return __virtualname__
    return False


def present(name, listen_port=None, fwmark=None, private_key=None,
        preshared_key=None):
    """
    Make sure a wireguard interface exists.
    """

    ret = dict(name=name, changes=dict(), result=False, comment=None)

    interface = __salt__['wg.show'](name)
    if not interface:
        interface = __salt__['wg.create'](name)
        ret['changes'][name] = 'Interface created.'

    show = __salt__['wg.show'](name)

    if int(show.get('listening port', 0)) != int(listen_port):
        __salt__['wg.set'](name, listen_port=listen_port)
        ret['changes']['listening port'] = dict(
                old=show.get('listening port', 0),
                new=listen_port,
        )

    if show.get('fwmark', None) != fwmark:
        __salt__['wg.set'](name, fwmark=fwmark)
        ret['changes']['fwmark'] = dict(
                old=show.get('fwmark', None),
                new=fwmark,
        )

    if show.get('private key') != private_key:
        __salt__['wg.set'](name, private_key=private_key)
        ret['changes']['private key'] = 'private key changed.'

    if show.get('preshared key') != preshared_key:
        __salt__['wg.set'](name, preshared_key=preshared_key)
        ret['changes']['preshared key'] = 'preshared key changed.'

    ret['result'] = True

    return ret


def absent(name):
    """
    Make sure a wireguard interface is absent.
    """

    ret = dict(name=name, changes=dict(), result=False, comment=None)

    interface = __salt__['wg.show'](name)
    if not interface:
        ret['comment'] = 'Interface %s already absent.' % (name,)
        ret['result'] = True
        return ret

    __salt__['wg.delete'](name)
    ret['changes'][name] = dict(old=name, new=None)
    ret['result'] = True
    return ret


def peer_present(name, interface, endpoint=None, persistent_keepalive=None,
                 allowed_ips=None):
    ret = dict(name=name, changes=dict(), result=False, comment=None)

    show = __salt__['wg.show'](interface)
    if not show:
        ret['comment'] = 'Interface %s does not exist.' % (interface)
        return ret

    show = __salt__['wg.show'](name=interface, peer=name)
    if not show:
        __salt__['wg.set'](interface, peer=name, endpoint=endpoint,
                persistent_keepalive=persistent_keepalive,
                allowed_ips=','.join(allowed_ips))
        ret['changes'][name] = 'Peer created.'
        ret['result'] = True
        return ret

    if show.get('endpoint') != endpoint:
        __salt__['wg.set'](interface, peer=name, endpoint=endpoint)
        ret['changes']['endpoint'] = 'Endpoint changed.'

    if show.get('persistent keepalive', None) != persistent_keepalive:
        __salt__['wg.set'](interface, peer=name,
                persistent_keepalive=persistent_keepalive)
        ret['changes']['persistent keepalive'] = 'persistent keepalive changed.'

    ret['result'] = True

    return ret


def peer_absent(name, interface):

    ret = dict(name=name, changes=dict(), result=False, comment=None)

    show = __salt__['wg.show'](interface)
    if not show:
        ret['comment'] = 'Interface %s does not exist.' % (interface)
        return ret

    show = __salt__['wg.show'](name=interface, peer=name)
    if not show:
        ret['comment'] = 'Peer %s already absent.' % (name)
        ret['result'] = True
        return ret

    __salt__['wg.set'](interface, peer=name, remove=True)
    ret['changes'][name] = dict(old=name, new=None)
    ret['result'] = True
    return ret