From 414569c1eaeccfe723619d621862acdb5907dde6 Mon Sep 17 00:00:00 2001
From: Michel Oosterhof <michel@oosterhof.net>
Date: Tue, 18 Oct 2016 15:07:59 +0400
Subject: [PATCH] wip

---
 twisted/plugins/cowrie_plugin.py | 11 ++++++-----
 1 file changed, 6 insertions(+), 5 deletions(-)

diff --git a/twisted/plugins/cowrie_plugin.py b/twisted/plugins/cowrie_plugin.py
index f8ea7cc6..74e402a1 100644
--- a/twisted/plugins/cowrie_plugin.py
+++ b/twisted/plugins/cowrie_plugin.py
@@ -37,7 +37,7 @@ from zope.interface import implementer
 import os
 import sys
 
-from twisted.python import usage
+from twisted.python import log, usage
 from twisted.plugin import IPlugin
 from twisted.application.service import IServiceMaker
 from twisted.application import internet, service
@@ -72,6 +72,7 @@ class CowrieServiceMaker(object):
     options = Options
     dbloggers = None
     output_plugins = None
+    cfg = None
 
     def makeService(self, options):
         """
@@ -105,13 +106,13 @@ class CowrieServiceMaker(object):
 
         # Load db loggers
         self.dbloggers = []
-        for x in self.cfg.sections():
+        for x in cfg.sections():
             if not x.startswith('database_'):
                 continue
             engine = x.split('_')[1]
             try:
                 dblogger = __import__( 'cowrie.dblog.{}'.format(engine),
-                    globals(), locals(), ['dblog']).DBLogger(self.cfg)
+                    globals(), locals(), ['dblog']).DBLogger(cfg)
                 log.addObserver(dblogger.emit)
                 self.dbloggers.append(dblogger)
                 log.msg("Loaded dblog engine: {}".format(engine))
@@ -121,13 +122,13 @@ class CowrieServiceMaker(object):
 
         # Load output modules
         self.output_plugins = []
-        for x in self.cfg.sections():
+        for x in cfg.sections():
             if not x.startswith('output_'):
                 continue
             engine = x.split('_')[1]
             try:
                 output = __import__( 'cowrie.output.{}'.format(engine),
-                    globals(), locals(), ['output']).Output(self.cfg)
+                    globals(), locals(), ['output']).Output(cfg)
                 log.addObserver(output.emit)
                 self.output_plugins.append(output)
                 log.msg("Loaded output engine: {}".format(engine))