[ADD] virtual beneficiary option

Author: teloconf

VERSION

@@ -1 +1 @@
-1.1.0
+1.2.0

examples/ais/accounts.py

@@ -12,7 +12,7 @@
 
 print("Searching customer accounts...")
 
-customer_id = 'f1923614953cb0e1f1da8b5c016fd5a7'
+customer_id = 'a95784c3ddfed8f3f20790c4ad338569'
 
 resp = fintecture.Customer.get_accounts(customer_id)
 

examples/ais/connect.py

@@ -7,7 +7,7 @@
 
 print("Searching URL to connect with AIS...")
 
-redirect_uri = 'https://webhook.site/5940c656-7fd3-40a0-ad41-9cfba1e986f3'
+redirect_uri = 'https://webhook.site/4ff3f300-c82c-4b4f-b92e-d0691656a663'
 
 resp = fintecture.AIS.connect(
     app_id=os.environ.get("FINTECTURE_APP_ID"),

examples/ais/oauth.py

@@ -11,7 +11,7 @@
 
 print("After user connect him account you will receive in your webhook a code for authenticate")
 
-code = 'ec2c1ee4d1f40f4db60ea30f4ea4769d'
+code = '5ebc08acf13a866a0a97c2a37013cb28'
 token_resp = fintecture.AIS.oauth(code=code)
 
 fintecture.access_token = token_resp['access_token']

examples/pis/connect.py

@@ -4,12 +4,10 @@
 
 import fintecture
 
-
 fintecture.app_id = os.environ.get("FINTECTURE_APP_ID")
 fintecture.app_secret = os.environ.get("FINTECTURE_APP_SECRET")
 fintecture.private_key = os.environ.get("FINTECTURE_PRIVATE_KEY")
 
-
 try:
     print("Searching URL to connect with PIS...")
 
@@ -23,6 +21,7 @@
 
     resp_connect = fintecture.PIS.connect(
         state="1234",
+        with_virtualbeneficiary=True,
         meta={
             'psu_name': 'M. John Doe',
             'psu_email': 'john@doe.com',
@@ -35,13 +34,17 @@
                 'city': 'Gotham',
                 'country': 'FR',
             },
+            "reconciliation": {
+                "level": "payment_session",
+                "match_amount": True
+            }
         },
         data={
-            'type': 'SEPA',
+            'type': 'connect',
             'attributes': {
                 'amount': '550.60',
                 'currency': 'EUR',
-                'communication': 'Order 15654'
+                'communication': 'Order 15654',
             }
         }
     )

examples/pis/request_pays.py

