API Events

Licensing không có bề mặt messaging bất đồng bộ. Application.configureComponents() chỉ đăng ký một Redis cache (useCacheRedis). Không có Kafka producer/consumer, không queue BullMQ, và không WebSocket emitter. Phụ thuộc @platformatic/kafka và bullmq trong package.json không được dùng.

1. Inbound — Kafka

Topic	Producer	Handler	Idempotency Key	Failure Mode
Không	—	—	—	—

2. Outbound — Kafka

Topic	Trigger	Consumers	Payload Schema
Không	—	—	—

3. Inbound — BullMQ

Queue	Job Type	Producer	Handler	Concurrency
Không	—	—	—	—

4. Outbound — BullMQ

Queue	Job Type	Trigger	Consumer Service
Không	—	—	—

5. WebSocket Emissions

Topic	Room	Trigger	Action Enum
Không	—	—	—

6. Payload Schemas

Payload xuyên service duy nhất là chứng chỉ license ghi vào Redis. Nó không phải sự kiện message-bus — nó là một key mà consumer kéo theo nhu cầu qua LicenseMiddleware của @nx/core.

Kênh chứng chỉ Redis

Khía cạnh	Giá trị
Producer	LicensingBaseService.publishCertificate() — redis.client.set(key, cert, 'EX', certTtl)
Consumer	@nx/core LicenseProvider (tức LicenseMiddleware) — redis.client.get(key)
Key	lic:certs:<entityType>:<entityId> (vd lic:certs:Merchant:123)
Value	Envelope chuỗi Base64 (payload AES-256-GCM + chữ ký Ed25519)
TTL	APP_ENV_LICENSING_CERT_TTL_SECONDS (mặc định 86400)

// Payload chứng chỉ đã giải mã — ILicenseCertificatePayload (@nx/core)
export interface ILicenseCertificatePayload<FeaturesType = Record<string, unknown>> {
  license: { id: string; key: string };
  entity: { type: string; id: string };
  status: string;             // LicenseStatuses
  tier: string;               // policy.type (PolicyTypes)
  features: FeaturesType;      // map PolicyFeature đã giải (đã merge override)
  activation: { limit: number } | null;
  expiresAt: string | null;
  issuedAt: string;
  certExpiresAt: string;       // độc lập với license.expiresAt — điều khiển Redis EX
}

// Envelope trên đường truyền — ICertificateEnvelope (@nx/core)
export interface ICertificateEnvelope {
  enc: string;  // ciphertext AES-256-GCM của JSON payload
  sig: string;  // chữ ký Ed25519 (base64url) trên "MESSAGE_PREFIX:enc"
  alg: string;  // "aes-256-gcm+ed25519"
}

7. Idempotency & Thứ tự

Bề mặt	Delivery	Thứ tự	Phục hồi
Chứng chỉ Redis	last-write-wins (một key mỗi entity)	n/a (chỉ trạng thái mới nhất)	Re-publish mỗi mutation vòng đời; hết hạn sau TTL → consumer thấy null (fail-open) cho tới khi re-issue

Khi cert thiếu hoặc xác minh thất bại, LicenseMiddleware là fail-open: nó đặt license context thành null (coi là "unknown", không phải "unlicensed").

8. Trang liên quan

• Integration — đường tin cậy với @nx/core
• Certificate System — chi tiết ký/xác minh
• Architecture — Kịch bản runtime