def get_user_storage_provider()

in airavata_django_portal_sdk/user_storage/api.py [0:0]

• 31 lines of code
• 6 McCabe index (conditional complexity)

def get_user_storage_provider(request, owner_username=None, storage_resource_id=None):
    # TODO: default the module_class_name to MFT provider
    module_class_name = None
    options = {}
    if not hasattr(settings, 'USER_STORAGES'):
        # make this backward compatible with the older settings
        module_class_name = 'airavata_django_portal_sdk.user_storage.backends.DjangoFileSystemProvider'
        storage_resource_id = settings.GATEWAY_DATA_STORE_RESOURCE_ID
        options = dict(directory=settings.GATEWAY_DATA_STORE_DIR)
        logger.warning("Please add the USER_STORAGES setting. Using legacy GATEWAY_DATA_STORE_RESOURCE_ID and GATEWAY_DATA_STORE_DIR settings.")
    else:
        if storage_resource_id is not None:
            for key in settings.USER_STORAGES:
                conf = settings.USER_STORAGES[key]
                if conf['STORAGE_RESOURCE_ID'] == storage_resource_id:
                    module_class_name = conf['BACKEND']
                    options = conf.get('OPTIONS', {})
                    break
        # If none of the configured USER_STORAGES match, use the default one
        if module_class_name is None:
            conf = settings.USER_STORAGES['default']
            module_class_name = conf['BACKEND']
            storage_resource_id = conf['STORAGE_RESOURCE_ID']
            options = conf.get('OPTIONS', {})

    module_name, class_name = module_class_name.rsplit(".", 1)
    module = importlib.import_module(module_name)
    BackendClass = getattr(module, class_name)
    authz_token = request.authz_token
    context = {
        'request': request,
        'owner_username': owner_username,
    }
    instance = BackendClass(authz_token, storage_resource_id, context=context, **options)
    return instance