49b2d49e40
- Resume persisted outbox jobs at startup without dropping writes when credentials are unavailable - Serialize IndexedDB revisions and guard sync completion against concurrent saves - Reconcile tombstones without reviving deleted documents and bound S3 metadata requests - Require explicit CORS configuration instead of overwriting bucket rules during connection tests - Keep ACP agents exclusive to the Design role and normalize invalid model limits
64 lines
1.8 KiB
TypeScript
64 lines
1.8 KiB
TypeScript
import { describe, expect, test } from 'bun:test'
|
|
|
|
import type { StorageDocument } from '@/app/integrations/storage'
|
|
import type { LocalCanvasMeta } from '@/app/storage/local-store'
|
|
import { reconcileStorageDocuments } from '@/app/storage/reconcile'
|
|
|
|
function localMeta(
|
|
id: string,
|
|
syncStatus: LocalCanvasMeta['syncStatus'],
|
|
tombstoned = false
|
|
): LocalCanvasMeta {
|
|
return {
|
|
id,
|
|
providerId: 's3-compatible',
|
|
name: `Local ${id}`,
|
|
updatedAt: '2026-01-02T00:00:00.000Z',
|
|
revision: 1,
|
|
syncStatus,
|
|
lastSyncedAt: null,
|
|
lastSyncError: null,
|
|
tombstoned,
|
|
hasFig: true,
|
|
hasThumb: false,
|
|
figSize: 1
|
|
}
|
|
}
|
|
|
|
function remoteDocument(id: string): StorageDocument {
|
|
return {
|
|
id,
|
|
name: `Remote ${id}`,
|
|
updatedAt: '2026-01-01T00:00:00.000Z',
|
|
metadataAuthoritative: true
|
|
}
|
|
}
|
|
|
|
describe('storage workspace reconciliation', () => {
|
|
test('keeps pending local metadata ahead of the remote listing', () => {
|
|
const result = reconcileStorageDocuments(
|
|
[localMeta('pending', 'pending')],
|
|
[remoteDocument('pending'), remoteDocument('remote')]
|
|
)
|
|
|
|
expect(result.documents.map((document) => document.name)).toEqual([
|
|
'Local pending',
|
|
'Remote remote'
|
|
])
|
|
expect(result.remoteDocumentsToSeed.map((document) => document.id)).toEqual(['remote'])
|
|
})
|
|
|
|
test('hides tombstones until deletion is confirmed and then purges them', () => {
|
|
const waiting = reconcileStorageDocuments(
|
|
[localMeta('deleted', 'synced', true)],
|
|
[remoteDocument('deleted')]
|
|
)
|
|
expect(waiting.documents).toEqual([])
|
|
expect(waiting.localIdsToPurge).toEqual([])
|
|
expect(waiting.remoteDocumentsToSeed).toEqual([])
|
|
|
|
const confirmed = reconcileStorageDocuments([localMeta('deleted', 'synced', true)], [])
|
|
expect(confirmed.localIdsToPurge).toEqual(['deleted'])
|
|
})
|
|
})
|