Complete initial subscription_transport tests

See notes in tests/test_subscription_transport.py for how to run
tests. This implementation is based on the
apollographql/subscriptions-transport-ws library and uses their
graphql subscriptions client for testing. Specifically, these
tests are compatable with npm package released version
subscriptions-transport-ws@0.5.4.

Tests are about halfway complete for that release version.

Author: hballard

graphql_subscriptions/subscription_transport_ws.py

@@ -77,13 +77,11 @@ def on_message(self, msg):
         if msg is None:
             return
 
-        class nonlocal:
-            on_init_resolve = None
-            on_init_reject = None
+        nonlocal = {'on_init_resolve': None, 'on_init_reject': None}
 
         def init_promise_handler(resolve, reject):
-            nonlocal.on_init_resolve = resolve
-            nonlocal.on_init_reject = reject
+            nonlocal['on_init_resolve'] = resolve
+            nonlocal['on_init_reject'] = reject
 
         self.connection_context['init_promise'] = Promise(init_promise_handler)
 
@@ -107,7 +105,7 @@ def on_message_return_handler(message):
                         self.on_connect(
                             parsed_message.get('payload'), self.ws))
 
-                nonlocal.on_init_resolve(on_connect_promise)
+                nonlocal['on_init_resolve'](on_connect_promise)
 
                 def init_success_promise_handler(result):
                     if not result:
@@ -218,7 +216,7 @@ def error_catch_handler(e):
                 # not sure if this behavior is correct or
                 # not per promises A spec...need to
                 # investigate
-                nonlocal.on_init_resolve(Promise.resolve(True))
+                nonlocal['on_init_resolve'](Promise.resolve(True))
 
                 self.connection_context['init_promise'].then(
                     subscription_start_promise_handler)
@@ -231,7 +229,7 @@ def subscription_end_promise_handler(result):
                         del self.connection_subscriptions[sub_id]
 
                 # same rationale as above
-                nonlocal.on_init_resolve(Promise.resolve(True))
+                nonlocal['on_init_resolve'](Promise.resolve(True))
 
                 self.connection_context['init_promise'].then(
                     subscription_end_promise_handler)

setup.py

@@ -8,7 +8,7 @@
 
 setup(
     name='graphql-subscriptions',
-    version='0.1.7',
+    version='0.1.8',
     author='Heath Ballard',
     author_email='heath.ballard@gmail.com',
     description=('A port of apollo-graphql subscriptions for python, using\
@@ -26,6 +26,11 @@
         'Programming Language :: Python :: 2.7',
         'License :: OSI Approved :: MIT License'
     ],
-    install_requires=['gevent-websocket', 'redis', 'promise', 'graphql-core'],
-    tests_require=['pytest', 'pytest-mock', 'fakeredis', 'graphene'],
+    install_requires=[
+        'gevent-websocket', 'redis', 'promise==1.0.1', 'graphql-core'
+    ],
+    tests_require=[
+        'pytest', 'pytest-mock', 'fakeredis', 'graphene', 'subprocess32',
+        'flask', 'flask-graphql', 'flask-sockets'
+    ],
     include_package_data=True)

tests/package.json

@@ -0,0 +1,6 @@
+{
+  "dependencies": {
+    "graphql": "^0.9.6",
+    "subscriptions-transport-ws": "0.5.4"
+  }
+}

tests/test_subscription_manager.py

@@ -13,12 +13,8 @@
 
 
 @pytest.fixture
-def mock_redis(monkeypatch):
+def pubsub(monkeypatch):
     monkeypatch.setattr(redis, 'StrictRedis', fakeredis.FakeStrictRedis)
-
-
-@pytest.fixture
-def pubsub(mock_redis):
     return RedisPubsub()