Rename ApolloSubscriptionServer class

Change class name to just "SubscriptionServer"

Author: hballard

README.md

@@ -48,10 +48,10 @@ $ pip install graphql-subscriptions
 
 #### Methods
 - `publish(trigger_name, payload)`: Trigger name is the subscription or pubsub channel; payload is the mutation object or message that will end up being passed to the subscription root_value; method called inside of mutation resolve function
-- `subscribe(query, operation_name, callback, variables, context, format_error, format_response)`: Called by ApolloSubscriptionServer upon receiving a new subscription from a websocket.  Arguments are parsed by ApolloSubscriptionServer from the graphql subscription query
-- `unsubscribe(sub_id)`: Sub_id is the subscription ID that is being tracked by the subscription manager instance -- returned from the `subscribe()` method and called by the ApolloSubscriptionServer
+- `subscribe(query, operation_name, callback, variables, context, format_error, format_response)`: Called by SubscriptionServer upon receiving a new subscription from a websocket.  Arguments are parsed by SubscriptionServer from the graphql subscription query
+- `unsubscribe(sub_id)`: Sub_id is the subscription ID that is being tracked by the subscription manager instance -- returned from the `subscribe()` method and called by the SubscriptionServer
 
-### ApolloSubscriptionServer(subscription_manager, websocket, keep_alive=None, on_subscribe=None, on_unsubscribe=None, on_connect=None, on_disconnect=None)
+### SubscriptionServer(subscription_manager, websocket, keep_alive=None, on_subscribe=None, on_unsubscribe=None, on_connect=None, on_disconnect=None)
 #### Arguments
 - `subscription_manager`: A subscripton manager instance (required).
 - `websocket`: The websocket object passed in from your route handler (required).
@@ -78,7 +78,7 @@ from flask_sockets import Sockets
 from graphql_subscriptions import (
     SubscriptionManager,
     RedisPubsub,
-    ApolloSubscriptionServer
+    SubscriptionServer
 )
 
 app = Flask(__name__)
@@ -106,7 +106,7 @@ subscription_mgr = SubscriptionManager(schema, pubsub)
 # subscription app / server -- passing in subscription manager and websocket
 @sockets.route('/socket')
 def socket_channel(websocket):
-    subscription_server = ApolloSubscriptionServer(subscription_mgr, websocket)
+    subscription_server = SubscriptionServer(subscription_mgr, websocket)
     subscription_server.handle()
     return []
 

graphql_subscriptions/__init__.py

@@ -1,4 +1,5 @@
 from subscription_manager import RedisPubsub, SubscriptionManager
-from subscription_transport_ws import ApolloSubscriptionServer
+from subscription_transport_ws import SubscriptionServer
+
+__all__ = ['RedisPubsub', 'SubscriptionManager', 'SubscriptionServer']
 
-__all__ = ['RedisPubsub', 'SubscriptionManager', 'ApolloSubscriptionServer']

graphql_subscriptions/subscription_transport_ws.py

@@ -15,7 +15,7 @@
 GRAPHQL_SUBSCRIPTIONS = 'graphql-subscriptions'
 
 
-class ApolloSubscriptionServer(WebSocketApplication):
+class SubscriptionServer(WebSocketApplication):
     def __init__(self,
                  subscription_manager,
                  websocket,
@@ -37,7 +37,7 @@ def __init__(self,
         self.connection_subscriptions = {}
         self.connection_context = {}
 
-        super(ApolloSubscriptionServer, self).__init__(websocket)
+        super(SubscriptionServer, self).__init__(websocket)
 
     def timer(self, callback, period):
         while True:

tests/test_subscription_transport.py

@@ -25,7 +25,7 @@
 import requests
 
 from graphql_subscriptions import (RedisPubsub, SubscriptionManager,
-                                   ApolloSubscriptionServer)
+                                   SubscriptionServer)
 
 from graphql_subscriptions.subscription_transport_ws import (
     SUBSCRIPTION_FAIL, SUBSCRIPTION_DATA, KEEPALIVE)
@@ -264,7 +264,7 @@ def sub_mgr_publish():
 
     @sockets.route('/socket')
     def socket_channel(websocket):
-        subscription_server = ApolloSubscriptionServer(sub_mgr, websocket,
+        subscription_server = SubscriptionServer(sub_mgr, websocket,
                                                        **options)
         subscription_server.handle()
         return []
@@ -323,7 +323,7 @@ def server_with_events(sub_mgr, schema, events_options):
 
 def test_raise_exception_when_create_server_and_no_sub_mgr():
     with pytest.raises(AssertionError):
-        ApolloSubscriptionServer(None, None)
+        SubscriptionServer(None, None)
 
 
 def test_should_trigger_on_connect_if_client_connect_valid(server_with_events):