+194

src/lib/ai-assistant.ts

reviewed

··· 1 1 + /** 2 2 + * AI Assistant — document AI actions via Aperture gateway. 3 3 + * 4 4 + * Pure logic module: prompt building, action definitions, response parsing. 5 5 + * API calls to Aperture handled by the integration layer. 6 6 + */ 7 7 + 8 8 + export type AIAction = 'summarize' | 'rewrite' | 'expand' | 'translate' | 'fix-grammar' | 'simplify' | 'make-formal' | 'make-casual'; 9 9 + 10 10 + export interface AIRequest { 11 11 + action: AIAction; 12 12 + content: string; 13 13 + /** Target language (for translate action) */ 14 14 + targetLanguage?: string; 15 15 + /** Additional context or instructions */ 16 16 + context?: string; 17 17 + /** Max tokens for response */ 18 18 + maxTokens: number; 19 19 + } 20 20 + 21 21 + export interface AIResponse { 22 22 + success: boolean; 23 23 + result: string; 24 24 + /** Tokens used */ 25 25 + tokensUsed: number; 26 26 + /** Action that was performed */ 27 27 + action: AIAction; 28 28 + } 29 29 + 30 30 + export interface AIConfig { 31 31 + /** Aperture gateway URL */ 32 32 + gatewayUrl: string; 33 33 + /** Model to use */ 34 34 + model: string; 35 35 + /** Default max tokens */ 36 36 + defaultMaxTokens: number; 37 37 + /** Available actions for the current context */ 38 38 + enabledActions: AIAction[]; 39 39 + } 40 40 + 41 41 + /** 42 42 + * Create default AI config. 43 43 + */ 44 44 + export function createAIConfig(gatewayUrl: string): AIConfig { 45 45 + return { 46 46 + gatewayUrl, 47 47 + model: 'claude-sonnet-4-20250514', 48 48 + defaultMaxTokens: 1024, 49 49 + enabledActions: ['summarize', 'rewrite', 'expand', 'translate', 'fix-grammar', 'simplify', 'make-formal', 'make-casual'], 50 50 + }; 51 51 + } 52 52 + 53 53 + /** 54 54 + * Build the system prompt for an AI action. 55 55 + */ 56 56 + export function buildSystemPrompt(action: AIAction, targetLanguage?: string): string { 57 57 + switch (action) { 58 58 + case 'summarize': 59 59 + return 'You are a helpful assistant. Summarize the following text concisely, preserving the key points. Return only the summary.'; 60 60 + case 'rewrite': 61 61 + return 'You are a helpful assistant. Rewrite the following text to improve clarity and flow while preserving the meaning. Return only the rewritten text.'; 62 62 + case 'expand': 63 63 + return 'You are a helpful assistant. Expand the following text with more detail, examples, and explanation. Return only the expanded text.'; 64 64 + case 'translate': 65 65 + return `You are a helpful translator. Translate the following text to ${targetLanguage || 'English'}. Return only the translation.`; 66 66 + case 'fix-grammar': 67 67 + return 'You are a helpful editor. Fix any grammar, spelling, and punctuation errors in the following text. Return only the corrected text.'; 68 68 + case 'simplify': 69 69 + return 'You are a helpful assistant. Simplify the following text to make it easier to understand, using shorter sentences and simpler words. Return only the simplified text.'; 70 70 + case 'make-formal': 71 71 + return 'You are a helpful assistant. Rewrite the following text in a formal, professional tone. Return only the rewritten text.'; 72 72 + case 'make-casual': 73 73 + return 'You are a helpful assistant. Rewrite the following text in a casual, friendly tone. Return only the rewritten text.'; 74 74 + } 75 75 + } 76 76 + 77 77 + /** 78 78 + * Build an AI request. 79 79 + */ 80 80 + export function buildRequest( 81 81 + action: AIAction, 82 82 + content: string, 83 83 + options: { targetLanguage?: string; context?: string; maxTokens?: number } = {}, 84 84 + ): AIRequest { 85 85 + return { 86 86 + action, 87 87 + content, 88 88 + targetLanguage: options.targetLanguage, 89 89 + context: options.context, 90 90 + maxTokens: options.maxTokens ?? 1024, 91 91 + }; 92 92 + } 93 93 + 94 94 + /** 95 95 + * Build the API payload for Aperture. 96 96 + */ 97 97 + export function buildApiPayload( 98 98 + request: AIRequest, 99 99 + config: AIConfig, 100 100 + ): { model: string; max_tokens: number; system: string; messages: Array<{ role: string; content: string }> } { 101 101 + const system = buildSystemPrompt(request.action, request.targetLanguage); 102 102 + const userContent = request.context 103 103 + ? `Context: ${request.context}\n\nText:\n${request.content}` 104 104 + : request.content; 105 105 + 106 106 + return { 107 107 + model: config.model, 108 108 + max_tokens: request.maxTokens, 109 109 + system, 110 110 + messages: [{ role: 'user', content: userContent }], 111 111 + }; 112 112 + } 113 113 + 114 114 + /** 115 115 + * Parse an AI response from the API. 116 116 + */ 117 117 + export function parseApiResponse( 118 118 + apiResponse: { content?: Array<{ text?: string }>; usage?: { output_tokens?: number } }, 119 119 + action: AIAction, 120 120 + ): AIResponse { 121 121 + const text = apiResponse.content?.[0]?.text ?? ''; 122 122 + const tokens = apiResponse.usage?.output_tokens ?? 0; 123 123 + 124 124 + return { 125 125 + success: text.length > 0, 126 126 + result: text, 127 127 + tokensUsed: tokens, 128 128 + action, 129 129 + }; 130 130 + } 131 131 + 132 132 + /** 133 133 + * Get available AI actions with labels. 134 134 + */ 135 135 + export function getAIActions(): Array<{ action: AIAction; label: string; icon: string }> { 136 136 + return [ 137 137 + { action: 'summarize', label: 'Summarize', icon: 'compress' }, 138 138 + { action: 'rewrite', label: 'Rewrite', icon: 'edit' }, 139 139 + { action: 'expand', label: 'Expand', icon: 'unfold' }, 140 140 + { action: 'translate', label: 'Translate', icon: 'globe' }, 141 141 + { action: 'fix-grammar', label: 'Fix Grammar', icon: 'check' }, 142 142 + { action: 'simplify', label: 'Simplify', icon: 'minimize' }, 143 143 + { action: 'make-formal', label: 'Make Formal', icon: 'briefcase' }, 144 144 + { action: 'make-casual', label: 'Make Casual', icon: 'smile' }, 145 145 + ]; 146 146 + } 147 147 + 148 148 + /** 149 149 + * Get common translation languages. 150 150 + */ 151 151 + export function getTranslationLanguages(): Array<{ code: string; name: string }> { 152 152 + return [ 153 153 + { code: 'en', name: 'English' }, 154 154 + { code: 'es', name: 'Spanish' }, 155 155 + { code: 'fr', name: 'French' }, 156 156 + { code: 'de', name: 'German' }, 157 157 + { code: 'it', name: 'Italian' }, 158 158 + { code: 'pt', name: 'Portuguese' }, 159 159 + { code: 'ja', name: 'Japanese' }, 160 160 + { code: 'ko', name: 'Korean' }, 161 161 + { code: 'zh', name: 'Chinese' }, 162 162 + { code: 'ar', name: 'Arabic' }, 163 163 + ]; 164 164 + } 165 165 + 166 166 + /** 167 167 + * Estimate token count (rough: ~4 chars per token). 168 168 + */ 169 169 + export function estimateTokens(text: string): number { 170 170 + return Math.ceil(text.length / 4); 171 171 + } 172 172 + 173 173 + /** 174 174 + * Check if content is within the token limit. 175 175 + */ 176 176 + export function isWithinLimit(content: string, maxInputTokens = 4096): boolean { 177 177 + return estimateTokens(content) <= maxInputTokens; 178 178 + } 179 179 + 180 180 + /** 181 181 + * Truncate content to fit within token limit. 182 182 + */ 183 183 + export function truncateToLimit(content: string, maxInputTokens = 4096): string { 184 184 + const maxChars = maxInputTokens * 4; 185 185 + if (content.length <= maxChars) return content; 186 186 + return content.slice(0, maxChars - 3) + '...'; 187 187 + } 188 188 + 189 189 + /** 190 190 + * Check if an action is enabled in the config. 191 191 + */ 192 192 + export function isActionEnabled(config: AIConfig, action: AIAction): boolean { 193 193 + return config.enabledActions.includes(action); 194 194 + }

