Skip to content
Merged
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
66 changes: 34 additions & 32 deletions backend/api/views.py
Original file line number Diff line number Diff line change
Expand Up @@ -13,6 +13,39 @@

import posthog
import pytz
from dateutil import parser
from dateutil.relativedelta import relativedelta
from django.conf import settings
from django.db.models import (
Count,
DecimalField,
F,
Max,
Min,
OuterRef,
Prefetch,
Q,
Subquery,
Sum,
Value,
)
from django.db.models.functions import Coalesce
from django.db.utils import IntegrityError
from django.http import HttpRequest, HttpResponseBadRequest, JsonResponse
from django.views.decorators.csrf import csrf_exempt
from drf_spectacular.utils import OpenApiParameter, extend_schema, inline_serializer
from rest_framework import mixins, serializers, status, viewsets
from rest_framework.decorators import (
action,
api_view,
authentication_classes,
permission_classes,
)
from rest_framework.exceptions import ValidationError
from rest_framework.permissions import IsAuthenticated
from rest_framework.response import Response
from rest_framework.views import APIView

from api.serializers.model_serializers import (
AddOnSubscriptionRecordCreateSerializer,
AddonSubscriptionRecordFilterSerializer,
Expand Down Expand Up @@ -51,27 +84,6 @@
MetricAccessRequestSerializer,
MetricAccessResponseSerializer,
)
from dateutil import parser
from dateutil.relativedelta import relativedelta
from django.conf import settings
from django.db.models import (
Count,
DecimalField,
F,
Max,
Min,
OuterRef,
Prefetch,
Q,
Subquery,
Sum,
Value,
)
from django.db.models.functions import Coalesce
from django.db.utils import IntegrityError
from django.http import HttpRequest, HttpResponseBadRequest, JsonResponse
from django.views.decorators.csrf import csrf_exempt
from drf_spectacular.utils import OpenApiParameter, extend_schema, inline_serializer
from metering_billing.auth.auth_utils import fast_api_key_validation_and_cache
from metering_billing.exceptions import (
DuplicateCustomer,
Expand Down Expand Up @@ -133,17 +145,6 @@
customer_created_webhook,
subscription_created_webhook,
)
from rest_framework import mixins, serializers, status, viewsets
from rest_framework.decorators import (
action,
api_view,
authentication_classes,
permission_classes,
)
from rest_framework.exceptions import ValidationError
from rest_framework.permissions import IsAuthenticated
from rest_framework.response import Response
from rest_framework.views import APIView

POSTHOG_PERSON = settings.POSTHOG_PERSON
SVIX_CONNECTOR = settings.SVIX_CONNECTOR
Expand Down Expand Up @@ -1841,6 +1842,7 @@ def ingest_event(data: dict, customer_id: str, organization_pk: int) -> None:
event_kwargs = {
"organization_id": organization_pk,
"cust_id": customer_id,
"customer_id": customer_id,
"event_name": data["event_name"],
"idempotency_id": data["idempotency_id"],
"time_created": data["time_created"],
Expand Down