Corrected PR remarks

Author: Roma Koshel

chef/api.py

@@ -1,5 +1,4 @@
 import six
-
 import datetime
 import logging
 import os
@@ -10,7 +9,6 @@
 import six.moves.urllib.request
 import six.moves.urllib.error
 import six.moves.urllib.parse
-
 import weakref
 
 import pkg_resources
@@ -30,22 +28,18 @@
 puts Chef::Config.configuration.to_json
 """.strip()
 
-
 def api_stack_value():
     if not hasattr(api_stack, 'value'):
         api_stack.value = []
     return api_stack.value
 
 
 class UnknownRubyExpression(Exception):
-
     """Token exception for unprocessed Ruby expressions."""
 
 
 class ChefRequest(six.moves.urllib.request.Request):
-
     """Workaround for using PUT/DELETE with urllib2."""
-
     def __init__(self, *args, **kwargs):
         self._method = kwargs.pop('method', None)
         # Request is an old-style class, no super() allowed.
@@ -58,7 +52,6 @@ def get_method(self):
 
 
 class ChefAPI(object):
-
     """The ChefAPI object is a wrapper for a single Chef server.
 
     .. admonition:: The API stack
@@ -87,7 +80,7 @@ def __init__(self, url, key, client, version='0.10.8', headers={}):
         self.key = key
         self.client = client
         self.version = version
-        self.headers = dict((k.lower(), v) for k, v in headers.items())
+        self.headers = dict((k.lower(), v) for k, v in six.iteritems(headers))
         self.version_parsed = pkg_resources.parse_version(self.version)
         self.platform = self.parsed_url.hostname == 'api.opscode.com'
         if not api_stack_value():
@@ -106,19 +99,18 @@ def from_config_file(cls, path):
         url = key_path = client_name = None
         for line in open(path):
             if not line.strip() or line.startswith('#'):
-                continue  # Skip blanks and comments
+                continue # Skip blanks and comments
             parts = line.split(None, 1)
             if len(parts) != 2:
-                continue  # Not a simple key/value, we can't parse it anyway
+                continue # Not a simple key/value, we can't parse it anyway
             key, value = parts
             md = cls.ruby_string_re.search(value)
             if md:
                 value = md.group(2)
             else:
                 # Not a string, don't even try
-                log.debug('Value for %s does not look like a string: %s' % (key, value))
+                log.debug('Value for {0} does not look like a string: {1}'.format(key, value))
                 continue
-
             def _ruby_value(match):
                 expr = match.group(1).strip()
                 if expr == 'current_dir':
@@ -208,17 +200,17 @@ def _request(self, method, url, data, headers):
 
     def request(self, method, path, headers={}, data=None):
         auth_headers = sign_request(key=self.key, http_method=method,
-                                    path=self.parsed_url.path + path.split('?', 1)[0], body=data,
-                                    host=self.parsed_url.netloc, timestamp=datetime.datetime.utcnow(),
-                                    user_id=self.client)
+            path=self.parsed_url.path+path.split('?', 1)[0], body=data,
+            host=self.parsed_url.netloc, timestamp=datetime.datetime.utcnow(),
+            user_id=self.client)
         request_headers = {}
         request_headers.update(self.headers)
-        request_headers.update(dict((k.lower(), v) for k, v in headers.items()))
+        request_headers.update(dict((k.lower(), v) for k, v in six.iteritems(headers)))
         request_headers['x-chef-version'] = self.version
         request_headers.update(auth_headers)
         try:
             response = self._request(method, self.url + path, data, dict(
-                (k.capitalize(), v) for k, v in request_headers.items()))
+                (k.capitalize(), v) for k, v in six.iteritems(request_headers)))
         except six.moves.urllib.error.HTTPError as e:
             e.content = e.read()
             try:
@@ -230,7 +222,7 @@ def request(self, method, path, headers={}, data=None):
         return response
 
     def api_request(self, method, path, headers={}, data=None):
-        headers = dict((k.lower(), v) for k, v in headers.items())
+        headers = dict((k.lower(), v) for k, v in six.iteritems(headers))
         headers['accept'] = 'application/json'
         if data is not None:
             headers['content-type'] = 'application/json'

chef/auth.py

@@ -1,29 +1,25 @@
+import six.moves
 import base64
 import datetime
 import hashlib
 import re
 
-
 def _ruby_b64encode(value):
     """The Ruby function Base64.encode64 automatically breaks things up
     into 60-character chunks.
     """
     b64 = base64.b64encode(value)
-    for i in range(0, len(b64), 60):
-        yield b64[i:i + 60].decode('utf-8')
-
+    for i in six.moves.range(0, len(b64), 60):
+        yield b64[i:i + 60].decode()
 
 def ruby_b64encode(value):
     return '\n'.join(_ruby_b64encode(value))
 
-
 def sha1_base64(value):
     """An implementation of Mixlib::Authentication::Digester."""
-    return ruby_b64encode(hashlib.sha1(value.encode('utf-8')).digest())
-
+    return ruby_b64encode(hashlib.sha1(value.encode()).digest())
 
 class UTC(datetime.tzinfo):
-
     """UTC timezone stub."""
 
     ZERO = datetime.timedelta(0)
@@ -39,22 +35,18 @@ def dst(self, dt):
 
 utc = UTC()
 
-
 def canonical_time(timestamp):
     if timestamp.tzinfo is not None:
         timestamp = timestamp.astimezone(utc).replace(tzinfo=None)
     return timestamp.replace(microsecond=0).isoformat() + 'Z'
 
 canonical_path_regex = re.compile(r'/+')
