Create make_response wrapper and execute function.

.gitignore

@@ -0,0 +1,2 @@
+__pycache__
+

lambdoo.py

@@ -0,0 +1,71 @@
+import functools
+import http
+import json
+import logging
+import os
+import ssl
+import xmlrpc.client
+
+import boto3
+
+_logger = logging.getLogger(__name__)
+_logger.setLevel(os.environ.get('LOG_LEVEL', logging.ERROR))
+
+ssm = None
+uid = None
+
+
+# https://docs.aws.amazon.com/apigateway/latest/developerguide/set-up-lambda-proxy-integrations.html#api-gateway-simple-proxy-for-lambda-output-format
+def make_response(func):
+    @functools.wraps(func)
+    def wrapper(event, context):
+        global _logger
+        _logger.debug("request %s", event)
+        try:
+            message = func(event, context) or http.HTTPStatus.OK.phrase
+            code = http.HTTPStatus.OK.value
+        except xmlrpc.client.Fault as e:
+            _logger.error(e.faultString)
+            message = e.faultString
+            code = {  # FIXME DRY magic numbers from odoo/service/wsgi_server.py
+                2: http.HTTPStatus.BAD_REQUEST.value,  # RPC_FAULT_CODE_WARNING
+                3: http.HTTPStatus.UNAUTHORIZED.value,  # RPC_FAULT_CODE_ACCESS_DENIED
+                4: http.HTTPStatus.FORBIDDEN.value,  # RPC_FAULT_CODE_ACCESS_ERROR,
+            }.get(e.faultCode, http.HTTPStatus.INTERNAL_SERVER_ERROR.value)  # RPC_FAULT_CODE_APPLICATION_ERROR
+        except xmlrpc.client.ProtocolError as e:
+            _logger.error(e.errmsg)
+            message = e.errmsg
+            code = e.errcode
+        except Exception as e:
+            _logger.exception(str(e))
+            message = http.HTTPStatus.INTERNAL_SERVER_ERROR.phrase
+            code = http.HTTPStatus.INTERNAL_SERVER_ERROR.value
+        response = {
+            'body': json.dumps({'message': message}),
+            'statusCode': code,
+        }
+        _logger.debug("response %s", response)
+        return response
+    return wrapper
+
+
+# https://www.odoo.com/documentation/15.0/developer/reference/external_api.html
+def execute(model, method, args, kwargs):
+    global ssm, uid
+    database = os.environ['ODOO_DATABASE']
+    context = ssl._create_unverified_context() if os.environ.get('SSL_NO_VERIFY') else None
+    host = os.environ['ODOO_HOST']
+    password = os.environ['ODOO_PASSWORD']
+    user = os.environ['ODOO_USER']
+
+    if password.startswith('/') or password.startswith('arn:'):
+        if not ssm:
+            ssm = boto3.client('ssm')
+        password = ssm.get_parameter(Name=password, WithDecryption=True)['Parameter']['Value']
+
+    if not uid:
+        with xmlrpc.client.ServerProxy(f"{host}/xmlrpc/2/common", context=context) as common:
+            uid = common.authenticate(database, user, password, {})
+
+    with xmlrpc.client.ServerProxy(f"{host}/xmlrpc/2/object", context=context) as object:
+        return object.execute_kw(database, uid, password, model, method, args, kwargs)