fix(session-policy): clamp pre-join sessions on invite acceptance, normalize expiresAt, sync unified nav test

Author: waleedlatif1

apps/sim/app/workspace/[workspaceId]/settings/navigation.test.ts

@@ -39,6 +39,7 @@ describe('unified settings navigation', () => {
       { id: 'inbox', label: 'Sim mailer', section: 'system' },
       { id: 'recently-deleted', label: 'Recently deleted', section: 'system' },
       { id: 'sso', label: 'Single sign-on', section: 'enterprise' },
+      { id: 'sessions', label: 'Session policies', section: 'enterprise' },
       { id: 'data-retention', label: 'Data retention', section: 'enterprise' },
       { id: 'data-drains', label: 'Data drains', section: 'enterprise' },
       { id: 'whitelabeling', label: 'Whitelabeling', section: 'enterprise' },

apps/sim/lib/auth/security-policy.ts

@@ -71,6 +71,11 @@ interface MembershipCacheEntry {
 
 const membershipCache = new Map<string, MembershipCacheEntry>()
 
+/** Drops the cached membership for a user (call when they join/leave an org). */
+export function invalidateMembershipCache(userId: string): void {
+  membershipCache.delete(userId)
+}
+
 /**
  * Resolves the org a user belongs to (users belong to at most one org),
  * served from a short TTL cache. Org security policies govern MEMBERS, not

apps/sim/lib/auth/session-policy.ts

@@ -4,7 +4,7 @@ import { organization } from '@sim/db/schema'
 import { createLogger } from '@sim/logger'
 import { eq, sql } from 'drizzle-orm'
 import { MIN_IDLE_TIMEOUT_HOURS } from '@/lib/api/contracts/organization'
-import { getMemberOrganizationId } from '@/lib/auth/security-policy'
+import { getMemberOrganizationId, invalidateMembershipCache } from '@/lib/auth/security-policy'
 
 const logger = createLogger('SessionPolicy')
 
@@ -150,6 +150,51 @@ export async function eagerClampOrgSessions(
   organizationId: string,
   policy: ResolvedSessionPolicy
 ): Promise<void> {
+  const bounds = clampBoundsSql(policy)
+  if (!bounds) return
+
+  await db.execute(sql`
+    UPDATE "session" SET expires_at = LEAST(${bounds})
+    WHERE impersonated_by IS NULL
+      AND user_id IN (
+        SELECT user_id FROM member WHERE organization_id = ${organizationId}
+      )
+  `)
+}
+
+/**
+ * Applies the org's session policy to a user who just JOINED the org:
+ * invalidates their cached membership (so the cookie-version and hook-clamp
+ * fallbacks see the new org immediately) and clamps their pre-join sessions,
+ * which otherwise keep their old expiry until the next sliding refresh.
+ * Best-effort by design — a failure here must never fail the join; the
+ * update-hook clamp self-heals within one refresh cycle.
+ */
+export async function applySessionPolicyToNewMember(
+  userId: string,
+  organizationId: string
+): Promise<void> {
+  try {
+    invalidateMembershipCache(userId)
+    const policy = await getSessionPolicy(organizationId)
+    const bounds = clampBoundsSql(policy)
+    if (!bounds) return
+
+    await db.execute(sql`
+      UPDATE "session" SET expires_at = LEAST(${bounds})
+      WHERE user_id = ${userId} AND impersonated_by IS NULL
+    `)
+  } catch (error) {
+    logger.error('Failed to apply session policy to new member; next refresh re-clamps', {
+      userId,
+      organizationId,
+      error,
+    })
+  }
+}
+
+/** SQL argument list for the LEAST() clamp, or null when the policy is empty. */
+function clampBoundsSql(policy: ResolvedSessionPolicy) {
   const bounds = [sql`expires_at`]
   if (policy.maxSessionHours) {
     const maxSecs = policy.maxSessionHours * 3600
@@ -159,13 +204,6 @@ export async function eagerClampOrgSessions(
     const idleSecs = Math.max(policy.idleTimeoutHours, MIN_IDLE_TIMEOUT_HOURS) * 3600
     bounds.push(sql`now() + make_interval(secs => ${idleSecs})`)
   }
-  if (bounds.length === 1) return
-
-  await db.execute(sql`
-    UPDATE "session" SET expires_at = LEAST(${sql.join(bounds, sql`, `)})
-    WHERE impersonated_by IS NULL
-      AND user_id IN (
-        SELECT user_id FROM member WHERE organization_id = ${organizationId}
-      )
-  `)
+  if (bounds.length === 1) return null
+  return sql.join(bounds, sql`, `)
 }

apps/sim/lib/invitations/core.ts

@@ -19,6 +19,7 @@ import { generateId } from '@sim/utils/id'
 import { normalizeEmail } from '@sim/utils/string'
 import { and, eq, inArray, isNull, lte, ne, sql } from 'drizzle-orm'
 import { setActiveOrganizationForCurrentSession } from '@/lib/auth/active-organization'
+import { applySessionPolicyToNewMember } from '@/lib/auth/session-policy'
 import { syncUsageLimitsFromSubscription } from '@/lib/billing/core/usage'
 import {
   acquireOrganizationMutationLock,
@@ -646,6 +647,10 @@ async function runInvitationAcceptancePostCommitEffects(
   }
 
   if (effects.organizationId && effects.memberRole) {
+    // Pre-join sessions keep their old expiry until the next sliding refresh;
+    // apply the org's session policy to them now (best-effort, never throws).
+    await applySessionPolicyToNewMember(input.userId, effects.organizationId)
+
     recordAudit({
       workspaceId: null,
       actorId: input.userId,