-
-
 def canonical_path(path):
     path = canonical_path_regex.sub('/', path)
     if len(path) > 1:
         path = path.rstrip('/')
     return path
 
-
 def canonical_request(http_method, path, hashed_body, timestamp, user_id):
     # Canonicalize request parameters
     http_method = http_method.upper()
@@ -68,7 +60,6 @@ def canonical_request(http_method, path, hashed_body, timestamp, user_id):
             'X-Ops-Timestamp:%(timestamp)s\n'
             'X-Ops-UserId:%(user_id)s' % vars())
 
-
 def sign_request(key, http_method, path, body, host, timestamp, user_id):
     """Generate the needed headers for the Opscode authentication protocol."""
     timestamp = canonical_time(timestamp)
@@ -86,5 +77,5 @@ def sign_request(key, http_method, path, body, host, timestamp, user_id):
     req = canonical_request(http_method, path, hashed_body, timestamp, user_id)
     sig = _ruby_b64encode(key.private_encrypt(req))
     for i, line in enumerate(sig):
-        headers['x-ops-authorization-%s' % (i + 1)] = line
+        headers['x-ops-authorization-%s'%(i+1)] = line
     return headers

chef/base.py

@@ -62,7 +62,7 @@ def __init__(self, name, api=None, skip_load=False):
         self._populate(data)
 
     def _populate(self, data):
-        for name, cls in self.__class__.attributes.items():
+        for name, cls in six.iteritems(self.__class__.attributes):
             if name in data:
                 value = cls(data[name])
             else:
@@ -82,7 +82,7 @@ def list(cls, api=None):
         """
         api = api or ChefAPI.get_global()
         cls._check_api_version(api)
-        names = [name for name, url in api[cls.url].items()]
+        names = [name for name, url in six.iteritems(api[cls.url])]
         return ChefQuery(cls, names, api)
 
     @classmethod
@@ -93,7 +93,7 @@ def create(cls, name, api=None, **kwargs):
         api = api or ChefAPI.get_global()
         cls._check_api_version(api)
         obj = cls(name, api, skip_load=True)
-        for key, value in kwargs.items():
+        for key, value in six.iteritems(kwargs):
             setattr(obj, key, value)
         api.api_request('POST', cls.url, data=obj)
         return obj
@@ -121,7 +121,7 @@ def to_dict(self):
             'json_class': 'Chef::'+self.__class__.__name__,
             'chef_type': self.__class__.__name__.lower(),
         }
-        for attr in self.__class__.attributes.keys():
+        for attr in six.iterkeys(self.__class__.attributes):
             d[attr] = getattr(self, attr)
         return d
 

chef/data_bag.py

@@ -19,7 +19,7 @@ class DataBag(six.with_metaclass(DataBagMeta, ChefObject, ChefQuery)):
 
         bag = DataBag('versions')
         item = bag['web']
-        for name, item in bag.iteritems():
+        for name, item in six.iteritems(bag):
             print item['qa_version']
     """
 
@@ -96,7 +96,7 @@ def create(cls, bag, name, api=None, **kwargs):
         keyword arguments."""
         api = api or ChefAPI.get_global()
         obj = cls(bag, name, api, skip_load=True)
-        for key, value in kwargs.items():
+        for key, value in six.iteritems(kwargs):
             obj[key] = value
         obj['id'] = name
         api.api_request('POST', cls.url+'/'+str(bag), data=obj.raw_data)

chef/fabric.py

@@ -1,12 +1,10 @@
-
-
+import six
 import functools
 
 from chef.api import ChefAPI, autoconfigure
 from chef.environment import Environment
 from chef.exceptions import ChefError, ChefAPIVersionError
 from chef.search import Search
-import collections
 
 try:
     from fabric.api import env, task, roles, output
@@ -39,7 +37,7 @@ def __init__(self, query, api, hostname_attr, environment=None):
         self.query = query
         self.api = api
         self.hostname_attr = hostname_attr
-        if isinstance(self.hostname_attr, str):
+        if isinstance(self.hostname_attr, six.string_types):
             self.hostname_attr = (self.hostname_attr,)
         self.environment = environment
 
@@ -52,7 +50,7 @@ def __call__(self):
             query += ' AND chef_environment:%s' % environment
         for row in Search('node', query, api=self.api):
             if row:
-                if isinstance(self.hostname_attr, collections.Callable):
+                if callable(self.hostname_attr):
                     val = self.hostname_attr(row.object)
                     if val:
                         yield val
@@ -192,7 +190,7 @@ def migrate():
     .. versionadded:: 0.2.1
     """
     # Allow passing a single iterable
-    if len(tags) == 1 and not isinstance(tags[0], str):
+    if len(tags) == 1 and not isinstance(tags[0], six.string_types):
         tags = tags[0]
     query = ' AND '.join('tags:%s'%tag.strip() for tag in tags)
     return chef_query(query, **kwargs)

chef/node.py

@@ -1,3 +1,4 @@
+import six
 import collections
 
 from chef.base import ChefObject
@@ -27,7 +28,7 @@ def __init__(self, search_path=[], path=None, write=None):
     def __iter__(self):
         keys = set()
         for d in self.search_path:
-            keys |= set(d.keys())
+            keys |= set(six.iterkeys(d))
         return iter(keys)
 
     def __len__(self):