Merge pull request #41 from pnegahdar/master

Fixed

Author: mahmoudimus

render_docs.py

@@ -0,0 +1,113 @@
+import glob2
+import os
+import json
+from mako.template import Template
+from mako.lookup import TemplateLookup
+
+
+def delete_by_file_type(file_type):
+    for each in glob2.glob('./scenarios/**/{}'.format(file_type)):
+        os.remove(each)
+
+
+def create_definitions(path):
+    with open(path, 'r') as py_mako:
+        content = py_mako.read()
+        try:
+            def_part = content.split("% if mode == 'definition':")[1] \
+                .split('% else:')[0]
+        except IndexError:
+            print "WARNING {} skipped".format(path)
+            def_part =  ''
+        def_part = def_part.strip()
+    path_to_write = os.path.dirname(path)
+    with open(os.path.join(path_to_write, 'definition.mako'),
+              'w+') as write_file:
+        write_file.write(def_part)
+    return def_part
+
+
+
+def create_request(path):
+    with open(path, 'r') as py_mako:
+        content = py_mako.read()
+        try:
+            request_part = content.split("% else:")[1] \
+                .split('% endif')[0]
+        except IndexError:
+            print "WARNING {} skipped".format(path)
+            request_part =  ''
+        request_part = request_part.strip()
+    path_to_write = os.path.dirname(path)
+    with open(os.path.join(path_to_write, 'request.mako'),'w+') as write_file:
+        write_file.write(request_part)
+    return request_part
+
+
+
+def run_fix():
+    for path in glob2.glob('./scenarios/**/python.mako'):
+        def_part = create_definitions(path)
+        req_part = create_request(path)
+        os.rename(path, os.path.join(os.path.dirname(path), 'original.mako'))
+
+
+def fix_main_mako():
+    with open('./scenarios/_main.mako', 'r') as file_name:
+        data = file_name.read()
+        new_data= data.replace('ctx.', '')
+    with open('./scenarios/_main.mako', 'w+b') as file_name:
+        file_name.write(new_data)
+
+
+
+def render_exec():
+    data = json.load(open('scenario.cache','r'))
+    lookup = TemplateLookup(directories=['./scenarios'])
+    for path in glob2.glob('./scenarios/**/original.mako'):
+        event_name = path.split('/')[-2]
+        template = Template(filename=path, lookup=lookup,)
+        try:
+            request = data[event_name].get('request', {})
+            payload = request.get('payload')
+            text = template.render(api_key=data['api_key'],
+                                  request=request, payload=payload).strip()
+            with open(os.path.join(os.path.dirname(path),
+                                   '{}.py'.format(event_name)),
+                                   'w+'
+                      ) as write_to:
+                write_to.write(text)
+        except KeyError:
+            print "WARN: Skipped {} since {} not in scenario.cache".format(
+                path, event_name)
+
+def render_rest():
+    for path in glob2.glob('./scenarios/**/*.py'):
+        dir = os.path.dirname(path)
+        with open(os.path.join(dir, 'python.mako'), 'w+b') as wfile:
+            top = open(os.path.join(dir, 'definition.mako'),'r').read()
+            bottom = open(path).read()
+            body = "% if mode == 'definition':\n\n{}".format(top) + "\n% " \
+                            "else:\n" + bottom + "\n\n% endif"
+            wfile.write(body)
+
+
+
+
+
+if __name__ == "__main__":
+    print "Setting up"
+    delete_by_file_type('curl.mako')
+    delete_by_file_type('__init__.py')
+    delete_by_file_type('metadata.py')
+    delete_by_file_type('php.mako')
+    delete_by_file_type('ruby.mako')
+    fix_main_mako()
+    print "Fixing"
+    run_fix()
+    print "Making Executables"
+    render_exec()
+    print "Rendering new mako files"
+    render_rest()
+
+

scenario.cache

