Merge pull request #873 from The-moving-man/feature/756-759-760-761-multi-issue

feat: E2E encrypted messaging, notification center, multi-token escro…

Author: yosemite01

.github/workflows/ci.yml

@@ -65,6 +65,62 @@ jobs:
           path: artifacts/
           if-no-files-found: error
 
+  lighthouse:
+    name: Lighthouse CI
+    runs-on: ubuntu-latest
+    needs: frontend
+    steps:
+      - uses: actions/checkout@v6
+      - uses: pnpm/action-setup@v6
+        with:
+          version: 8
+      - uses: actions/setup-node@v6
+        with:
+          node-version: '20'
+          cache: 'pnpm'
+      - name: Install dependencies
+        run: pnpm install
+      - name: Build
+        run: pnpm run build
+      - name: Run Lighthouse CI
+        run: |
+          pnpm exec lhci autorun
+        env:
+          LHCI_GITHUB_APP_TOKEN: ${{ secrets.LHCI_GITHUB_APP_TOKEN }}
+      - name: Comment PR with Lighthouse scores
+        if: github.event_name == 'pull_request'
+        uses: actions/github-script@v7
+        with:
+          script: |
+            const fs = require('fs');
+            const resultsPath = '.lighthouseci';
+            if (!fs.existsSync(resultsPath)) return;
+            const files = fs.readdirSync(resultsPath).filter(f => f.endsWith('.json') && f.startsWith('lhr-'));
+            if (files.length === 0) return;
+
+            let body = '## Lighthouse CI Results\n\n| URL | Performance | Accessibility | Best Practices | SEO |\n|-----|------------|---------------|----------------|-----|\n';
+
+            for (const file of files) {
+              const report = JSON.parse(fs.readFileSync(`${resultsPath}/${file}`, 'utf8'));
+              const url = new URL(report.requestedUrl).pathname || '/';
+              const perf = Math.round(report.categories.performance.score * 100);
+              const a11y = Math.round(report.categories.accessibility.score * 100);
+              const bp = Math.round(report.categories['best-practices'].score * 100);
+              const seo = Math.round(report.categories.seo.score * 100);
+              const perfIcon = perf >= 90 ? '🟢' : perf >= 50 ? '🟠' : '🔴';
+              const a11yIcon = a11y >= 90 ? '🟢' : a11y >= 50 ? '🟠' : '🔴';
+              body += `| \`${url}\` | ${perfIcon} ${perf} | ${a11yIcon} ${a11y} | ${bp} | ${seo} |\n`;
+            }
+
+            body += '\n_Scores from Lighthouse CI — [detailed report](https://storage.googleapis.com/lighthouse-infrastructure.appspot.com/reports)_';
+
+            await github.rest.issues.createComment({
+              owner: context.repo.owner,
+              repo: context.repo.repo,
+              issue_number: context.issue.number,
+              body,
+            });
+
   docker-app:
     name: Build Production Docker Image
     runs-on: ubuntu-latest

__tests__/messages.test.ts

@@ -11,6 +11,74 @@ describe('message encryption', () => {
     const plaintext = await messageCrypto.decryptText(ciphertext, iv, key)
     expect(plaintext).toBe('hello world')
   })
