Function clearWorkspaceAnalyticsState

src/node/services/analytics/etl.ts:763–779

(
  conn: DuckDBConnection,
  workspaceId: string
)

}

export async function clearWorkspaceAnalyticsState(
  conn: DuckDBConnection,
  workspaceId: string
): Promise<void> {
  assert(workspaceId.trim().length > 0, "clearWorkspaceAnalyticsState: workspaceId is required");

  await conn.run("BEGIN TRANSACTION");
  try {
    await conn.run("DELETE FROM events WHERE workspace_id = ?", [workspaceId]);
    await conn.run("DELETE FROM ingest_watermarks WHERE workspace_id = ?", [workspaceId]);
    await conn.run("DELETE FROM delegation_rollups WHERE parent_workspace_id = ?", [workspaceId]);
    await conn.run("COMMIT");
  } catch (error) {
    await conn.run("ROLLBACK");
    throw error;
  }
}

function serializeHeadSignatureValue(value: string | number | null): string {
  if (value === null) {