# reactor — Contract

Hand-maintained for Phase 6; the `## Inputs` table is generated from
`src/commands/index.js` (see Phase 9 generator). Keep ≤ 80 lines.

## Inputs (msg.topic on Port 0)

| Canonical | Aliases (deprecated) | Payload | Effect |
|---|---|---|---|
| `data.clock` | `clock` | `msg.timestamp` (ms since epoch) | Calls `source.updateState(timestamp)` — advances the ASM kinetics integrator by `n_iter` time steps that fit between `currentTime` and the supplied timestamp (scaled by `speedUpFactor`). |
| `data.fluent` | `Fluent` | `{ inlet: number, F: number, C: number[13] }` | Writes the per-inlet flow rate (`F`, m³/d) and concentration vector (`C`) into `engine.Fs[inlet]` / `engine.Cs_in[inlet]`. |
| `data.otr` | `OTR` | numeric | Sets the externally-supplied oxygen transfer rate (used when `kla` is NaN). |
| `data.temperature` | `Temperature` | numeric or `{ value: number }` | Sets `engine.temperature` (°C). Non-numeric payloads are warned and ignored. |
| `data.dispersion` | `Dispersion` | numeric | PFR only — sets the axial dispersion coefficient `D` (m²/d). |
| `child.register` | `registerChild` | child node id (string) | Looks up the sibling node via `RED.nodes.getNode(id)` and delegates to `source.childRegistrationUtils.registerChild` with `msg.positionVsParent`. |

Aliases log a one-time deprecation warning the first time they fire.

## Outputs (msg.topic on Port 0/1/2)

- **Port 0 (process):** every tick emits the engine's effluent:
  `{ topic: 'Fluent', payload: { inlet: 0, F, C: number[13] }, timestamp }`.
  For a PFR an additional `{ topic: 'GridProfile', payload: { grid, n_x, d_x, length, species, timestamp } }`
  message goes out on the same port before the effluent.
- **Port 1 (InfluxDB telemetry):** formatted via `outputUtils.formatMsg(..., 'influxdb')`
  from `getOutput()` — carries `flow_total`, `temperature`, and one field per ASM3
  species (`S_O`, `S_I`, `S_S`, `S_NH`, `S_N2`, `S_NO`, `S_HCO`, `X_I`, `X_S`, `X_H`,
  `X_STO`, `X_A`, `X_TS`).
- **Port 2 (registration):** at startup the node sends one
  `{ topic: 'child.register', payload: <node.id>, positionVsParent, distance }`
  to its parent.

## Events emitted by `source.emitter`

- `stateChange` — fires after every `updateState()` that advances the integrator.
  Payload is the new `currentTime` (ms since epoch). Downstream reactors register
  via `child.register` and subscribe to this event to pull the upstream
  effluent on each advance.
- `output-changed` — base notification fired by `updateState()` so the
  BaseNodeAdapter pipeline pushes outputs (currently used only as a heartbeat;
  effluent is emitted directly from the periodic tick).

## Children accepted

- `measurement` — subscribes to `<type>.measured.<position>` on the child's
  `measurements.emitter`. Recognised reconciliations: `temperature.measured.atEquipment`
  writes `engine.temperature`; PFR additionally honours
  `quantity (oxygen).measured.<distance>` to reconcile dissolved-oxygen
  concentration into the nearest grid cell.
- `reactor` — registers as the upstream reactor; the downstream `updateState`
  pulls the upstream effluent into `Fs[0]` / `Cs_in[0]` before integrating.