Overview

Fact: a price table exists, with its B2B and B2C default price groups. The payload is the table header.

When it is published. CNA OneCNA OneService•v1.0.0Franchise operating system (franchises and employees, pricing, products and learning books, school operations). Publishe...PublishesGrantApplicationAccess, EmployeeCreated +6SubscribesInviteUser, FranchiseCreated +9Ownercna-platformMapRepoView docs, in franchisorCreateLearningBookPriceTable, after the command that creates the table and its default groups returns. Before that, the validity is checked: no overlap with the last table and a duration between 3 and 18 months; the year is derived from the last table (plus one) or from startsOn. type is always LEARNING_BOOK today. Published after the write, not inside afterCommit.

What the consumer does. cna-one’s pricing process (priceTableConsumer, handler syncPriceTableCreatedToLearningBookPrices):

1. Ignores tables whose type is not LEARNING_BOOK.
2. Loads the table’s default price groups and the learning books currently available. Either list empty: logs a warning and stops.
3. Idempotency guard: if the default groups already hold any price, stops without writing. Redelivery neither duplicates nor overwrites.
4. Builds one FIXED price per default group and learning book. The amount is copied from the previous year’s table when that table has a price for the same sales channel and book; otherwise it is left null for someone to fill in.
5. Upserts the prices.

Failures are logged and reported to Sentry, never rethrown.

Kafka

Payload schema

Source of truth

import { ProductType } from "db/enums/product/Product";

export type PriceTablePayload = {
  id: string;
  type: ProductType;
  year: number;
  name: string;
  startsOn: string;
  endsOn: string;
};

class PriceTableCreated extends Event<PriceTablePayload> {
  public static owner = "ONE";
  public static aggregateRoot = "PriceTable";
  public static routingKey = "id";
}

The class exists only in cna-one.