@@ -0,0 +1,187 @@
+<%def name="recursive_expand(dikt, delimiter='\\')">
+<%
+    if not dikt:
+        raise StopIteration
+    
+    keys = sorted(dikt.keys(), key=lambda x: isinstance(dikt[x], dict))
+    try:
+        last = keys[-1]
+    except IndexError:
+        last = keys[0]
+    
+    lines = []
+    for k in keys:
+        if isinstance(dikt[k], dict):
+            for subk, v, slash in recursive_expand(dikt[k], delimiter):
+                lines.append(('{0}[{1}]'.format(k, subk), v, slash))
+        else:
+            lines.append((k, dikt[k], '' if k is last else delimiter))
+    return lines
+%>
+</%def>
+
+## http://stackoverflow.com/a/6701741/133514
+<%def name="route_for_endpoint(endpoint, select=None)">
+<%
+  return context['Endpoint'](ctx, endpoint, select)
+%>
+</%def>
+
+<%def name="interpolate_uri(uri, **kwargs)">
+<%
+  # this basically parses :bank_account_id to a string with {bank_account_id}
+  # for much easier interpolation.
+  import re
+  # note that it shouldn't start with a digit!
+  _uri = re.sub('(:([^\d]\w+))+', r'{\2}', uri)
+  return _uri.format(**kwargs)
+%>
+</%def>
+
+<%def name="make_endpoint(endpoint_name, select=None)">
+<%
+  return context['Endpoint'](ctx, endpoint_name, select)
+%>
+</%def>
+
+<%def name="php_boilerplate()">
+## i'm putting this between an interpolation because pycharm's introspection
+## correctly detects that this is an unclosed tag and warns me..annoying.
+${"<?php"}
+
+require(__DIR__ . '/vendor/autoload.php');
+
+Httpful\Bootstrap::init();
+RESTful\Bootstrap::init();
+Balanced\Bootstrap::init();
+
+%if api_location:
+Balanced\Settings::configure("${api_location}", "${api_key}");
+%else:
+Balanced\Settings::$api_key = "${api_key}";
+%endif
+
+</%def>
+
+<%def name="python_boilerplate()">
+import balanced
+
+%if api_location:
+balanced.config.root_uri = "${api_location}"
+%endif
+balanced.configure("${api_key}")
+
+</%def>
+
+<%def name="ruby_boilerplate()">
+require 'balanced'
+%if api_location:
+<%
+  import urlparse
+  parsed_url = urlparse.urlparse(api_location)
+  _root_url = parsed_url.netloc
+  if ':' in _root_url:
+      _root_url, _, _ = parsed_url.netloc.partition(':')
+
+%>
+options = {
+  :scheme => 'http',
+  :host => '${_root_url}',
+  :port => 5000,
+}
+Balanced.configure('${api_key}', options)
+%else:
+Balanced.configure('${api_key}')
+%endif
+</%def>
+
+
+<%def name="curl_show_template(endpoint_name)">
+% if mode == 'definition':
+<%
+  ep = Endpoint(ctx, endpoint_name, select='shortest')
+%>
+   ${ep.method} ${ep.url}
+% else:
+  <%
+    slash = '\\'
+  %>
+  curl ${Endpoint.qualify_uri(ctx, request['uri'])} ${slash}
+     -u ${api_key}:
+% endif
+</%def>
+
+
+<%def name="curl_create_template(endpoint_name, uri='uri', ep=None)">
+<%
+  ep = Endpoint(ctx, endpoint_name, select='shortest')
+%>
+%if mode == 'definition':
+   ${ep.method} ${ep.url}
+%elif mode == 'request':
+  <%
+    slash = '\\'
+  %>
+  curl ${Endpoint.qualify_uri(ctx, request[uri])} ${slash}
+     -u ${api_key}: ${slash}
+  %if 'payload' in request:
+   %for k, v, slash in recursive_expand(request['payload']):
+     -d "${k}=${v}" ${slash}
+   %endfor
+  %else:
+     -X POST
+  %endif
+%endif
+</%def>
+
+<%def name="curl_update_template(endpoint_name, uri='uri', ep=None)">
+<%
+  ep = Endpoint(ctx, endpoint_name, select='shortest')
+%>
+%if mode == 'definition':
+   ${ep.method} ${ep.url}
+%elif mode == 'request':
+  <%
+    slash = '\\'
+  %>
+  curl ${Endpoint.qualify_uri(ctx, request[uri])} ${slash}
+     -u ${api_key}: ${slash}
+     -X PUT ${slash}
+   %for k, v, slash in recursive_expand(request['payload']):
+     -d "${k}=${v}" ${slash}
+   %endfor
+%endif
+</%def>
+
+
+<%def name="curl_list_template(endpoint_name, limit=2, ep=None)">
+<%
+  ep = Endpoint(ctx, endpoint_name, select='shortest')
+%>
+% if request == 'definition':
+  ${ep.method} ${ep.url}
+%elif mode == 'request':
+  <%
+    slash = '\\'
+  %>
+   curl ${Endpoint.qualify_uri(ctx, request['uri'], limit=limit)} ${slash}
+      -u ${api_key}:
+% endif
+</%def>
+
+<%def name="curl_delete_template(endpoint_name, ep=None)">
+<%
+  ep = Endpoint(ctx, endpoint_name)
+%>
+% if mode == 'definition':
+  ${ep.method} ${ep.url}
+% else:
+  <%
+    slash = '\\'
+  %>
+   curl ${Endpoint.qualify_uri(ctx, request['uri'])} ${slash}
+     -u ${api_key}: ${slash}
+     -X DELETE
+% endif
+</%def>
+

