feat: test against semaphore (#17)

* feat: test against semaphore

* chore: refactor stripping module into event module

* fix: install rust non-interactively

* fix: add rust to path

* chore: travis cache

* fix: encoding bug under py3

Author: untitaker

.flake8

@@ -3,3 +3,4 @@ ignore = E203, E266, E501, W503, E402, E731
 max-line-length = 80
 max-complexity = 18
 select = B,C,E,F,W,T4,B9
+exclude=checkouts,lol*,.tox

.gitignore

@@ -18,3 +18,4 @@ venv
 .vscode/tags
 .pytest_cache
 .hypothesis
+checkouts

.travis.yml

@@ -9,6 +9,13 @@ python:
   - "3.6"
   - "3.7-dev"
 
+cache:
+  pip: true
+  directories:
+    - checkouts/semaphore/target/debug/
+    - ~/.cargo/registry/
+    - ~/.rustup/
+
 branches:
   only:
     - master
@@ -26,7 +33,10 @@ matrix:
         - zeus upload -t "application/zip+wheel" dist/*
 
 install:
+  - curl https://sh.rustup.rs -sSf | sh -s -- -y
+  - . $HOME/.cargo/env
   - pip install tox
+  - sh scripts/checkout-semaphore.sh
 
 script:
   - sh scripts/runtox.sh

pyproject.toml

@@ -0,0 +1,15 @@
+[tool.black]
+exclude = '''
+/(
+    \.git
+  | \.hg
+  | \.mypy_cache
+  | \.tox
+  | \.venv
+  | _build
+  | buck-out
+  | build
+  | dist
+  | checkouts
+)/
+'''

scripts/checkout-semaphore.sh

@@ -0,0 +1,23 @@
+#!/bin/sh
+
+# This script is able to restore partially checked out repositories,
+# repositories that have all files but no git content, repositories checked out
+# on the wrong branch, etc.
+#
+# This is mainly useful because Travis creates an empty folder in the attempt
+# to restore the build cache.
+
+set -xe
+
+if [ ! -d checkouts/semaphore/.git ]; then
+    mkdir -p checkouts/semaphore/
+fi
+
+cd checkouts/semaphore/
+git init
+git remote remove origin || true
+git remote add origin https://github.com/getsentry/semaphore
+git fetch
+git reset --hard origin/master
+git clean -f
+cargo build

sentry_sdk/client.py

@@ -3,10 +3,10 @@
 import random
 import atexit
 
-from .utils import Dsn, SkipEvent, ContextVar, Event
+from .utils import Dsn, SkipEvent, ContextVar
 from .transport import Transport
 from .consts import DEFAULT_OPTIONS, SDK_INFO
-from .stripping import strip_event, flatten_metadata
+from .event import strip_event, flatten_metadata, Event
 
 
 NO_DSN = object()

sentry_sdk/stripping.py renamed to sentry_sdk/event.py

@@ -1,8 +1,70 @@
+import uuid
+from datetime import datetime
+
 from collections import Mapping, Sequence
 
+from .utils import exceptions_from_error_tuple
 from ._compat import text_type
 
 
+def datetime_to_json(dt):
+    return dt.strftime("%Y-%m-%dT%H:%M:%SZ")
+
+
+class Event(Mapping):
+    __slots__ = ("_data", "_exc_value")
+
+    def __init__(self, data={}):
+        self._data = {
+            "event_id": uuid.uuid4().hex,
+            "timestamp": datetime_to_json(datetime.utcnow()),
+            "level": "error",
+        }
+
+        self._data.update(data)
+
+        self._exc_value = None
+
+    def set_exception(self, exc_type, exc_value, tb, with_locals):
+        self["exception"] = {
+            "values": exceptions_from_error_tuple(exc_type, exc_value, tb, with_locals)
+        }
+        self._exc_value = exc_value
+
+    def __getitem__(self, key):
+        return self._data[key]
+
+    def __contains__(self, key):
+        return key in self._data
+
+    def get(self, *a, **kw):
+        return self._data.get(*a, **kw)
+
+    def setdefault(self, *a, **kw):
+        return self._data.setdefault(*a, **kw)
+
+    def __setitem__(self, key, value):
+        self._data[key] = value
+
+    def __iter__(self):
+        return iter(self._data)
+
+    def __len__(self):
+        return len(self._data)
+
+    def iter_frames(self):
+        stacktraces = []
+        if "stacktrace" in self:
+            stacktraces.append(self["stacktrace"])
+        if "exception" in self:
+            for exception in self["exception"].get("values") or ():
+                if "stacktrace" in exception:
+                    stacktraces.append(exception["stacktrace"])
+        for stacktrace in stacktraces:
+            for frame in stacktrace.get("frames") or ():
+                yield frame
+
+
 class AnnotatedValue(object):
     def __init__(self, value, metadata):
         self.value = value

sentry_sdk/hub.py

@@ -4,7 +4,8 @@
 
 from ._compat import with_metaclass
 from .scope import Scope
-from .utils import Event, skip_internal_frames, ContextVar
+from .utils import skip_internal_frames, ContextVar
+from .event import Event
 
 
 _local = ContextVar("sentry_current_hub")

sentry_sdk/integrations/_wsgi.py

@@ -1,7 +1,7 @@
 import json
 
 from sentry_sdk.hub import _should_send_default_pii
-from sentry_sdk.stripping import AnnotatedValue
+from sentry_sdk.event import AnnotatedValue
 
 
 def get_environ(environ):

sentry_sdk/integrations/logging.py

@@ -3,9 +3,11 @@
 
 import sys
 import logging
+import datetime
 
 from sentry_sdk import get_current_hub, capture_event, add_breadcrumb
-from sentry_sdk.utils import to_string, Event, skip_internal_frames
+from sentry_sdk.utils import to_string, skip_internal_frames
+from sentry_sdk.event import Event, datetime_to_json
 from sentry_sdk.hub import _internal_exceptions
 
 from . import Integration
@@ -51,6 +53,9 @@ def _breadcrumb_from_record(self, record):
             "level": self._logging_to_event_level(record.levelname),
             "category": record.name,
             "message": record.message,
+            "timestamp": datetime_to_json(
+                datetime.datetime.fromtimestamp(record.created)
+            ),
         }
 
     def _emit(self, record):