channel group support admin api's only

3 files changed, 149 insertions, 35 deletions

diff --git a/python/examples/cr.py b/python/examples/cr.py
index ad8e3c9..c537780 100644
--- a/python/examples/cr.py
+++ b/python/examples/cr.py
@@ -9,9 +9,9 @@
 import sys
 from Pubnub import Pubnub
 
-publish_key = len(sys.argv) > 1 and sys.argv[1] or 'demo'
-subscribe_key = len(sys.argv) > 2 and sys.argv[2] or 'demo'
-secret_key = len(sys.argv) > 3 and sys.argv[3] or 'demo'
+publish_key = len(sys.argv) > 1 and sys.argv[1] or 'pam'
+subscribe_key = len(sys.argv) > 2 and sys.argv[2] or 'pam'
+secret_key = len(sys.argv) > 3 and sys.argv[3] or 'pam'
 cipher_key = len(sys.argv) > 4 and sys.argv[4] or ''
 ssl_on = len(sys.argv) > 5 and bool(sys.argv[5]) or False
 
@@ -19,12 +19,15 @@ ssl_on = len(sys.argv) > 5 and bool(sys.argv[5]) or False
 ## Initiate Pubnub State
 ## -----------------------------------------------------------------------
 pubnub = Pubnub(publish_key=publish_key, subscribe_key=subscribe_key,
-                secret_key=secret_key, cipher_key=cipher_key, ssl_on=ssl_on)
+                secret_key=secret_key, cipher_key=cipher_key, ssl_on=ssl_on, auth_key="abcd")
 channel = 'hello_world'
 
 def callback(message):
     print(message)
 
+print pubnub.revoke(channel_group='dev:abcd', auth_key="abcd")
+print pubnub.audit(channel_group="dev:abcd")
+print pubnub.grant(channel_group='dev:abcd', read=True, write=True, manage=True, auth_key="abcd")
 print pubnub.channel_group_list_namespaces()
 print pubnub.channel_group_list_groups(namespace='aaa')
 print pubnub.channel_group_list_groups(namespace='foo')
