마일스톤 데이터베이스 어댑터

/**
 * 마일스톤 데이터베이스 어댑터를 정의하는 인터페이스.
 */
export interface IMilestoneDatabaseAdapter<S> {
    /**
     * 마일스톤 스냅샷을 저장하는 간격.
     * -1이면 마일스톤 스냅샷 저장이 비활성화됩니다.
     */
    interval: number;
    /**
     * 마일스톤 스냅샷을 저장합니다.
     */
    saveMilestoneSnapshot(snapshot: ISnapshot<S>): Promise<boolean>;
    /**
     * 문서 ID와 버전으로 마일스톤 스냅샷을 조회합니다.
     */
    getMilestoneSnapshot(id: string, version: number): Promise<ISnapshot<S> | null>;
}

import { IMilestoneDatabaseAdapter } from '@mescius/js-collaboration-ot';

// 커스텀 마일스톤 어댑터
class CustomMilestoneDb implements IMilestoneDatabaseAdapter {
  constructor() {
    this.interval = 1000; // 기본 간격
    this.map = new Map(); // 스냅샷 목록 저장
  }

  async saveMilestoneSnapshot(snapshot) {
    let list = this.map.get(snapshot.id) || [];
    list.push(JSON.parse(JSON.stringify(snapshot)));
    list.sort((a, b) => a.v - b.v); // 버전 기준 정렬
    this.map.set(snapshot.id, list);
    return true;
  }

  async getMilestoneSnapshot(id, version) {
    const list = this.map.get(id) || [];
    let result;
    for (const snapshot of list) {
      if (snapshot.v <= version) {
        result = snapshot;
      } else {
        break;
      }
    }
    return JSON.parse(JSON.stringify(result)) ?? null;
  }
}

const docService = new DocumentServices({
  db: new MemoryDb(),
  milestoneDb: new CustomMilestoneDb()
});