scenarios/_main.mako

@@ -0,0 +1,7 @@
+import balanced
+
+balanced.configure("46c08048cd8811e2acae026ba7c1aba6")
+
+
+account = balanced.Account.find('/v1/marketplaces/TEST-MP29J5STPtZVvnjAFndM0N62/accounts/AC1SUaFl5mNtKGOA3LeO2IxN')
+account.add_card('/v1/marketplaces/TEST-MP29J5STPtZVvnjAFndM0N62/cards/CC1UxG1UwXYFcslMhp4wq2Mg')

scenarios/account_add_card/account_add_card.py

@@ -0,0 +1 @@
+balanced.Account.add_card

scenarios/account_add_card/definition.mako

@@ -0,0 +1,13 @@
+% if mode == 'definition':
+
+balanced.Account.add_card
+% else:
+import balanced
+
+balanced.configure("46c08048cd8811e2acae026ba7c1aba6")
+
+
+account = balanced.Account.find('/v1/marketplaces/TEST-MP29J5STPtZVvnjAFndM0N62/accounts/AC1SUaFl5mNtKGOA3LeO2IxN')
+account.add_card('/v1/marketplaces/TEST-MP29J5STPtZVvnjAFndM0N62/cards/CC1UxG1UwXYFcslMhp4wq2Mg')
+
+% endif

scenarios/account_add_card/python.mako

@@ -0,0 +1,7 @@
+import balanced
+
+balanced.configure("46c08048cd8811e2acae026ba7c1aba6")
+
+
+account = balanced.Account.find('/v1/marketplaces/TEST-MP29J5STPtZVvnjAFndM0N62/accounts/AC1SUaFl5mNtKGOA3LeO2IxN')
+account.add_card('/v1/marketplaces/TEST-MP29J5STPtZVvnjAFndM0N62/cards/CC1UxG1UwXYFcslMhp4wq2Mg')

scenarios/account_add_card/request.mako

@@ -0,0 +1,7 @@
+import balanced
+
+balanced.configure("46c08048cd8811e2acae026ba7c1aba6")
+
+
+account = balanced.Account.find('/v1/marketplaces/TEST-MP29J5STPtZVvnjAFndM0N62/accounts/AC41WWE1V0nZtw5J8BicNwnB')
+account.debit(amount=1000, hold_uri='/v1/marketplaces/TEST-MP29J5STPtZVvnjAFndM0N62/holds/HL4b3zuvRlumVNFMeKl0h5Pk')

scenarios/account_capture_hold/account_capture_hold.py

@@ -0,0 +1 @@
+balanced.Account.debit()

scenarios/account_capture_hold/definition.mako

@@ -0,0 +1,13 @@
+% if mode == 'definition':
+
+balanced.Account.debit()
+% else:
+import balanced
+
+balanced.configure("46c08048cd8811e2acae026ba7c1aba6")
+
+
+account = balanced.Account.find('/v1/marketplaces/TEST-MP29J5STPtZVvnjAFndM0N62/accounts/AC41WWE1V0nZtw5J8BicNwnB')
+account.debit(amount=1000, hold_uri='/v1/marketplaces/TEST-MP29J5STPtZVvnjAFndM0N62/holds/HL4b3zuvRlumVNFMeKl0h5Pk')
+
+% endif

scenarios/account_capture_hold/python.mako

@@ -0,0 +1,7 @@
+import balanced
+
+balanced.configure("46c08048cd8811e2acae026ba7c1aba6")
+
+
+account = balanced.Account.find('/v1/marketplaces/TEST-MP29J5STPtZVvnjAFndM0N62/accounts/AC41WWE1V0nZtw5J8BicNwnB')
+account.debit(amount=1000, hold_uri='/v1/marketplaces/TEST-MP29J5STPtZVvnjAFndM0N62/holds/HL4b3zuvRlumVNFMeKl0h5Pk')

scenarios/account_capture_hold/request.mako

@@ -0,0 +1,6 @@
+import balanced
+
+balanced.configure("46c08048cd8811e2acae026ba7c1aba6")
+
+
+account = balanced.Account().save()

scenarios/account_create/account_create.py

@@ -0,0 +1 @@
+balanced.Account(...).save()

scenarios/account_create/definition.mako

@@ -0,0 +1,12 @@
+% if mode == 'definition':
+
+balanced.Account(...).save()
+% else:
+import balanced
+
+balanced.configure("46c08048cd8811e2acae026ba7c1aba6")
+
+
+account = balanced.Account().save()
+
+% endif