CartSnitch
Track prices. Save money.
@@ -88,10 +94,10 @@ export function Login() {Don't have an account?{' '} - + Sign up
-
+ 
+
+
+
+ Your Digital Receipt
+Kroger Plus Member
+
+
+
+ Kroger #882 - Downtown
+123 Main Street
Anytown, OH 45202
Date: 03/15/2026
+Receipt #: KR-2026-0315-4829
+Transaction #: TXN-789123456
+
+
+
+ Items Purchased
+Whole Milk 1 Gallon $3.99
+Sourdough Bread $4.49
+Free Range Eggs 12ct $5.99
+Baby Spinach 5oz $4.29
+
+
+
+ Subtotal: $18.76
+Tax: $1.24
+Total: $20.00
+
+
+
+ Kroger Plus Savings: $3.25 saved on this order.
+
+
+
+
\ No newline at end of file
diff --git a/receiptwitness/tests/fixtures/meijer_email_receipt.html b/receiptwitness/tests/fixtures/meijer_email_receipt.html
new file mode 100644
index 0000000..f61deb3
--- /dev/null
+++ b/receiptwitness/tests/fixtures/meijer_email_receipt.html
@@ -0,0 +1,127 @@
+
+
+
+
+
+ Thank you for shopping at Kroger!
+Keep your receipt for returns within 90 days.
+
+
+
+
+
+
+
+
diff --git a/receiptwitness/tests/fixtures/target_email_receipt.html b/receiptwitness/tests/fixtures/target_email_receipt.html
new file mode 100644
index 0000000..70f0720
--- /dev/null
+++ b/receiptwitness/tests/fixtures/target_email_receipt.html
@@ -0,0 +1,44 @@
+
+
+
+
+
+
+
+ MEIJER
+Digital Receipt
+
+
+
+
+
+ Meijer Store #42
+1555 Lake Drive SE, Grand Rapids, MI 49506
+| Item | +Qty | +Price | +
|---|---|---|
| ORGANIC BANANAS | +1 | +$0.69 | +
| WHOLE MILK 1 GAL | +1 | +$4.29 | +
| MEIJER WHOLE GRAIN OAT CEREAL 18OZ | +1 | +$4.99 | +
| FRESH BROCCOLI CROWN | +1 | +$2.49 | +
| GROUND BEEF 85/15 1LB | +1 | +$6.99 | +
| SOURDOUGH BREAD | +1 | +$3.99 | +
| MEIJER BABY SPINACH 5OZ | +1 | +$4.49 | +
| LARGE EGGS DOZEN | +1 | +$3.29 | +
+
+
+
+
+ Subtotal
+ $31.22
+
+
+ Tax
+ $2.19
+
+
+ Total Savings
+ -$3.40
+
+
+ Total
+ $33.41
+
+
+ 
+
+
+
+ Order Confirmation
+Thanks for shopping Target Circle!
+
+
+
+ Target Store #1247 - Riverside
+4500 River Road
Columbus, OH 43220
Date: 03/18/2026
+Order #: TGT-2026-0318-9124
+Confirmation #: CNF-44772819
+
+
+
+ Items Purchased
+Good & Gather Whole Milk 1 Gal $3.89
+Arborio Rice 2lb bag $6.49
+Parmesan Wedge 8oz $7.99
+
+
+
+ Subtotal: $18.37
+Tax: $1.45
+Total: $19.82
+
+
+
+ Target Circle offer saved you $0.30 on this order.
+
+
+
+
\ No newline at end of file
diff --git a/receiptwitness/tests/test_api/__init__.py b/receiptwitness/tests/test_api/__init__.py
new file mode 100644
index 0000000..598c2e0
--- /dev/null
+++ b/receiptwitness/tests/test_api/__init__.py
@@ -0,0 +1 @@
+"""Tests for the ReceiptWitness API routes."""
diff --git a/receiptwitness/tests/test_api/test_webhook.py b/receiptwitness/tests/test_api/test_webhook.py
new file mode 100644
index 0000000..2b208de
--- /dev/null
+++ b/receiptwitness/tests/test_api/test_webhook.py
@@ -0,0 +1,101 @@
+"""Tests for the /inbound/email webhook endpoint."""
+
+import hashlib
+import hmac
+import time
+from unittest.mock import AsyncMock, patch
+
+import pytest
+from fastapi.testclient import TestClient
+
+from receiptwitness.main import app
+
+
+@pytest.fixture
+def client():
+ return TestClient(app)
+
+
+@pytest.fixture
+def mock_redis():
+ redis_mock = AsyncMock()
+ with patch("receiptwitness.api.routes.get_redis", return_value=redis_mock):
+ enqueue_patcher = patch("receiptwitness.api.routes.enqueue_email", new_callable=AsyncMock)
+ with enqueue_patcher as mock_enqueue:
+ yield {"redis": redis_mock, "enqueue": mock_enqueue}
+
+
+def make_signature(signing_key: str, token: str, timestamp: str) -> str:
+ return hmac.new(
+ signing_key.encode(),
+ f"{timestamp}{token}".encode(),
+ hashlib.sha256,
+ ).hexdigest()
+
+
+def valid_form(signing_key: str = "test-secret"):
+ ts = str(int(time.time()))
+ token = "test-token"
+ sig = make_signature(signing_key, token, ts)
+ return {
+ "token": token,
+ "timestamp": ts,
+ "signature": sig,
+ "sender": "sender@example.com",
+ "recipient": "receipts+user123@example.com",
+ "subject": "Your Meijer Receipt",
+ "body-html": "Questions? Call Target Guest Services at 1-800-591-3869.
+Receipt valid for returns within 30 days.
+Thank you for shopping at Meijer
", + "body-plain": "Thank you for shopping at Meijer", + "Message-Id": "Your receipt from Meijer on " + "2026-03-28 has been processed.
" + "5 items, total: $42.99
" + ), + } + ) + + @pytest.mark.asyncio + async def test_skips_when_disabled(self, mock_resend): + from receiptwitness.notifications.email import send_receipt_notification + + with patch("receiptwitness.notifications.email.settings") as mock_settings: + mock_settings.notifications_enabled = False + mock_settings.resend_api_key = "re_testkey_123" + + await send_receipt_notification( + user_email="user@example.com", + store_name="Meijer", + item_count=5, + total=42.99, + purchase_date="2026-03-28", + ) + + mock_resend.Emails.send.assert_not_called() + + @pytest.mark.asyncio + async def test_skips_when_api_key_empty(self, mock_resend): + from receiptwitness.notifications.email import send_receipt_notification + + with patch("receiptwitness.notifications.email.settings") as mock_settings: + mock_settings.notifications_enabled = True + mock_settings.resend_api_key = "" + + await send_receipt_notification( + user_email="user@example.com", + store_name="Meijer", + item_count=5, + total=42.99, + purchase_date="2026-03-28", + ) + + mock_resend.Emails.send.assert_not_called() diff --git a/receiptwitness/tests/test_parsers/test_email/__init__.py b/receiptwitness/tests/test_parsers/test_email/__init__.py new file mode 100644 index 0000000..e69de29 diff --git a/receiptwitness/tests/test_parsers/test_email/test_detector.py b/receiptwitness/tests/test_parsers/test_email/test_detector.py new file mode 100644 index 0000000..87a5aac --- /dev/null +++ b/receiptwitness/tests/test_parsers/test_email/test_detector.py @@ -0,0 +1,49 @@ +"""Tests for retailer detector.""" + +from receiptwitness.parsers.email.base import EmailReceipt +from receiptwitness.parsers.email.detector import detect_retailer + + +def test_detect_meijer(): + email = EmailReceipt( + sender="receipts@meijer.com", + recipient="user@example.com", + subject="Your Receipt", + ) + assert detect_retailer(email) == "meijer" + + +def test_detect_kroger(): + email = EmailReceipt( + sender="noreply@email.kroger.com", + recipient="user@example.com", + subject="Your Receipt", + ) + assert detect_retailer(email) == "kroger" + + +def test_detect_target(): + email = EmailReceipt( + sender="TargetThank you for shopping on April 1, 2026
+Total: $15.00
+ + + """ + email = EmailReceipt( + sender="receipts@email.meijer.com", + recipient="shopper@example.com", + subject=None, + body_html=html, + ) + parser = MeijerEmailParser() + result = parser.parse(email) + assert result["purchase_date"] == "2026-04-01" + + def test_missing_totals_defaults_to_zero(self): + html = "Just an email with no totals
" + email = EmailReceipt( + sender="receipts@email.meijer.com", + recipient="shopper@example.com", + subject="Receipt", + body_html=html, + ) + parser = MeijerEmailParser() + result = parser.parse(email) + assert result["total"] == Decimal("0") + assert result["subtotal"] is None + assert result["tax"] is None diff --git a/receiptwitness/tests/test_parsers/test_email/test_target_email_parser.py b/receiptwitness/tests/test_parsers/test_email/test_target_email_parser.py new file mode 100644 index 0000000..ffa33db --- /dev/null +++ b/receiptwitness/tests/test_parsers/test_email/test_target_email_parser.py @@ -0,0 +1,93 @@ +"""Tests for TargetEmailParser.""" + +from pathlib import Path + +from receiptwitness.parsers.email.base import EmailReceipt +from receiptwitness.parsers.email.target import TargetEmailParser + +FIXTURE_PATH = Path(__file__).parent.parent.parent / "fixtures" / "target_email_receipt.html" + + +class TestTargetEmailParser: + """Tests for TargetEmailParser.""" + + def setup_method(self) -> None: + self.parser = TargetEmailParser() + self.fixture_html = FIXTURE_PATH.read_text() + + def test_can_parse_target_sender(self) -> None: + email = EmailReceipt( + sender="receipts@target.com", + recipient="user@example.com", + subject="Your Target Order Confirmation", + body_html=self.fixture_html, + ) + assert self.parser.can_parse(email) is True + + def test_can_parse_circle_in_body(self) -> None: + email = EmailReceipt( + sender="someone@unknown.com", + recipient="user@example.com", + subject="Your Receipt", + body_html="Target Circle savings offer", + ) + assert self.parser.can_parse(email) is True + + def test_cannot_parse_unrelated(self) -> None: + email = EmailReceipt( + sender="noreply@walmart.com", + recipient="user@example.com", + subject="Your Receipt", + body_html="Walmart receipt", + ) + assert self.parser.can_parse(email) is False + + def test_parse_items(self) -> None: + email = EmailReceipt( + sender="orders@target.com", + recipient="user@example.com", + subject="Your Target Order", + body_html=self.fixture_html, + ) + result = self.parser.parse(email) + items = result.get("items", []) + assert len(items) >= 3 + product_names = [item["product_name_raw"] for item in items] + assert any("Whole Milk" in name for name in product_names) + assert any("Arborio" in name for name in product_names) + for item in items: + assert "unit_price" in item + assert "extended_price" in item + + def test_parse_totals(self) -> None: + email = EmailReceipt( + sender="orders@target.com", + recipient="user@example.com", + subject="Your Target Order", + body_html=self.fixture_html, + ) + result = self.parser.parse(email) + total = result.get("total", 0) + assert total > 0 + + def test_parse_receipt_id(self) -> None: + email = EmailReceipt( + sender="orders@target.com", + recipient="user@example.com", + subject="Your Target Order", + body_html=self.fixture_html, + ) + result = self.parser.parse(email) + receipt_id = result.get("receipt_id", "") + assert "TGT-2026" in receipt_id or "CNF" in receipt_id + + def test_parse_date(self) -> None: + email = EmailReceipt( + sender="orders@target.com", + recipient="user@example.com", + subject="Your Target Order", + body_html=self.fixture_html, + ) + result = self.parser.parse(email) + purchase_date = result.get("purchase_date", "") + assert purchase_date == "2026-03-18" diff --git a/receiptwitness/tests/test_queue/__init__.py b/receiptwitness/tests/test_queue/__init__.py new file mode 100644 index 0000000..e69de29 diff --git a/receiptwitness/tests/test_queue/test_email_queue.py b/receiptwitness/tests/test_queue/test_email_queue.py new file mode 100644 index 0000000..05ffb51 --- /dev/null +++ b/receiptwitness/tests/test_queue/test_email_queue.py @@ -0,0 +1,79 @@ +"""Tests for email queue using DragonflyDB Streams.""" + +import pytest +from fakeredis import aioredis as fake_aioredis + +from receiptwitness.queue.email import ( + CONSUMER_GROUP, + STREAM_KEY, + EmailJob, + ack_email, + consume_emails, + enqueue_email, + ensure_consumer_group, +) + + +@pytest.fixture +async def fake_client(): + """Yield a fake async Redis client.""" + client = fake_aioredis.FakeRedis(decode_responses=True) + yield client + await client.aclose() + + +@pytest.fixture +def sample_job(): + """Sample EmailJob for testing.""" + return EmailJob( + user_id="user-123", + sender="no-reply@kroger.com", + recipient="user@example.com", + subject="Kroger Receipt", + body_html="Receipt", + body_plain="Receipt", + received_at="2026-04-01T12:00:00Z", + message_id="msg-abc-123", + ) + + +@pytest.mark.asyncio +async def test_enqueue_and_consume(fake_client, sample_job): + """Enqueue a job, consume it, verify fields match.""" + msg_id = await enqueue_email(fake_client, sample_job) + assert msg_id is not None + + consumed = await consume_emails(fake_client, "test-worker", count=1, block_ms=100) + assert len(consumed) == 1 + consumed_id, consumed_job = consumed[0] + assert consumed_id == msg_id + assert consumed_job.user_id == sample_job.user_id + assert consumed_job.sender == sample_job.sender + assert consumed_job.recipient == sample_job.recipient + assert consumed_job.subject == sample_job.subject + assert consumed_job.message_id == sample_job.message_id + + +@pytest.mark.asyncio +async def test_ack_removes_from_pending(fake_client, sample_job): + """After ack, message is no longer pending.""" + msg_id = await enqueue_email(fake_client, sample_job) + + # Consume the message (moves it to pending) + consumed = await consume_emails(fake_client, "test-worker", count=1, block_ms=100) + assert len(consumed) == 1 + + # Acknowledge it + await ack_email(fake_client, msg_id) + + # Check pending count for this consumer group + pending = await fake_client.xpending(STREAM_KEY, CONSUMER_GROUP) + assert pending is None or pending["pending"] == 0 + + +@pytest.mark.asyncio +async def test_ensure_consumer_group_idempotent(fake_client): + """Calling ensure_consumer_group twice does not error.""" + await ensure_consumer_group(fake_client) + # Calling again should not raise + await ensure_consumer_group(fake_client) diff --git a/receiptwitness/tests/test_worker/__init__.py b/receiptwitness/tests/test_worker/__init__.py new file mode 100644 index 0000000..e69de29 diff --git a/receiptwitness/tests/test_worker/test_email_worker.py b/receiptwitness/tests/test_worker/test_email_worker.py new file mode 100644 index 0000000..bc05724 --- /dev/null +++ b/receiptwitness/tests/test_worker/test_email_worker.py @@ -0,0 +1,188 @@ +"""Tests for email_worker.""" + +from decimal import Decimal +from unittest.mock import AsyncMock, MagicMock, patch + +import pytest +from fakeredis import aioredis as fake_aioredis + +from receiptwitness.parsers.email.base import EmailReceipt +from receiptwitness.queue.email import ( + EmailJob, +) +from receiptwitness.worker.email_worker import ( + process_job, + resolve_user, +) + +# --------------------------------------------------------------------------- +# Fixtures +# --------------------------------------------------------------------------- + + +@pytest.fixture +async def fake_redis(): + """Fake async Redis client for queue testing.""" + client = fake_aioredis.FakeRedis(decode_responses=True) + yield client + await client.aclose() + + +@pytest.fixture +def sample_email_job(): + """Sample EmailJob matching DragonflyDB queue schema.""" + return EmailJob( + user_id="token-abc-123", + sender="no-reply@meijer.com", + recipient="user@example.com", + subject="Your Meijer Receipt", + body_html="Total: $42.00", + body_plain="Total: $42.00", + received_at="2026-04-01T12:00:00Z", + message_id="msg-xyz-789", + ) + + +@pytest.fixture +def sample_email(): + """Sample EmailReceipt for parser testing.""" + return EmailReceipt( + sender="no-reply@meijer.com", + recipient="user@example.com", + subject="Your Meijer Receipt", + body_html="Total: $42.00Receipt #12345", + body_plain="Total: $42.00", + received_at="2026-04-01T12:00:00Z", + ) + + +# --------------------------------------------------------------------------- +# resolve_user tests +# --------------------------------------------------------------------------- + + +@pytest.mark.asyncio +async def test_resolve_user_valid_token(): + """Valid token returns user_id string.""" + mock_session = AsyncMock() + mock_result = MagicMock() + mock_result.scalar_one_or_none.return_value = "user-uuid-42" + mock_session.execute.return_value = mock_result + mock_session.__aenter__ = AsyncMock(return_value=mock_session) + mock_session.__aexit__ = AsyncMock(return_value=None) + + factory = MagicMock(return_value=mock_session) + + with patch( + "receiptwitness.worker.email_worker.get_async_session_factory", + return_value=factory, + ): + user_id = await resolve_user("token-abc-123") + + assert user_id == "user-uuid-42" + factory.assert_called_once() + + +@pytest.mark.asyncio +async def test_resolve_user_invalid_token(): + """Invalid token returns None.""" + mock_session = AsyncMock() + mock_result = MagicMock() + mock_result.scalar_one_or_none.return_value = None + mock_session.execute.return_value = mock_result + mock_session.__aenter__ = AsyncMock(return_value=mock_session) + mock_session.__aexit__ = AsyncMock(return_value=None) + + factory = MagicMock(return_value=mock_session) + + with patch( + "receiptwitness.worker.email_worker.get_async_session_factory", + return_value=factory, + ): + user_id = await resolve_user("bad-token") + + assert user_id is None + + +# --------------------------------------------------------------------------- +# process_job tests +# --------------------------------------------------------------------------- + + +@pytest.mark.asyncio +async def test_process_job_unknown_retailer(sample_email_job): + """Unknown retailer logs warning and returns True (ack, no retry).""" + unknown_job = EmailJob( + user_id="token-abc-123", + sender="no-reply@unknownretailer.com", + recipient="user@example.com", + subject="Receipt", + body_html="", + body_plain="", + received_at="2026-04-01T12:00:00Z", + message_id="msg-xyz-789", + ) + + with ( + patch( + "receiptwitness.worker.email_worker.resolve_user", + return_value="user-uuid-42", + ), + patch( + "receiptwitness.worker.email_worker.publish_receipt_ingested", + new_callable=AsyncMock, + ) as mock_publish, + ): + result = await process_job("msg-id-1", unknown_job) + + assert result is True + mock_publish.assert_not_called() + + +@pytest.mark.asyncio +async def test_process_job_success(sample_email_job, sample_email): + """Known retailer: full pipeline runs — parse, normalize, publish event.""" + parsed_data = { + "receipt_id": "RCP-999", + "purchase_date": "2026-04-01", + "total": Decimal("42.00"), + "items": [ + { + "product_name_raw": "ORGANIC BANANAS", + "quantity": Decimal("1"), + "unit_price": Decimal("0.69"), + "extended_price": Decimal("0.69"), + }, + ], + } + + mock_parser = MagicMock() + mock_parser.parse.return_value = parsed_data + + with ( + patch( + "receiptwitness.worker.email_worker.resolve_user", + return_value="user-uuid-42", + ), + patch.dict( + "receiptwitness.worker.email_worker.PARSERS", + {"meijer": mock_parser}, + clear=False, + ), + patch( + "receiptwitness.worker.email_worker.publish_receipt_ingested", + new_callable=AsyncMock, + ) as mock_publish, + ): + result = await process_job("msg-id-1", sample_email_job) + + assert result is True + mock_parser.parse.assert_called_once() + mock_publish.assert_called_once_with( + user_id="user-uuid-42", + store_slug="meijer", + purchase_id="RCP-999", + purchase_date="2026-04-01", + item_count=1, + total=Decimal("42.00"), + ) diff --git a/scripts/seed-dev-job.yaml b/scripts/seed-dev-job.yaml new file mode 100644 index 0000000..2d5cc86 --- /dev/null +++ b/scripts/seed-dev-job.yaml @@ -0,0 +1,61 @@ +# seed-dev-job.yaml +# K8s Job to run the CartSnitch seed runner against the dev database. +# +# Usage: +# kubectl apply -f seed-dev-job.yaml -n cartsnitch-dev +# +# To view logs: +# kubectl logs -n cartsnitch-dev job/seed-dev -f +# +# To re-run after fixing issues: +# kubectl delete -f seed-dev-job.yaml -n cartsnitch-dev && kubectl apply -f seed-dev-job.yaml -n cartsnitch-dev +# +apiVersion: batch/v1 +kind: Job +metadata: + name: seed-dev + namespace: cartsnitch-dev + labels: + app: cartsnitch + component: seed + environment: dev + annotations: + description: "Runs cartsnitch-common seed runner to populate dev database with realistic test data." +spec: + # Prevent retries — a failed seed run should be investigated, not auto-repeated. + backoffLimit: 0 + # Do not run concurrently; sequential runs are safer for truncate+reseed. + concurrencyPolicy: Forbid + template: + metadata: + labels: + app: cartsnitch + component: seed + environment: dev + spec: + restartPolicy: Never + containers: + - name: seed + # Use slim Python image with the cartsnitch-common package installed from git. + # The common repo is public; no additional secret is needed for the pip install. + image: python:3.12-slim + command: + - sh + - -c + - | + pip install --no-cache-dir "cartsnitch-common @ git+https://github.com/cartsnitch/common.git@main" && \ + python -m cartsnitch_common.seed --database-url "$${DATABASE_URL}" + env: + - name: DATABASE_URL + valueFrom: + secretKeyRef: + name: cartsnitch-secrets + key: database-url-pg + optional: false + resources: + requests: + cpu: 100m + memory: 256Mi + limits: + cpu: 500m + memory: 512Mi diff --git a/scripts/seed-dev.sh b/scripts/seed-dev.sh new file mode 100755 index 0000000..a478015 --- /dev/null +++ b/scripts/seed-dev.sh @@ -0,0 +1,104 @@ +#!/usr/bin/env bash +# ============================================================================= +# seed-dev.sh — Run the CartSnitch seed runner against the dev database. +# +# Usage: +# ./seed-dev.sh Run full seed against dev +# ./seed-dev.sh --dry-run Show planned record counts without writing +# ./seed-dev.sh --help Show this help +# +# Prerequisites: +# - kubectl configured for the cartsnitch-dev cluster +# - Namespace cartsnitch-dev exists (CNPG Postgres must be running) +# +# What it does: +# 1. Starts a background port-forward to cartsnitch-pg-rw:5432 +# 2. Waits for the tunnel to be ready +# 3. Runs python -m cartsnitch_common.seed with --database-url pointing +# to localhost:
Price Trends
-
-
+ Connect a store to see price trends
@@ -173,6 +157,7 @@ function AuthenticatedDashboard({ userName }: { userName: string }) {
function DashboardSkeleton() {
return (
+ = {
+ meijer: { name: 'Meijer', color: '#e31837', icon: '/icons/stores/meijer.svg' },
+ kroger: { name: 'Kroger', color: '#0033a0', icon: '/icons/stores/kroger.svg' },
+ target: { name: 'Target', color: '#cc0000', icon: '/icons/stores/target.svg' },
+};
+
+export function getStore(slug: string) {
+ return STORE_SLUGS[slug.toLowerCase()] ?? null;
+}
+
+export function getStoreName(slug: string): string {
+ return getStore(slug)?.name ?? slug;
+}
diff --git a/vitest.config.ts b/vitest.config.ts
index 1dec76f..30c96d0 100644
--- a/vitest.config.ts
+++ b/vitest.config.ts
@@ -7,5 +7,6 @@ export default defineConfig({
environment: 'jsdom',
globals: true,
setupFiles: ['./src/test/setup.ts'],
+ exclude: ['e2e/**', 'node_modules/**'],
},
})
Loading CartSnitch…
@@ -186,15 +171,3 @@ function DashboardSkeleton() {
)
}
-
-function SparklinePlaceholder() {
- return (
-
-
- )
-}
diff --git a/src/pages/Login.tsx b/src/pages/Login.tsx
index 214dcd4..ae7fc0c 100644
--- a/src/pages/Login.tsx
+++ b/src/pages/Login.tsx
@@ -31,8 +31,14 @@ export function Login() {
throw new Error(authError.message ?? 'Sign in failed')
}
- setAuthenticated(true)
- navigate('/')
+ // After successful signIn, force a session fetch to confirm the cookie is set
+ // before navigating to the protected route
+ const sessionResult = await authClient.getSession()
+ if (sessionResult.data) {
+ navigate('/')
+ } else {
+ setError('Sign in failed. Please try again.')
+ }
} catch {
if (import.meta.env.VITE_MOCK_AUTH === 'true') {
setAuthenticated(true)
@@ -46,7 +52,7 @@ export function Login() {
}
return (
-
-
-
-
-
-
+
+
)
}
diff --git a/src/pages/Register.tsx b/src/pages/Register.tsx
index a65e7b6..c75e2d6 100644
--- a/src/pages/Register.tsx
+++ b/src/pages/Register.tsx
@@ -38,8 +38,15 @@ export function Register() {
throw new Error(authError.message ?? 'Registration failed')
}
- setAuthenticated(true)
- navigate('/')
+ // After successful signUp, force a session fetch to confirm the cookie is set
+ // before navigating to the protected route
+ const sessionResult = await authClient.getSession()
+ if (sessionResult.data) {
+ navigate('/')
+ } else {
+ // Session not established — show success message and link to login
+ setError('Account created! Please sign in.')
+ }
} catch {
if (import.meta.env.VITE_MOCK_AUTH === 'true') {
setAuthenticated(true)
diff --git a/src/test/mocks/handlers.ts b/src/test/mocks/handlers.ts
new file mode 100644
index 0000000..4282004
--- /dev/null
+++ b/src/test/mocks/handlers.ts
@@ -0,0 +1,65 @@
+import { http, HttpResponse } from 'msw'
+import type { Purchase, Product, Coupon, PriceAlert } from '../../types/api.ts'
+
+const mockPurchases: Purchase[] = [
+ {
+ id: 'pur_1',
+ storeId: 'store_1',
+ storeName: 'Kroger',
+ date: '2024-01-15',
+ total: 42.5,
+ items: [
+ { id: 'item_1', productId: 'prod_1', name: 'Milk', quantity: 1, price: 3.99, unitPrice: 3.99 },
+ { id: 'item_2', productId: 'prod_2', name: 'Bread', quantity: 2, price: 5.98, unitPrice: 2.99 },
+ ],
+ },
+]
+
+const mockProducts: Product[] = [
+ {
+ id: 'prod_1',
+ name: 'Whole Milk',
+ brand: 'Kroger',
+ category: 'Dairy',
+ prices: [{ storeId: 'store_1', storeName: 'Kroger', price: 3.99, lastUpdated: '2024-01-15' }],
+ },
+ {
+ id: 'prod_2',
+ name: 'Whole Wheat Bread',
+ brand: 'Nature\'s Own',
+ category: 'Bakery',
+ prices: [{ storeId: 'store_1', storeName: 'Kroger', price: 2.99, lastUpdated: '2024-01-15' }],
+ },
+]
+
+const mockCoupons: Coupon[] = [
+ {
+ id: 'coupon_1',
+ productId: 'prod_1',
+ storeName: 'Kroger',
+ description: '$1 off milk',
+ discount: '$1.00',
+ expiresAt: '2024-12-31',
+ code: 'MILK1',
+ },
+]
+
+const mockAlerts: PriceAlert[] = [
+ {
+ id: 'alert_1',
+ productId: 'prod_1',
+ productName: 'Whole Milk',
+ targetPrice: 2.99,
+ currentPrice: 3.99,
+ triggered: false,
+ },
+]
+
+export const handlers = [
+ http.get('/api/v1/health', () => HttpResponse.json({ status: 'ok' })),
+ http.get('/api/v1/purchases', () => HttpResponse.json(mockPurchases)),
+ http.get('/api/v1/products', () => HttpResponse.json(mockProducts)),
+ http.get('/api/v1/products/prod_1', () => HttpResponse.json(mockProducts[0])),
+ http.get('/api/v1/coupons', () => HttpResponse.json(mockCoupons)),
+ http.get('/api/v1/alerts', () => HttpResponse.json(mockAlerts)),
+]
diff --git a/src/test/mocks/server.ts b/src/test/mocks/server.ts
new file mode 100644
index 0000000..86f7d61
--- /dev/null
+++ b/src/test/mocks/server.ts
@@ -0,0 +1,4 @@
+import { setupServer } from 'msw/node'
+import { handlers } from './handlers'
+
+export const server = setupServer(...handlers)
diff --git a/src/test/setup.ts b/src/test/setup.ts
index d0618e8..c6d0755 100644
--- a/src/test/setup.ts
+++ b/src/test/setup.ts
@@ -1 +1,6 @@
import '@testing-library/jest-dom/vitest'
+import { server } from './mocks/server'
+
+beforeAll(() => server.listen())
+afterEach(() => server.resetHandlers())
+afterAll(() => server.close())
diff --git a/src/utils/__tests__/formatCurrency.test.ts b/src/utils/__tests__/formatCurrency.test.ts
new file mode 100644
index 0000000..cb7cbfa
--- /dev/null
+++ b/src/utils/__tests__/formatCurrency.test.ts
@@ -0,0 +1,33 @@
+import { describe, it, expect } from 'vitest';
+import { formatCurrency } from '../formatCurrency';
+
+describe('formatCurrency', () => {
+ it('formats 0 cents as $0.00', () => {
+ expect(formatCurrency(0)).toBe('$0.00');
+ });
+
+ it('formats 199 cents as $1.99', () => {
+ expect(formatCurrency(199)).toBe('$1.99');
+ });
+
+ it('formats 10000 cents as $100.00', () => {
+ expect(formatCurrency(10000)).toBe('$100.00');
+ });
+
+ it('handles negative values', () => {
+ expect(formatCurrency(-500)).toBe('-$5.00');
+ });
+
+ it('handles large numbers', () => {
+ expect(formatCurrency(99999999)).toBe('$999,999.99');
+ });
+
+ it('supports custom locale', () => {
+ expect(formatCurrency(1999, 'de-DE', 'EUR')).toContain('19,99');
+ });
+
+ it('supports custom currency', () => {
+ const result = formatCurrency(1000, 'en-US', 'EUR');
+ expect(result).toContain('10.00');
+ });
+});
diff --git a/src/utils/__tests__/formatDate.test.ts b/src/utils/__tests__/formatDate.test.ts
new file mode 100644
index 0000000..8e291d4
--- /dev/null
+++ b/src/utils/__tests__/formatDate.test.ts
@@ -0,0 +1,62 @@
+import { describe, it, expect, beforeEach, afterEach, vi } from 'vitest';
+import { formatDate } from '../formatDate';
+
+describe('formatDate', () => {
+ describe('short style', () => {
+ it('formats an ISO date string', () => {
+ const result = formatDate('2024-03-15', 'short');
+ expect(result).toMatch(/Mar 15, 2024/);
+ });
+
+ it('formats a Date object', () => {
+ const result = formatDate(new Date('2024-03-15'), 'short');
+ expect(result).toMatch(/Mar 15, 2024/);
+ });
+ });
+
+ describe('long style', () => {
+ it('formats with weekday and full month name', () => {
+ const result = formatDate('2024-03-15', 'long');
+ expect(result).toMatch(/Friday/);
+ expect(result).toMatch(/March/);
+ });
+ });
+
+ describe('relative style', () => {
+ beforeEach(() => {
+ vi.useFakeTimers();
+ });
+
+ afterEach(() => {
+ vi.useRealTimers();
+ });
+
+ it('returns "just now" for very recent dates', () => {
+ const now = new Date('2024-01-01T12:00:00Z');
+ vi.setSystemTime(now);
+ const result = formatDate(new Date('2024-01-01T11:59:59Z'), 'relative');
+ expect(result).toBe('just now');
+ });
+
+ it('returns minutes ago', () => {
+ const now = new Date('2024-01-01T12:00:00Z');
+ vi.setSystemTime(now);
+ const result = formatDate(new Date('2024-01-01T11:45:00Z'), 'relative');
+ expect(result).toBe('15m ago');
+ });
+
+ it('returns hours ago', () => {
+ const now = new Date('2024-01-01T12:00:00Z');
+ vi.setSystemTime(now);
+ const result = formatDate(new Date('2024-01-01T09:00:00Z'), 'relative');
+ expect(result).toBe('3h ago');
+ });
+
+ it('returns days ago', () => {
+ const now = new Date('2024-01-05T12:00:00Z');
+ vi.setSystemTime(now);
+ const result = formatDate(new Date('2024-01-01T12:00:00Z'), 'relative');
+ expect(result).toBe('4d ago');
+ });
+ });
+});
diff --git a/src/utils/__tests__/storeSlugs.test.ts b/src/utils/__tests__/storeSlugs.test.ts
new file mode 100644
index 0000000..9a06429
--- /dev/null
+++ b/src/utils/__tests__/storeSlugs.test.ts
@@ -0,0 +1,46 @@
+import { describe, it, expect } from 'vitest';
+import { getStore, getStoreName, STORE_SLUGS } from '../storeSlugs';
+
+describe('storeSlugs', () => {
+ describe('STORE_SLUGS constant', () => {
+ it('contains meijer, kroger, and target', () => {
+ expect(STORE_SLUGS).toHaveProperty('meijer');
+ expect(STORE_SLUGS).toHaveProperty('kroger');
+ expect(STORE_SLUGS).toHaveProperty('target');
+ });
+ });
+
+ describe('getStore', () => {
+ it('returns store data for known slug', () => {
+ const store = getStore('meijer');
+ expect(store).toEqual({
+ name: 'Meijer',
+ color: '#e31837',
+ icon: '/icons/stores/meijer.svg',
+ });
+ });
+
+ it('returns null for unknown slug', () => {
+ expect(getStore('unknown-store')).toBeNull();
+ });
+
+ it('is case insensitive', () => {
+ expect(getStore('KROGER')).toBeTruthy();
+ expect(getStore('Target')).toBeTruthy();
+ });
+ });
+
+ describe('getStoreName', () => {
+ it('returns store name for known slug', () => {
+ expect(getStoreName('kroger')).toBe('Kroger');
+ });
+
+ it('returns raw slug for unknown store', () => {
+ expect(getStoreName('unknown-store')).toBe('unknown-store');
+ });
+
+ it('is case insensitive', () => {
+ expect(getStoreName('TARGET')).toBe('Target');
+ });
+ });
+});
diff --git a/src/utils/formatCurrency.ts b/src/utils/formatCurrency.ts
new file mode 100644
index 0000000..22d63db
--- /dev/null
+++ b/src/utils/formatCurrency.ts
@@ -0,0 +1,10 @@
+export function formatCurrency(
+ cents: number,
+ locale = 'en-US',
+ currency = 'USD'
+): string {
+ return new Intl.NumberFormat(locale, {
+ style: 'currency',
+ currency,
+ }).format(cents / 100);
+}
diff --git a/src/utils/formatDate.ts b/src/utils/formatDate.ts
new file mode 100644
index 0000000..f726cee
--- /dev/null
+++ b/src/utils/formatDate.ts
@@ -0,0 +1,34 @@
+export function formatDate(
+ date: string | Date,
+ style: 'short' | 'long' | 'relative' = 'short'
+): string {
+ const d = typeof date === 'string' ? new Date(date) : date;
+
+ if (style === 'short') {
+ return d.toLocaleDateString('en-US', {
+ month: 'short',
+ day: 'numeric',
+ year: 'numeric',
+ });
+ }
+
+ if (style === 'long') {
+ return d.toLocaleDateString('en-US', {
+ weekday: 'long',
+ month: 'long',
+ day: 'numeric',
+ year: 'numeric',
+ });
+ }
+
+ // relative
+ const diff = Date.now() - d.getTime();
+ const seconds = Math.floor(diff / 1000);
+ if (seconds < 60) return 'just now';
+ const minutes = Math.floor(seconds / 60);
+ if (minutes < 60) return `${minutes}m ago`;
+ const hours = Math.floor(minutes / 60);
+ if (hours < 24) return `${hours}h ago`;
+ const days = Math.floor(hours / 24);
+ return `${days}d ago`;
+}
diff --git a/src/utils/storeSlugs.ts b/src/utils/storeSlugs.ts
new file mode 100644
index 0000000..4fef82f
--- /dev/null
+++ b/src/utils/storeSlugs.ts
@@ -0,0 +1,13 @@
+export const STORE_SLUGS: Record