session_redis_public/monitoring_log_requests/models/ir_http.py

# -*- coding: utf-8 -*-
# Copyright 2016 Camptocamp SA
# License AGPL-3.0 or later (http://www.gnu.org/licenses/agpl.html)

import json
import logging
import time

from openerp import models
from openerp.http import request
from openerp.tools.config import config


_logger = logging.getLogger('monitoring.http.requests')


class IrHttp(models.AbstractModel):
    _inherit = 'ir.http'

    def _dispatch(self):
        begin = time.time()
        response = super(IrHttp, self)._dispatch()
        end = time.time()
        info = self._monitoring_info(response, begin, end)
        self._monitoring_log(info)
        return response

    def _monitoring_info(self, response, begin, end):
        info = {
            # timing
            'start_time': time.strftime("%Y-%m-%d %H:%M:%S",
                                        time.gmtime(begin)),
            'duration': end - begin,
            # HTTP things
            'method': request.httprequest.method,
            'url': request.httprequest.url,
            'path': request.httprequest.environ.get('PATH_INFO'),
            'content_type': request.httprequest.environ.get('CONTENT_TYPE'),
            'user_agent': request.httprequest.environ.get('HTTP_USER_AGENT'),
            # Odoo things
            'db': None,
            'uid': request.uid,
            'login': None,
            'json_method': None,
            'server_environment': config.get('running_env'),
            'model': None,
            'model_method': None,
            # response things
            'response_status_code': response.status_code,
        }
        if hasattr(request, 'session'):
            info.update({
                'login': request.session.get('login'),
                'db': request.session.get('db'),
            })
        if hasattr(request, 'jsonrequest'):
            info['json_method'] = request.jsonrequest.get('method')
        if hasattr(request, 'params'):
            info.update({
                'model': request.params.get('model'),
                'model_method': request.params.get('method'),
            })
        return info

    def _monitoring_log(self, info):
        _logger.info(json.dumps(info))