Reformat pkg_resources in PEP 8 style

--HG--
branch : setuptools
extra : convert_revision : svn%3A6015fed2-1504-0410-9fe1-9d1591cc4771/sandbox/trunk/setuptools%4040995

pkg_resources.py

@@ -13,6 +13,12 @@ The package resource API is designed to work with normal filesystem packages,
 .zip files and with custom PEP 302 loaders that support the ``get_data()``
 method.
 """
+
+import sys
+import os
+import time
+import zipimport
+
 __all__ = [
     'register_loader_type', 'get_provider', 'IResourceProvider',
     'ResourceManager', 'iter_distributions', 'require', 'resource_string',
@@ -20,7 +26,6 @@ __all__ = [
     'cleanup_resources', # 'glob_resources'
 ]
 
-import sys,os,zipimport,time
 _provider_factories = {}
 
 def register_loader_type(loader_type, provider_factory):
@@ -32,28 +37,28 @@ def register_loader_type(loader_type, provider_factory):
     """
     _provider_factories[loader_type] = provider_factory
 
+
 def get_provider(moduleName):
     """Return an IResourceProvider for the named module"""
     module = sys.modules[moduleName]
-    loader = getattr(module,'__loader__',None)
-    return _find_adapter(_provider_factories,loader)(module)
+    loader = getattr(module, '__loader__', None)
+    return _find_adapter(_provider_factories, loader)(module)
 
 
 class IResourceProvider:
-
     """An object that provides access to package resources"""
 
-    def get_resource_filename(manager,resource_name):
+    def get_resource_filename(manager, resource_name):
         """Return a true filesystem path for `resource_name`
 
         `manager` must be an ``IResourceManager``"""
 
-    def get_resource_stream(manager,resource_name):
+    def get_resource_stream(manager, resource_name):
         """Return a readable file-like object for `resource_name`
 
         `manager` must be an ``IResourceManager``"""
 
-    def get_resource_string(manager,resource_name):
+    def get_resource_string(manager, resource_name):
         """Return a string containing the contents of `resource_name`
 
         `manager` must be an ``IResourceManager``"""
@@ -68,18 +73,11 @@ class IResourceProvider:
         """The named metadata resource as a string"""
 
     def get_metadata_lines(name):
-        """The named metadata resource as a filtered list of stripped lines"""
-
+        """The named metadata resource as a filtered iterator of stripped lines"""
 
     # XXX list_resources?  glob_resources?
 
 
-
-
-
-
-
-
 class ResourceManager:
     """Manage resource extraction and packages"""
 
@@ -88,38 +86,21 @@ class ResourceManager:
     def __init__(self):
         self.cached_files = []
 
-    def resource_exists(self,package_name,resource_name):
+    def resource_exists(self, package_name, resource_name):
         """Does the named resource exist in the named package?"""
-        return get_provider(package_name).has_resource(self,resource_name)
+        return get_provider(package_name).has_resource(self, resource_name)
 
-    def resource_filename(self,package_name,resource_name):
+    def resource_filename(self, package_name, resource_name):
         """Return a true filesystem path for specified resource"""
-        return get_provider(package_name).get_resource_filename(self,resource_name)
+        return get_provider(package_name).get_resource_filename(self, resource_name)
 
-    def resource_stream(self,package_name,resource_name):
+    def resource_stream(self, package_name, resource_name):
         """Return a readable file-like object for specified resource"""
-        return get_provider(package_name).get_resource_stream(self,resource_name)
+        return get_provider(package_name).get_resource_stream(self, resource_name)
 
-    def resource_string(self,package_name,resource_name):
+    def resource_string(self, package_name, resource_name):
         """Return specified resource as a string"""
-        return get_provider(package_name).get_resource_string(self,resource_name)
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+        return get_provider(package_name).get_resource_string(self, resource_name)
 
     def get_cache_path(self, archive_name, names=()):
         """Return absolute location in cache for `archive_name` and `names`
@@ -141,27 +122,22 @@ class ResourceManager:
         self.cached_files.append(target_path)
         return target_path
 
-
-    def require(self,requirement,path=None):
+    def require(self, requirement, path=None):
         """Ensure a distribution matching `requirement` is on ``sys.path``
 
         The `requirement` and `path` arguments are the same as for
         the ``iter_distributions()`` method, but `requirement` is not optional
         for `require`, since you must specify the desired distribution name.
         """
-        for dist in self.iter_distributions(requirement,path):
+        for dist in self.iter_distributions(requirement, path):
             dist.require()
             return
         else:
-            pass #raise ImportError(
-            #    "No distributions found matching "+repr(requirement)
+            pass
+            #raise ImportError(
+            #    "No distributions found matching " + repr(requirement)
             #)
 
-
-
-
-
-
     # XXX Not yet implemented
 
     def postprocess(self, filename):
@@ -174,10 +150,10 @@ class ResourceManager:
         extracting a compressed resource.  They should not call it on resources
         that are already in the filesystem.
         """