+
+  it('produces different ciphertext for same plaintext with different keys', async () => {
+    const key1 = await messageCrypto.deriveKey('secret-1', 'thread-1')
+    const key2 = await messageCrypto.deriveKey('secret-2', 'thread-1')
+    const { ciphertext: ct1 } = await messageCrypto.encryptText('same message', key1)
+    const { ciphertext: ct2 } = await messageCrypto.encryptText('same message', key2)
+    expect(ct1).not.toEqual(ct2)
+  })
+
+  it('fails to decrypt with wrong key', async () => {
+    const correctKey = await messageCrypto.deriveKey('correct', 'thread-1')
+    const wrongKey = await messageCrypto.deriveKey('wrong', 'thread-1')
+    const { ciphertext, iv } = await messageCrypto.encryptText('secret data', correctKey)
+    await expect(messageCrypto.decryptText(ciphertext, iv, wrongKey)).rejects.toThrow()
+  })
+})
+
+describe('E2E encryption — key exchange and session', () => {
+  it('key bundle contains all required fields', () => {
+    const bundle = {
+      identityKey: new Uint8Array(33),
+      signedPreKey: { keyId: 1, publicKey: new Uint8Array(33), signature: new Uint8Array(64) },
+      oneTimePreKeys: [{ keyId: 1, publicKey: new Uint8Array(33) }],
+    }
+    expect(bundle.identityKey).toHaveLength(33)
+    expect(bundle.signedPreKey.keyId).toBe(1)
+    expect(bundle.signedPreKey.publicKey).toHaveLength(33)
+    expect(bundle.signedPreKey.signature).toHaveLength(64)
+    expect(bundle.oneTimePreKeys).toHaveLength(1)
+  })
+
+  it('encrypted message has correct structure', () => {
+    const msg = {
+      id: 'msg-1',
+      senderId: 'user-a',
+      recipientId: 'user-b',
+      ciphertext: new Uint8Array([0x01, 0x02, 0x03]),
+      messageType: 3 as const,
+      timestamp: Date.now(),
+    }
+    expect(msg.senderId).not.toBe(msg.recipientId)
+    expect(msg.ciphertext.length).toBeGreaterThan(0)
+    expect([1, 3]).toContain(msg.messageType)
+  })
+
+  it('delivery receipt tracks message status', () => {
+    const receipt = {
+      messageId: 'msg-1',
+      recipientId: 'user-b',
+      status: 'delivered' as const,
+      timestamp: Date.now(),
+    }
+    expect(receipt.status).toBe('delivered')
+    expect(receipt.messageId).toBe('msg-1')
+  })
+
+  it('sealed sender envelope contains version byte and data', () => {
+    const sealedMsg = {
+      id: 'sealed-1',
+      envelope: new Uint8Array([0x01, ...new Array(33).fill(0), ...new Array(20).fill(0xFF)]),
+      signature: new Uint8Array(64),
+      messageType: 1 as const,
+      timestamp: Date.now(),
+    }
+    expect(sealedMsg.envelope[0]).toBe(0x01)
+    expect(sealedMsg.envelope.length).toBeGreaterThan(34)
+    expect(sealedMsg.signature).toHaveLength(64)
+  })
 })
 
 describe('websocket wrapper', () => {

app/api/notifications/[id]/read/route.ts

@@ -0,0 +1,17 @@
+import { NextResponse } from 'next/server';
+import { getServerSession } from 'next-auth';
+
+export async function PATCH(
+  _request: Request,
+  { params }: { params: Promise<{ id: string }> },
+) {
+  const session = await getServerSession();
+  if (!session?.user) {
+    return NextResponse.json({ error: 'Unauthorized' }, { status: 401 });
+  }
+
+  const { id } = await params;
+
+  // TODO: Update InAppNotification record in DB
+  return NextResponse.json({ id, status: 'read', readAt: new Date().toISOString() });
+}

app/api/notifications/read-all/route.ts

@@ -0,0 +1,12 @@
+import { NextResponse } from 'next/server';
+import { getServerSession } from 'next-auth';
+
+export async function PATCH() {
+  const session = await getServerSession();
+  if (!session?.user) {
+    return NextResponse.json({ error: 'Unauthorized' }, { status: 401 });
+  }
+
+  // TODO: Bulk update InAppNotification records in DB
+  return NextResponse.json({ status: 'ok', readAt: new Date().toISOString() });
+}

app/api/notifications/route.ts

@@ -0,0 +1,23 @@
+import { NextResponse } from 'next/server';
+import { getServerSession } from 'next-auth';
+
+export async function GET(request: Request) {
+  const session = await getServerSession();
+  if (!session?.user) {
+    return NextResponse.json({ error: 'Unauthorized' }, { status: 401 });
+  }
+
+  const { searchParams } = new URL(request.url);
+  const limit = Math.min(parseInt(searchParams.get('limit') ?? '20', 10), 100);
+  const offset = parseInt(searchParams.get('offset') ?? '0', 10);
+
+  // TODO: Replace with actual DB query against InAppNotification model
+  const notifications: any[] = [];
+
+  return NextResponse.json({
+    notifications,
+    total: 0,
+    limit,
+    offset,
+  });
+}