refs dictation-toolbox#385, resolve content_loader/nexus circular import

Author: synkarius

_caster.py

@@ -3,30 +3,34 @@
 main Caster module
 Created on Jun 29, 2014
 '''
+import datetime
+
+from castervoice.lib.ctrl.mgr.loading.load.content_loader import ContentLoader
+from castervoice.lib.ctrl.mgr.loading.load.content_request_generator import ContentRequestGenerator
 
 import logging
 logging.basicConfig()
 from dragonfly import get_engine
-
-
 from castervoice.lib.ctrl.dependencies import DependencyMan  # requires nothing
-
 DependencyMan().initialize()
-
 _NEXUS = None
 from castervoice.lib import settings  # requires toml
 if settings.SYSTEM_INFORMATION["platform"] != "win32":
     raise SystemError("Your platform is not currently supported by Caster.")
 settings.WSR = __name__ == "__main__"
-from castervoice.lib.ccr.standard import SymbolSpecs
+
 if settings.WSR:
     from castervoice.lib.ccr.standard import SymbolSpecs
     SymbolSpecs.set_cancel_word("escape")
 from castervoice.lib import control
+
+_crg = ContentRequestGenerator()
+_content_loader = ContentLoader(_crg)
+control.init_nexus(_content_loader)
+
 _NEXUS = control.nexus()
 
 from castervoice.asynch.sikuli import sikuli_controller
-
 if not globals().has_key('profile_switch_occurred'):
     # Load user rules
     _NEXUS.process_user_content()
@@ -37,11 +41,8 @@
     reload(sikulixx)
 else:
     profile_switch_occurred = None
-
 if settings.SETTINGS["sikuli"]["enabled"]:
     sikuli_controller.get_instance().bootstrap_start_server_proxy()
-
 print("\n*- Starting " + settings.SOFTWARE_NAME + " -*")
-
 if settings.WSR:
     get_engine().recognize_forever()

castervoice/apps/griddouglas.py

@@ -6,6 +6,7 @@
 from castervoice.asynch.mouse import grids
 import win32api, win32con
 
+from castervoice.lib.ccr.standard import SymbolSpecs
 from castervoice.lib.ctrl.mgr.rule_details import RuleDetails
 from castervoice.lib.merge.additions import IntegerRefST
 from castervoice.lib.merge.mergerule import MergeRule

castervoice/apps/gridrainbow.py

@@ -6,6 +6,7 @@
 import win32api, win32con
 
 from castervoice.lib import control, settings
+from castervoice.lib.ccr.standard import SymbolSpecs
 from castervoice.lib.ctrl.mgr.rule_details import RuleDetails
 from castervoice.lib.merge.additions import IntegerRefST
 from castervoice.lib.merge.mergerule import MergeRule

castervoice/lib/control.py

@@ -1,9 +1,11 @@
 _NEXUS = None
+print(" HERE IMPORTING NEXUS ... ")
+
+def init_nexus(content_loader):
+    global _NEXUS
+    from castervoice.lib.ctrl.nexus import Nexus
+    _NEXUS = Nexus(content_loader)
 
 
 def nexus():
-    global _NEXUS
-    if _NEXUS is None:
-        from castervoice.lib.ctrl.nexus import Nexus
-        _NEXUS = Nexus()
     return _NEXUS

castervoice/lib/ctrl/mgr/grammar_manager.py

@@ -77,9 +77,11 @@ def initialize(self):
             return
 
         for rcn in self._config.get_active_rule_class_names():
+            print("initialize:rcn: " + rcn)
             is_ccr = self._managed_rules[rcn].declared_ccrtype is not None
             if is_ccr and not self._ccr_toggle.is_active():
                 continue
+            print("initialize:rcn:activate: " + rcn)
             self._activate_rule(rcn, True)
 
         self._initial_activations_complete = True
@@ -163,6 +165,8 @@ def _activate_rule(self, class_name, active):
             active_mrs = [self._managed_rules[rcn] for rcn in active_rule_class_names]
             active_ccr_mrs = [mr for mr in active_mrs if mr.details.declared_ccrtype is not None]
 
+            print("_activate_rule: " + str(len(active_ccr_mrs)))
+
             '''
             The merge may result in 1 to n+1 rules where n is the number of ccr app rules
             which are in the active rules list.

castervoice/lib/ctrl/mgr/loading/load/content_loader.py

@@ -1,3 +1,4 @@
+import datetime
 import importlib
 import traceback
 from sys import modules as MODULES
@@ -88,11 +89,13 @@ def _process_requests(self, requests):
         result = []
 
         for request in requests:
+            print("log {} {} {}".format(1, datetime.datetime.today(), request.module_name))
             if request.directory not in path:
                 path.append(request.directory)
             content_item = self.idem_import_module(request.module_name, request.content_type)
             if content_item is not None:
                 result.append(content_item)
+            print("log {} {} {}".format(2, datetime.datetime.today(), request.module_name))
 
         return result
 

castervoice/lib/ctrl/nexus.py

@@ -1,3 +1,5 @@
+import datetime
+
 from castervoice.lib.ctrl.grammar_container import GrammarContainer
 from castervoice.lib.ctrl.mgr.ccr_toggle import CCRToggle
 from castervoice.lib.ctrl.mgr.grammar_activator import GrammarActivator
@@ -34,14 +36,15 @@
 
 
 class Nexus:
-    def __init__(self):
+    def __init__(self, content_loader):
         """
         The Nexus is the 'glue code' of Caster. It is where the things reside which
         manage global state. It is also an access point to those things for other
         things which need them. This access should be limited.
         """
 
         '''CasterState is used for impl of the asynchronous actions'''
+
         self.state = CasterState()
 
         '''rpc class for interacting with Caster UI elements via xmlrpclib'''
@@ -68,8 +71,7 @@ def __init__(self):
 
         '''unified loading mechanism for [rules, transformers, hooks] 
         from [caster starter locations, user dir]'''
-        crg = ContentRequestGenerator()
-        self._content_loader = ContentLoader(crg)
+        self._content_loader = content_loader
 
         '''mapping rule maker: like the ccrmerger, but doesn't merge and isn't ccr'''
         mapping_rule_maker = MappingRuleMaker(transformers_runner, smrc)