-        # print "postprocessing",filename     # XXX
-
+        # XXX
+        # print "postprocessing", filename     
 
-    def iter_distributions(self,requirement=None,path=None):
+    def iter_distributions(self, requirement=None, path=None):
         """Iterate over distributions in `path` matching `requirement`
 
         The `path` is a sequence of ``sys.path`` items.  If not supplied,
@@ -186,22 +162,8 @@ class ResourceManager:
         The `requirement` is an optional string specifying the name of the
         desired distribution.
         """
-        return ()   # XXX
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+        # XXX
+        return ()
 
     def set_extraction_path(self, path):
         """Set the base path where resources will be extracted to, if needed.
@@ -236,12 +198,7 @@ class ResourceManager:
         directory used for extractions.
         """
         # XXX
-
-
-
-
-
-
+        pass
 
 
 class DefaultProvider:
@@ -249,166 +206,152 @@ class DefaultProvider:
 
     egg_info = None
 
-    def __init__(self,module):
+    def __init__(self, module):
         self.module = module
-        self.loader = getattr(module,'__loader__',None)
+        self.loader = getattr(module, '__loader__',None)
         self.module_path = os.path.dirname(module.__file__)
 
-    def get_resource_filename(self,manager,resource_name):
+    def get_resource_filename(self, manager, resource_name):
         return self._fn(resource_name)
 
-    def get_resource_stream(self,manager,resource_name):
-        return open(self._fn(resource_name),'rb')
+    def get_resource_stream(self, manager, resource_name):
+        return open(self._fn(resource_name), 'rb')
 
-    def get_resource_string(manager,resource_name):
+    def get_resource_string(self, manager, resource_name):
         return self._get(self._fn(resource_name))
 
-    def has_resource(self,resource_name):
+    def has_resource(self, resource_name):
         return self._has(self._fn(resource_name))
 
-    def has_metadata(self,name):
+    def has_metadata(self, name):
         if not self.egg_info:
             raise NotImplementedError("Only .egg supports metadata")
-        return self._has(os.path.join(self.egg_info,*name.split('/')))
+        return self._has(os.path.join(self.egg_info, *name.split('/')))
 
-    def get_metadata(self,name):
+    def get_metadata(self, name):
         if not self.egg_info:
             raise NotImplementedError("Only .egg supports metadata")
-        return self._get(os.path.join(self.egg_info,*name.split('/')))
-
-    def get_metadata_lines(self,name):
-        return [
-            line.strip() for line in self.get_metadata(name).splitlines()
-                if line.strip()
-        ]
-
+        return self._get(os.path.join(self.egg_info, *name.split('/')))
 
+    def get_metadata_lines(self, name):
+        for line in self.get_metadata(name).splitlines():
+            line = line.strip()
+            if line:
+                yield line
 
-
-    def _has(self,path):
+    def _has(self, path):
         return os.path.exists(path)
 
-    def _get(self,path):
-        stream = open(path,'rb')
+    def _get(self, path):
+        stream = open(path, 'rb')
         try:
             return stream.read()
         finally:
             stream.close()
 
-    def _fn(self,resource_name):
+    def _fn(self, resource_name):
         return os.path.join(self.module_path, *resource_name.split('/'))
 
 
 register_loader_type(type(None), DefaultProvider)
 
 
-
 class NullProvider(DefaultProvider):
     """Try to implement resource support for arbitrary PEP 302 loaders"""
 
-    def _has(self,path):
+    def _has(self, path):
         raise NotImplementedError(
             "Can't perform this operation for unregistered loader type"
         )
 
-    def _get(self,path):
-        if hasattr(self.loader, 'get_data'):
-            return self.loader.get_data(path)
+    def _get(self, path):
+        get_data = getattr(self.loader, 'get_data', None)
+        if get_data is None:
             raise NotImplementedError(
                 "Can't perform this operation for loaders without 'get_data()'"
             )
+        return get_data(path)
 
 
 register_loader_type(object, NullProvider)
 
 
-
-
-
-
 class ZipProvider(DefaultProvider):
     """Resource support for zips and eggs"""
 
     egg_name = None
     eagers = None
 
-    def __init__(self,module):
+    def __init__(self, module):
         self.module = module
         self.loader = module.__loader__
         self.zipinfo = zipimport._zip_directory_cache[self.loader.archive]
-        self.zip_pre = self.loader.archive+os.sep
+        self.zip_pre = self.loader.archive + os.sep
 
         path = self.module_path = os.path.dirname(module.__file__)
         old = None
         self.prefix = []