+175

src/lib/matrix-integration.ts

reviewed

··· 1 1 + /** 2 2 + * Matrix/Owl Integration — share docs to Matrix, receive notifications. 3 3 + * 4 4 + * Pure logic module: message formatting, link generation, notification config. 5 5 + * Matrix client API calls handled by the integration layer. 6 6 + */ 7 7 + 8 8 + export interface MatrixShareConfig { 9 9 + roomId: string; 10 10 + docId: string; 11 11 + docType: 'docs' | 'sheets' | 'slides'; 12 12 + docTitle: string; 13 13 + /** Base URL of the crypt instance */ 14 14 + baseUrl: string; 15 15 + /** Optional message to include */ 16 16 + message: string; 17 17 + } 18 18 + 19 19 + export interface NotificationConfig { 20 20 + /** Matrix room to send notifications to */ 21 21 + roomId: string; 22 22 + /** Events to notify on */ 23 23 + events: NotificationEvent[]; 24 24 + /** Mention @room on urgent events */ 25 25 + mentionRoom: boolean; 26 26 + } 27 27 + 28 28 + export type NotificationEvent = 'comment' | 'mention' | 'edit' | 'share' | 'delete'; 29 29 + 30 30 + export interface MatrixMessage { 31 31 + msgtype: 'm.text'; 32 32 + body: string; 33 33 + format: 'org.matrix.custom.html'; 34 34 + formatted_body: string; 35 35 + } 36 36 + 37 37 + export interface ThreadSummaryRequest { 38 38 + roomId: string; 39 39 + threadId: string; 40 40 + docTitle: string; 41 41 + } 42 42 + 43 43 + /** 44 44 + * Generate a share link for a document. 45 45 + */ 46 46 + export function generateShareLink(baseUrl: string, docType: string, docId: string): string { 47 47 + return `${baseUrl}/${docType}/${docId}`; 48 48 + } 49 49 + 50 50 + /** 51 51 + * Format a share message for Matrix. 52 52 + */ 53 53 + export function formatShareMessage(config: MatrixShareConfig): MatrixMessage { 54 54 + const link = generateShareLink(config.baseUrl, config.docType, config.docId); 55 55 + const typeLabel = config.docType === 'docs' ? 'document' : config.docType === 'sheets' ? 'spreadsheet' : 'presentation'; 56 56 + const prefix = config.message ? `${config.message}\n\n` : ''; 57 57 + 58 58 + const body = `${prefix}Shared ${typeLabel}: ${config.docTitle}\n${link}`; 59 59 + const formatted_body = `${prefix ? `<p>${escapeHtml(config.message)}</p>` : ''}<p>Shared ${typeLabel}: <a href="${escapeHtml(link)}">${escapeHtml(config.docTitle)}</a></p>`; 60 60 + 61 61 + return { 62 62 + msgtype: 'm.text', 63 63 + body, 64 64 + format: 'org.matrix.custom.html', 65 65 + formatted_body, 66 66 + }; 67 67 + } 68 68 + 69 69 + /** 70 70 + * Format a notification message. 71 71 + */ 72 72 + export function formatNotification( 73 73 + event: NotificationEvent, 74 74 + userName: string, 75 75 + docTitle: string, 76 76 + docLink: string, 77 77 + mentionRoom = false, 78 78 + ): MatrixMessage { 79 79 + const actions: Record<NotificationEvent, string> = { 80 80 + comment: 'commented on', 81 81 + mention: 'mentioned you in', 82 82 + edit: 'edited', 83 83 + share: 'shared', 84 84 + delete: 'deleted', 85 85 + }; 86 86 + 87 87 + const action = actions[event] || 'updated'; 88 88 + const roomMention = mentionRoom ? '@room ' : ''; 89 89 + const body = `${roomMention}${userName} ${action} "${docTitle}"\n${docLink}`; 90 90 + const formatted_body = `${roomMention}<strong>${escapeHtml(userName)}</strong> ${action} "<a href="${escapeHtml(docLink)}">${escapeHtml(docTitle)}</a>"`; 91 91 + 92 92 + return { 93 93 + msgtype: 'm.text', 94 94 + body, 95 95 + format: 'org.matrix.custom.html', 96 96 + formatted_body, 97 97 + }; 98 98 + } 99 99 + 100 100 + /** 101 101 + * Create a default notification config. 102 102 + */ 103 103 + export function createNotificationConfig(roomId: string): NotificationConfig { 104 104 + return { 105 105 + roomId, 106 106 + events: ['comment', 'mention'], 107 107 + mentionRoom: false, 108 108 + }; 109 109 + } 110 110 + 111 111 + /** 112 112 + * Check if a notification should be sent for an event. 113 113 + */ 114 114 + export function shouldNotify(config: NotificationConfig, event: NotificationEvent): boolean { 115 115 + return config.events.includes(event); 116 116 + } 117 117 + 118 118 + /** 119 119 + * Add an event to notification config. 120 120 + */ 121 121 + export function addNotificationEvent(config: NotificationConfig, event: NotificationEvent): NotificationConfig { 122 122 + if (config.events.includes(event)) return config; 123 123 + return { ...config, events: [...config.events, event] }; 124 124 + } 125 125 + 126 126 + /** 127 127 + * Remove an event from notification config. 128 128 + */ 129 129 + export function removeNotificationEvent(config: NotificationConfig, event: NotificationEvent): NotificationConfig { 130 130 + return { ...config, events: config.events.filter(e => e !== event) }; 131 131 + } 132 132 + 133 133 + /** 134 134 + * Format a thread summary request message (sent to Owl). 135 135 + */ 136 136 + export function formatThreadSummaryRequest(request: ThreadSummaryRequest): MatrixMessage { 137 137 + const body = `@owl Please summarize this thread and create a document titled "${request.docTitle}"`; 138 138 + const formatted_body = `<a href="https://matrix.to/#/@owl:matrix.lobster-hake.ts.net">@owl</a> Please summarize this thread and create a document titled "<strong>${escapeHtml(request.docTitle)}</strong>"`; 139 139 + 140 140 + return { 141 141 + msgtype: 'm.text', 142 142 + body, 143 143 + format: 'org.matrix.custom.html', 144 144 + formatted_body, 145 145 + }; 146 146 + } 147 147 + 148 148 + /** 149 149 + * Get all available notification events. 150 150 + */ 151 151 + export function getNotificationEvents(): Array<{ event: NotificationEvent; label: string }> { 152 152 + return [ 153 153 + { event: 'comment', label: 'New comments' }, 154 154 + { event: 'mention', label: 'Mentions' }, 155 155 + { event: 'edit', label: 'Document edits' }, 156 156 + { event: 'share', label: 'Document shared' }, 157 157 + { event: 'delete', label: 'Document deleted' }, 158 158 + ]; 159 159 + } 160 160 + 161 161 + /** 162 162 + * Validate a Matrix room ID format. 163 163 + */ 164 164 + export function isValidRoomId(roomId: string): boolean { 165 165 + return /^![a-zA-Z0-9._=\-/]+:[a-zA-Z0-9.\-]+$/.test(roomId); 166 166 + } 167 167 + 168 168 + /** Escape HTML for safe insertion */ 169 169 + function escapeHtml(str: string): string { 170 170 + return str 171 171 + .replace(/&/g, '&amp;') 172 172 + .replace(/</g, '&lt;') 173 173 + .replace(/>/g, '&gt;') 174 174 + .replace(/"/g, '&quot;'); 175 175 + }

+282

src/lib/offline-sync.ts

reviewed

··· 1 1 + /** 2 2 + * PWA Offline-First — IndexedDB cache, sync queue, install prompt logic. 3 3 + * 4 4 + * Pure logic module: sync queue management, cache metadata, conflict resolution. 5 5 + * IndexedDB and Service Worker APIs handled by the platform layer. 6 6 + */ 7 7 + 8 8 + export type SyncStatus = 'pending' | 'syncing' | 'synced' | 'conflict' | 'error'; 9 9 + 10 10 + export interface CachedDocument { 11 11 + docId: string; 12 12 + docType: 'docs' | 'sheets'; 13 13 + title: string; 14 14 + /** Encrypted content (stored as-is) */ 15 15 + encryptedData: string; 16 16 + /** Last sync timestamp */ 17 17 + lastSynced: number; 18 18 + /** Local modification timestamp */ 19 19 + lastModified: number; 20 20 + /** Server version at time of cache */ 21 21 + serverVersion: number; 22 22 + syncStatus: SyncStatus; 23 23 + } 24 24 + 25 25 + export interface SyncQueueItem { 26 26 + id: string; 27 27 + docId: string; 28 28 + operation: 'create' | 'update' | 'delete'; 29 29 + /** Encrypted payload */ 30 30 + payload: string; 31 31 + /** When the operation was queued */ 32 32 + queuedAt: number; 33 33 + /** Number of sync attempts */ 34 34 + attempts: number; 35 35 + /** Last error message */ 36 36 + lastError: string | null; 37 37 + } 38 38 + 39 39 + export interface OfflineState { 40 40 + isOnline: boolean; 41 41 + /** Cached documents */ 42 42 + documents: Map<string, CachedDocument>; 43 43 + /** Pending sync queue */ 44 44 + syncQueue: SyncQueueItem[]; 45 45 + /** Last successful sync */ 46 46 + lastSync: number; 47 47 + /** Whether a sync is in progress */ 48 48 + syncing: boolean; 49 49 + } 50 50 + 51 51 + export interface ConflictResolution { 52 52 + docId: string; 53 53 + strategy: 'local' | 'remote' | 'merge'; 54 54 + resolvedData: string; 55 55 + } 56 56 + 57 57 + let _queueCounter = 0; 58 58 + 59 59 + /** 60 60 + * Create initial offline state. 61 61 + */ 62 62 + export function createOfflineState(): OfflineState { 63 63 + return { 64 64 + isOnline: true, 65 65 + documents: new Map(), 66 66 + syncQueue: [], 67 67 + lastSync: 0, 68 68 + syncing: false, 69 69 + }; 70 70 + } 71 71 + 72 72 + /** 73 73 + * Set online status. 74 74 + */ 75 75 + export function setOnline(state: OfflineState, online: boolean): OfflineState { 76 76 + return { ...state, isOnline: online }; 77 77 + } 78 78 + 79 79 + /** 80 80 + * Cache a document locally. 81 81 + */ 82 82 + export function cacheDocument( 83 83 + state: OfflineState, 84 84 + docId: string, 85 85 + docType: 'docs' | 'sheets', 86 86 + title: string, 87 87 + encryptedData: string, 88 88 + serverVersion: number, 89 89 + ): OfflineState { 90 90 + const now = Date.now(); 91 91 + const doc: CachedDocument = { 92 92 + docId, 93 93 + docType, 94 94 + title, 95 95 + encryptedData, 96 96 + lastSynced: now, 97 97 + lastModified: now, 98 98 + serverVersion, 99 99 + syncStatus: 'synced', 100 100 + }; 101 101 + const documents = new Map(state.documents); 102 102 + documents.set(docId, doc); 103 103 + return { ...state, documents }; 104 104 + } 105 105 + 106 106 + /** 107 107 + * Mark a cached document as locally modified. 108 108 + */ 109 109 + export function markModified(state: OfflineState, docId: string, encryptedData: string): OfflineState { 110 110 + const doc = state.documents.get(docId); 111 111 + if (!doc) return state; 112 112 + const documents = new Map(state.documents); 113 113 + documents.set(docId, { 114 114 + ...doc, 115 115 + encryptedData, 116 116 + lastModified: Date.now(), 117 117 + syncStatus: 'pending', 118 118 + }); 119 119 + return { ...state, documents }; 120 120 + } 121 121 + 122 122 + /** 123 123 + * Remove a cached document. 124 124 + */ 125 125 + export function removeCachedDocument(state: OfflineState, docId: string): OfflineState { 126 126 + const documents = new Map(state.documents); 127 127 + documents.delete(docId); 128 128 + return { ...state, documents }; 129 129 + } 130 130 + 131 131 + /** 132 132 + * Queue a sync operation. 133 133 + */ 134 134 + export function queueSync( 135 135 + state: OfflineState, 136 136 + docId: string, 137 137 + operation: SyncQueueItem['operation'], 138 138 + payload: string, 139 139 + ): OfflineState { 140 140 + const item: SyncQueueItem = { 141 141 + id: `sync-${Date.now()}-${++_queueCounter}`, 142 142 + docId, 143 143 + operation, 144 144 + payload, 145 145 + queuedAt: Date.now(), 146 146 + attempts: 0, 147 147 + lastError: null, 148 148 + }; 149 149 + return { ...state, syncQueue: [...state.syncQueue, item] }; 150 150 + } 151 151 + 152 152 + /** 153 153 + * Remove a completed item from the sync queue. 154 154 + */ 155 155 + export function dequeueSync(state: OfflineState, itemId: string): OfflineState { 156 156 + return { ...state, syncQueue: state.syncQueue.filter(i => i.id !== itemId) }; 157 157 + } 158 158 + 159 159 + /** 160 160 + * Record a failed sync attempt. 161 161 + */ 162 162 + export function recordSyncFailure(state: OfflineState, itemId: string, error: string): OfflineState { 163 163 + return { 164 164 + ...state, 165 165 + syncQueue: state.syncQueue.map(i => 166 166 + i.id === itemId ? { ...i, attempts: i.attempts + 1, lastError: error } : i, 167 167 + ), 168 168 + }; 169 169 + } 170 170 + 171 171 + /** 172 172 + * Get the next item to sync (oldest first). 173 173 + */ 174 174 + export function nextSyncItem(state: OfflineState): SyncQueueItem | null { 175 175 + return state.syncQueue.length > 0 ? state.syncQueue[0] : null; 176 176 + } 177 177 + 178 178 + /** 179 179 + * Check if a document needs syncing. 180 180 + */ 181 181 + export function needsSync(doc: CachedDocument): boolean { 182 182 + return doc.syncStatus === 'pending' || doc.syncStatus === 'conflict'; 183 183 + } 184 184 + 185 185 + /** 186 186 + * Get all documents that need syncing. 187 187 + */ 188 188 + export function pendingDocuments(state: OfflineState): CachedDocument[] { 189 189 + return Array.from(state.documents.values()).filter(needsSync); 190 190 + } 191 191 + 192 192 + /** 193 193 + * Detect a conflict (local and server both modified). 194 194 + */ 195 195 + export function detectConflict(doc: CachedDocument, serverVersion: number): boolean { 196 196 + return doc.syncStatus === 'pending' && serverVersion > doc.serverVersion; 197 197 + } 198 198 + 199 199 + /** 200 200 + * Mark a document as conflicted. 201 201 + */ 202 202 + export function markConflict(state: OfflineState, docId: string): OfflineState { 203 203 + const doc = state.documents.get(docId); 204 204 + if (!doc) return state; 205 205 + const documents = new Map(state.documents); 206 206 + documents.set(docId, { ...doc, syncStatus: 'conflict' }); 207 207 + return { ...state, documents }; 208 208 + } 209 209 + 210 210 + /** 211 211 + * Resolve a conflict. 212 212 + */ 213 213 + export function resolveConflict( 214 214 + state: OfflineState, 215 215 + resolution: ConflictResolution, 216 216 + ): OfflineState { 217 217 + const doc = state.documents.get(resolution.docId); 218 218 + if (!doc) return state; 219 219 + const documents = new Map(state.documents); 220 220 + documents.set(resolution.docId, { 221 221 + ...doc, 222 222 + encryptedData: resolution.resolvedData, 223 223 + syncStatus: 'pending', 224 224 + lastModified: Date.now(), 225 225 + }); 226 226 + return { ...state, documents }; 227 227 + } 228 228 + 229 229 + /** 230 230 + * Mark sync as complete for a document. 231 231 + */ 232 232 + export function markSynced( 233 233 + state: OfflineState, 234 234 + docId: string, 235 235 + serverVersion: number, 236 236 + ): OfflineState { 237 237 + const doc = state.documents.get(docId); 238 238 + if (!doc) return state; 239 239 + const documents = new Map(state.documents); 240 240 + documents.set(docId, { 241 241 + ...doc, 242 242 + lastSynced: Date.now(), 243 243 + serverVersion, 244 244 + syncStatus: 'synced', 245 245 + }); 246 246 + return { ...state, documents }; 247 247 + } 248 248 + 249 249 + /** 250 250 + * Get sync queue length. 251 251 + */ 252 252 + export function queueLength(state: OfflineState): number { 253 253 + return state.syncQueue.length; 254 254 + } 255 255 + 256 256 + /** 257 257 + * Get count of cached documents. 258 258 + */ 259 259 + export function cachedDocCount(state: OfflineState): number { 260 260 + return state.documents.size; 261 261 + } 262 262 + 263 263 + /** 264 264 + * Check if there are any pending operations. 265 265 + */ 266 266 + export function hasPendingWork(state: OfflineState): boolean { 267 267 + return state.syncQueue.length > 0 || pendingDocuments(state).length > 0; 268 268 + } 269 269 + 270 270 + /** 271 271 + * Get items that have failed too many times (> maxAttempts). 272 272 + */ 273 273 + export function failedItems(state: OfflineState, maxAttempts = 3): SyncQueueItem[] { 274 274 + return state.syncQueue.filter(i => i.attempts >= maxAttempts); 275 275 + } 276 276 + 277 277 + /** 278 278 + * Purge failed items from the queue. 279 279 + */ 280 280 + export function purgeFailedItems(state: OfflineState, maxAttempts = 3): OfflineState { 281 281 + return { ...state, syncQueue: state.syncQueue.filter(i => i.attempts < maxAttempts) }; 282 282 + }

+199

tests/ai-assistant.test.ts

reviewed

··· 1 1 + import { describe, it, expect } from 'vitest'; 2 2 + import { 3 3 + createAIConfig, 4 4 + buildSystemPrompt, 5 5 + buildRequest, 6 6 + buildApiPayload, 7 7 + parseApiResponse, 8 8 + getAIActions, 9 9 + getTranslationLanguages, 10 10 + estimateTokens, 11 11 + isWithinLimit, 12 12 + truncateToLimit, 13 13 + isActionEnabled, 14 14 + } from '../src/lib/ai-assistant'; 15 15 + 16 16 + describe('ai-assistant', () => { 17 17 + describe('createAIConfig', () => { 18 18 + it('creates config with gateway URL', () => { 19 19 + const config = createAIConfig('http://ai'); 20 20 + expect(config.gatewayUrl).toBe('http://ai'); 21 21 + expect(config.model).toBeTruthy(); 22 22 + expect(config.defaultMaxTokens).toBe(1024); 23 23 + expect(config.enabledActions).toHaveLength(8); 24 24 + }); 25 25 + }); 26 26 + 27 27 + describe('buildSystemPrompt', () => { 28 28 + it('builds summarize prompt', () => { 29 29 + const prompt = buildSystemPrompt('summarize'); 30 30 + expect(prompt).toContain('Summarize'); 31 31 + }); 32 32 + 33 33 + it('builds rewrite prompt', () => { 34 34 + expect(buildSystemPrompt('rewrite')).toContain('Rewrite'); 35 35 + }); 36 36 + 37 37 + it('builds expand prompt', () => { 38 38 + expect(buildSystemPrompt('expand')).toContain('Expand'); 39 39 + }); 40 40 + 41 41 + it('builds translate prompt with language', () => { 42 42 + const prompt = buildSystemPrompt('translate', 'Spanish'); 43 43 + expect(prompt).toContain('Spanish'); 44 44 + }); 45 45 + 46 46 + it('defaults to English for translate', () => { 47 47 + const prompt = buildSystemPrompt('translate'); 48 48 + expect(prompt).toContain('English'); 49 49 + }); 50 50 + 51 51 + it('builds fix-grammar prompt', () => { 52 52 + expect(buildSystemPrompt('fix-grammar')).toContain('grammar'); 53 53 + }); 54 54 + 55 55 + it('builds simplify prompt', () => { 56 56 + expect(buildSystemPrompt('simplify')).toContain('Simplify'); 57 57 + }); 58 58 + 59 59 + it('builds make-formal prompt', () => { 60 60 + expect(buildSystemPrompt('make-formal')).toContain('formal'); 61 61 + }); 62 62 + 63 63 + it('builds make-casual prompt', () => { 64 64 + expect(buildSystemPrompt('make-casual')).toContain('casual'); 65 65 + }); 66 66 + }); 67 67 + 68 68 + describe('buildRequest', () => { 69 69 + it('builds a basic request', () => { 70 70 + const req = buildRequest('summarize', 'Hello world'); 71 71 + expect(req.action).toBe('summarize'); 72 72 + expect(req.content).toBe('Hello world'); 73 73 + expect(req.maxTokens).toBe(1024); 74 74 + }); 75 75 + 76 76 + it('accepts options', () => { 77 77 + const req = buildRequest('translate', 'Hello', { targetLanguage: 'French', maxTokens: 512 }); 78 78 + expect(req.targetLanguage).toBe('French'); 79 79 + expect(req.maxTokens).toBe(512); 80 80 + }); 81 81 + }); 82 82 + 83 83 + describe('buildApiPayload', () => { 84 84 + it('builds Aperture-compatible payload', () => { 85 85 + const config = createAIConfig('http://ai'); 86 86 + const request = buildRequest('summarize', 'Long text here'); 87 87 + const payload = buildApiPayload(request, config); 88 88 + expect(payload.model).toBeTruthy(); 89 89 + expect(payload.max_tokens).toBe(1024); 90 90 + expect(payload.system).toContain('Summarize'); 91 91 + expect(payload.messages).toHaveLength(1); 92 92 + expect(payload.messages[0].role).toBe('user'); 93 93 + expect(payload.messages[0].content).toBe('Long text here'); 94 94 + }); 95 95 + 96 96 + it('includes context when provided', () => { 97 97 + const config = createAIConfig('http://ai'); 98 98 + const request = buildRequest('rewrite', 'Fix this', { context: 'Technical document' }); 99 99 + const payload = buildApiPayload(request, config); 100 100 + expect(payload.messages[0].content).toContain('Context: Technical document'); 101 101 + expect(payload.messages[0].content).toContain('Fix this'); 102 102 + }); 103 103 + }); 104 104 + 105 105 + describe('parseApiResponse', () => { 106 106 + it('parses successful response', () => { 107 107 + const result = parseApiResponse({ 108 108 + content: [{ text: 'Summary here' }], 109 109 + usage: { output_tokens: 50 }, 110 110 + }, 'summarize'); 111 111 + expect(result.success).toBe(true); 112 112 + expect(result.result).toBe('Summary here'); 113 113 + expect(result.tokensUsed).toBe(50); 114 114 + expect(result.action).toBe('summarize'); 115 115 + }); 116 116 + 117 117 + it('handles empty response', () => { 118 118 + const result = parseApiResponse({ content: [], usage: {} }, 'rewrite'); 119 119 + expect(result.success).toBe(false); 120 120 + expect(result.result).toBe(''); 121 121 + }); 122 122 + 123 123 + it('handles missing fields gracefully', () => { 124 124 + const result = parseApiResponse({}, 'expand'); 125 125 + expect(result.success).toBe(false); 126 126 + expect(result.tokensUsed).toBe(0); 127 127 + }); 128 128 + }); 129 129 + 130 130 + describe('getAIActions', () => { 131 131 + it('returns 8 actions', () => { 132 132 + expect(getAIActions()).toHaveLength(8); 133 133 + }); 134 134 + 135 135 + it('all have labels and icons', () => { 136 136 + for (const action of getAIActions()) { 137 137 + expect(action.label).toBeTruthy(); 138 138 + expect(action.icon).toBeTruthy(); 139 139 + } 140 140 + }); 141 141 + }); 142 142 + 143 143 + describe('getTranslationLanguages', () => { 144 144 + it('returns 10 languages', () => { 145 145 + expect(getTranslationLanguages()).toHaveLength(10); 146 146 + }); 147 147 + 148 148 + it('includes English', () => { 149 149 + expect(getTranslationLanguages().some(l => l.code === 'en')).toBe(true); 150 150 + }); 151 151 + }); 152 152 + 153 153 + describe('estimateTokens', () => { 154 154 + it('estimates ~4 chars per token', () => { 155 155 + expect(estimateTokens('abcd')).toBe(1); 156 156 + expect(estimateTokens('12345678')).toBe(2); 157 157 + }); 158 158 + 159 159 + it('rounds up', () => { 160 160 + expect(estimateTokens('abc')).toBe(1); 161 161 + }); 162 162 + }); 163 163 + 164 164 + describe('isWithinLimit', () => { 165 165 + it('returns true for short text', () => { 166 166 + expect(isWithinLimit('hello')).toBe(true); 167 167 + }); 168 168 + 169 169 + it('returns false for text exceeding limit', () => { 170 170 + const longText = 'a'.repeat(20000); 171 171 + expect(isWithinLimit(longText, 1000)).toBe(false); 172 172 + }); 173 173 + }); 174 174 + 175 175 + describe('truncateToLimit', () => { 176 176 + it('returns text unchanged when within limit', () => { 177 177 + expect(truncateToLimit('hello', 100)).toBe('hello'); 178 178 + }); 179 179 + 180 180 + it('truncates and adds ellipsis', () => { 181 181 + const long = 'a'.repeat(500); 182 182 + const truncated = truncateToLimit(long, 100); 183 183 + expect(truncated.length).toBeLessThanOrEqual(400); 184 184 + expect(truncated).toMatch(/\.\.\.$/); 185 185 + }); 186 186 + }); 187 187 + 188 188 + describe('isActionEnabled', () => { 189 189 + it('returns true for enabled actions', () => { 190 190 + const config = createAIConfig('http://ai'); 191 191 + expect(isActionEnabled(config, 'summarize')).toBe(true); 192 192 + }); 193 193 + 194 194 + it('returns false for disabled actions', () => { 195 195 + const config = { ...createAIConfig('http://ai'), enabledActions: ['summarize' as const] }; 196 196 + expect(isActionEnabled(config, 'rewrite')).toBe(false); 197 197 + }); 198 198 + }); 199 199 + });

+183

tests/matrix-integration.test.ts

reviewed

··· 1 1 + import { describe, it, expect } from 'vitest'; 2 2 + import { 3 3 + generateShareLink, 4 4 + formatShareMessage, 5 5 + formatNotification, 6 6 + createNotificationConfig, 7 7 + shouldNotify, 8 8 + addNotificationEvent, 9 9 + removeNotificationEvent, 10 10 + formatThreadSummaryRequest, 11 11 + getNotificationEvents, 12 12 + isValidRoomId, 13 13 + } from '../src/lib/matrix-integration'; 14 14 + 15 15 + describe('matrix-integration', () => { 16 16 + describe('generateShareLink', () => { 17 17 + it('generates a share link', () => { 18 18 + expect(generateShareLink('https://tools.example.com', 'docs', 'abc')).toBe('https://tools.example.com/docs/abc'); 19 19 + }); 20 20 + }); 21 21 + 22 22 + describe('formatShareMessage', () => { 23 23 + it('formats a share message with HTML', () => { 24 24 + const msg = formatShareMessage({ 25 25 + roomId: '!room:matrix.org', 26 26 + docId: 'doc-1', 27 27 + docType: 'docs', 28 28 + docTitle: 'Meeting Notes', 29 29 + baseUrl: 'https://tools.example.com', 30 30 + message: '', 31 31 + }); 32 32 + expect(msg.msgtype).toBe('m.text'); 33 33 + expect(msg.body).toContain('Meeting Notes'); 34 34 + expect(msg.body).toContain('document'); 35 35 + expect(msg.formatted_body).toContain('<a href='); 36 36 + }); 37 37 + 38 38 + it('includes custom message', () => { 39 39 + const msg = formatShareMessage({ 40 40 + roomId: '!room:matrix.org', 41 41 + docId: 'doc-1', 42 42 + docType: 'sheets', 43 43 + docTitle: 'Budget', 44 44 + baseUrl: 'https://tools.example.com', 45 45 + message: 'Please review this', 46 46 + }); 47 47 + expect(msg.body).toContain('Please review this'); 48 48 + expect(msg.body).toContain('spreadsheet'); 49 49 + expect(msg.formatted_body).toContain('Please review this'); 50 50 + }); 51 51 + 52 52 + it('labels slides as presentation', () => { 53 53 + const msg = formatShareMessage({ 54 54 + roomId: '!room:matrix.org', 55 55 + docId: 's-1', 56 56 + docType: 'slides', 57 57 + docTitle: 'Pitch Deck', 58 58 + baseUrl: 'https://x.com', 59 59 + message: '', 60 60 + }); 61 61 + expect(msg.body).toContain('presentation'); 62 62 + }); 63 63 + 64 64 + it('escapes HTML in title', () => { 65 65 + const msg = formatShareMessage({ 66 66 + roomId: '!room:matrix.org', 67 67 + docId: 'doc-1', 68 68 + docType: 'docs', 69 69 + docTitle: '<script>alert("xss")</script>', 70 70 + baseUrl: 'https://x.com', 71 71 + message: '', 72 72 + }); 73 73 + expect(msg.formatted_body).not.toContain('<script>'); 74 74 + expect(msg.formatted_body).toContain('&lt;script&gt;'); 75 75 + }); 76 76 + }); 77 77 + 78 78 + describe('formatNotification', () => { 79 79 + it('formats a comment notification', () => { 80 80 + const msg = formatNotification('comment', 'Alice', 'Budget', 'https://x.com/sheets/1'); 81 81 + expect(msg.body).toContain('Alice'); 82 82 + expect(msg.body).toContain('commented on'); 83 83 + expect(msg.body).toContain('Budget'); 84 84 + }); 85 85 + 86 86 + it('formats a mention notification', () => { 87 87 + const msg = formatNotification('mention', 'Bob', 'Notes', 'https://x.com/docs/1'); 88 88 + expect(msg.body).toContain('mentioned you in'); 89 89 + }); 90 90 + 91 91 + it('includes @room when mentionRoom is true', () => { 92 92 + const msg = formatNotification('delete', 'Admin', 'Old Doc', 'https://x.com/docs/1', true); 93 93 + expect(msg.body).toContain('@room'); 94 94 + }); 95 95 + 96 96 + it('does not include @room by default', () => { 97 97 + const msg = formatNotification('edit', 'Alice', 'Doc', 'https://x.com/docs/1'); 98 98 + expect(msg.body).not.toContain('@room'); 99 99 + }); 100 100 + }); 101 101 + 102 102 + describe('createNotificationConfig', () => { 103 103 + it('creates config with default events', () => { 104 104 + const config = createNotificationConfig('!room:matrix.org'); 105 105 + expect(config.roomId).toBe('!room:matrix.org'); 106 106 + expect(config.events).toContain('comment'); 107 107 + expect(config.events).toContain('mention'); 108 108 + expect(config.mentionRoom).toBe(false); 109 109 + }); 110 110 + }); 111 111 + 112 112 + describe('shouldNotify', () => { 113 113 + it('returns true for subscribed events', () => { 114 114 + const config = createNotificationConfig('!room:matrix.org'); 115 115 + expect(shouldNotify(config, 'comment')).toBe(true); 116 116 + expect(shouldNotify(config, 'mention')).toBe(true); 117 117 + }); 118 118 + 119 119 + it('returns false for unsubscribed events', () => { 120 120 + const config = createNotificationConfig('!room:matrix.org'); 121 121 + expect(shouldNotify(config, 'edit')).toBe(false); 122 122 + expect(shouldNotify(config, 'delete')).toBe(false); 123 123 + }); 124 124 + }); 125 125 + 126 126 + describe('addNotificationEvent / removeNotificationEvent', () => { 127 127 + it('adds a new event', () => { 128 128 + const config = createNotificationConfig('!room:matrix.org'); 129 129 + const updated = addNotificationEvent(config, 'edit'); 130 130 + expect(updated.events).toContain('edit'); 131 131 + }); 132 132 + 133 133 + it('does not duplicate existing event', () => { 134 134 + const config = createNotificationConfig('!room:matrix.org'); 135 135 + const updated = addNotificationEvent(config, 'comment'); 136 136 + expect(updated.events.filter(e => e === 'comment')).toHaveLength(1); 137 137 + }); 138 138 + 139 139 + it('removes an event', () => { 140 140 + const config = createNotificationConfig('!room:matrix.org'); 141 141 + const updated = removeNotificationEvent(config, 'comment'); 142 142 + expect(updated.events).not.toContain('comment'); 143 143 + }); 144 144 + }); 145 145 + 146 146 + describe('formatThreadSummaryRequest', () => { 147 147 + it('formats Owl request', () => { 148 148 + const msg = formatThreadSummaryRequest({ 149 149 + roomId: '!room:matrix.org', 150 150 + threadId: '$thread123', 151 151 + docTitle: 'Sprint Planning', 152 152 + }); 153 153 + expect(msg.body).toContain('@owl'); 154 154 + expect(msg.body).toContain('Sprint Planning'); 155 155 + expect(msg.formatted_body).toContain('matrix.to'); 156 156 + }); 157 157 + }); 158 158 + 159 159 + describe('getNotificationEvents', () => { 160 160 + it('returns 5 event types', () => { 161 161 + expect(getNotificationEvents()).toHaveLength(5); 162 162 + }); 163 163 + 164 164 + it('all have labels', () => { 165 165 + for (const e of getNotificationEvents()) { 166 166 + expect(e.label).toBeTruthy(); 167 167 + } 168 168 + }); 169 169 + }); 170 170 + 171 171 + describe('isValidRoomId', () => { 172 172 + it('validates correct room IDs', () => { 173 173 + expect(isValidRoomId('!abc123:matrix.org')).toBe(true); 174 174 + expect(isValidRoomId('!room_name:server.example.com')).toBe(true); 175 175 + }); 176 176 + 177 177 + it('rejects invalid room IDs', () => { 178 178 + expect(isValidRoomId('abc')).toBe(false); 179 179 + expect(isValidRoomId('#room:matrix.org')).toBe(false); 180 180 + expect(isValidRoomId('')).toBe(false); 181 181 + }); 182 182 + }); 183 183 + });

+247

tests/offline-sync.test.ts

reviewed

··· 1 1 + import { describe, it, expect } from 'vitest'; 2 2 + import { 3 3 + createOfflineState, 4 4 + setOnline, 5 5 + cacheDocument, 6 6 + markModified, 7 7 + removeCachedDocument, 8 8 + queueSync, 9 9 + dequeueSync, 10 10 + recordSyncFailure, 11 11 + nextSyncItem, 12 12 + needsSync, 13 13 + pendingDocuments, 14 14 + detectConflict, 15 15 + markConflict, 16 16 + resolveConflict, 17 17 + markSynced, 18 18 + queueLength, 19 19 + cachedDocCount, 20 20 + hasPendingWork, 21 21 + failedItems, 22 22 + purgeFailedItems, 23 23 + } from '../src/lib/offline-sync'; 24 24 + 25 25 + describe('offline-sync', () => { 26 26 + describe('createOfflineState', () => { 27 27 + it('creates initial state', () => { 28 28 + const state = createOfflineState(); 29 29 + expect(state.isOnline).toBe(true); 30 30 + expect(state.documents.size).toBe(0); 31 31 + expect(state.syncQueue).toHaveLength(0); 32 32 + expect(state.lastSync).toBe(0); 33 33 + expect(state.syncing).toBe(false); 34 34 + }); 35 35 + }); 36 36 + 37 37 + describe('setOnline', () => { 38 38 + it('sets online status', () => { 39 39 + const state = createOfflineState(); 40 40 + expect(setOnline(state, false).isOnline).toBe(false); 41 41 + expect(setOnline(state, true).isOnline).toBe(true); 42 42 + }); 43 43 + }); 44 44 + 45 45 + describe('cacheDocument', () => { 46 46 + it('caches a document', () => { 47 47 + let state = createOfflineState(); 48 48 + state = cacheDocument(state, 'doc-1', 'docs', 'Notes', 'encrypted-data', 1); 49 49 + expect(cachedDocCount(state)).toBe(1); 50 50 + const doc = state.documents.get('doc-1')!; 51 51 + expect(doc.title).toBe('Notes'); 52 52 + expect(doc.syncStatus).toBe('synced'); 53 53 + expect(doc.serverVersion).toBe(1); 54 54 + }); 55 55 + 56 56 + it('overwrites existing cache', () => { 57 57 + let state = createOfflineState(); 58 58 + state = cacheDocument(state, 'doc-1', 'docs', 'V1', 'data1', 1); 59 59 + state = cacheDocument(state, 'doc-1', 'docs', 'V2', 'data2', 2); 60 60 + expect(cachedDocCount(state)).toBe(1); 61 61 + expect(state.documents.get('doc-1')!.title).toBe('V2'); 62 62 + }); 63 63 + }); 64 64 + 65 65 + describe('markModified', () => { 66 66 + it('marks document as pending sync', () => { 67 67 + let state = createOfflineState(); 68 68 + state = cacheDocument(state, 'doc-1', 'docs', 'Notes', 'old', 1); 69 69 + state = markModified(state, 'doc-1', 'new-data'); 70 70 + const doc = state.documents.get('doc-1')!; 71 71 + expect(doc.syncStatus).toBe('pending'); 72 72 + expect(doc.encryptedData).toBe('new-data'); 73 73 + }); 74 74 + 75 75 + it('returns unchanged for missing doc', () => { 76 76 + const state = createOfflineState(); 77 77 + expect(markModified(state, 'fake', 'data')).toBe(state); 78 78 + }); 79 79 + }); 80 80 + 81 81 + describe('removeCachedDocument', () => { 82 82 + it('removes a document from cache', () => { 83 83 + let state = createOfflineState(); 84 84 + state = cacheDocument(state, 'doc-1', 'docs', 'X', 'data', 1); 85 85 + state = removeCachedDocument(state, 'doc-1'); 86 86 + expect(cachedDocCount(state)).toBe(0); 87 87 + }); 88 88 + }); 89 89 + 90 90 + describe('sync queue', () => { 91 91 + it('queues a sync operation', () => { 92 92 + let state = createOfflineState(); 93 93 + state = queueSync(state, 'doc-1', 'update', 'payload'); 94 94 + expect(queueLength(state)).toBe(1); 95 95 + expect(state.syncQueue[0].docId).toBe('doc-1'); 96 96 + expect(state.syncQueue[0].operation).toBe('update'); 97 97 + expect(state.syncQueue[0].attempts).toBe(0); 98 98 + }); 99 99 + 100 100 + it('dequeues a completed item', () => { 101 101 + let state = createOfflineState(); 102 102 + state = queueSync(state, 'doc-1', 'update', 'payload'); 103 103 + const itemId = state.syncQueue[0].id; 104 104 + state = dequeueSync(state, itemId); 105 105 + expect(queueLength(state)).toBe(0); 106 106 + }); 107 107 + 108 108 + it('records sync failure', () => { 109 109 + let state = createOfflineState(); 110 110 + state = queueSync(state, 'doc-1', 'update', 'payload'); 111 111 + const itemId = state.syncQueue[0].id; 112 112 + state = recordSyncFailure(state, itemId, 'Network error'); 113 113 + expect(state.syncQueue[0].attempts).toBe(1); 114 114 + expect(state.syncQueue[0].lastError).toBe('Network error'); 115 115 + }); 116 116 + 117 117 + it('nextSyncItem returns oldest', () => { 118 118 + let state = createOfflineState(); 119 119 + state = queueSync(state, 'doc-1', 'update', 'p1'); 120 120 + state = queueSync(state, 'doc-2', 'create', 'p2'); 121 121 + expect(nextSyncItem(state)!.docId).toBe('doc-1'); 122 122 + }); 123 123 + 124 124 + it('nextSyncItem returns null when empty', () => { 125 125 + expect(nextSyncItem(createOfflineState())).toBeNull(); 126 126 + }); 127 127 + }); 128 128 + 129 129 + describe('needsSync', () => { 130 130 + it('returns true for pending', () => { 131 131 + const doc = { docId: 'x', docType: 'docs' as const, title: '', encryptedData: '', lastSynced: 0, lastModified: 1, serverVersion: 1, syncStatus: 'pending' as const }; 132 132 + expect(needsSync(doc)).toBe(true); 133 133 + }); 134 134 + 135 135 + it('returns true for conflict', () => { 136 136 + const doc = { docId: 'x', docType: 'docs' as const, title: '', encryptedData: '', lastSynced: 0, lastModified: 1, serverVersion: 1, syncStatus: 'conflict' as const }; 137 137 + expect(needsSync(doc)).toBe(true); 138 138 + }); 139 139 + 140 140 + it('returns false for synced', () => { 141 141 + const doc = { docId: 'x', docType: 'docs' as const, title: '', encryptedData: '', lastSynced: 0, lastModified: 0, serverVersion: 1, syncStatus: 'synced' as const }; 142 142 + expect(needsSync(doc)).toBe(false); 143 143 + }); 144 144 + }); 145 145 + 146 146 + describe('pendingDocuments', () => { 147 147 + it('returns only pending/conflict docs', () => { 148 148 + let state = createOfflineState(); 149 149 + state = cacheDocument(state, 'doc-1', 'docs', 'A', 'data', 1); 150 150 + state = cacheDocument(state, 'doc-2', 'docs', 'B', 'data', 1); 151 151 + state = markModified(state, 'doc-1', 'new-data'); 152 152 + expect(pendingDocuments(state)).toHaveLength(1); 153 153 + }); 154 154 + }); 155 155 + 156 156 + describe('conflict detection and resolution', () => { 157 157 + it('detects conflict when server has newer version', () => { 158 158 + const doc = { docId: 'x', docType: 'docs' as const, title: '', encryptedData: '', lastSynced: 0, lastModified: 1, serverVersion: 1, syncStatus: 'pending' as const }; 159 159 + expect(detectConflict(doc, 2)).toBe(true); 160 160 + }); 161 161 + 162 162 + it('no conflict when server version matches', () => { 163 163 + const doc = { docId: 'x', docType: 'docs' as const, title: '', encryptedData: '', lastSynced: 0, lastModified: 1, serverVersion: 1, syncStatus: 'pending' as const }; 164 164 + expect(detectConflict(doc, 1)).toBe(false); 165 165 + }); 166 166 + 167 167 + it('marks document as conflicted', () => { 168 168 + let state = createOfflineState(); 169 169 + state = cacheDocument(state, 'doc-1', 'docs', 'X', 'data', 1); 170 170 + state = markConflict(state, 'doc-1'); 171 171 + expect(state.documents.get('doc-1')!.syncStatus).toBe('conflict'); 172 172 + }); 173 173 + 174 174 + it('resolves conflict with new data', () => { 175 175 + let state = createOfflineState(); 176 176 + state = cacheDocument(state, 'doc-1', 'docs', 'X', 'old', 1); 177 177 + state = markConflict(state, 'doc-1'); 178 178 + state = resolveConflict(state, { docId: 'doc-1', strategy: 'local', resolvedData: 'resolved' }); 179 179 + const doc = state.documents.get('doc-1')!; 180 180 + expect(doc.encryptedData).toBe('resolved'); 181 181 + expect(doc.syncStatus).toBe('pending'); 182 182 + }); 183 183 + }); 184 184 + 185 185 + describe('markSynced', () => { 186 186 + it('marks a document as synced with new version', () => { 187 187 + let state = createOfflineState(); 188 188 + state = cacheDocument(state, 'doc-1', 'docs', 'X', 'data', 1); 189 189 + state = markModified(state, 'doc-1', 'new'); 190 190 + state = markSynced(state, 'doc-1', 2); 191 191 + const doc = state.documents.get('doc-1')!; 192 192 + expect(doc.syncStatus).toBe('synced'); 193 193 + expect(doc.serverVersion).toBe(2); 194 194 + }); 195 195 + }); 196 196 + 197 197 + describe('hasPendingWork', () => { 198 198 + it('returns false for clean state', () => { 199 199 + expect(hasPendingWork(createOfflineState())).toBe(false); 200 200 + }); 201 201 + 202 202 + it('returns true with queued items', () => { 203 203 + let state = createOfflineState(); 204 204 + state = queueSync(state, 'doc-1', 'update', 'p'); 205 205 + expect(hasPendingWork(state)).toBe(true); 206 206 + }); 207 207 + 208 208 + it('returns true with pending documents', () => { 209 209 + let state = createOfflineState(); 210 210 + state = cacheDocument(state, 'doc-1', 'docs', 'X', 'data', 1); 211 211 + state = markModified(state, 'doc-1', 'new'); 212 212 + expect(hasPendingWork(state)).toBe(true); 213 213 + }); 214 214 + }); 215 215 + 216 216 + describe('failedItems / purgeFailedItems', () => { 217 217 + it('identifies failed items', () => { 218 218 + let state = createOfflineState(); 219 219 + state = queueSync(state, 'doc-1', 'update', 'p'); 220 220 + const itemId = state.syncQueue[0].id; 221 221 + state = recordSyncFailure(state, itemId, 'err'); 222 222 + state = recordSyncFailure(state, itemId, 'err'); 223 223 + state = recordSyncFailure(state, itemId, 'err'); 224 224 + expect(failedItems(state, 3)).toHaveLength(1); 225 225 + }); 226 226 + 227 227 + it('purges failed items', () => { 228 228 + let state = createOfflineState(); 229 229 + state = queueSync(state, 'doc-1', 'update', 'p'); 230 230 + const itemId = state.syncQueue[0].id; 231 231 + state = recordSyncFailure(state, itemId, 'err'); 232 232 + state = recordSyncFailure(state, itemId, 'err'); 233 233 + state = recordSyncFailure(state, itemId, 'err'); 234 234 + state = purgeFailedItems(state, 3); 235 235 + expect(queueLength(state)).toBe(0); 236 236 + }); 237 237 + 238 238 + it('keeps items under failure threshold', () => { 239 239 + let state = createOfflineState(); 240 240 + state = queueSync(state, 'doc-1', 'update', 'p'); 241 241 + const itemId = state.syncQueue[0].id; 242 242 + state = recordSyncFailure(state, itemId, 'err'); 243 243 + state = purgeFailedItems(state, 3); 244 244 + expect(queueLength(state)).toBe(1); 245 245 + }); 246 246 + }); 247 247 + });