lambdoo.py

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)