События

Правила

• События не содержат raw answer, answer key, hidden solution и teacher notes.
• События проверки публикуются после commit результата.
• Evidence events являются низкоуровневыми signals, не mastery.
• Usage events нужны соседним доменам для трассировки версии задачи.
• Повторная доставка входящих команд идемпотентна.

Общий envelope

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

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

Event	Когда	Payload
task-bank.problem.created	создана задача	problemId, code, subjectKey
task-bank.problem.published	опубликована задача	problemId, versionId, version
task-bank.problem.retired	задача выведена из новых использований	problemId, reason
task-bank.problem_version.published	опубликована version	problemId, versionId, version
task-bank.problem_set.published	опубликована подборка	problemSetId, slug, purpose
task-bank.activity_template.published	опубликован шаблон активности	activityTemplateId, version, activityType
task-bank.activity_template.retired	шаблон больше не используется для новых экспортов	activityTemplateId, reason
task-bank.program_template.published	опубликована программа	programTemplateId, version, programType
task-bank.program_template.retired	программа retired	programTemplateId, reason
task-bank.content_export_snapshot.created	создан snapshot	snapshotId, sourceRef, targetRef, status
task-bank.content_export_snapshot.locked	snapshot зафиксирован	snapshotId, sourceRef, targetRef, payloadHash
task-bank.public_projection.updated	обновлена public-safe projection	problemId, canonicalUrl, publicStatus
task-bank.problem_relation.confirmed	подтверждена связь задач	relationId, relationType, fromProblemId, toProblemId
task-bank.problem_usage.created	создан usage	usageId, problemVersionId, contextRef
task-bank.attempt.started	начата attempt	attemptId, problemVersionId, userId
task-bank.attempt.submitted	отправлен ответ	attemptId, problemVersionId, userId
task-bank.answer_check.completed	проверка завершена	checkId, attemptId, score, status
task-bank.manual_review.required	нужна ручная проверка	reviewId, attemptId
task-bank.answer_check.overridden	результат изменён вручную	checkId, attemptId, reason
task-bank.evidence.created	создан evidence	evidenceId, problemId, userId, signal
task-bank.solution.accessed	закрытое решение прочитано	problemVersionId, actor.id, context

Входящие команды

Источник	Команда	Использование
LMS	create usage	привязать задачу к уроку/домашке
LMS	create activity/program export snapshot	импортировать content template
LMS	submit/check attempt	проверить учебную попытку
competitions	create locked usage	привязать задачу к туру
competitions	create locked content snapshot	зафиксировать набор/тур
competitions	submit/check attempt	проверить олимпиадный ответ
storefront	request public projection	открыть задачу/подборку в каталоге
management	request aggregate evidence	прочитать агрегаты

Payload examples

task-bank.problem_usage.created

type ProblemUsageCreatedPayload = {
  usageId: string;
  problemVersionId: string;
  contextRef: {
    domain: 'lms' | 'competitions' | 'management' | 'storefront' | 'manual';
    type: string;
    id: string;
  };
  scoringRuleSnapshot?: Record<string, unknown>;
};

task-bank.content_export_snapshot.locked

type ContentExportSnapshotLockedPayload = {
  snapshotId: string;
  sourceRef: {
    type: 'problem_set' | 'activity_template' | 'program_template';
    id: string;
    version: number;
  };
  targetRef: {
    domain: 'lms' | 'competitions' | 'storefront' | 'management' | 'manual';
    type: string;
    id?: string;
  };
  payloadHash: string;
  lockedAt: string;
};

task-bank.public_projection.updated

type PublicProjectionUpdatedPayload = {
  problemId: string;
  canonicalUrl: string;
  publicStatus: 'published' | 'hidden' | 'embargoed';
  primaryTopicId?: string;
};

task-bank.answer_check.completed

type AnswerCheckCompletedPayload = {
  checkId: string;
  attemptId: string;
  problemVersionId: string;
  status: 'checked' | 'needs_manual_review' | 'failed' | 'overridden';
  isCorrect?: boolean;
  score?: number;
  maxScore?: number;
};

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

Сценарий	Ключ
create usage	usage:{contextDomain}:{contextType}:{contextId}:{problemVersionId}:{position}
create export snapshot	snapshot:{sourceType}:{sourceId}:{sourceVersion}:{targetDomain}:{targetType}:{targetId}
lock export snapshot	snapshot:lock:{snapshotId}:{payloadHash}
start attempt	attempt:start:{context}:{userId}:{problemVersionId}:{clientKey}
submit attempt	attempt:submit:{attemptId}:{answerHash}
auto check	check:auto:{attemptId}:{checkingRuleId}
evidence	evidence:{attemptId}:{signal}

Retention

Данные	Срок
problem versions	бессрочно
locked content export snapshots	не меньше retention target context
raw attempts	по privacy policy и требованиям LMS/competitions
answer checks	бессрочно или до архивирования контекста
evidence	аналитический срок, минимум 5 лет
audit logs	5 лет