Russell Keith-Magee avatar Russell Keith-Magee committed 2b46f36

Modified libcloud backend to allow it to be used a default file storage

Comments (0)

Files changed (1)


     from import get_driver
-    from import ObjectDoesNotExistError
+    from import ObjectDoesNotExistError, Provider
 except ImportError:
     raise ImproperlyConfigured("Could not load libcloud")
 class LibCloudStorage(Storage):
     """Django storage derived class using apache libcloud to operate
     on supported providers"""
-    def __init__(self, provider_name, option=None):
+    def __init__(self, provider_name=None, option=None):
+        if provider_name is None:
+            provider_name = getattr(settings, 'DEFAULT_LIBCLOUD_PROVIDER', 'default')
         self.provider = settings.LIBCLOUD_PROVIDERS.get(provider_name)
         if not self.provider:
             raise ImproperlyConfigured(
-                'LIBCLOUD_PROVIDERS %s not define or invalid' % provider_name)
+                'LIBCLOUD_PROVIDERS %s not defined or invalid' % provider_name)
-            Driver = get_driver(self.provider['type'])
+            provider_type = self.provider['type']
+            if isinstance(provider_type, basestring):
+                module_path, tag = provider_type.rsplit('.', 1)
+                if module_path != '':
+                    raise ValueError("Invalid module path")
+                provider_type = getattr(Provider, tag)
+            Driver = get_driver(provider_type)
             self.driver = Driver(
         except Exception, e:
             raise ImproperlyConfigured(
-                "Unable to create libcloud driver type %s" % \
+                "Unable to create libcloud driver type %s: %s" % \
                 (self.provider.get('type'), e))
         self.bucket = self.provider['bucket']   # Limit to one container
         clean_name = self._clean_name(name)
             return self.driver.get_object(self.bucket, clean_name)
-        except ObjectDoesNotExistError, e:
+        except ObjectDoesNotExistError:
             return None
     def delete(self, name):
-        """Delete objet on remote"""
+        """Delete object on remote"""
         obj = self._get_object(name)
         if obj:
             return self.driver.delete_object(obj)
         return self.driver.download_object_as_stream(obj, obj.size).next()
     def _save(self, name, file):
-        self.driver.upload_object_via_stream(file, self._get_bucket(), name)
+        self.driver.upload_object_via_stream(iter(file), self._get_bucket(), name)
+        return name
 class LibCloudFile(File):
-    """File intherited class for libcloud storage objects read and write"""
+    """File inherited class for libcloud storage objects read and write"""
     def __init__(self, name, storage, mode):
         self._name = name
         self._storage = storage
Tip: Filter by directory path e.g. /media app.js to search for public/media/app.js.
Tip: Use camelCasing e.g. ProjME to search for
Tip: Filter by extension type e.g. /repo .js to search for all .js files in the /repo directory.
Tip: Separate your search with spaces e.g. /ssh pom.xml to search for src/ssh/pom.xml.
Tip: Use ↑ and ↓ arrow keys to navigate and return to view the file.
Tip: You can also navigate files with Ctrl+j (next) and Ctrl+k (previous) and view the file with Ctrl+o.
Tip: You can also navigate files with Alt+j (next) and Alt+k (previous) and view the file with Alt+o.