diff --git a/src/app/(portal)/portal/login/page.tsx b/src/app/(portal)/portal/login/page.tsx index b2e2a47a..bd8601c6 100644 --- a/src/app/(portal)/portal/login/page.tsx +++ b/src/app/(portal)/portal/login/page.tsx @@ -10,10 +10,27 @@ import { Input } from '@/components/ui/input'; import { Label } from '@/components/ui/label'; import { BrandedAuthShell } from '@/components/shared/branded-auth-shell'; +/** + * Validate the `?next=` post-login redirect target. auth-flow-auditor M10: + * an unvalidated `next` lets `/portal/login?next=https://evil.example` + * navigate cross-site after sign-in. Only allow same-origin paths + * scoped to the portal surface — anything else falls back to the + * dashboard. + */ +function safeNextPath(raw: string | null): string { + const fallback = '/portal/dashboard'; + if (!raw) return fallback; + // Reject absolute URLs (http://, https://, //evil.example) and + // protocol-relative URLs. Only `/portal/...` paths are kept. + if (!raw.startsWith('/portal/')) return fallback; + if (raw.startsWith('//')) return fallback; + return raw; +} + export default function PortalLoginPage() { const router = useRouter(); const search = useSearchParams(); - const next = search.get('next') ?? '/portal/dashboard'; + const next = safeNextPath(search.get('next')); const [email, setEmail] = useState(''); const [password, setPassword] = useState(''); diff --git a/src/lib/auth/index.ts b/src/lib/auth/index.ts index 2f786f06..fb30c773 100644 --- a/src/lib/auth/index.ts +++ b/src/lib/auth/index.ts @@ -65,6 +65,12 @@ function buildAuth() { minPasswordLength: 9, // Accounts are admin-created only - no self-service email verification flow. requireEmailVerification: false, + // auth-flow-auditor C1: revoke every existing session for the user + // when their password is reset. Without this, a stolen cookie + // keeps working forever after the legitimate owner does the + // forgot-password dance. Better Auth flips this internally; the + // option below routes through `internalAdapter.deleteSessions(userId)`. + revokeSessionsOnPasswordReset: true, // Self-service password reset for CRM users. The reset link lands // on the existing /reset-password page (which already handles // better-auth's token + new-password POST). The email send goes diff --git a/src/lib/db/migrations/0058_portal_password_revocation.sql b/src/lib/db/migrations/0058_portal_password_revocation.sql new file mode 100644 index 00000000..050721ff --- /dev/null +++ b/src/lib/db/migrations/0058_portal_password_revocation.sql @@ -0,0 +1,11 @@ +-- auth-flow-auditor C1 (portal half): add a per-user +-- password-change watermark so JWT sessions issued before the watermark +-- can be rejected by `verifyPortalToken` without a global secret rotation. +-- +-- Stamped to NOW() for existing rows so no current session is invalidated +-- on deploy; future password resets / activations update it. + +ALTER TABLE portal_users + ADD COLUMN IF NOT EXISTS password_changed_at timestamptz NOT NULL DEFAULT now(); + +-- No index needed: lookup is a single-row PK fetch keyed on portal_users.id. diff --git a/src/lib/db/schema/portal.ts b/src/lib/db/schema/portal.ts index 496da315..2252b76a 100644 --- a/src/lib/db/schema/portal.ts +++ b/src/lib/db/schema/portal.ts @@ -29,6 +29,17 @@ export const portalUsers = pgTable( * until the user activates their account. */ passwordHash: text('password_hash'), + /** + * Watermark for JWT-session revocation on password change. Any + * `verifyPortalToken` call where the JWT's `iat` is older than this + * value rejects the token even if it's otherwise valid. Updated on + * `resetPassword`, `activateAccount`, and `changePortalPassword` so + * a stolen cookie stops working after the legitimate owner does the + * forgot-password / change-password dance. auth-flow-auditor C1. + */ + passwordChangedAt: timestamp('password_changed_at', { withTimezone: true }) + .notNull() + .defaultNow(), name: text('name'), isActive: boolean('is_active').notNull().default(true), lastLoginAt: timestamp('last_login_at', { withTimezone: true }), diff --git a/src/lib/portal/auth.ts b/src/lib/portal/auth.ts index 017b9d2a..666c0eb6 100644 --- a/src/lib/portal/auth.ts +++ b/src/lib/portal/auth.ts @@ -1,5 +1,9 @@ import { SignJWT, jwtVerify } from 'jose'; import { cookies } from 'next/headers'; +import { eq } from 'drizzle-orm'; + +import { db } from '@/lib/db'; +import { portalUsers } from '@/lib/db/schema/portal'; const PORTAL_SECRET = new TextEncoder().encode(process.env.BETTER_AUTH_SECRET); export const PORTAL_COOKIE = 'portal_session'; @@ -14,6 +18,10 @@ export interface PortalSession { clientId: string; portId: string; email: string; + /** Portal user id — needed by verifyPortalToken to fetch + * passwordChangedAt for the iat-vs-watermark check. Mirrors what + * `portalUsers.id` resolves to. */ + portalUserId: string; } export async function createPortalToken(session: PortalSession): Promise { @@ -32,7 +40,25 @@ export async function verifyPortalToken(token: string): Promise ({ + db: { + query: { + portalUsers: { + findFirst: vi.fn(async () => ({ + // Watermark in the past so iat (≈ now) is later. + passwordChangedAt: new Date(Date.now() - 60_000), + isActive: true, + })), + }, + }, + }, +})); + +const { createPortalToken, verifyPortalToken } = await import('@/lib/portal/auth'); const SECRET = new TextEncoder().encode(process.env.BETTER_AUTH_SECRET); const SESSION = { + portalUserId: PORTAL_USER_ID, clientId: '11111111-1111-1111-1111-111111111111', portId: '22222222-2222-2222-2222-222222222222', email: 'client@example.com',