mirror of
https://github.com/hanzoai/insights.git
synced 2026-10-30 16:15:31 +00:00
zeekay
bc4ddf332b
Mechanically re-derived: bin/debrand runs over a fresh import of posthog/posthog@fa1a9a60d4 (2026-08-06). The pipeline (.hanzo/workflows), the Dockerfiles and bin/docker* entrypoints, compose files, LLM.md and the squashed initial migration are restored from the shipped tree, same as the previous import. The prune's import-closure guard kept 21 products the new core now imports; dropping them is a refactor now, recorded rather than forced.
80 lines
3.5 KiB
Python
80 lines
3.5 KiB
Python
from django.apps import AppConfig
|
|
|
|
|
|
class CustomerAnalyticsConfig(AppConfig):
|
|
default_auto_field = "django.db.models.BigAutoField"
|
|
name = "products.customer_analytics.backend"
|
|
label = "customer_analytics"
|
|
|
|
def ready(self) -> None:
|
|
self._register_person_property_hooks()
|
|
self._register_workflows_account_audience()
|
|
|
|
def _register_workflows_account_audience(self) -> None:
|
|
"""Give the workflows batch trigger its account-audience implementation without
|
|
workflows importing this product (the dependency runs the other way). The query
|
|
impls are imported lazily so InsightsQL stays off the django.setup() path.
|
|
"""
|
|
from products.workflows.backend.services.account_audience import (
|
|
AccountAudienceFilters,
|
|
register_account_audience_provider,
|
|
)
|
|
|
|
class _Provider:
|
|
def count_accounts(self, team, filters: AccountAudienceFilters) -> int:
|
|
from products.customer_analytics.backend.facade import api # noqa: PLC0415
|
|
|
|
return api.count_accounts_for_audience(team, filters)
|
|
|
|
def list_account_external_ids(
|
|
self, team, filters: AccountAudienceFilters, *, cursor: str | None, limit: int
|
|
) -> list[str]:
|
|
from products.customer_analytics.backend.facade import api # noqa: PLC0415
|
|
|
|
return api.list_account_external_ids_for_audience(team, filters, cursor=cursor, limit=limit)
|
|
|
|
def get_account_group_type_name(self, team) -> str | None:
|
|
from products.customer_analytics.backend.facade import api # noqa: PLC0415
|
|
|
|
return api.get_account_group_type_name(team)
|
|
|
|
register_account_audience_provider(_Provider())
|
|
|
|
def _register_person_property_hooks(self) -> None:
|
|
"""Tell the data-import pipeline which columns to stage for a schema's person-property
|
|
sources, and give its post-sync upsert job the full source configs — without
|
|
warehouse_sources importing this product. The impls are imported lazily so the models stay
|
|
off the django.setup() path.
|
|
"""
|
|
from products.warehouse_sources.backend.facade.hooks import (
|
|
PersonPropertySourceProjection,
|
|
PersonPropertySyncRunRecord,
|
|
PersonPropertySyncSource,
|
|
register_person_property_projection,
|
|
register_person_property_sync_recorder,
|
|
register_person_property_sync_sources,
|
|
)
|
|
|
|
def _projection_resolver(team_id: int, schema_id) -> list[PersonPropertySourceProjection] | None:
|
|
from products.customer_analytics.backend.logic.person_property_projection import ( # noqa: PLC0415
|
|
person_property_projection,
|
|
)
|
|
|
|
return person_property_projection(team_id, schema_id)
|
|
|
|
def _sync_sources_resolver(team_id: int, schema_id) -> list[PersonPropertySyncSource] | None:
|
|
from products.customer_analytics.backend.logic.person_property_projection import ( # noqa: PLC0415
|
|
person_property_sync_sources,
|
|
)
|
|
|
|
return person_property_sync_sources(team_id, schema_id)
|
|
|
|
def _run_recorder(record: PersonPropertySyncRunRecord) -> None:
|
|
from products.customer_analytics.backend.logic.person_property_runs import record_sync_run # noqa: PLC0415
|
|
|
|
record_sync_run(record)
|
|
|
|
register_person_property_projection(_projection_resolver)
|
|
register_person_property_sync_sources(_sync_sources_resolver)
|
|
register_person_property_sync_recorder(_run_recorder)
|