wip

Author: jonathanlloyd

.dev_requirements.txt.swp

@@ -1,2 +1,3 @@
 nose
 pylint
+requests-mock

dev_requirements.txt

@@ -1,7 +1,10 @@
 """Pusher Push Notifications Python server SDK"""
 
+import requests
 import six
 
+SDK_VERSION = '0.9.0'
+
 
 class PushNotifications(object):
     """Pusher Push Notifications API client
@@ -28,3 +31,18 @@ def endpoint(self):
             self.instance_id,
         )
         return self._endpoint or default_endpoint
+
+    def publish(self, publish_body):
+        requests.post(
+            'https://{}/publish_api/v1/instances/{}/publishes'.format(
+                self.endpoint,
+                self.instance_id,
+            ),
+            json=publish_body,
+            headers={
+                'authorization': 'Bearer {}'.format(self.secret_key),
+                'x-pusher-library': 'pusher-push-notifications-python {}'.format(
+                    SDK_VERSION,
+                )
+            },
+        )

pusher_push_notifications/__init__.py

@@ -1 +1,2 @@
 six==1.10.0
+requests==2.18.4

requirements.txt

@@ -2,6 +2,8 @@
 
 import unittest
 
+import requests_mock
+
 from pusher_push_notifications import PushNotifications
 
 
@@ -54,3 +56,58 @@ def test_constructor_should_accept_endpoint_override(self):
             pn_client.endpoint,
             'example.com/push',
         )
+
+    def test_publish_should_make_correct_http_request(self):
+        pn_client = PushNotifications(
+            'INSTANCE_ID',
+            'SECRET_KEY'
+        )
+        with requests_mock.Mocker() as http_mock:
+            http_mock.register_uri(
+                requests_mock.ANY,
+                requests_mock.ANY,
+            )
+            pn_client.publish({
+                'interests': ['donuts'],
+                'apns': {
+                    'aps': {
+                        'alert': 'Hello World!',
+                    },
+                },
+            })
+            req = http_mock.request_history[0]
+
+        method = req.method
+        path = req.path
+        headers = dict(req._request.headers.lower_items())
+        body = req.json()
+
+        self.assertEqual(
+            method,
+            'POST',
+        )
+        self.assertEqual(
+            path,
+            '/publish_api/v1/instances/instance_id/publishes',
+        )
+        self.assertDictEqual(
+            headers,
+            {
+                'content-type': 'application/json',
+                'content-length': '69',
+                'authorization': 'Bearer SECRET_KEY',
+                'x-pusher-library': 'pusher-push-notifications-python 0.9.0',
+                'host': 'instance_id.pushnotifications.pusher.com',
+            },
+        )
+        self.assertDictEqual(
+            body,
+            {
+                'interests': ['donuts'],
+                'apns': {
+                    'aps': {
+                        'alert': 'Hello World!',
+                    },
+                },
+            },
+        )