@@ -62,6 +62,7 @@
 resp_request_to_pay = fintecture.PIS.request_to_pay(
     redirect_uri,
     language='es',
+    state='85321',
     meta={
         'psu_name': 'M. John Doe',
         'psu_email': 'john@doe.com',
@@ -95,4 +96,4 @@
 # session_id        fee8b638c1c44af1a4a2dd7dd781ecf8
 # status            payment_created
 # provider          cmcifrpp
-# state             1234
+# state             85321

fintecture/api_resources/__init__.py

@@ -1,11 +1,13 @@
+# File generated from our OpenAPI spec
 from __future__ import absolute_import, division, print_function
 
 # flake8: noqa
 
-from fintecture.api_resources.error_object import ErrorObject
+from fintecture.api_resources.error_object import ErrorObject, OAuthErrorObject
 from fintecture.api_resources.list_object import ListObject
 from fintecture.api_resources.search_result_object import SearchResultObject
 
+from fintecture.api_resources import identity
 from fintecture.api_resources import test_helpers
 
 from fintecture.api_resources.ais import AIS

fintecture/api_resources/abstract/api_resource.py

@@ -49,17 +49,21 @@ def _request(
         self,
         method_,
         url_,
-        app_id=None,
+        api_key=None,
+        idempotency_key=None,
         fintecture_version=None,
+        fintecture_account=None,
         headers=None,
         params=None,
     ):
         obj = FintectureObject._request(
             self,
             method_,
             url_,
-            app_id,
+            api_key,
+            idempotency_key,
             fintecture_version,
+            fintecture_account,
             headers,
             params,
         )
@@ -77,7 +81,9 @@ def _request_and_refresh(
         method_,
         url_,
         app_id=None,
+        idempotency_key=None,
         fintecture_version=None,
+        fintecture_account=None,
         headers=None,
         params=None,
     ):
@@ -86,7 +92,9 @@ def _request_and_refresh(
             method_,
             url_,
             app_id,
+            idempotency_key,
             fintecture_version,
+            fintecture_account,
             headers,
             params,
         )
@@ -102,32 +110,69 @@ def _static_request(
         method_,
         url_,
         app_id=None,
+        idempotency_key=None,
         fintecture_version=None,
+        fintecture_account=None,
         params=None,
     ):
         params = None if params is None else params.copy()
+        idempotency_key = util.read_special_variable(
+            params, "idempotency_key", idempotency_key
+        )
         fintecture_version = util.read_special_variable(
             params, "fintecture_version", fintecture_version
         )
-        fintecture_app_id = util.read_special_variable(
-            params, "app_id", app_id
-        )
-        fintecture_app_secret = util.read_special_variable(
-            params, "app_secret", None
-        )
-        fintecture_private_key = util.read_special_variable(
-            params, "private_key", None
+        fintecture_account = util.read_special_variable(
+            params, "fintecture_account", fintecture_account
         )
         headers = util.read_special_variable(params, "headers", None)
 
         requestor = api_requestor.APIRequestor(
-            app_id=fintecture_app_id,
-            app_secret=fintecture_app_secret,
-            private_key=fintecture_private_key,
-            api_version=fintecture_version,
+            app_id, api_version=fintecture_version, account=fintecture_account
         )
 
-        response, my_app_id = requestor.request(method_, url_, params, headers)
+        if idempotency_key is not None:
+            headers = {} if headers is None else headers.copy()
+            headers.update(util.populate_headers(idempotency_key))
+
+        response, api_key = requestor.request(method_, url_, params, headers)
         return util.convert_to_fintecture_object(
-            response, my_app_id, fintecture_version, params
+            response, api_key, fintecture_version, fintecture_account, params
+        )
+
+    # The `method_` and `url_` arguments are suffixed with an underscore to
+    # avoid conflicting with actual request parameters in `params`.
+    @classmethod
+    def _static_request_stream(
+        cls,
+        method_,
+        url_,
+        api_key=None,
+        idempotency_key=None,
+        fintecture_version=None,
+        fintecture_account=None,
+        params=None,
+    ):
+        params = None if params is None else params.copy()
+        api_key = util.read_special_variable(params, "api_key", api_key)
+        idempotency_key = util.read_special_variable(
+            params, "idempotency_key", idempotency_key
+        )
+        fintecture_version = util.read_special_variable(
+            params, "fintecture_version", fintecture_version
         )
+        fintecture_account = util.read_special_variable(
+            params, "fintecture_account", fintecture_account
+        )
+        headers = util.read_special_variable(params, "headers", None)
+
+        requestor = api_requestor.APIRequestor(
+            api_key, api_version=fintecture_version, account=fintecture_account
+        )
+
+        if idempotency_key is not None:
+            headers = {} if headers is None else headers.copy()
+            headers.update(util.populate_headers(idempotency_key))
+
+        response, _ = requestor.request_stream(method_, url_, params, headers)
+        return response

fintecture/api_resources/abstract/createable_api_resource.py

@@ -7,14 +7,18 @@ class CreateableAPIResource(APIResource):
     @classmethod
     def create(
         cls,
-        app_id=None,
+        api_key=None,
+        idempotency_key=None,
         fintecture_version=None,
+        fintecture_account=None,
         **params
     ):
         return cls._static_request(
             "post",
             cls.class_url(),
-            app_id,
+            api_key,
+            idempotency_key,
             fintecture_version,
+            fintecture_account,
             params,
         )

fintecture/api_resources/abstract/custom_method.py

@@ -4,10 +4,10 @@
 from fintecture.six.moves.urllib.parse import quote_plus
 
 
-def custom_method(name, http_verb, http_path=None):
-    if http_verb not in ["get", "post", "patch", "delete"]:
+def custom_method(name, http_verb, http_path=None, is_streaming=False):
+    if http_verb not in ["get", "post", "delete"]:
         raise ValueError(
-            "Invalid http_verb: %s. Must be one of 'get', 'post', 'patch' or 'delete'"
+            "Invalid http_verb: %s. Must be one of 'get', 'post' or 'delete'"
             % http_verb
         )
     if http_path is None:
@@ -29,7 +29,18 @@ def custom_method_request(cls, sid, **params):
 
             return obj
 
-        class_method_impl = classmethod(custom_method_request)
+        def custom_method_request_stream(cls, sid, **params):
+            url = "%s/%s/%s" % (
+                cls.class_url(),
+                quote_plus(util.utf8(sid)),
+                http_path,
+            )
+            return cls._static_request_stream(http_verb, url, params=params)
+
+        if is_streaming:
+            class_method_impl = classmethod(custom_method_request_stream)
+        else:
+            class_method_impl = classmethod(custom_method_request)
 
         existing_method = getattr(cls, name, None)
         if existing_method is None: