mirror of
https://github.com/PostHog/posthog.git
synced 2024-12-01 04:12:23 +01:00
7a5bcab99e
* add back hook * add back hook * filter event matcher * create artificial event to query for actions * fix test * possible solution * remove printer * reformat * remove test_event temp * comment out tests * comment out * uncomment * patch another * reduce var * fix timestamp
52 lines
1.9 KiB
Python
52 lines
1.9 KiB
Python
import re
|
|
from typing import Any, Dict
|
|
|
|
import requests
|
|
from celery import Task
|
|
from django.conf import settings
|
|
|
|
from posthog.celery import app
|
|
from posthog.models import Action, Event, Team
|
|
from posthog.tasks.webhooks import determine_webhook_type, get_formatted_message
|
|
|
|
|
|
@app.task(ignore_result=True, bind=True, max_retries=3)
|
|
def post_event_to_webhook_ee(self: Task, event: Dict[str, Any], team_id: int, site_url: str) -> None:
|
|
try:
|
|
team = Team.objects.get(pk=team_id)
|
|
_event = Event.objects.create(
|
|
event=event["event"],
|
|
distinct_id=event["distinct_id"],
|
|
properties=event["properties"],
|
|
team=team,
|
|
site_url=site_url,
|
|
**({"timestamp": event["timestamp"]} if event["timestamp"] else {}),
|
|
**({"elements": event["elements_list"]} if event["elements_list"] else {})
|
|
)
|
|
|
|
actions = Action.objects.filter(team_id=team_id, post_to_slack=True).all()
|
|
|
|
if not site_url:
|
|
site_url = settings.SITE_URL
|
|
|
|
if team.slack_incoming_webhook:
|
|
for action in actions:
|
|
qs = Event.objects.filter(pk=_event.pk).query_db_by_action(action)
|
|
if qs:
|
|
message_text, message_markdown = get_formatted_message(action, _event, site_url,)
|
|
if determine_webhook_type(team) == "slack":
|
|
message = {
|
|
"text": message_text,
|
|
"blocks": [{"type": "section", "text": {"type": "mrkdwn", "text": message_markdown},},],
|
|
}
|
|
else:
|
|
message = {
|
|
"text": message_markdown,
|
|
}
|
|
requests.post(team.slack_incoming_webhook, verify=False, json=message)
|
|
|
|
_event.delete()
|
|
|
|
except:
|
|
self.retry(countdown=2 ** self.request.retries)
|