Class SchedulesMongoDB

stores/mongodb/src/storage/domains/schedules/index.ts:93–303

}

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

  static readonly MANAGED_COLLECTIONS = [TABLE_SCHEDULES, TABLE_SCHEDULE_TRIGGERS] as const;

  /**
   * Only trigger (fire-history) rows are retention-eligible — schedule
   * definitions are config, not growth. Anchor `actual_fire_at` is stored as a
   * raw epoch-ms number, so `anchorType: 'epoch-ms'` keeps the cutoff numeric.
   * The default composite index `(schedule_id, actual_fire_at)` can't serve a
   * bare `actual_fire_at` range scan, hence the lazy single-field anchor index.
   */
  static override readonly retentionTables: RetentionTablesDescriptor = {
    triggers: { table: TABLE_SCHEDULE_TRIGGERS, column: 'actual_fire_at', anchorType: 'epoch-ms', indexed: true },
  };

  constructor(config: MongoDBDomainConfig) {
    super();
    this.#connector = resolveMongoDBConfig(config);
    this.#skipDefaultIndexes = config.skipDefaultIndexes;
    this.#indexes = config.indexes?.filter(idx =>
      (SchedulesMongoDB.MANAGED_COLLECTIONS as readonly string[]).includes(idx.collection),
    );
  }

  private getSchedulesCollection() {
    return this.#connector.getCollection(TABLE_SCHEDULES);
  }

  private getTriggersCollection() {
    return this.#connector.getCollection(TABLE_SCHEDULE_TRIGGERS);
  }

  /** Delete trigger (fire-history) rows older than the `triggers` policy's `maxAge`, batched. */
  async prune(policies: Record<string, TableRetentionPolicy>, options?: PruneOptions): Promise<PruneResult[]> {
    const targets = resolveTargets({
      policies,
      descriptor: SchedulesMongoDB.retentionTables,
      order: ['triggers'],
    });
    return runPrune({ connector: this.#connector, domain: 'schedules', targets, options, logger: this.logger });
  }

  getDefaultIndexDefinitions(): MongoDBIndexConfig[] {
    return [
      { collection: TABLE_SCHEDULES, keys: { id: 1 }, options: { unique: true } },
      { collection: TABLE_SCHEDULES, keys: { status: 1, next_fire_at: 1 } },
      { collection: TABLE_SCHEDULES, keys: { 'target.workflowId': 1 } },
      { collection: TABLE_SCHEDULES, keys: { owner_type: 1, owner_id: 1 } },
      { collection: TABLE_SCHEDULE_TRIGGERS, keys: { id: 1 }, options: { unique: true } },
      { collection: TABLE_SCHEDULE_TRIGGERS, keys: { schedule_id: 1, actual_fire_at: -1 } },
      { collection: TABLE_SCHEDULE_TRIGGERS, keys: { parent_trigger_id: 1 } },
    ];
  }

  async createDefaultIndexes(): Promise<void> {