Class ScoresLibSQL

stores/libsql/src/storage/domains/scores/index.ts:39–439

}

export class ScoresLibSQL extends ScoresStorage {
  /**
   * Scorer results accumulate as evals run. Single table, anchored on `createdAt`.
   */
  static override readonly retentionTables: RetentionTablesDescriptor = {
    scorers: { table: TABLE_SCORERS, column: 'createdAt', indexed: true },
  };

  #db: LibSQLDB;
  #client: Client;

  constructor(config: LibSQLDomainConfig) {
    super();
    const client = resolveClient(config);
    this.#client = client;
    this.#db = new LibSQLDB({ client, maxRetries: config.maxRetries, initialBackoffMs: config.initialBackoffMs });
  }

  async init(): Promise<void> {
    await this.#db.createTable({ tableName: TABLE_SCORERS, schema: SCORERS_SCHEMA });
    // Add columns for backwards compatibility
    await this.#db.alterTable({
      tableName: TABLE_SCORERS,
      schema: SCORERS_SCHEMA,
      ifNotExists: ['spanId', 'requestContext', 'organizationId', 'projectId', 'batchId', 'datasetId', 'datasetItemId'],
    });
  }

  async dangerouslyClearAll(): Promise<void> {
    await this.#db.deleteData({ tableName: TABLE_SCORERS });
  }

  /** Delete scorer results older than the `scorers` policy's `maxAge`, batched. */
  async prune(policies: Record<string, TableRetentionPolicy>, options?: PruneOptions): Promise<PruneResult[]> {
    const targets = resolveTargets({
      policies,
      descriptor: ScoresLibSQL.retentionTables,
      order: ['scorers'],
    });
    return runPrune({ db: this.#db, domain: 'scores', targets, options, logger: this.logger });
  }

  async listScoresByRunId({
    runId,
    pagination,
    filters,
  }: {
    runId: string;
    pagination: StoragePagination;
    filters?: ScoreTenancyFilters;
  }): Promise<ListScoresResponse> {
    try {
      const { page, perPage: perPageInput } = pagination;

      const conditions: string[] = [`runId = ?`];
      const queryParams: InValue[] = [runId];
      appendTenancyConditions(conditions, queryParams, filters);
      const whereClause = `WHERE ${conditions.join(' AND ')}`;