diff --git a/warcprox/controller.py b/warcprox/controller.py
index 30446c3..644fdec 100644
--- a/warcprox/controller.py
+++ b/warcprox/controller.py
@@ -212,6 +212,8 @@ class WarcproxController(object):
                 self._postfetch_chain.append(
                         warcprox.ListenerPostfetchProcessor(
                             plugin, self.options))
+            elif hasattr(plugin, 'CHAIN_POSITION') and plugin.CHAIN_POSITION == 'early':
+                self._postfetch_chain.insert(0, plugin) # or insert early but later than 0?
             else:
                 self._postfetch_chain.append(plugin)
 
diff --git a/warcprox/writerthread.py b/warcprox/writerthread.py
index 27c5eea..854319c 100644
--- a/warcprox/writerthread.py
+++ b/warcprox/writerthread.py
@@ -85,8 +85,8 @@ class WarcWriterProcessor(warcprox.BaseStandardPostfetchProcessor):
                           if recorded_url.do_not_archive
                           else False)
         # special warc name prefix '-' means "don't archive"
-        return prefix != '-' and (not do_not_archive) and
-               self._filter_accepts(recorded_url)
+        return (prefix != '-' and (not do_not_archive)
+                and self._filter_accepts(recorded_url))
 
     def _log(self, recorded_url, records):
         try: