Source code for pygobbler.upload_directory

import os
from . import allocate_upload_directory
from . import _utils as ut




def upload_directory(project: str, asset: str, version: str, directory: str, staging: str, url: str, probation: bool = False):
    """
    Upload a directory as a new versioned asset of a project in the registry.

    Args:
        project:
            The name of an existing project.

        asset:
            The name of a new or existing asset in ``project``.

        version:
            The name of a new version of ``asset``.

        directory:
            Path to a directory to be uploaded. For best performace, this
            should be a subdirectory of ``staging``, e.g., as created by
            :py:func:`~.allocate_upload_directory`.

        staging:
            Path to the staging directory.

        url:
            URL for the Gobbler REST API.

        probation:
            Whether to upload a probational version.
    """
    directory = os.path.normpath(directory)
    staging = os.path.normpath(staging)

    if os.path.dirname(directory) != staging:
        newdir = allocate_upload_directory(staging) 

        for root, dirs, files in os.walk(directory):
            for f in files:
                src = os.path.join(root, f)
                rel = os.path.relpath(src, directory)
                dest = os.path.join(newdir, rel)
                os.makedirs(os.path.dirname(dest), exist_ok=True)

                slink = ""
                if os.path.islink(src):
                    slink = os.readlink(src)

                if slink == "" or not os.path.isabs(slink):
                    try:
                        os.link(src, dest)
                    except:
                        import shutil
                        shutil.copy(src, dest)
                else:
                    os.symlink(slink, dest)

        directory = newdir

    req = {
        "source": os.path.basename(directory),
        "project": project,
        "asset": asset,
        "version": version,
        "on_probation": probation
    }
    ut.dump_request(staging, url, "upload", req)
    return