Method replaceRecords

packages/storage/src/artifact-store.ts:1237–1254

(records: ArtifactRecord[])

  }

  private replaceRecords(records: ArtifactRecord[]): void {
    const bySession = new Map<string, ArtifactRecord[]>();
    for (const record of records) {
      const sessionRecords = bySession.get(record.sessionId);
      if (sessionRecords) sessionRecords.push(record);
      else bySession.set(record.sessionId, [record]);
    }
    const snapshots = new Map<string, ArtifactSessionSnapshot>();
    for (const [sessionId, sessionRecords] of bySession) {
      sessionRecords.sort(compareArtifactRecords);
      snapshots.set(sessionId, {
        records: sessionRecords,
        revision: artifactListRevision(sessionRecords),
      });
    }
    this.records = records;
    this.sessionSnapshots = snapshots;
  }

  private async publishPurgeIntentUnlocked(artifactIds: readonly string[]): Promise<void> {
    const contents = JSON.stringify({