@@ -35,6 +38,9 @@ print pubnub.channel_group_remove_channel(channel_group='dev:abcd', channel="hi"
 print pubnub.channel_group_list_channels(channel_group='dev:abcd')
 
 
+pubnub.revoke(channel_group='dev:abcd', auth_key="abcd", callback=callback, error=callback)
+pubnub.audit(channel_group="dev:abcd", callback=callback, error=callback)
+pubnub.grant(channel_group='dev:abcd', read=True, write=True, manage=True, auth_key="abcd", callback=callback, error=callback)
 pubnub.channel_group_list_namespaces(callback=callback, error=callback)
 pubnub.channel_group_list_groups(namespace='aaa', callback=callback, error=callback)
 pubnub.channel_group_list_groups(namespace='foo', callback=callback, error=callback)
@@ -42,4 +48,4 @@ pubnub.channel_group_list_channels(channel_group='dev:abcd', callback=callback,
 pubnub.channel_group_add_channel(channel_group='dev:abcd', channel="hi", callback=callback, error=callback)
 pubnub.channel_group_list_channels(channel_group='dev:abcd', callback=callback, error=callback)
 pubnub.channel_group_remove_channel(channel_group='dev:abcd', channel="hi", callback=callback, error=callback)
-pubnub.channel_group_list_channels(channel_group='dev:abcd', callback=callback, error=callback)
\ No newline at end of file
+pubnub.channel_group_list_channels(channel_group='dev:abcd', callback=callback, error=callback)
diff --git a/python/tests/test_cg.py b/python/tests/test_cg.py
new file mode 100644
index 0000000..a823e44
--- /dev/null
+++ b/python/tests/test_cg.py
@@ -0,0 +1,107 @@
+from Pubnub import Pubnub
+import time
+import random
+
+
+pubnub = Pubnub("demo","demo")
+pubnub.set_u(True)
+
+def rand_str(s):
+	return str(s) + '-' + str(random.randint(1, 100000000000))
+
+
+def test_1():
+	channel 		= rand_str('channel')
+	channel2 		= rand_str('channel')
+	channel_group 	= rand_str('group')
+	channel_group2  = rand_str('group')
+	namespace       = rand_str('ns')
+
+	resp = pubnub.channel_group_add_channel(channel_group=namespace + ':' + channel_group, channel=channel)
+	assert resp['status'] 	== 200
+	assert resp['message'] 	== 'OK'
+	assert resp['error'] 	== False
+
+	resp = pubnub.channel_group_add_channel(channel_group=namespace + ':' + channel_group, channel=channel2)
+	assert resp['status'] 	== 200
+	assert resp['message'] 	== 'OK'
+	assert resp['error'] 	== False
+
+	resp = pubnub.channel_group_add_channel(channel_group=namespace + ':' + channel_group2, channel=channel)
+	assert resp['status'] 	== 200
+	assert resp['message'] 	== 'OK'
+	assert resp['error'] 	== False
+
+	resp = pubnub.channel_group_add_channel(channel_group=namespace + ':' + channel_group2, channel=channel2)
+	assert resp['status'] 	== 200
+	assert resp['message'] 	== 'OK'
+	assert resp['error'] 	== False
+
+
+	resp = pubnub.channel_group_list_channels(channel_group=namespace + ':' + channel_group)
+	assert channel in resp['payload']['channels']
+	assert channel2 in resp['payload']['channels']
+	assert len(resp['payload']['channels']) == 2
+
+	resp = pubnub.channel_group_remove_channel(channel_group=namespace + ':' + channel_group, channel=channel2)
+	print resp
+	assert resp['status'] 	== 200
+	assert resp['message'] 	== 'OK'
+	assert resp['error'] 	== False
+
+	resp = pubnub.channel_group_list_channels(channel_group=namespace + ':' + channel_group)
+	print resp
+	assert channel in resp['payload']['channels']
+	assert len(resp['payload']['channels']) == 1
+
+
+	resp = pubnub.channel_group_list_channels(channel_group=namespace + ':' + channel_group2)
+	assert channel in resp['payload']['channels']
+	assert channel2 in resp['payload']['channels']
+	assert len(resp['payload']['channels']) == 2
+
+	resp = pubnub.channel_group_remove_channel(channel_group=namespace + ':' + channel_group2, channel=channel2)
+	print resp
+	assert resp['status'] 	== 200
+	assert resp['message'] 	== 'OK'
+	assert resp['error'] 	== False
+
+	resp = pubnub.channel_group_list_channels(channel_group=namespace + ':' + channel_group2)
+	print resp
+	assert channel in resp['payload']['channels']
+	assert len(resp['payload']['channels']) == 1
+
+
+
+	resp = pubnub.channel_group_list_groups(namespace=namespace)
+	assert channel_group in resp['payload']['groups']
+	assert channel_group2 in resp['payload']['groups']
+	assert len(resp['payload']['groups']) == 2
+
+	resp = pubnub.channel_group_remove_group(channel_group=namespace + ':' + channel_group2)
+	print resp
+	assert resp['status'] 	== 200
+	assert resp['message'] 	== 'OK'
+	assert resp['error'] 	== False
+
+
+	resp = pubnub.channel_group_list_groups(namespace=namespace)
+	assert channel_group in resp['payload']['groups']
+	assert len(resp['payload']['groups']) == 1
+
+
+	resp = pubnub.channel_group_list_namespaces()
+	assert namespace in resp['payload']['namespaces']
+
+	resp = pubnub.channel_group_remove_namespace(namespace=namespace)
+	print resp
+	assert resp['status'] 	== 200
+	assert resp['message'] 	== 'OK'
+	assert resp['error'] 	== False
+
+	resp = pubnub.channel_group_list_namespaces()
+	assert namespace not in resp['payload']['namespaces']
+
+
+
+
diff --git a/python/tests/test_grant.py b/python/tests/test_grant.py
index 6826335..9ecafdf 100644
--- a/python/tests/test_grant.py
+++ b/python/tests/test_grant.py
@@ -4,17 +4,18 @@ from Pubnub import Pubnub
 import time
 
 pubnub = Pubnub("demo","demo")
-pubnub_pam = Pubnub("pub-c-c077418d-f83c-4860-b213-2f6c77bde29a", 
-	"sub-c-e8839098-f568-11e2-a11a-02ee2ddab7fe", "sec-c-OGU3Y2Q4ZWUtNDQwMC00NTI1LThjNWYtNWJmY2M4OGIwNjEy")
+pubnub_pam = Pubnub("pam", 
+	"pam", "pam")
 
 
 # Grant permission read true, write true, on channel ( Sync Mode )
 def test_1():
 	resp = pubnub_pam.grant(channel="abcd", auth_key="abcd", read=True, write=True, ttl=1)
+	print resp
 	assert resp['message'] == 'Success'
 	assert resp['payload'] == {
-								'auths': {'abcd': {'r': 1, 'w': 1}},
-								'subscribe_key': 'sub-c-e8839098-f568-11e2-a11a-02ee2ddab7fe',
+								'auths': {'abcd': {'r': 1, 'w': 1, 'm' : 0}},
+								'subscribe_key': 'pam',
 								'level': 'user', 'channel': 'abcd', 'ttl': 1
 							  }
 							
@@ -24,8 +25,8 @@ def test_2():
 	resp = pubnub_pam.grant(channel="abcd", auth_key="abcd", read=False, write=False, ttl=1)
 	assert resp['message'] == 'Success'
 	assert resp['payload'] == {
-								'auths': {'abcd': {'r': 0, 'w': 0}},
-								'subscribe_key': 'sub-c-e8839098-f568-11e2-a11a-02ee2ddab7fe',
+								'auths': {'abcd': {'r': 0, 'w': 0, 'm' : 0}},
+								'subscribe_key': 'pam',
 								'level': 'user', 'channel': 'abcd', 'ttl': 1
 							  }
 
@@ -34,8 +35,8 @@ def test_3():
 	resp = pubnub_pam.grant(channel="abcd", auth_key="abcd", read=True, write=False, ttl=1)
 	assert resp['message'] == 'Success'
 	assert resp['payload'] == {
-								'auths': {'abcd': {'r': 1, 'w': 0}},
-								'subscribe_key': 'sub-c-e8839098-f568-11e2-a11a-02ee2ddab7fe',
+								'auths': {'abcd': {'r': 1, 'w': 0, 'm' : 0}},
+								'subscribe_key': 'pam',
 								'level': 'user', 'channel': 'abcd', 'ttl': 1
 							  }
 
@@ -44,8 +45,8 @@ def test_4():
 	resp = pubnub_pam.grant(channel="abcd", auth_key="abcd", read=True, write=False, ttl=1)
 	assert resp['message'] == 'Success'
 	assert resp['payload'] == {
-								'auths': {'abcd': {'r': 1, 'w': 0}},
-								'subscribe_key': 'sub-c-e8839098-f568-11e2-a11a-02ee2ddab7fe',
+								'auths': {'abcd': {'r': 1, 'w': 0, 'm' : 0}},
+								'subscribe_key': 'pam',
 								'level': 'user', 'channel': 'abcd', 'ttl': 1
 							  }
 
@@ -54,8 +55,8 @@ def test_5():
 	resp = pubnub_pam.grant(channel="abcd", auth_key="abcd", read=True, write=False, ttl=10)
 	assert resp['message'] == 'Success'
 	assert resp['payload'] == {
-								'auths': {'abcd': {'r': 1, 'w': 0}},
-								'subscribe_key': 'sub-c-e8839098-f568-11e2-a11a-02ee2ddab7fe',
+								'auths': {'abcd': {'r': 1, 'w': 0, 'm' : 0}},
+								'subscribe_key': 'pam',
 								'level': 'user', 'channel': 'abcd', 'ttl': 10
 							  }
 
@@ -64,8 +65,8 @@ def test_6():
 	resp = pubnub_pam.grant(auth_key="abcd", read=True, write=False, ttl=10)
 	assert resp['message'] == 'Success'
 	assert resp['payload'] == {
-								'subscribe_key': 'sub-c-e8839098-f568-11e2-a11a-02ee2ddab7fe',
-								'level': 'subkey' , u'r': 1, u'w': 0, 'ttl': 10
+								'subscribe_key': 'pam',
+								'level': 'subkey' , u'r': 1, u'w': 0, 'm' : 0, 'ttl': 10
 							  }
 
 
@@ -74,8 +75,8 @@ def test_7():
 	resp = pubnub_pam.grant(auth_key="abcd", read=False, write=False)
 	assert resp['message'] == 'Success'
 	assert resp['payload'] == {
-								'subscribe_key': 'sub-c-e8839098-f568-11e2-a11a-02ee2ddab7fe',
-								'level': 'subkey' , u'r': 0, u'w': 0, 'ttl': 1
+								'subscribe_key': 'pam',
+								'level': 'subkey' , u'r': 0, u'w': 0, 'm' : 0, 'ttl': 1
 							  }
 
 
@@ -92,8 +93,8 @@ def test_8():
 	resp = pubnub_pam.grant(channel=channel, read=True, write=True, auth_key=auth_key, ttl=10)
 	assert resp == 			{
 								'message': u'Success',
-								'payload': {u'auths': {auth_key : {u'r': 1, u'w': 1}},
-								u'subscribe_key': u'sub-c-e8839098-f568-11e2-a11a-02ee2ddab7fe',
+								'payload': {u'auths': {auth_key : {u'r': 1, u'w': 1, 'm' : 0}},
+								u'subscribe_key': u'pam',
 								u'level': u'user', u'channel': channel, u'ttl': 10}
 							}
 	resp = pubnub_pam.publish(channel=channel,message=message)
@@ -114,8 +115,8 @@ def test_9():
 	print resp
 	assert resp == 			{
 								'message': u'Success',
-								'payload': {u'auths': {auth_key : {u'r': 1, u'w': 1}},
-								u'subscribe_key': u'sub-c-e8839098-f568-11e2-a11a-02ee2ddab7fe',
+								'payload': {u'auths': {auth_key : {u'r': 1, u'w': 1, 'm' : 0}},
+								u'subscribe_key': u'pam',
 								u'level': u'user', u'channel': channel, u'ttl': 10}
 							}
 	resp = pubnub_pam.publish(channel=channel,message=message)
@@ -124,8 +125,8 @@ def test_9():
 	print resp
 	assert resp == 			{
 								'message': u'Success',
-								'payload': {u'auths': {auth_key : {u'r': 0, u'w': 0}},
-								u'subscribe_key': u'sub-c-e8839098-f568-11e2-a11a-02ee2ddab7fe',
+								'payload': {u'auths': {auth_key : {u'r': 0, u'w': 0, 'm' : 0}},
+								u'subscribe_key': u'pam',
 								u'level': u'user', u'channel': channel, u'ttl': 1}
 							}
 	resp = pubnub_pam.publish(channel=channel,message=message)
@@ -146,8 +147,8 @@ def test_10():
 	print resp
 	assert resp == 			{
 									'message': u'Success',
-									'payload': { u'channels': {channel: {u'r': 1, u'w': 1}},
-									u'subscribe_key': u'sub-c-e8839098-f568-11e2-a11a-02ee2ddab7fe',
+									'payload': { u'channels': {channel: {u'r': 1, u'w': 1, 'm' : 0}},
+									u'subscribe_key': u'pam',
 									u'level': u'channel', u'ttl': 10}
 								}
 	resp = pubnub_pam.publish(channel=channel,message=message)
@@ -156,8 +157,8 @@ def test_10():
 	print resp
 	assert resp == 			{
 									'message': u'Success',
-									'payload': { u'channels': {channel : {u'r': 0, u'w': 0}},
-									u'subscribe_key': u'sub-c-e8839098-f568-11e2-a11a-02ee2ddab7fe',
+									'payload': { u'channels': {channel : {u'r': 0, u'w': 0, 'm' : 0}},
+									u'subscribe_key': u'pam',
 									u'level': u'channel', u'ttl': 1}
 								}
 	resp = pubnub_pam.publish(channel=channel,message=message)
@@ -178,8 +179,8 @@ def test_11():
 	print resp
 	assert resp == 			{
 									'message': u'Success',
-									'payload': { u'r': 1, u'w': 1,
-									u'subscribe_key': u'sub-c-e8839098-f568-11e2-a11a-02ee2ddab7fe',
+									'payload': { u'r': 1, u'w': 1, 'm' : 0,
+									u'subscribe_key': u'pam',
 									u'level': u'subkey', u'ttl': 10}
 								}
 	resp = pubnub_pam.publish(channel=channel,message=message)
@@ -188,8 +189,8 @@ def test_11():
 	print resp
 	assert resp == 			{
 									'message': u'Success',
-									'payload': {u'r': 0, u'w': 0,
-									u'subscribe_key': u'sub-c-e8839098-f568-11e2-a11a-02ee2ddab7fe',
+									'payload': {u'r': 0, u'w': 0, 'm' : 0,
+									u'subscribe_key': u'pam',
 									u'level': u'subkey', u'ttl': 1}
 								}
 	resp = pubnub_pam.publish(channel=channel,message=message)