Method _assertInsertOpsCarryAuthor

src/node/db/Pad.ts:123–157

* Validate that every `+` (insert) op in `aChangeset` carries an * `author` attribute that resolves through `pool`. Callers that have * already rebased onto pad.pool pass the post-rebase changeset, so * we accept the pad's own pool here. * * Throws an Error if any insert op is missing

(aChangeset: string, pool: AttributePool)

   * path emits them at line boundaries.
   */
  private static _assertInsertOpsCarryAuthor(aChangeset: string, pool: AttributePool) {
    let unpacked;
    try {
      unpacked = unpack(aChangeset);
    } catch (e: any) {
      // unpack already throws a descriptive error; rethrow as-is so the
      // caller's failure mode stays the same.
      throw e;
    }
    for (const op of deserializeOps(unpacked.ops)) {
      if (op.opcode !== '+') continue;
      // Pure-newline inserts (e.g. `|1+1` for a single line break) are
      // tolerated — the client's line assembler handles them regardless
      // of attribs, and the API restoreRevision path emits them at
      // line boundaries.
      if (op.lines > 0 && op.chars === op.lines) continue;
      if (!op.attribs) {
        throw new Error(
            'insert op without an author attribute ' +
            `(empty attribs): ${aChangeset}`);
      }
      let authorIdSeen: string | undefined;
      try {
        authorIdSeen = AttributeMap.fromString(op.attribs, pool).get('author');
      } catch (e: any) {
        throw new Error(
            'insert op references an attribute number ' +
            `not present in the pool: ${aChangeset} (${e && e.message || e})`);
      }
      if (!authorIdSeen) {
        throw new Error(
            'insert op without an author attribute: ' + aChangeset);
      }
    }
  }

  private db: Database;
  private atext: AText;