Click to upload or drag and drop
- *This is the abstract.
', - DOI: '10.1234/sleep.2024', - type: 'journal-article', - volume: '15', - issue: '3', - page: '100-110', - }, - }), - }); - - const result = await fetchFromDOI('10.1234/sleep.2024'); - - expect(result.title).toBe('Effect of Sleep on Cognitive Performance'); - expect(result.firstAuthor).toBe('Smith'); - expect(result.publicationYear).toBe(2024); - expect(result.journal).toBe('Sleep Medicine'); - expect(result.abstract).toBe('This is the abstract.'); // HTML stripped - expect(result.doi).toBe('10.1234/sleep.2024'); - expect(result.volume).toBe('15'); - expect(result.issue).toBe('3'); - expect(result.pages).toBe('100-110'); - }); - - it('should format multiple authors correctly', async () => { - mockFetch.mockResolvedValue({ - ok: true, - json: () => - Promise.resolve({ - message: { - title: ['Test'], - author: [ - { family: 'Smith', given: 'John' }, - { family: 'Doe', given: 'Jane' }, - { family: 'Brown', given: 'Bob' }, - ], - DOI: '10.1234/test', - }, - }), - }); - - const result = await fetchFromDOI('10.1234/test'); - - expect(result.authors).toContain('Smith, John'); - expect(result.authors).toContain('Doe, Jane'); - expect(result.authors).toContain('Brown, Bob'); - }); - - it('should handle missing publication date', async () => { - mockFetch.mockResolvedValue({ - ok: true, - json: () => - Promise.resolve({ - message: { - title: ['Test'], - author: [], - DOI: '10.1234/test', - // No published, published-print, or published-online - }, - }), - }); - - const result = await fetchFromDOI('10.1234/test'); - - expect(result.publicationYear).toBeNull(); - }); - - it('should try published-print if published is missing', async () => { - mockFetch.mockResolvedValue({ - ok: true, - json: () => - Promise.resolve({ - message: { - title: ['Test'], - author: [], - DOI: '10.1234/test', - 'published-print': { 'date-parts': [[2023]] }, - }, - }), - }); - - const result = await fetchFromDOI('10.1234/test'); - - expect(result.publicationYear).toBe(2023); - }); -}); - -describe('fetchReferenceByIdentifier', () => { - beforeEach(() => { - mockFetch.mockReset(); - }); - - it('should detect and fetch DOI', async () => { - mockFetch - .mockResolvedValueOnce({ - ok: true, - json: () => - Promise.resolve({ - message: { - title: ['DOI Article'], - author: [{ family: 'Test' }], - DOI: '10.1234/test', - }, - }), - }) - .mockResolvedValueOnce({ - // Unpaywall check - ok: true, - json: () => Promise.resolve({ oa_locations: [] }), - }); - - const result = await fetchReferenceByIdentifier('10.1234/test'); - - expect(result.title).toBe('DOI Article'); - expect(result.importSource).toBe('doi'); - }); - - it('should detect DOI with https prefix', async () => { - mockFetch - .mockResolvedValueOnce({ - ok: true, - json: () => - Promise.resolve({ - message: { title: ['Test'], author: [], DOI: '10.1234/test' }, - }), - }) - .mockResolvedValueOnce({ - ok: true, - json: () => Promise.resolve({ oa_locations: [] }), - }); - - const result = await fetchReferenceByIdentifier('https://doi.org/10.1234/test'); - - expect(result.importSource).toBe('doi'); - }); - - it('should throw for unrecognized identifier', async () => { - mockFetch.mockResolvedValue({ - ok: false, - status: 404, - }); - - await expect(fetchReferenceByIdentifier('invalid-identifier')).rejects.toThrow( - 'Could not identify reference', - ); - }); - - it('should include PDF availability info from Unpaywall', async () => { - mockFetch - .mockResolvedValueOnce({ - ok: true, - json: () => - Promise.resolve({ - message: { title: ['Test'], author: [], DOI: '10.1234/test' }, - }), - }) - .mockResolvedValueOnce({ - ok: true, - json: () => - Promise.resolve({ - oa_locations: [ - { - url_for_pdf: 'https://arxiv.org/pdf/test.pdf', - host_type: 'repository', - }, - ], - }), - }); - - const result = await fetchReferenceByIdentifier('10.1234/test'); - - expect(result.pdfAvailable).toBe(true); - expect(result.pdfAccessible).toBe(true); - expect(result.pdfUrl).toContain('arxiv'); - }); -}); diff --git a/packages/landing/src/lib/__tests__/referenceParser.test.js b/packages/landing/src/lib/__tests__/referenceParser.test.js deleted file mode 100644 index 5e3f9358..00000000 --- a/packages/landing/src/lib/__tests__/referenceParser.test.js +++ /dev/null @@ -1,170 +0,0 @@ -/** - * Tests for referenceParser.js - */ - -import { describe, it, expect } from 'vitest'; -import { parseRIS, parseBibTeX, parseReferences, getRefDisplayName } from '../referenceParser.js'; - -describe('referenceParser', () => { - describe('parseRIS', () => { - it('parses a basic RIS entry', () => { - const ris = `TY - JOUR -TI - Effect of sleep on cognitive performance -AU - Smith, John -AU - Doe, Jane -PY - 2023 -JO - Sleep Medicine -AB - This study examines the relationship between sleep and cognition. -DO - 10.1234/sleep.2023.001 -ER - `; - - const refs = parseRIS(ris); - expect(refs).toHaveLength(1); - expect(refs[0].title).toBe('Effect of sleep on cognitive performance'); - expect(refs[0].firstAuthor).toBe('Smith'); - expect(refs[0].publicationYear).toBe(2023); - expect(refs[0].journal).toBe('Sleep Medicine'); - expect(refs[0].doi).toBe('10.1234/sleep.2023.001'); - }); - - it('parses multiple RIS entries', () => { - const ris = `TY - JOUR -TI - First Study -AU - Author, One -PY - 2022 -ER - -TY - JOUR -TI - Second Study -AU - Author, Two -PY - 2023 -ER - `; - - const refs = parseRIS(ris); - expect(refs).toHaveLength(2); - expect(refs[0].title).toBe('First Study'); - expect(refs[1].title).toBe('Second Study'); - }); - - it('handles "First Last" author format', () => { - const ris = `TY - JOUR -TI - Test Study -AU - John Smith -PY - 2024 -ER - `; - - const refs = parseRIS(ris); - expect(refs[0].firstAuthor).toBe('Smith'); - }); - - it('extracts year from date format', () => { - const ris = `TY - JOUR -TI - Test Study -AU - Test Author -DA - 2024/05/15 -ER - `; - - const refs = parseRIS(ris); - expect(refs[0].publicationYear).toBe(2024); - }); - }); - - describe('parseBibTeX', () => { - it('parses a basic BibTeX entry', () => { - const bibtex = `@article{smith2023, - title = {Effect of exercise on health}, - author = {Smith, John and Doe, Jane}, - year = {2023}, - journal = {Health Journal}, - doi = {10.5678/health.2023.002} -}`; - - const refs = parseBibTeX(bibtex); - expect(refs).toHaveLength(1); - expect(refs[0].title).toBe('Effect of exercise on health'); - expect(refs[0].firstAuthor).toBe('Smith'); - expect(refs[0].publicationYear).toBe(2023); - }); - - it('parses multiple BibTeX entries', () => { - const bibtex = `@article{one2022, - title = {First Article}, - author = {One, Author}, - year = {2022} -} - -@book{two2023, - title = {Second Book}, - author = {Two, Author}, - year = {2023} -}`; - - const refs = parseBibTeX(bibtex); - expect(refs).toHaveLength(2); - }); - }); - - describe('parseReferences', () => { - it('auto-detects RIS format', () => { - const content = `TY - JOUR -TI - Auto Detected Study -AU - Test, Author -PY - 2024 -ER - `; - - const refs = parseReferences(content, 'unknown.txt'); - expect(refs).toHaveLength(1); - expect(refs[0].title).toBe('Auto Detected Study'); - }); - - it('auto-detects BibTeX format', () => { - const content = `@article{test, - title = {Auto Detected Article}, - author = {Test Author}, - year = {2024} -}`; - - const refs = parseReferences(content, 'unknown.txt'); - expect(refs).toHaveLength(1); - expect(refs[0].title).toBe('Auto Detected Article'); - }); - - it('uses extension hint for .ris files', () => { - const content = `TY - JOUR -TI - Test -AU - Author -ER - `; - - const refs = parseReferences(content, 'export.ris'); - expect(refs).toHaveLength(1); - }); - - it('uses extension hint for .bib files', () => { - const content = `@article{test, title={Test}, author={Author}, year={2024}}`; - - const refs = parseReferences(content, 'library.bib'); - expect(refs).toHaveLength(1); - }); - }); - - describe('getRefDisplayName', () => { - it('formats author and year correctly', () => { - const ref = { firstAuthor: 'Smith', publicationYear: 2023 }; - expect(getRefDisplayName(ref)).toBe('Smith (2023)'); - }); - - it('handles missing author', () => { - const ref = { firstAuthor: null, publicationYear: 2023 }; - expect(getRefDisplayName(ref)).toBe('Unknown (2023)'); - }); - - it('handles missing year', () => { - const ref = { firstAuthor: 'Smith', publicationYear: null }; - expect(getRefDisplayName(ref)).toBe('Smith (n.d.)'); - }); - - it('handles both missing', () => { - const ref = {}; - expect(getRefDisplayName(ref)).toBe('Unknown (n.d.)'); - }); - }); -}); diff --git a/packages/landing/src/primitives/__tests__/avatarCache.test.js b/packages/landing/src/primitives/__tests__/avatarCache.test.js deleted file mode 100644 index 38727804..00000000 --- a/packages/landing/src/primitives/__tests__/avatarCache.test.js +++ /dev/null @@ -1,79 +0,0 @@ -import { beforeEach, describe, expect, it } from 'vitest'; -import 'fake-indexeddb/auto'; -import { db } from '../db.js'; -import { - getCachedAvatar, - cacheAvatar, - removeCachedAvatar, - pruneExpiredAvatars, -} from '../avatarCache.js'; - -describe('avatarCache', () => { - beforeEach(async () => { - await db.avatars.clear(); - }); - - describe('cacheAvatar and getCachedAvatar', () => { - it('caches and retrieves avatar', async () => { - const dataUrl = 'data:image/png;base64,abc123'; - - await cacheAvatar('user-1', dataUrl); - - const result = await getCachedAvatar('user-1'); - expect(result).toBe(dataUrl); - }); - - it('returns null for non-existent user', async () => { - const result = await getCachedAvatar('nonexistent'); - expect(result).toBeNull(); - }); - - it('returns null for null/undefined userId', async () => { - expect(await getCachedAvatar(null)).toBeNull(); - expect(await getCachedAvatar(undefined)).toBeNull(); - }); - - it('overwrites existing avatar', async () => { - await cacheAvatar('user-1', 'data:image/png;base64,old'); - await cacheAvatar('user-1', 'data:image/png;base64,new'); - - const result = await getCachedAvatar('user-1'); - expect(result).toBe('data:image/png;base64,new'); - }); - }); - - describe('removeCachedAvatar', () => { - it('removes a cached avatar', async () => { - await cacheAvatar('user-1', 'data:image/png;base64,abc'); - - await removeCachedAvatar('user-1'); - - const result = await getCachedAvatar('user-1'); - expect(result).toBeNull(); - }); - - it('handles removing non-existent avatar gracefully', async () => { - await removeCachedAvatar('nonexistent'); - }); - }); - - describe('pruneExpiredAvatars', () => { - it('removes expired avatars', async () => { - // Insert an "expired" avatar directly - const thirtyOneDaysAgo = Date.now() - 31 * 24 * 60 * 60 * 1000; - await db.avatars.put({ - userId: 'old-user', - dataUrl: 'data:image/png;base64,old', - cachedAt: thirtyOneDaysAgo, - }); - - // Insert a fresh avatar - await cacheAvatar('new-user', 'data:image/png;base64,new'); - - await pruneExpiredAvatars(); - - expect(await getCachedAvatar('old-user')).toBeNull(); - expect(await getCachedAvatar('new-user')).toBe('data:image/png;base64,new'); - }); - }); -}); diff --git a/packages/landing/src/primitives/__tests__/db.test.js b/packages/landing/src/primitives/__tests__/db.test.js deleted file mode 100644 index 516535df..00000000 --- a/packages/landing/src/primitives/__tests__/db.test.js +++ /dev/null @@ -1,268 +0,0 @@ -/** - * Tests for db.js - Unified Dexie database - * - * Phase 1 of Dexie migration: Verify database schema and basic operations - */ - -import { describe, it, expect, beforeEach, afterEach } from 'vitest'; -import 'fake-indexeddb/auto'; - -// Reset the database before importing to get a fresh instance -let db, deleteProjectData, clearAllData; - -describe('db.js - Unified Dexie Database', () => { - beforeEach(async () => { - // Import db instance and helper functions - // Test isolation achieved via afterEach cleanup (deleteProjectData/clearAllData) - const module = await import('../db.js'); - db = module.db; - deleteProjectData = module.deleteProjectData; - clearAllData = module.clearAllData; - - // Ensure database is open - if (!db.isOpen()) { - await db.open(); - } - }); - - afterEach(async () => { - // Clear all data between tests - if (db.isOpen()) { - await db.projects.clear(); - await db.pdfs.clear(); - await db.avatars.clear(); - await db.formStates.clear(); - await db.localChecklists.clear(); - await db.localChecklistPdfs.clear(); - } - }); - - describe('Database Initialization', () => { - it('should open database successfully', () => { - expect(db.isOpen()).toBe(true); - expect(db.name).toBe('corates'); - }); - - it('should have all expected tables', () => { - // y-dexie creates internal tables for Y.Doc updates (prefixed with $) - const userTables = db.tables - .map(t => t.name) - .filter(n => !n.startsWith('$')) - .sort(); - expect(userTables).toEqual([ - 'avatars', - 'formStates', - 'localChecklistPdfs', - 'localChecklists', - 'pdfs', - 'projects', - ]); - }); - }); - - describe('Projects Table', () => { - it('should add and retrieve a project', async () => { - const project = { - id: 'proj-123', - orgId: 'org-456', - updatedAt: Date.now(), - }; - - await db.projects.add(project); - const retrieved = await db.projects.get('proj-123'); - - expect(retrieved.id).toBe('proj-123'); - expect(retrieved.orgId).toBe('org-456'); - }); - - it('should query projects by orgId', async () => { - await db.projects.bulkAdd([ - { id: 'proj-1', orgId: 'org-A', updatedAt: 1 }, - { id: 'proj-2', orgId: 'org-A', updatedAt: 2 }, - { id: 'proj-3', orgId: 'org-B', updatedAt: 3 }, - ]); - - const orgAProjects = await db.projects.where('orgId').equals('org-A').toArray(); - - expect(orgAProjects).toHaveLength(2); - expect(orgAProjects.map(p => p.id).sort()).toEqual(['proj-1', 'proj-2']); - }); - }); - - describe('PDFs Table', () => { - it('should add and retrieve a PDF cache entry', async () => { - const pdfEntry = { - id: 'proj-1:study-1:test.pdf', - projectId: 'proj-1', - studyId: 'study-1', - fileName: 'test.pdf', - data: new ArrayBuffer(100), - size: 100, - cachedAt: Date.now(), - }; - - await db.pdfs.add(pdfEntry); - const retrieved = await db.pdfs.get('proj-1:study-1:test.pdf'); - - expect(retrieved.projectId).toBe('proj-1'); - expect(retrieved.studyId).toBe('study-1'); - expect(retrieved.fileName).toBe('test.pdf'); - expect(retrieved.size).toBe(100); - }); - - it('should query PDFs by projectId', async () => { - await db.pdfs.bulkAdd([ - { - id: 'proj-1:study-1:a.pdf', - projectId: 'proj-1', - studyId: 'study-1', - fileName: 'a.pdf', - data: new ArrayBuffer(10), - size: 10, - cachedAt: 1, - }, - { - id: 'proj-1:study-2:b.pdf', - projectId: 'proj-1', - studyId: 'study-2', - fileName: 'b.pdf', - data: new ArrayBuffer(20), - size: 20, - cachedAt: 2, - }, - { - id: 'proj-2:study-1:c.pdf', - projectId: 'proj-2', - studyId: 'study-1', - fileName: 'c.pdf', - data: new ArrayBuffer(30), - size: 30, - cachedAt: 3, - }, - ]); - - const proj1Pdfs = await db.pdfs.where('projectId').equals('proj-1').toArray(); - - expect(proj1Pdfs).toHaveLength(2); - expect(proj1Pdfs.map(p => p.fileName).sort()).toEqual(['a.pdf', 'b.pdf']); - }); - - it('should order PDFs by cachedAt for LRU eviction', async () => { - await db.pdfs.bulkAdd([ - { - id: 'p:s:newest.pdf', - projectId: 'p', - studyId: 's', - fileName: 'newest.pdf', - data: new ArrayBuffer(10), - size: 10, - cachedAt: 3000, - }, - { - id: 'p:s:oldest.pdf', - projectId: 'p', - studyId: 's', - fileName: 'oldest.pdf', - data: new ArrayBuffer(10), - size: 10, - cachedAt: 1000, - }, - { - id: 'p:s:middle.pdf', - projectId: 'p', - studyId: 's', - fileName: 'middle.pdf', - data: new ArrayBuffer(10), - size: 10, - cachedAt: 2000, - }, - ]); - - const ordered = await db.pdfs.orderBy('cachedAt').toArray(); - - expect(ordered.map(p => p.fileName)).toEqual(['oldest.pdf', 'middle.pdf', 'newest.pdf']); - }); - }); - - describe('deleteProjectData', () => { - it('should delete project and associated PDFs', async () => { - await db.projects.add({ id: 'proj-to-delete', orgId: 'org-1', updatedAt: 1 }); - await db.projects.add({ id: 'proj-to-keep', orgId: 'org-1', updatedAt: 2 }); - - await db.pdfs.bulkAdd([ - { - id: 'proj-to-delete:s1:a.pdf', - projectId: 'proj-to-delete', - studyId: 's1', - fileName: 'a.pdf', - data: new ArrayBuffer(10), - size: 10, - cachedAt: 1, - }, - { - id: 'proj-to-delete:s2:b.pdf', - projectId: 'proj-to-delete', - studyId: 's2', - fileName: 'b.pdf', - data: new ArrayBuffer(10), - size: 10, - cachedAt: 2, - }, - { - id: 'proj-to-keep:s1:c.pdf', - projectId: 'proj-to-keep', - studyId: 's1', - fileName: 'c.pdf', - data: new ArrayBuffer(10), - size: 10, - cachedAt: 3, - }, - ]); - - await deleteProjectData('proj-to-delete'); - - const projects = await db.projects.toArray(); - expect(projects).toHaveLength(1); - expect(projects[0].id).toBe('proj-to-keep'); - - const pdfs = await db.pdfs.toArray(); - expect(pdfs).toHaveLength(1); - expect(pdfs[0].projectId).toBe('proj-to-keep'); - }); - }); - - describe('clearAllData', () => { - it('should clear all session tables', async () => { - await db.projects.add({ id: 'p1', orgId: 'o1', updatedAt: 1 }); - await db.pdfs.add({ - id: 'p1:s1:a.pdf', - projectId: 'p1', - studyId: 's1', - fileName: 'a.pdf', - data: new ArrayBuffer(10), - size: 10, - cachedAt: 1, - }); - - await clearAllData(); - - expect(await db.projects.count()).toBe(0); - expect(await db.pdfs.count()).toBe(0); - }); - - it('should not clear local checklists', async () => { - await db.localChecklists.add({ - id: 'local-123', - name: 'Practice', - type: 'AMSTAR2', - data: {}, - createdAt: Date.now(), - updatedAt: Date.now(), - }); - - await clearAllData(); - - expect(await db.localChecklists.count()).toBe(1); - }); - }); -}); diff --git a/packages/landing/src/primitives/__tests__/pdfCache.test.js b/packages/landing/src/primitives/__tests__/pdfCache.test.js deleted file mode 100644 index c29374d4..00000000 --- a/packages/landing/src/primitives/__tests__/pdfCache.test.js +++ /dev/null @@ -1,153 +0,0 @@ -import { beforeEach, describe, expect, it } from 'vitest'; -import 'fake-indexeddb/auto'; -import { db } from '../db.js'; -import { - cachePdf, - getCachedPdf, - removeCachedPdf, - clearStudyCache, - clearProjectCache, - getCacheSize, -} from '../pdfCache.js'; - -describe('pdfCache', () => { - beforeEach(async () => { - await db.pdfs.clear(); - }); - - describe('cachePdf and getCachedPdf', () => { - it('caches and retrieves PDF data', async () => { - const data = new ArrayBuffer(100); - new Uint8Array(data).fill(42); - - const result = await cachePdf('project-1', 'study-1', 'test.pdf', data); - expect(result).toBe(true); - - const retrieved = await getCachedPdf('project-1', 'study-1', 'test.pdf'); - expect(retrieved).not.toBeNull(); - expect(retrieved.byteLength).toBe(100); - expect(new Uint8Array(retrieved)[0]).toBe(42); - }); - - it('returns null for non-existent cache entry', async () => { - const result = await getCachedPdf('project-1', 'study-1', 'nonexistent.pdf'); - expect(result).toBeNull(); - }); - - it('overwrites existing cache entry', async () => { - const data1 = new ArrayBuffer(100); - new Uint8Array(data1).fill(1); - - const data2 = new ArrayBuffer(200); - new Uint8Array(data2).fill(2); - - await cachePdf('project-1', 'study-1', 'test.pdf', data1); - await cachePdf('project-1', 'study-1', 'test.pdf', data2); - - const retrieved = await getCachedPdf('project-1', 'study-1', 'test.pdf'); - expect(retrieved.byteLength).toBe(200); - expect(new Uint8Array(retrieved)[0]).toBe(2); - }); - - it('rejects files exceeding single file limit', async () => { - const largeData = new ArrayBuffer(51 * 1024 * 1024); // 51MB - - const result = await cachePdf('project-1', 'study-1', 'huge.pdf', largeData); - expect(result).toBe(false); - - const retrieved = await getCachedPdf('project-1', 'study-1', 'huge.pdf'); - expect(retrieved).toBeNull(); - }); - }); - - describe('removeCachedPdf', () => { - it('removes a cached PDF', async () => { - const data = new ArrayBuffer(100); - - await cachePdf('project-1', 'study-1', 'test.pdf', data); - const result = await removeCachedPdf('project-1', 'study-1', 'test.pdf'); - expect(result).toBe(true); - - const retrieved = await getCachedPdf('project-1', 'study-1', 'test.pdf'); - expect(retrieved).toBeNull(); - }); - - it('returns true even when entry does not exist', async () => { - const result = await removeCachedPdf('project-1', 'study-1', 'nonexistent.pdf'); - expect(result).toBe(true); - }); - }); - - describe('clearStudyCache', () => { - it('clears all PDFs for a specific study', async () => { - const data = new ArrayBuffer(100); - - await cachePdf('project-1', 'study-1', 'file1.pdf', data); - await cachePdf('project-1', 'study-1', 'file2.pdf', data); - await cachePdf('project-1', 'study-2', 'file3.pdf', data); - - const deleted = await clearStudyCache('project-1', 'study-1'); - expect(deleted).toBe(2); - - expect(await getCachedPdf('project-1', 'study-1', 'file1.pdf')).toBeNull(); - expect(await getCachedPdf('project-1', 'study-1', 'file2.pdf')).toBeNull(); - expect(await getCachedPdf('project-1', 'study-2', 'file3.pdf')).not.toBeNull(); - }); - }); - - describe('clearProjectCache', () => { - it('clears all PDFs for a specific project', async () => { - const data = new ArrayBuffer(100); - - await cachePdf('project-1', 'study-1', 'file1.pdf', data); - await cachePdf('project-1', 'study-2', 'file2.pdf', data); - await cachePdf('project-2', 'study-1', 'file3.pdf', data); - - const deleted = await clearProjectCache('project-1'); - expect(deleted).toBe(2); - - expect(await getCachedPdf('project-1', 'study-1', 'file1.pdf')).toBeNull(); - expect(await getCachedPdf('project-1', 'study-2', 'file2.pdf')).toBeNull(); - expect(await getCachedPdf('project-2', 'study-1', 'file3.pdf')).not.toBeNull(); - }); - }); - - describe('getCacheSize', () => { - it('returns 0 for empty cache', async () => { - const size = await getCacheSize(); - expect(size).toBe(0); - }); - - it('returns total size of all cached PDFs', async () => { - const data1 = new ArrayBuffer(1000); - const data2 = new ArrayBuffer(2000); - - await cachePdf('project-1', 'study-1', 'file1.pdf', data1); - await cachePdf('project-1', 'study-2', 'file2.pdf', data2); - - const size = await getCacheSize(); - expect(size).toBe(3000); - }); - }); - - describe('LRU eviction', () => { - it('evicts oldest entries when cache limit exceeded', async () => { - // Cache limit is 200MB, so we test with smaller files but verify ordering - const data = new ArrayBuffer(1000); - - // Cache multiple entries with different timestamps - await cachePdf('project-1', 'study-1', 'old.pdf', data); - await new Promise(r => setTimeout(r, 10)); // Small delay for cachedAt difference - await cachePdf('project-1', 'study-2', 'newer.pdf', data); - - // Verify both are cached - expect(await getCachedPdf('project-1', 'study-1', 'old.pdf')).not.toBeNull(); - expect(await getCachedPdf('project-1', 'study-2', 'newer.pdf')).not.toBeNull(); - - // Verify ordering by cachedAt - const entries = await db.pdfs.orderBy('cachedAt').toArray(); - expect(entries[0].fileName).toBe('old.pdf'); - expect(entries[1].fileName).toBe('newer.pdf'); - }); - }); -}); diff --git a/packages/landing/src/primitives/__tests__/projectStore.test.js b/packages/landing/src/primitives/__tests__/projectStore.test.js deleted file mode 100644 index 39e5c03c..00000000 --- a/packages/landing/src/primitives/__tests__/projectStore.test.js +++ /dev/null @@ -1,203 +0,0 @@ -/** - * Tests for projectStore - Central store for project data (Zustand) - * - * P0 Priority: Core state management - * Tests the store's ability to manage project data, connection states, - * and active project tracking. - */ - -import { describe, it, expect, beforeEach } from 'vitest'; -import { useProjectStore } from '@/stores/projectStore.ts'; - -describe('projectStore - Project Data Management', () => { - beforeEach(() => { - // Reset the store to initial state before each test - useProjectStore.setState({ - projects: {}, - activeProjectId: null, - connections: {}, - projectStats: {}, - }); - }); - - describe('setProjectData / getState', () => { - it('should store and retrieve project data', () => { - const projectId = 'test-project-1'; - const data = { - studies: [{ id: 'study-1', name: 'Test Study' }], - members: [{ userId: 'user-1', role: 'owner' }], - meta: { name: 'Test Project', description: 'A test project' }, - }; - - useProjectStore.getState().setProjectData(projectId, data); - const state = useProjectStore.getState(); - - expect(state.projects[projectId]).toBeDefined(); - expect(state.projects[projectId].studies).toEqual(data.studies); - expect(state.projects[projectId].members).toEqual(data.members); - expect(state.projects[projectId].meta).toEqual(data.meta); - }); - - it('should initialize project with empty arrays if not set', () => { - const projectId = 'test-project-2'; - useProjectStore.getState().setProjectData(projectId, {}); - - const project = useProjectStore.getState().projects[projectId]; - expect(project.studies).toEqual([]); - expect(project.members).toEqual([]); - expect(project.meta).toEqual({}); - }); - - it('should update existing project data without overwriting unset fields', () => { - const projectId = 'test-project-3'; - - useProjectStore.getState().setProjectData(projectId, { - studies: [{ id: 'study-1', name: 'Study 1' }], - members: [{ userId: 'user-1', role: 'owner' }], - meta: { name: 'Original Name' }, - }); - - // Update only studies - useProjectStore.getState().setProjectData(projectId, { - studies: [ - { id: 'study-1', name: 'Study 1' }, - { id: 'study-2', name: 'Study 2' }, - ], - }); - - const project = useProjectStore.getState().projects[projectId]; - expect(project.studies.length).toBe(2); - expect(project.members.length).toBe(1); - expect(project.meta.name).toBe('Original Name'); - }); - }); - - describe('clearProject', () => { - it('should remove project from cache', () => { - const projectId = 'to-clear'; - useProjectStore.getState().setProjectData(projectId, { meta: { name: 'To Clear' } }); - expect(useProjectStore.getState().projects[projectId]).toBeDefined(); - - useProjectStore.getState().clearProject(projectId); - expect(useProjectStore.getState().projects[projectId]).toBeUndefined(); - }); - - it('should clear active project if it matches', () => { - const projectId = 'active-to-clear'; - useProjectStore.getState().setProjectData(projectId, { meta: {} }); - useProjectStore.getState().setActiveProject(projectId); - - useProjectStore.getState().clearProject(projectId); - - expect(useProjectStore.getState().activeProjectId).toBeNull(); - }); - - it('should also clear connection state', () => { - const projectId = 'clear-with-connection'; - useProjectStore.getState().setProjectData(projectId, { meta: {} }); - useProjectStore.getState().dispatchConnectionEvent(projectId, { type: 'CONNECT_REQUESTED' }); - - useProjectStore.getState().clearProject(projectId); - - const connState = useProjectStore.getState().connections[projectId]; - expect(connState).toBeUndefined(); - }); - }); -}); - -describe('projectStore - Connection State Management', () => { - beforeEach(() => { - useProjectStore.setState({ - projects: {}, - activeProjectId: null, - connections: {}, - projectStats: {}, - }); - }); - - describe('getConnectionState via selector', () => { - it('should return default state for unknown project', () => { - const state = useProjectStore.getState().connections['unknown']; - // No entry exists, should be undefined (selector handles the default) - expect(state).toBeUndefined(); - }); - }); - - describe('dispatchConnectionEvent', () => { - it('should transition through connection phases', () => { - const projectId = 'conn-test'; - - useProjectStore.getState().dispatchConnectionEvent(projectId, { type: 'CONNECT_REQUESTED' }); - let conn = useProjectStore.getState().connections[projectId]; - expect(conn.phase).toBe('connecting'); - - useProjectStore.getState().dispatchConnectionEvent(projectId, { type: 'REMOTE_CONNECTED' }); - conn = useProjectStore.getState().connections[projectId]; - expect(conn.phase).toBe('connected'); - - useProjectStore.getState().dispatchConnectionEvent(projectId, { type: 'SYNC_COMPLETE' }); - conn = useProjectStore.getState().connections[projectId]; - expect(conn.phase).toBe('synced'); - }); - - it('should set error state on access denied', () => { - const projectId = 'error-test'; - - useProjectStore.getState().dispatchConnectionEvent(projectId, { - type: 'ACCESS_DENIED', - reason: 'Connection failed', - }); - - const conn = useProjectStore.getState().connections[projectId]; - expect(conn.phase).toBe('error'); - expect(conn.error).toBe('Connection failed'); - }); - - it('should reset to idle', () => { - const projectId = 'reset-test'; - - useProjectStore.getState().dispatchConnectionEvent(projectId, { type: 'CONNECT_REQUESTED' }); - useProjectStore.getState().dispatchConnectionEvent(projectId, { type: 'SYNC_COMPLETE' }); - expect(useProjectStore.getState().connections[projectId].phase).toBe('synced'); - - useProjectStore.getState().dispatchConnectionEvent(projectId, { type: 'RESET' }); - expect(useProjectStore.getState().connections[projectId].phase).toBe('idle'); - }); - }); -}); - -describe('projectStore - Active Project', () => { - beforeEach(() => { - useProjectStore.setState({ - projects: {}, - activeProjectId: null, - connections: {}, - projectStats: {}, - }); - }); - - describe('setActiveProject', () => { - it('should return null when no active project', () => { - expect(useProjectStore.getState().activeProjectId).toBeNull(); - }); - - it('should set active project ID', () => { - useProjectStore.getState().setActiveProject('project-123'); - expect(useProjectStore.getState().activeProjectId).toBe('project-123'); - }); - - it('should return active project data when cached', () => { - const projectId = 'active-test'; - useProjectStore.getState().setProjectData(projectId, { - meta: { name: 'Active Project' }, - studies: [], - members: [], - }); - useProjectStore.getState().setActiveProject(projectId); - - const state = useProjectStore.getState(); - expect(state.activeProjectId).toBe(projectId); - expect(state.projects[projectId].meta.name).toBe('Active Project'); - }); - }); -}); diff --git a/packages/landing/src/primitives/useProject/checklists/handlers/robins-i.test.js b/packages/landing/src/primitives/useProject/checklists/handlers/robins-i.test.js deleted file mode 100644 index 025c8f12..00000000 --- a/packages/landing/src/primitives/useProject/checklists/handlers/robins-i.test.js +++ /dev/null @@ -1,66 +0,0 @@ -/** - * Tests for ROBINSIHandler - comment field Y.Text preservation - */ - -import { describe, it, expect, beforeEach } from 'vitest'; -import * as Y from 'yjs'; -import { ROBINSIHandler } from './robins-i.js'; - -describe('ROBINSIHandler - comment field Y.Text handling', () => { - let handler; - let doc; - - beforeEach(() => { - handler = new ROBINSIHandler(); - doc = new Y.Doc(); - }); - - describe('setYTextField helper method', () => { - it('should create Y.Text when field does not exist', () => { - const questionYMap = doc.getMap('question'); - handler.setYTextField(questionYMap, 'comment', 'New comment'); - - const comment = questionYMap.get('comment'); - expect(comment).toBeInstanceOf(Y.Text); - expect(comment.toString()).toBe('New comment'); - }); - - it('should update existing Y.Text in place, preserving object identity', () => { - const questionYMap = doc.getMap('question'); - const existingText = new Y.Text(); - existingText.insert(0, 'Original comment'); - questionYMap.set('comment', existingText); - - handler.setYTextField(questionYMap, 'comment', 'Updated comment'); - - const comment = questionYMap.get('comment'); - expect(comment).toBe(existingText); - expect(comment.toString()).toBe('Updated comment'); - }); - - it('should upgrade legacy string to Y.Text', () => { - const questionYMap = doc.getMap('question'); - questionYMap.set('comment', 'Legacy string comment'); - - handler.setYTextField(questionYMap, 'comment', 'New comment'); - - const comment = questionYMap.get('comment'); - expect(comment).toBeInstanceOf(Y.Text); - expect(comment.toString()).toBe('New comment'); - }); - - it('should handle null by converting to empty string', () => { - const questionYMap = doc.getMap('question'); - const existingText = new Y.Text(); - existingText.insert(0, 'Existing text'); - questionYMap.set('comment', existingText); - - handler.setYTextField(questionYMap, 'comment', null); - - const comment = questionYMap.get('comment'); - expect(comment).toBeInstanceOf(Y.Text); - expect(comment.toString()).toBe(''); - expect(comment).toBe(existingText); - }); - }); -}); diff --git a/packages/landing/tsconfig.json b/packages/landing/tsconfig.json deleted file mode 100644 index 26a72966..00000000 --- a/packages/landing/tsconfig.json +++ /dev/null @@ -1,26 +0,0 @@ -{ - "include": ["**/*.ts", "**/*.tsx", "eslint.config.js", "prettier.config.js", "vite.config.ts"], - "compilerOptions": { - "target": "ES2022", - "jsx": "react-jsx", - "module": "ESNext", - "lib": ["ES2022", "DOM", "DOM.Iterable"], - "types": ["vite/client"], - "moduleResolution": "bundler", - "allowImportingTsExtensions": true, - "allowJs": true, - "verbatimModuleSyntax": false, - "noEmit": true, - "skipLibCheck": true, - "strict": true, - "noUnusedLocals": true, - "noUnusedParameters": true, - "noFallthroughCasesInSwitch": true, - "noUncheckedSideEffectImports": true, - "baseUrl": ".", - "paths": { - "@/*": ["./src/*"], - "@workers/rpc": ["../workers/dist/rpc/index.d.ts"] - } - } -} diff --git a/packages/mcp-memory/README.md b/packages/mcp-memory/README.md deleted file mode 100644 index 7e27ddff..00000000 --- a/packages/mcp-memory/README.md +++ /dev/null @@ -1,169 +0,0 @@ -# @corates/mcp-memory - -Persistent, repository-scoped long-term memory for agentic workloads. - -## Overview - -This MCP server provides a persistent knowledge base where agents can: - -- Search memory before tasks to retrieve relevant context -- Propose durable knowledge after tasks for future reference -- The server validates, deduplicates, and versions all knowledge - -Memory is stored in `.mcp/memory.db` and committed to git, so knowledge is shared across all contributors. - -## Knowledge Types - -| Type | Description | Example | -| ------------- | ---------------------------------- | ----------------------------------------- | -| **Fact** | Objective, verifiable information | "The web package uses SolidJS 1.8" | -| **Decision** | Intentional choice with rationale | "We use Zod over Yup for Workers compat" | -| **Procedure** | Step-by-step operational knowledge | "To add an API route: 1) Create file..." | -| **Pattern** | Repeated structure or practice | "All stores use createStore with actions" | - -## Tools - -### search_memory - -Search for relevant knowledge before starting a task. - -```json -{ - "query": "authentication patterns", - "types": ["pattern", "decision"], - "limit": 10 -} -``` - -### propose_memory_write - -Submit new knowledge for validation and storage. - -```json -{ - "type": "decision", - "title": "Use Better-Auth over Lucia", - "content": "Better-Auth was chosen because it has native Cloudflare Workers support and built-in organization features.", - "tags": ["auth", "architecture"], - "source": { - "type": "discussion", - "reference": "PR #142" - } -} -``` - -### propose_memory_update - -Refine or supersede existing knowledge. - -```json -{ - "target_id": "abc-123", - "action": "supersede", - "title": "Use Better-Auth over Lucia (v2)", - "content": "Updated guidance for Better-Auth v2...", - "justification": "Better-Auth v2 released with breaking changes" -} -``` - -## Setup - -### 1. Build the package - -```bash -pnpm --filter @corates/mcp-memory build -``` - -### 2. Configure your MCP client - -#### Claude Code / Cursor - -Add to your MCP settings (usually `~/.config/claude/mcp.json` or similar): - -```json -{ - "mcpServers": { - "corates-memory": { - "command": "node", - "args": ["/path/to/corates/packages/mcp-memory/dist/server.js"], - "env": { - "MCP_MEMORY_REPO_ROOT": "/path/to/corates" - } - } - } -} -``` - -#### VS Code with Copilot - -Add to your workspace `.vscode/mcp.json`: - -```json -{ - "servers": { - "corates-memory": { - "command": "node", - "args": ["${workspaceFolder}/packages/mcp-memory/dist/server.js"], - "env": { - "MCP_MEMORY_REPO_ROOT": "${workspaceFolder}" - } - } - } -} -``` - -### 3. First run - -The first run will: - -1. Create `.mcp/memory.db` if it does not exist -2. Download the embedding model (~50MB, cached locally) - -## Development - -```bash -# Install dependencies -pnpm install - -# Build -pnpm --filter @corates/mcp-memory build - -# Run tests -pnpm --filter @corates/mcp-memory test - -# Watch mode -pnpm --filter @corates/mcp-memory dev -``` - -## Architecture - -``` -MCP Server (stdio) - | - +-- Tools - | +-- search_memory - | +-- propose_memory_write - | +-- propose_memory_update - | - +-- Embedding Service (local, @xenova/transformers) - | +-- all-MiniLM-L6-v2 (384 dimensions) - | - +-- Storage (SQLite via better-sqlite3) - +-- .mcp/memory.db -``` - -## Server Responsibilities - -The server handles (agents do not): - -- Schema validation -- Duplicate detection (embedding similarity) -- Confidence scoring -- Version management -- Embedding generation - -## Environment Variables - -| Variable | Description | Default | -| ---------------------- | -------------------- | ---------------------------------- | -| `MCP_MEMORY_REPO_ROOT` | Repository root path | Auto-detected from server location | diff --git a/packages/mcp-memory/__tests__/confidence.test.ts b/packages/mcp-memory/__tests__/confidence.test.ts deleted file mode 100644 index 5397c61a..00000000 --- a/packages/mcp-memory/__tests__/confidence.test.ts +++ /dev/null @@ -1,119 +0,0 @@ -/** - * Tests for confidence scoring - */ - -import { describe, it, expect } from 'vitest'; -import { computeConfidence } from '../src/confidence.js'; - -describe('computeConfidence', () => { - it('should return base confidence for minimal entry', () => { - const confidence = computeConfidence({ - type: 'fact', - content: 'Short content.', - }); - - // Base fact confidence is 0.6 - expect(confidence).toBeGreaterThanOrEqual(0.6); - expect(confidence).toBeLessThan(0.75); - }); - - it('should increase confidence with source', () => { - const withoutSource = computeConfidence({ - type: 'decision', - content: 'A decision was made.', - }); - - const withSource = computeConfidence({ - type: 'decision', - content: 'A decision was made.', - source: { type: 'discussion' }, - }); - - expect(withSource).toBeGreaterThan(withoutSource); - }); - - it('should increase confidence with source reference', () => { - const withoutRef = computeConfidence({ - type: 'pattern', - content: 'A pattern is used.', - source: { type: 'code' }, - }); - - const withRef = computeConfidence({ - type: 'pattern', - content: 'A pattern is used.', - source: { type: 'code', reference: 'src/index.ts' }, - }); - - expect(withRef).toBeGreaterThan(withoutRef); - }); - - it('should increase confidence with longer content', () => { - const shortContent = computeConfidence({ - type: 'procedure', - content: 'Do this.', - }); - - const longContent = computeConfidence({ - type: 'procedure', - content: - 'Step 1: Do this thing first. Step 2: Then do this other thing. Step 3: Finally, complete the process by doing this last thing. This ensures everything is done correctly.', - }); - - expect(longContent).toBeGreaterThan(shortContent); - }); - - it('should factor in agent confidence hint', () => { - const noHint = computeConfidence({ - type: 'fact', - content: 'A fact about something.', - }); - - const highHint = computeConfidence({ - type: 'fact', - content: 'A fact about something.', - confidenceHint: 0.95, - }); - - const lowHint = computeConfidence({ - type: 'fact', - content: 'A fact about something.', - confidenceHint: 0.2, - }); - - expect(highHint).toBeGreaterThan(noHint); - expect(lowHint).toBeLessThan(noHint); - }); - - it('should clamp confidence to [0, 1]', () => { - const maxConfidence = computeConfidence({ - type: 'fact', - content: 'A'.repeat(1000), - source: { type: 'code', reference: 'src/test.ts' }, - confidenceHint: 1.0, - }); - - expect(maxConfidence).toBeLessThanOrEqual(1); - - const minConfidence = computeConfidence({ - type: 'pattern', - content: 'Short.', - confidenceHint: 0, - }); - - expect(minConfidence).toBeGreaterThanOrEqual(0); - }); - - it('should vary by knowledge type', () => { - const content = 'Same content for all types here.'; - - const factConf = computeConfidence({ type: 'fact', content }); - const decisionConf = computeConfidence({ type: 'decision', content }); - const _procedureConf = computeConfidence({ type: 'procedure', content }); - const patternConf = computeConfidence({ type: 'pattern', content }); - - // Facts have highest base confidence - expect(factConf).toBeGreaterThan(decisionConf); - expect(factConf).toBeGreaterThan(patternConf); - }); -}); diff --git a/packages/mcp-memory/__tests__/storage.test.ts b/packages/mcp-memory/__tests__/storage.test.ts deleted file mode 100644 index 405e533b..00000000 --- a/packages/mcp-memory/__tests__/storage.test.ts +++ /dev/null @@ -1,299 +0,0 @@ -/** - * Tests for SQLite storage - */ - -import { describe, it, expect, beforeEach, afterEach } from 'vitest'; -import { SqliteStorage } from '../src/storage/sqlite.js'; -import fs from 'fs'; -import path from 'path'; -import os from 'os'; - -describe('SqliteStorage', () => { - let storage: SqliteStorage; - let testDir: string; - - beforeEach(async () => { - // Create temp directory for test database - testDir = fs.mkdtempSync(path.join(os.tmpdir(), 'mcp-memory-test-')); - storage = new SqliteStorage(testDir); - await storage.initialize(); - }); - - afterEach(async () => { - await storage.close(); - // Clean up test directory - fs.rmSync(testDir, { recursive: true, force: true }); - }); - - describe('initialize', () => { - it('should create database and tables', async () => { - const dbPath = path.join(testDir, '.mcp', 'memory.db'); - expect(fs.existsSync(dbPath)).toBe(true); - }); - }); - - describe('create', () => { - it('should create a new entry and return id', async () => { - const id = await storage.create({ - type: 'fact', - title: 'Test Fact', - content: 'This is a test fact about the codebase.', - tags: ['test', 'example'], - confidence: 0.7, - embedding: new Array(384).fill(0.1), - }); - - expect(id).toBeDefined(); - expect(typeof id).toBe('string'); - }); - - it('should store entry with all fields', async () => { - const id = await storage.create({ - type: 'decision', - title: 'Use TypeScript', - content: 'We use TypeScript for type safety.', - tags: ['architecture'], - source: { - type: 'discussion', - reference: 'PR #42', - }, - confidence: 0.8, - embedding: new Array(384).fill(0.2), - }); - - const entry = await storage.getById(id); - expect(entry).not.toBeNull(); - expect(entry!.type).toBe('decision'); - expect(entry!.title).toBe('Use TypeScript'); - expect(entry!.source?.type).toBe('discussion'); - expect(entry!.source?.reference).toBe('PR #42'); - }); - }); - - describe('getById', () => { - it('should return null for non-existent id', async () => { - const entry = await storage.getById('non-existent-id'); - expect(entry).toBeNull(); - }); - - it('should return entry for valid id', async () => { - const id = await storage.create({ - type: 'pattern', - title: 'Test Pattern', - content: 'This is a pattern.', - tags: [], - confidence: 0.5, - embedding: new Array(384).fill(0), - }); - - const entry = await storage.getById(id); - expect(entry).not.toBeNull(); - expect(entry!.id).toBe(id); - }); - }); - - describe('update', () => { - it('should update entry content and increment version', async () => { - const id = await storage.create({ - type: 'procedure', - title: 'Deploy Process', - content: 'Step 1: Build', - tags: [], - confidence: 0.6, - embedding: new Array(384).fill(0.3), - }); - - await storage.update(id, { - content: 'Step 1: Build\nStep 2: Deploy', - }); - - const entry = await storage.getById(id); - expect(entry!.content).toBe('Step 1: Build\nStep 2: Deploy'); - expect(entry!.version).toBe(2); - }); - - it('should throw for non-existent entry', async () => { - await expect(storage.update('non-existent', { content: 'new content' })).rejects.toThrow( - 'Entry not found', - ); - }); - }); - - describe('supersede', () => { - it('should create new entry and mark old as superseded', async () => { - const oldId = await storage.create({ - type: 'fact', - title: 'Old Fact', - content: 'This is outdated.', - tags: [], - confidence: 0.5, - embedding: new Array(384).fill(0.1), - }); - - const newId = await storage.supersede(oldId, { - type: 'fact', - title: 'New Fact', - content: 'This is the updated information.', - tags: [], - confidence: 0.7, - embedding: new Array(384).fill(0.2), - }); - - const oldEntry = await storage.getById(oldId); - expect(oldEntry!.supersededBy).toBe(newId); - - const newEntry = await storage.getById(newId); - expect(newEntry!.supersededBy).toBeUndefined(); - }); - - it('should throw if entry already superseded', async () => { - const oldId = await storage.create({ - type: 'fact', - title: 'Old Fact', - content: 'This is outdated.', - tags: [], - confidence: 0.5, - embedding: new Array(384).fill(0.1), - }); - - await storage.supersede(oldId, { - type: 'fact', - title: 'New Fact', - content: 'Updated.', - tags: [], - confidence: 0.7, - embedding: new Array(384).fill(0.2), - }); - - await expect( - storage.supersede(oldId, { - type: 'fact', - title: 'Another Fact', - content: 'Cannot supersede twice.', - tags: [], - confidence: 0.7, - embedding: new Array(384).fill(0.3), - }), - ).rejects.toThrow('Entry already superseded'); - }); - }); - - describe('search', () => { - beforeEach(async () => { - // Create test entries with different embeddings - await storage.create({ - type: 'fact', - title: 'Database Uses SQLite', - content: 'The project uses SQLite for local storage.', - tags: ['database', 'architecture'], - confidence: 0.8, - embedding: [1, 0, 0, ...new Array(381).fill(0)], - }); - - await storage.create({ - type: 'decision', - title: 'Chose React over Vue', - content: 'We chose React because of ecosystem.', - tags: ['frontend', 'architecture'], - confidence: 0.7, - embedding: [0, 1, 0, ...new Array(381).fill(0)], - }); - - await storage.create({ - type: 'pattern', - title: 'Error Handling Pattern', - content: 'All errors use AppError class.', - tags: ['patterns', 'errors'], - confidence: 0.6, - embedding: [0, 0, 1, ...new Array(381).fill(0)], - }); - }); - - it('should return entries sorted by relevance', async () => { - // Query embedding similar to first entry - const queryEmbedding = [0.9, 0.1, 0, ...new Array(381).fill(0)]; - - const results = await storage.search({ query: 'database' }, queryEmbedding); - - expect(results.results.length).toBeGreaterThan(0); - expect(results.results[0].title).toBe('Database Uses SQLite'); - }); - - it('should filter by type', async () => { - const queryEmbedding = [0.5, 0.5, 0.5, ...new Array(381).fill(0)]; - - const results = await storage.search( - { query: 'architecture', types: ['decision'] }, - queryEmbedding, - ); - - expect(results.results.every(r => r.type === 'decision')).toBe(true); - }); - - it('should filter by confidence', async () => { - const queryEmbedding = [0.5, 0.5, 0.5, ...new Array(381).fill(0)]; - - const results = await storage.search({ query: 'test', minConfidence: 0.75 }, queryEmbedding); - - expect(results.results.every(r => r.confidence >= 0.75)).toBe(true); - }); - - it('should exclude superseded entries by default', async () => { - const oldId = await storage.create({ - type: 'fact', - title: 'Old Entry', - content: 'This will be superseded.', - tags: [], - confidence: 0.9, - embedding: [0.8, 0.8, 0.8, ...new Array(381).fill(0)], - }); - - await storage.supersede(oldId, { - type: 'fact', - title: 'New Entry', - content: 'This replaces the old one.', - tags: [], - confidence: 0.9, - embedding: [0.8, 0.8, 0.8, ...new Array(381).fill(0)], - }); - - const queryEmbedding = [0.8, 0.8, 0.8, ...new Array(381).fill(0)]; - const results = await storage.search({ query: 'test' }, queryEmbedding); - - const titles = results.results.map(r => r.title); - expect(titles).not.toContain('Old Entry'); - expect(titles).toContain('New Entry'); - }); - }); - - describe('findSimilar', () => { - it('should find entries above similarity threshold', async () => { - await storage.create({ - type: 'fact', - title: 'Similar Entry', - content: 'This is similar.', - tags: [], - confidence: 0.7, - embedding: [1, 0, 0, ...new Array(381).fill(0)], - }); - - await storage.create({ - type: 'fact', - title: 'Different Entry', - content: 'This is different.', - tags: [], - confidence: 0.7, - embedding: [0, 1, 0, ...new Array(381).fill(0)], - }); - - const similar = await storage.findSimilar( - [0.99, 0.01, 0, ...new Array(381).fill(0)], - 0.9, - 10, - ); - - expect(similar.length).toBe(1); - expect(similar[0].entry.title).toBe('Similar Entry'); - }); - }); -}); diff --git a/packages/mcp-memory/__tests__/validation.test.ts b/packages/mcp-memory/__tests__/validation.test.ts deleted file mode 100644 index 1a8dd163..00000000 --- a/packages/mcp-memory/__tests__/validation.test.ts +++ /dev/null @@ -1,190 +0,0 @@ -/** - * Tests for validation schemas - */ - -import { describe, it, expect } from 'vitest'; -import { SearchQuerySchema, CreateEntrySchema, UpdateEntrySchema } from '../src/validation.js'; - -describe('SearchQuerySchema', () => { - it('should accept valid search query', () => { - const result = SearchQuerySchema.safeParse({ - query: 'authentication patterns', - types: ['pattern', 'decision'], - limit: 5, - }); - - expect(result.success).toBe(true); - }); - - it('should reject empty query', () => { - const result = SearchQuerySchema.safeParse({ - query: '', - }); - - expect(result.success).toBe(false); - }); - - it('should apply defaults', () => { - const result = SearchQuerySchema.parse({ - query: 'test', - }); - - expect(result.limit).toBe(10); - expect(result.min_confidence).toBe(0.3); - }); - - it('should reject invalid types', () => { - const result = SearchQuerySchema.safeParse({ - query: 'test', - types: ['invalid'], - }); - - expect(result.success).toBe(false); - }); -}); - -describe('CreateEntrySchema', () => { - it('should accept valid entry', () => { - const result = CreateEntrySchema.safeParse({ - type: 'fact', - title: 'Valid Title', - content: 'This is valid content for the entry.', - tags: ['test'], - }); - - expect(result.success).toBe(true); - }); - - it('should reject title too short', () => { - const result = CreateEntrySchema.safeParse({ - type: 'fact', - title: 'Hi', - content: 'Valid content here.', - }); - - expect(result.success).toBe(false); - if (!result.success) { - expect(result.error.issues[0].path).toContain('title'); - } - }); - - it('should reject title too long', () => { - const result = CreateEntrySchema.safeParse({ - type: 'fact', - title: 'A'.repeat(101), - content: 'Valid content here.', - }); - - expect(result.success).toBe(false); - }); - - it('should reject content too short', () => { - const result = CreateEntrySchema.safeParse({ - type: 'fact', - title: 'Valid Title', - content: 'Short', - }); - - expect(result.success).toBe(false); - if (!result.success) { - expect(result.error.issues[0].path).toContain('content'); - } - }); - - it('should accept source with reference', () => { - const result = CreateEntrySchema.safeParse({ - type: 'decision', - title: 'Valid Title', - content: 'This is valid content for the entry.', - source: { - type: 'code', - reference: 'src/index.ts', - }, - }); - - expect(result.success).toBe(true); - }); - - it('should accept confidence hint', () => { - const result = CreateEntrySchema.parse({ - type: 'pattern', - title: 'Valid Pattern', - content: 'This is a pattern that is used.', - confidence_hint: 0.9, - }); - - expect(result.confidence_hint).toBe(0.9); - }); - - it('should reject invalid confidence hint', () => { - const result = CreateEntrySchema.safeParse({ - type: 'pattern', - title: 'Valid Pattern', - content: 'This is a pattern that is used.', - confidence_hint: 1.5, - }); - - expect(result.success).toBe(false); - }); -}); - -describe('UpdateEntrySchema', () => { - it('should accept valid supersede', () => { - const result = UpdateEntrySchema.safeParse({ - target_id: '550e8400-e29b-41d4-a716-446655440000', - action: 'supersede', - title: 'New Title', - content: 'Updated content here.', - justification: 'Information was outdated.', - }); - - expect(result.success).toBe(true); - }); - - it('should accept valid refine', () => { - const result = UpdateEntrySchema.safeParse({ - target_id: '550e8400-e29b-41d4-a716-446655440000', - action: 'refine', - content: 'Refined content here.', - justification: 'Added more detail.', - }); - - expect(result.success).toBe(true); - }); - - it('should reject invalid UUID', () => { - const result = UpdateEntrySchema.safeParse({ - target_id: 'not-a-uuid', - action: 'refine', - content: 'Valid content here.', - justification: 'Valid justification.', - }); - - expect(result.success).toBe(false); - if (!result.success) { - expect(result.error.issues[0].path).toContain('target_id'); - } - }); - - it('should reject empty justification', () => { - const result = UpdateEntrySchema.safeParse({ - target_id: '550e8400-e29b-41d4-a716-446655440000', - action: 'refine', - content: 'Valid content here.', - justification: 'Hi', - }); - - expect(result.success).toBe(false); - }); - - it('should reject invalid action', () => { - const result = UpdateEntrySchema.safeParse({ - target_id: '550e8400-e29b-41d4-a716-446655440000', - action: 'delete', - content: 'Valid content here.', - justification: 'Valid justification.', - }); - - expect(result.success).toBe(false); - }); -}); diff --git a/packages/mcp-memory/mcp-config.example.json b/packages/mcp-memory/mcp-config.example.json deleted file mode 100644 index 27dd9a60..00000000 --- a/packages/mcp-memory/mcp-config.example.json +++ /dev/null @@ -1,11 +0,0 @@ -{ - "mcpServers": { - "corates-memory": { - "command": "node", - "args": ["packages/mcp-memory/dist/server.js"], - "env": { - "MCP_MEMORY_REPO_ROOT": "/Users/jacobmaynard/Documents/Repos/corates" - } - } - } -} diff --git a/packages/mcp-memory/package.json b/packages/mcp-memory/package.json deleted file mode 100644 index 00eaf1c9..00000000 --- a/packages/mcp-memory/package.json +++ /dev/null @@ -1,34 +0,0 @@ -{ - "name": "@corates/mcp-memory", - "version": "1.0.0", - "license": "PolyForm-Noncommercial-1.0.0", - "description": "Persistent, repository-scoped long-term memory for agentic workloads", - "bin": { - "corates-mcp-memory": "./dist/server.js" - }, - "type": "module", - "scripts": { - "build": "tsc", - "dev": "tsc --watch", - "typecheck": "tsc --noEmit", - "clean": "rm -rf dist", - "start": "node dist/server.js", - "list": "tsx scripts/list.ts", - "lint": "eslint .", - "test": "vitest run", - "test:watch": "vitest" - }, - "dependencies": { - "@modelcontextprotocol/sdk": "^1.28.0", - "@xenova/transformers": "^2.17.2", - "better-sqlite3": "^12.8.0", - "zod": "^4.3.6" - }, - "devDependencies": { - "@types/better-sqlite3": "^7.6.13", - "@types/node": "^25.5.0", - "tsx": "^4.21.0", - "typescript": "^5.9.3", - "vitest": "^4.1.2" - } -} diff --git a/packages/mcp-memory/scripts/list.ts b/packages/mcp-memory/scripts/list.ts deleted file mode 100644 index 892bd7e4..00000000 --- a/packages/mcp-memory/scripts/list.ts +++ /dev/null @@ -1,119 +0,0 @@ -#!/usr/bin/env tsx -/** - * CLI viewer for memory database entries - * - * Run with: pnpm --filter @corates/mcp-memory list - */ - -import fs from 'fs'; -import path from 'path'; -import { fileURLToPath } from 'url'; -import Database from 'better-sqlite3'; -import { DATABASE_PATH } from '../src/constants.js'; - -const __filename = fileURLToPath(import.meta.url); -const __dirname = path.dirname(__filename); -const repoRoot = path.resolve(__dirname, '..', '..', '..'); -const dbPath = path.join(repoRoot, DATABASE_PATH); - -interface KnowledgeRow { - id: string; - type: string; - title: string; - content: string; - tags: string; - source_type: string | null; - source_reference: string | null; - confidence: number; - version: number; - superseded_by: string | null; - created_at: string; - updated_at: string; -} - -function formatDate(iso: string): string { - return new Date(iso).toLocaleDateString('en-US', { - year: 'numeric', - month: 'short', - day: 'numeric', - }); -} - -function truncate(str: string, maxLength: number): string { - if (str.length <= maxLength) return str; - return str.slice(0, maxLength - 3) + '...'; -} - -function main(): void { - // Check if database exists - if (!fs.existsSync(dbPath)) { - console.log('No memory database found at:', dbPath); - console.log('Run the MCP server or seed script to create it.'); - process.exit(0); - } - - const db = new Database(dbPath, { readonly: true }); - - // Get stats - const countRow = db - .prepare('SELECT COUNT(*) as count FROM knowledge_entries WHERE superseded_by IS NULL') - .get() as { count: number }; - const supersededRow = db - .prepare('SELECT COUNT(*) as count FROM knowledge_entries WHERE superseded_by IS NOT NULL') - .get() as { count: number }; - - console.log('='.repeat(80)); - console.log('CORATES MEMORY DATABASE'); - console.log('='.repeat(80)); - console.log(`Location: ${dbPath}`); - console.log(`Active entries: ${countRow.count}`); - console.log(`Superseded entries: ${supersededRow.count}`); - console.log('='.repeat(80)); - - // Get entries by type - const types = ['fact', 'decision', 'procedure', 'pattern']; - - for (const type of types) { - const rows = db - .prepare( - `SELECT * FROM knowledge_entries - WHERE type = ? AND superseded_by IS NULL - ORDER BY confidence DESC, updated_at DESC`, - ) - .all(type) as KnowledgeRow[]; - - if (rows.length === 0) continue; - - console.log(`\n${type.toUpperCase()}S (${rows.length})`); - console.log('-'.repeat(80)); - - for (const row of rows) { - const tags = JSON.parse(row.tags) as string[]; - const tagStr = tags.length > 0 ? ` [${tags.join(', ')}]` : ''; - const confidence = (row.confidence * 100).toFixed(0); - - console.log(`\n ${row.title}${tagStr}`); - console.log(` ID: ${row.id} | v${row.version} | ${confidence}% confidence`); - console.log(` Updated: ${formatDate(row.updated_at)}`); - - if (row.source_type) { - const sourceRef = row.source_reference ? ` (${row.source_reference})` : ''; - console.log(` Source: ${row.source_type}${sourceRef}`); - } - - // Show truncated content - const contentLines = row.content.split('\n'); - const preview = contentLines.slice(0, 3).join('\n '); - console.log(` ---`); - console.log(` ${truncate(preview, 200)}`); - } - } - - db.close(); - - console.log('\n' + '='.repeat(80)); - console.log('TIP: Use a SQLite browser for full access to .mcp/memory.db'); - console.log('='.repeat(80) + '\n'); -} - -main(); diff --git a/packages/mcp-memory/src/confidence.ts b/packages/mcp-memory/src/confidence.ts deleted file mode 100644 index 88fd4fbb..00000000 --- a/packages/mcp-memory/src/confidence.ts +++ /dev/null @@ -1,54 +0,0 @@ -/** - * Confidence scoring for memory entries - */ - -import type { KnowledgeType } from './types.js'; - -// Base confidence by knowledge type -const TYPE_BASE_CONFIDENCE: RecordAccess Denied
-You do not have admin privileges.
- - } - > -- Showing {(page() - 1) * (usersData()?.pagination?.limit || 20) + 1} to{' '} - {Math.min( - page() * (usersData()?.pagination?.limit || 20), - usersData()?.pagination?.total || 0, - )}{' '} - of {usersData()?.pagination?.total || 0} users -
-Access Denied
-You do not have admin privileges.
- - } - > -Access Denied
-You do not have admin privileges.
- - } - > -Select a table to view its contents
-No rows in this table
-| handleSort(col)}
- >
-
- |
- );
- }}
-
|---|
|
- |
- );
- }}
-
No grants
} - > -{grant.type}
- {grant.revokedAt ? - - Revoked - - : - Active - - } -Starts: {formatDate(grant.startsAt)}
-Expires: {formatDate(grant.expiresAt)}
-Created: {formatDate(grant.createdAt)}
- {grant.revokedAt &&Revoked: {formatDate(grant.revokedAt)}
} -Effective Plan
-{currentPlan()}
-{effectivePlanId()}
-Access Mode
-- {accessMode() === 'full' ? - - Full Access - - : - Read Only - - } -
-Source
-{billingSource()}
-- Effective Because -
-{getSourceReason()}
-No entitlements
} - > -No quotas
} - > -Access Denied
-You do not have admin privileges.
- - } - > - {/* Header */} -
- {orgDetails()?.org?.slug || ''}
-
Members
-- {orgDetails()?.stats?.memberCount ?? 0} -
-Projects
-- {orgDetails()?.stats?.projectCount ?? 0} -
-{org.name}
-
- {info.getValue()}
-
- ),
- },
- {
- accessorKey: 'stats.memberCount',
- header: 'Members',
- cell: info => {
- const org = info.row.original;
- return (
- Access Denied
-You do not have admin privileges.
- - } - > -- Showing {(page() - 1) * (orgsData()?.pagination?.limit || 20) + 1} to{' '} - {Math.min( - page() * (orgsData()?.pagination?.limit || 20), - orgsData()?.pagination?.total || 0, - )}{' '} - of {orgsData()?.pagination?.total || 0} organizations -
-Access Denied
-You do not have admin privileges.
- - } - > - {/* Back link */} - -Failed to load project details
- -{projectData().project.description}
-No members
} - > -| User | -Role | -Joined | -Actions | -
|---|---|---|---|
|
-
-
-
-
- {member.userDisplayName || member.userName}
-
-
- {member.userEmail} - |
- - - {member.role} - - | -- {formatShortDate(member.joinedAt)} - | -- - | -
No files uploaded
} - > -| File | -Type | -Size | -Uploaded By | -Uploaded | -
|---|---|---|---|---|
|
-
-
- |
- - {file.fileType || '-'} - | -- {formatBytes(file.fileSize)} - | -
- |
- - {formatShortDate(file.createdAt)} - | -
No invitations
} - > -| Role | -Status | -Invited By | -Created | -|
|---|---|---|---|---|
| {invitation.email} | -
-
- {invitation.role}
-
- |
-
- |
- - - {invitation.inviterDisplayName || invitation.inviterName} - - | -- {formatShortDate(invitation.createdAt)} - | -
{project.name}
-{project.description}
-@{project.orgSlug}
-Access Denied
-You do not have admin privileges.
- - } - > -Failed to load projects
- -{title()}
-{value()}
- -- Note: This dashboard shows all PDFs in R2 storage. PDFs marked as - "Orphaned" are files in R2 that are not tracked in the mediaFiles database table (e.g., - from failed cleanup). You can safely delete orphaned PDFs to free up storage space. -
-| - - | -File Name | -Size | -Project ID | -Study ID | -Uploaded | -Actions | -
-
-
- |
-
- }
- >
- - No documents found - | - - } - > - {doc => ( -
|---|---|---|---|---|---|---|
| - - | -
-
- {doc.fileName}
-
- |
- - {formatFileSize(doc.size)} - | -- - {doc.projectId} - - | -- {doc.studyId} - | -- {formatDate(doc.uploaded)} - | -- - | -
- Showing {documentsData()?.documents?.length || 0} document - {documentsData()?.documents?.length === 1 ? '' : 's'} -
-- Results truncated after processing 10,000 objects. Use pagination to continue. -
-