@@ -45,6 +45,7 @@ def _get(self, path, **params):
45
45
def _post (self , path , params ):
46
46
return self ._request ('POST' , path , params = params )
47
47
48
+ #stream functionality
48
49
def send (self , feed_name , data ):
49
50
feed_name = quote (feed_name )
50
51
path = "api/feeds/{}/streams/send" .format (feed_name )
@@ -76,3 +77,32 @@ def create_stream(self, feed_id_or_key, data):
76
77
path = "api/feeds/{}/streams" .format (feed_id_or_key )
77
78
return self ._post (path , data )
78
79
80
+ #group functionality
81
+ def send_group (self , group_name , data ):
82
+ group_name = quote (group_name )
83
+ path = "api/groups/{}/send" .format (group_name )
84
+ return self ._post (path , {'value' : data })
85
+
86
+ def receive_group (self , group_name ):
87
+ group_name = quote (group_name )
88
+ path = "api/groups/{}/last" .format (group_name )
89
+ return self ._get (path )
90
+
91
+ def receive_next_group (self , group_name ):
92
+ group_name = quote (group_name )
93
+ path = "api/groups/{}/next" .format (group_name )
94
+ return self ._get (path )
95
+
96
+ def receive_previous_group (self , group_name ):
97
+ group_name = quote (group_name )
98
+ path = "api/groups/{}/last" .format (group_name )
99
+ return self ._get (path )
100
+
101
+ def groups (self , group_id_or_key ):
102
+ path = "api/groups/{}" .format (group_id_or_key )
103
+ return self ._get (path )
104
+
105
+ def create_group (self , group_id_or_key , data ):
106
+ path = "api/groups/{}" .format (group_id_or_key )
107
+ return self ._post (path , data )
108
+
0 commit comments