First commit

Author: bhch

.gitignore

@@ -0,0 +1,19 @@
+__pycache__/
+*.py[cod]
+
+env/
+bin/
+build/
+_build/
+develop-eggs/
+dist/
+eggs/
+lib/
+lib64/
+parts/
+sdist/
+var/
+*.egg-info/
+*.egg
+.eggs
+.installed.cfg

LICENSE.txt

@@ -0,0 +1,26 @@
+Copyright (c) 2021, Bharat Chauhan
+
+Redistribution and use in source and binary forms, with or without modification, 
+are permitted provided that the following conditions are met:
+
+1. Redistributions of source code must retain the above copyright notice, this 
+list of conditions and the following disclaimer.
+
+2. Redistributions in binary form must reproduce the above copyright notice, 
+this list of conditions and the following disclaimer in the documentation and/or 
+other materials provided with the distribution.
+
+3. Neither the name of the copyright holder nor the names of its contributors 
+may be used to endorse or promote products derived from this software without 
+specific prior written permission.
+
+THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" 
+AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, 
+THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE 
+ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE 
+FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL 
+DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR 
+SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER 
+CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, 
+OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE 
+OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.

README.md

@@ -0,0 +1,35 @@
+# async-stripe
+
+An asynchronous wrapper around the official stripe library. 
+
+/!\ **Note:** This is still a work in progress and doesn't provide async support 
+for all the resources yet.
+
+## Usage
+
+The usage api is kept very similar to stripe's official library:
+
+```python
+from async_stripe import stripe
+
+stripe.api_key = '<stripe-secret-key>'
+
+payment_intent = await stripe.PaymentIntent.create(amount=1000, currency='usd')
+
+print(payment_intent.id)
+```
+
+### Sync usage
+
+Currently, only a limited operations have async usage. For those cases, you'll 
+have to fall back to using sync code (without the `await` keyword).
+
+## Requirements
+
+ + Tornado (used for making async http requests)
+ + stripe (official stripe library)
+
+
+## License
+
+[BSD-3-Clause](LICENSE.txt)

async_stripe/__init__.py

@@ -0,0 +1 @@
+from .patched_stripe import stripe

async_stripe/patched_stripe.py

@@ -0,0 +1,29 @@
+import stripe as real_stripe
+from .resources import (
+    AsyncPaymentMethod, AsyncPaymentIntent, AsyncCustomer
+    )
+
+class Stripe:
+    def __init__(self):
+        self._api_key = None
+        self._public_key = None
+        self._webhook_secret = None
+
+    PaymentMethod = AsyncPaymentMethod
+    PaymentIntent = AsyncPaymentIntent
+    Customer = AsyncCustomer
+
+    @property
+    def api_key(self):
+        return self._api_key
+
+    @api_key.setter
+    def api_key(self, value):
+        self._api_key = value
+        real_stripe.api_key = value
+
+    def __getattr__(self, name):
+            return getattr(real_stripe, name)
+
+
+stripe = Stripe()

async_stripe/resources/__init__.py

@@ -0,0 +1,16 @@
+from .base import AsyncBaseResource, BASE_URL
+
+class AsyncPaymentMethod(AsyncBaseResource):
+    resource = 'PaymentMethod'
+    url = BASE_URL + 'payment_methods'  
+
+
+class AsyncPaymentIntent(AsyncBaseResource):
+    resource = 'PaymentIntent'
+    url = BASE_URL + 'payment_intents'
+
+
+class AsyncCustomer(AsyncBaseResource):
+    resource = 'Customer'
+    url = BASE_URL + 'customers'
+    

async_stripe/resources/base.py

@@ -0,0 +1,65 @@
+import json
+from urllib.parse import urlencode
+from tornado.httpclient import AsyncHTTPClient, HTTPError
+from stripe.api_requestor import _api_encode
+from async_stripe.patched_stripe import real_stripe
+
+
+BASE_URL = 'https://api.stripe.com/v1/'
+
+
+client = AsyncHTTPClient()
+
+
+class ResourceMetaclass(type):
+    def __getattr__(cls, name):
+        resource = getattr(real_stripe, cls.resource)
+        return getattr(resource, name)
+
+
+class AsyncBaseResource(metaclass=ResourceMetaclass):
+    @classmethod
+    async def fetch(cls, url, method='GET', data=None):
+        if data:
+            body = urlencode(list(_api_encode(data)), doseq=True)
+        else:
+            body = None
+
+        try:
+            response = await client.fetch(
+                url,
+                method=method,
+                auth_username=real_stripe.api_key,
+                body=body
+            )
+        except HTTPError as e:
+            # :TODO: log exception
+            if hasattr(e, 'response'):
+                print('ERROR:', e.code)
+                print(e.response.body)
+            raise
+        except Exception as e:
+            # :TODO: log exception
+            raise
+        else:
+            obj = real_stripe.util.convert_to_stripe_object(json.loads(response.body), real_stripe.api_key)
+            return obj
+
+    @classmethod
+    async def retrieve(cls, id):
+        url = cls.url + '/' + id
+        obj = await cls.fetch(url)
+        return obj
+
+    @classmethod
+    async def create(cls, **kwargs):
+        url = cls.url
+        obj = await cls.fetch(url, method='POST', data=kwargs)
+        return obj
+
+    @classmethod
+    async def modify(cls, id, **kwargs):
+        url = cls.url + '/' + id
+        obj = await cls.fetch(url, method='POST', data=kwargs)
+        return obj
+