Function writeToD1

telemetry-worker/src/index.ts:216–268

* Persist a sanitized batch: one `events` row per event, plus the machine×day and * first-seen bookkeeping the dashboard's retention/activation panels need. One D1 * `batch()` = one implicit transaction = one round trip. * * Fail-silent by design: the client treats every response as final and ne

(
  env: Env,
  machineId: string,
  common: JsonObject,
  batch: StoredEvent[],
)

 * logged (Workers Logs) with counts only — never the payload.
 */
async function writeToD1(
  env: Env,
  machineId: string,
  common: JsonObject,
  batch: StoredEvent[],
): Promise<void> {
  try {
    const receivedAt = new Date().toISOString();
    const insertEvent = env.DB.prepare(INSERT_EVENT);
    const stmts: D1PreparedStatement[] = [];
    // Envelope columns are identical for every row in the batch.
    const envelopeCols = [
      asText(common.codegraph_version),
      asText(common.os),
      asText(common.arch),
      asInt(common.node_major),
      asFlag(common.ci),
      asInt(common.schema_version),
    ] as const;
    // A batch can span days (offline buffers hold completed-day rollups), so
    // machine_days gets one row per distinct day rather than one per batch.
    const days = new Set<string>();

    for (const e of batch) {
      const day = (e.ts ?? receivedAt).slice(0, 10);
      days.add(day);
      stmts.push(
        insertEvent.bind(
          receivedAt,
          e.ts ?? null,
          day,
          e.event,
          machineId,
          ...envelopeCols,
          JSON.stringify(e.props),
        ),
      );
    }

    const prod = common.ci === true ? 0 : 1;
    const upsertDay = env.DB.prepare(UPSERT_MACHINE_DAY);
    for (const day of days) stmts.push(upsertDay.bind(machineId, day, prod));

    const firstDay = [...days].sort()[0];
    if (firstDay !== undefined) {
      stmts.push(env.DB.prepare(UPSERT_FIRST_SEEN).bind(machineId, firstDay));
    }

    await env.DB.batch(stmts);
  } catch (err) {
    console.error(JSON.stringify({ msg: 'd1 write failed', err: String(err), events: batch.length }));
  }
}

export default {
  async fetch(request, env, ctx): Promise<Response> {