From 99b1453493c82812333062fabe9e91143b2ff0c5 Mon Sep 17 00:00:00 2001 From: Devendra Date: Tue, 25 Nov 2014 19:29:23 +0530 Subject: channel group support admin api's only --- python/tests/test_cg.py | 107 +++++++++++++++++++++++++++++++++++++++++++++ python/tests/test_grant.py | 61 +++++++++++++------------- 2 files changed, 138 insertions(+), 30 deletions(-) create mode 100644 python/tests/test_cg.py (limited to 'python/tests') 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) -- cgit v1.2.3