mirror of
https://github.com/PostHog/posthog.git
synced 2024-11-28 00:46:45 +01:00
008ee1f04c
* Use `statshog` over python-statsd More support for tags! * Include custom tags for every query + add annotation to query After this we can: - Figure out from query logs where queries are coming from (speeding up debugging) - Break down query speeds by user queries vs others (e.g. celery) -- better represents overall speed - Can figure out how fast queries are on average for various teams * Use tags in more queries over interpolation This way we can set up more interesting graphs \o/ * Solve mypy error * Fix a flaky test (due to ordering)
36 lines
1.4 KiB
Python
36 lines
1.4 KiB
Python
from typing import Optional
|
|
|
|
from django.db import models
|
|
from rest_hooks.models import AbstractHook
|
|
from statshog.defaults.django import statsd
|
|
|
|
from ee.tasks.hooks import DeliverHook
|
|
from posthog.models.team import Team
|
|
from posthog.models.utils import generate_random_token
|
|
|
|
|
|
class Hook(AbstractHook):
|
|
id = models.CharField(primary_key=True, max_length=50, default=generate_random_token)
|
|
user = models.ForeignKey("posthog.User", related_name="rest_hooks", on_delete=models.CASCADE)
|
|
team = models.ForeignKey("posthog.Team", related_name="rest_hooks", on_delete=models.CASCADE)
|
|
resource_id = models.IntegerField(null=True, blank=True)
|
|
|
|
|
|
def find_and_fire_hook(
|
|
event_name: str, instance: models.Model, user_override: Team, payload_override: Optional[dict] = None,
|
|
):
|
|
if not user_override.organization.is_feature_available("zapier"):
|
|
return
|
|
hooks = Hook.objects.filter(event=event_name, team=user_override)
|
|
if event_name == "action_performed":
|
|
# action_performed is a resource_id-filterable hook
|
|
hooks = hooks.filter(models.Q(resource_id=instance.pk))
|
|
for hook in hooks:
|
|
statsd.incr("posthog_cloud_hooks_rest_fired")
|
|
hook.deliver_hook(instance, payload_override)
|
|
|
|
|
|
def deliver_hook_wrapper(target, payload, instance, hook):
|
|
# pass IDs not objects because using pickle for objects is a bad thing
|
|
DeliverHook.apply_async(kwargs=dict(target=target, payload=payload, hook_id=hook.id))
|