-        while path!=old:
+        while path != old:
             if path.lower().endswith('.egg'):
                 self.egg_name = os.path.basename(path)
-                self.egg_info = os.path.join(path,'EGG-INFO')
+                self.egg_info = os.path.join(path, 'EGG-INFO')
                 break
             old = path
             path, base = os.path.split(path)
             self.prefix.append(base)
 
-    def _short_name(self,path):
+    def _short_name(self, path):
         if path.startswith(self.zip_pre):
             return path[len(self.zip_pre):]
         return path
 
-    def _has(self,path):
+    def _has(self, path):
         return self._short_name(path) in self.zipinfo
 
-    def _get(self,path):
+    def _get(self, path):
         return self.loader.get_data(path)
 
     def get_resource_stream(self, manager, resource_name):
         from cStringIO import StringIO
         return StringIO(self.get_resource_string(manager, resource_name))
 
-
-
-    def _extract_resource(self,manager,resource_name):
+    def _extract_resource(self, manager, resource_name):
         parts = resource_name.split('/')
         zip_path = os.path.join(self.module_path, *parts)
-        zip_stat = self.zipinfo[os.path.join(*self.prefix+parts)]
-        t,d,size = zip_stat[5],zip_stat[6],zip_stat[3]
+        zip_stat = self.zipinfo[os.path.join(*(self.prefix + parts))]
+        t, d, size = zip_stat[5], zip_stat[6], zip_stat[3]
         date_time = (
-            (d>>9)+1980, (d>>5)&0xF, d&0x1F, (t&0xFFFF)>>11, (t>>5)&0x3F,
-            (t&0x1F) * 2, 0, 0, -1
+            (d >> 9) + 1980, (d >> 5) & 0xF, d & 0x1F,
+            (t & 0xFFFF) >> 11, (t >> 5) & 0x3F,
+            (t & 0x1F) * 2, 0, 0, -1
         )
         timestamp = time.mktime(date_time)
         real_path = manager.get_cache_path(self.egg_name, self.prefix+parts)
 
         if os.path.isfile(real_path):
             stat = os.stat(real_path)
-            if stat.st_size==size and stat.st_mtime==timestamp:
+            if stat.st_size == size and stat.st_mtime == timestamp:
                 # size and stamp match, don't bother extracting
                 return real_path
 
         # print "extracting", zip_path
 
         data = self.loader.get_data(zip_path)
-        open(real_path,'wb').write(data)
-        os.utime(real_path,(timestamp,timestamp))
+        open(real_path, 'wb').write(data)
+        os.utime(real_path, (timestamp, timestamp))
         manager.postprocess(real_path)
         return real_path
 
     def _get_eager_resources(self):
         if self.eagers is None:
             eagers = []
-            for name in 'native_libs.txt', 'eager_resources.txt':
+            for name in ('native_libs.txt', 'eager_resources.txt'):
                 if self.has_metadata(name):
                     eagers.extend(self.get_metadata_lines(name))
             self.eagers = eagers
         return self.eagers
 
-
-
-
-
-
-
-    def get_resource_filename(self,manager,resource_name):
+    def get_resource_filename(self, manager, resource_name):
         if not self.egg_name:
             raise NotImplementedError(
                 "resource_filename() only supported for .egg, not .zip"
@@ -418,47 +361,25 @@ class ZipProvider(DefaultProvider):
         eagers = self._get_eager_resources()
         if resource_name in eagers:
             for name in eagers:
-                self._extract_resource(manager,name)
+                self._extract_resource(manager, name)
 
-        return self._extract_resource(manager,resource_name)
+        return self._extract_resource(manager, resource_name)
 
 
 register_loader_type(zipimport.zipimporter, ZipProvider)
 
 
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
 def _get_mro(cls):
     """Get an mro for a type or classic class"""
-    if not isinstance(cls,type):
-        class cls(cls,object): pass
+    if not isinstance(cls, type):
+        cls = type('', (cls, object), {})
         return cls.__mro__[1:]
     return cls.__mro__
 
-def _find_adapter(registry,ob):
+
+def _find_adapter(registry, ob):
     """Return an adapter factory for `ob` from `registry`"""
-    for t in _get_mro(getattr(ob,'__class__',type(ob))):
+    for t in _get_mro(getattr(ob, '__class__', type(ob))):
         if t in registry:
             return registry[t]
 
@@ -469,24 +390,12 @@ def _ensure_directory(path):
         os.makedirs(dirname)
 
 
-
 # Set up global resource manager
 
 _manager = ResourceManager()
 
-for name in dir(_manager):
+def _initialize(g):
+    for name in dir(_manager):
         if not name.startswith('_'):
-        globals()[name] = getattr(_manager,name)
-
-
-
-
-
-
-
-
-
-
-
-
-
+            g[name] = getattr(_manager, name)
+_initialize(globals())