События

Правила

• Management читает события соседних доменов как input для метрик, но не становится владельцем этих фактов.
• Все исходящие события имеют messageId, occurredAt, producer, producerInstance, messageVersion.
• Payload не должен содержать PII, если достаточно ссылки на entity id или агрегата.
• Для событий, создающих задачи, используется deduplicationKey.
• Повторная доставка события должна быть идемпотентной.

Общий envelope

type DomainEvent<TPayload> = {
  messageId: string;
  messageKind: 'event';
  messageType: string;
  messageVersion: number;
  producer: 'management';
  producerInstance: string;
  traceId: string;
  occurredAt: string;
  correlationId?: string;
  actor?: {
    type: 'user' | 'service' | 'system';
    id?: string;
  };
  data: TPayload;
  metadata?: Record<string, unknown>;
};

Исходящие события

Event	Когда	Payload
management.metric.created	создана метрика	metricId, key, owner, sourceDomain
management.metric_version.created	создана версия формулы	metricId, version
management.metric_recalculation.requested	запрошен пересчёт	metricId, periodStart, periodEnd
management.metric.recalculated	пересчёт завершён	metricId, periodStart, periodEnd, qualityStatus
management.dashboard.published	опубликован dashboard	dashboardId, slug, audience
management.plan.created	создан план	planId, type, ownerUserId
management.plan.published	опубликован план	planId, publishedByUserId
management.plan.approved	план утверждён	planId, approvedByUserId
management.plan.closed	план закрыт	planId, statusSummary
management.task.created	создана задача	taskId, assigneeUserId, sourceRef
management.task_status.changed	изменён статус задачи	taskId, from, to
management.task.completed	задача завершена	taskId, completedAt
management.team_task.created	создана командная задача	taskId, teamRef, sourceRef
management.team_task.assigned	командная задача назначена исполнителю	taskId, assigneeUserId, teamRef
management.team_task.reminded	срок командной задачи близко	taskId, assigneeUserId, dueAt
management.team_task.updated	командная задача изменена	taskId, changedFields
management.team_task_comment.created	добавлен комментарий	commentId, taskId
management.alert.opened	сработал alert	alertId, ruleKey, severity
management.alert.resolved	alert закрыт	alertId, resolvedAt
management.recommendation.created	создана рекомендация	recommendationId, goalProfileId, type
management.recommendation.dismissed	рекомендация отклонена	recommendationId, reason
management.diagnostic.scheduled	назначена диагностика	diagnosticSessionId, studentProfileId, scheduledAt
management.goal.activated	цель активирована	goalId, goalProfileId, activatedAt
management.data_quality_issue.created	найдена проблема данных	issueId, severity, dataSourceKey
management.action.executed	выполнено действие	actionId, actionType, status

Входящие события

Источник	События	Использование
storefront	lead/form/campaign/page events	трафик, конверсия, заявки
CRM	lead, deal, invoice, payment, entitlement, ticket events	продажи, выручка, долги, support
LMS	enrollment, lesson, submission, progress events	активность, completion, прогресс
task-bank	attempt, checked, evidence events	учебные signals, сложность, темы
competitions	registration, submission, result, document events	участие и результаты
identity	user, organization, role assignment events	сотрудники, организации, access context

Payload examples

management.task.created

type ManagementTaskCreatedPayload = {
  taskId: string;
  title: string;
  assigneeUserId?: string;
  priority: 'low' | 'normal' | 'high' | 'urgent';
  sourceRef?: {
    domain: string;
    type: string;
    id: string;
  };
  deduplicationKey?: string;
};

management.metric.recalculated

type ManagementMetricRecalculatedPayload = {
  metricId: string;
  metricKey: string;
  periodStart: string;
  periodEnd: string;
  segment?: Record<string, unknown>;
  qualityStatus: 'complete' | 'partial' | 'stale' | 'failed' | 'unknown';
  calculatedAt: string;
};

management.data_quality_issue.created

type ManagementDataQualityIssueCreatedPayload = {
  issueId: string;
  dataSourceKey?: string;
  severity: 'info' | 'warning' | 'critical';
  title: string;
  openedAt: string;
};

Идемпотентность

Сценарий	Ключ
загрузка input event	producer:messageId
создание task из alert	alert:{alertId}:task
создание recurring task	template:{templateId}:period:{period}
пересчёт метрики	metric:{metricId}:version:{version}:period:{period}:segment:{hash}

Retention

Данные	Срок
сырые входящие event references	180 дней
metric values	бессрочно или до архивирования метрики
task history	5 лет
audit logs	5 лет
data quality issues	3 года
exports metadata	1 год