Method append

packages/computerd/src/exec/log.ts:90–121

(name: "stdout" | "stderr", value: Uint8Array)

  }

  append(name: "stdout" | "stderr", value: Uint8Array): number {
    const meta = this.meta();
    if (meta === undefined) throw new Error(`log ${this.id}: append after dispose`);
    if (meta.exited_at !== null) throw new Error(`log ${this.id}: append after exit`);
    const seq = this.nextSeq++;
    if (meta.evicted === 1) {
      // Silently drop. The live stream already got the bytes;
      // we just can't replay them. Keep the seq counter
      // advancing so the live stream's seq numbering stays
      // monotonic and gap-free.
      return seq;
    }
    const kind = name === "stdout" ? KIND_STDOUT : KIND_STDERR;
    const ts = this.opts.now();
    const newBytes = meta.bytes + value.byteLength;
    if (newBytes > this.opts.maxBytes) {
      this.evict();
      return seq;
    }
    this.db.transactionSync(() => {
      this.db.run(
        `INSERT INTO computerd_exec_log (exec_id, seq, ts, kind, value) VALUES (?, ?, ?, ?, ?)`,
        this.id,
        seq,
        ts,
        kind,
        value,
      );
      this.db.run(`UPDATE computerd_exec_meta SET bytes = ? WHERE exec_id = ?`, newBytes, this.id);
    });
    return seq;
  }

  // Advance the seq counter and return the next value without writing
  // any row to the database. Used for events that the runner emits on