/usr/share/pyshared/oops_twisted/log.py is in python-oops-twisted 0.0.6-0ubuntu2.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 | # Copyright (c) 2010, 2011, Canonical Ltd
#
# This program is free software: you can redistribute it and/or modify
# it under the terms of the GNU Lesser General Public License as published by
# the Free Software Foundation, version 3 only.
#
# This program is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
# GNU Lesser General Public License for more details.
#
# You should have received a copy of the GNU Lesser General Public License
# along with this program. If not, see <http://www.gnu.org/licenses/>.
# GNU Lesser General Public License version 3 (see the file LICENSE).
"""twisted.log observer to create OOPSes for failures."""
__metaclass__ = type
import datetime
from pytz import utc
from twisted.python.log import (
ILogObserver,
textFromEventDict,
)
from zope.interface import implements
__all__ = [
'OOPSObserver',
]
class OOPSObserver:
"""Convert twisted log events to OOPSes if they are failures."""
implements(ILogObserver)
def __init__(self, config, fallback=None):
""""Create an OOPSObserver.
:param config: An oops_twisted.Config.
:param fallback: If supplied, a callable to pass non-failure log
events to, and to inform (as non-failures) when an OOPS has
occurred.
"""
self.config = config
assert fallback is None or callable(fallback)
self.fallback = fallback
def emit(self, eventDict):
"""Handle a twisted log entry.
Note that you should generally pass the actual observer to twisted
functions, as the observer instance 'implements' ILogObserver, but the
emit method does not (and cannot).
:return: For testing convenience returns the oops report and a deferred
which fires after all publication and fallback forwarding has
occured, though the twisted logging protocol does not need (or
examine) the return value.
"""
if not eventDict.get('isError'):
if self.fallback:
self.fallback(eventDict)
return None, None
context = {}
context['twisted_failure'] = eventDict.get('failure')
report = self.config.create(context)
report['time'] = datetime.datetime.fromtimestamp(
eventDict['time'], utc)
report['tb_text'] = textFromEventDict(eventDict)
d = self.config.publish(report)
if self.fallback:
d.addCallback(self._fallback_report, report, dict(eventDict))
return report, d
__call__ = emit
def _fallback_report(self, ids, report, event):
# If ids is empty, no publication occured so there is no id to forward:
# don't alter the event at all in this case.
if ids:
event['isError'] = False
event.pop('failure', None)
event['message'] = ["Logged OOPS id %s: %s: %s" % (
report['id'], report.get('type', 'No exception type'),
report.get('value', 'No exception value'))]
if ids is not None:
self.fallback(event)
|