Class ScoresStorageMongoDB

stores/mongodb/src/storage/domains/scores/index.ts:48–530

}

export class ScoresStorageMongoDB extends ScoresStorage {
  #connector: MongoDBConnector;
  #skipDefaultIndexes?: boolean;
  #indexes?: MongoDBIndexConfig[];

  /** Collections managed by this domain */
  static readonly MANAGED_COLLECTIONS = [TABLE_SCORERS] as const;

  /** Anchor is the score row's creation time, stored as a BSON date. */
  static override readonly retentionTables: RetentionTablesDescriptor = {
    scorers: { table: TABLE_SCORERS, column: 'createdAt', indexed: true },
  };

  constructor(config: MongoDBDomainConfig) {
    super();
    this.#connector = resolveMongoDBConfig(config);
    this.#skipDefaultIndexes = config.skipDefaultIndexes;
    // Filter indexes to only those for collections managed by this domain
    this.#indexes = config.indexes?.filter(idx =>
      (ScoresStorageMongoDB.MANAGED_COLLECTIONS as readonly string[]).includes(idx.collection),
    );
  }

  private async getCollection(name: string) {
    return this.#connector.getCollection(name);
  }

  /** 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: ScoresStorageMongoDB.retentionTables,
      order: ['scorers'],
    });
    return runPrune({ connector: this.#connector, domain: 'scores', targets, options, logger: this.logger });
  }

  /**
   * Returns default index definitions for the scores domain collections.
   * These indexes optimize common query patterns for score lookups.
   */
  getDefaultIndexDefinitions(): MongoDBIndexConfig[] {
    return [
      { collection: TABLE_SCORERS, keys: { id: 1 }, options: { unique: true } },
      { collection: TABLE_SCORERS, keys: { scorerId: 1 } },
      { collection: TABLE_SCORERS, keys: { runId: 1 } },
      { collection: TABLE_SCORERS, keys: { entityId: 1, entityType: 1 } },
      { collection: TABLE_SCORERS, keys: { traceId: 1, spanId: 1 } },
      { collection: TABLE_SCORERS, keys: { createdAt: -1 } },
      { collection: TABLE_SCORERS, keys: { source: 1 } },
    ];
  }

  async createDefaultIndexes(): Promise<void> {
    if (this.#skipDefaultIndexes) {
      return;
    }