.github/9
ISSUE_TEMPLATE/3bug_report.md config.yml feature_request.md
workflows/3ci.yml clean-clone.yml release.yml
CODEOWNERS dependabot.yml pull_request_template.md
apps/630
api/250
src/243
common/30
__tests__/3authorize.test.ts bigint-serialization.interceptor.test.ts files-limits.test.ts
filters/1all-exceptions.filter.ts
guards/3auth.guard.ts internal-service.guard.ts rate-limit.guard.ts
interceptors/2actor-context.interceptor.ts bigint-serialization.interceptor.ts
middleware/2idempotency.test.ts idempotency.ts
pipes/1zod-validation.pipe.ts
actor-context.ts audit.service.ts cache.test.ts cache.ts cookies.ts core.module.ts deprecation.ts email.service.ts errors.ts event-bus.ts log-scrubber.test.ts log-scrubber.ts logger.ts permission-cache-bridge.ts prisma.service.ts redis.service.ts trace-metadata.ts types.ts
config/1env.ts
lib/11
__tests__/5crypto.test.ts filter-builder.test.ts jwt.test.ts pagination.test.ts positions.test.ts
authorize.ts crypto.ts filter-builder.ts jwt.ts pagination.ts positions.ts
modules/197
ai/28
__tests__/4ai-writing.test.ts database-ai.test.ts generate-executor.test.ts prompts.test.ts
generator/4executor.ts generate.controller.ts generate.dto.ts generate.service.ts
ai-chat.service.ts ai-rate-limit.ts ai-writing.controller.ts ai-writing.dto.ts ai-writing.service.ts ai.controller.ts ai.module.ts ai.service.ts budget-guard.service.ts database-ai.controller.ts database-ai.dto.ts database-ai.service.ts db-prompts.ts dto.ts gateway-provider.ts ledger.service.ts prompts.ts rag.controller.ts rag.dto.ts rag.service.ts
api-keys/3api-keys.controller.ts api-keys.module.ts api-keys.service.ts
audit/2audit-log.controller.ts audit.module.ts
auth/4auth.controller.ts auth.module.ts auth.service.ts dto.ts
automations/5automations.controller.ts automations.module.ts automations.service.ts dto.ts webhook-incoming.controller.ts
blocks/5
__tests__/1batch-version-cas.test.ts
block.service.ts blocks.controller.ts blocks.module.ts dto.ts
comments/4comments.controller.ts comments.module.ts comments.service.ts dto.ts
databases/9
__tests__/3normalize-select-options.test.ts option-id-canonicalization.test.ts record-open-query-shape.test.ts
database.service.ts databases.controller.ts databases.module.ts dto.ts property-cache-schema.ts query.service.ts
docs/2docs.controller.ts docs.module.ts
files/10
__tests__/1quota.test.ts
dto.ts files.controller.ts files.module.ts files.service.ts quota.ts record.ts s3.ts uploads.controller.ts uploads.service.ts
forms/18debug.controller.ts form.dto.ts forms.controller.ts forms.module.ts forms.service.ts markdown.test.ts markdown.ts optional-auth.guard.ts public-forms.controller.ts public-forms.service.ts question.dto.ts questions.service.ts rate-limit.ts recaptcha.ts slug.ts submissions.controller.ts submissions.service.ts submit-schema.ts
health/3health.controller.ts health.module.ts health.service.ts
integrations/3integrations.controller.ts integrations.module.ts integrations.service.ts
internal/12
__tests__/2flush-query-shape.test.ts internal.endpoints.test.ts
ai-test-seam.controller.ts ai-test-seam.dto.ts ai-test-seam.service.ts internal.controller.ts internal.dto.ts internal.module.ts internal.service.ts test-seam.controller.ts test-seam.dto.ts test-seam.service.ts
notifications/3notifications.controller.ts notifications.module.ts notifications.service.ts
oauth/6
__tests__/1oauth.scopes.test.ts
oauth.controller.ts oauth.module.ts oauth.service.ts scopes.ts token-keys.ts
org/15audit.service.ts embed-preview.controller.ts guards.ts members.service.ts org-admin.controller.ts org-policy.service.ts org.module.ts overview.service.ts policy-effective.controller.ts policy.schema.ts policy.test.ts retention.service.ts totp.test.ts totp.ts two-factor.service.ts
orgs/5dto.ts orgs.controller.ts orgs.module.ts orgs.service.ts util.ts
pages/4dto.ts page.service.ts pages.controller.ts pages.module.ts
scim/15
__tests__/3email-mapping.test.ts etag.test.ts filters.test.ts
etag.ts filters.ts groups.service.ts schemas.ts scim-admin.controller.ts scim-admin.service.ts scim-auth.guard.ts scim-auth.service.ts scim-errors.ts scim.controller.ts scim.module.ts users.service.ts
search/4
__tests__/1search.service.test.ts
search.controller.ts search.module.ts search.service.ts
sessions/3sessions.controller.ts sessions.module.ts sessions.service.ts
share/3share.controller.ts share.module.ts share.service.ts
sso/16
__tests__/4enforcement.test.ts oidc.verify.test.ts provisioning.test.ts saml.validate.test.ts
enforcement.ts oidc.controller.ts oidc.service.ts oidc.ts provisioning.service.ts saml.controller.ts saml.ts schemas.ts sso-admin.controller.ts sso-admin.service.ts sso-secrets.ts sso.module.ts
teams/4dto.ts teams.controller.ts teams.module.ts teams.service.ts
users/4dto.ts users.controller.ts users.module.ts users.service.ts
webhooks/3webhooks.controller.ts webhooks.module.ts webhooks.service.ts
workspaces/4dto.ts workspaces.controller.ts workspaces.module.ts workspaces.service.ts
types/1xmldom.d.ts
app.module.ts constants.ts main.ts
_probe_rawbody.cjs .env.example Dockerfile package.json README.md tsconfig.json vitest.config.ts
realtime/33
src/17auth.ts comments.ts config.ts event-source.ts http-store.ts index.ts metrics.ts notifications.ts page-updated-source.ts presence.ts prisma-store.ts protocol.ts rate-limit.ts room-key.ts rooms.ts server.ts update-log.ts
test/11auth.test.ts config.test.ts event-source.test.ts http-store.test.ts metrics-merge.test.ts page-updated-source.test.ts presence.test.ts protocol.test.ts rate-limit.test.ts rooms.test.ts task-0094-builders.test.ts
.env.example Dockerfile package.json README.md tsconfig.json
web/255
src/244
app/45
__tests__/1theme-tokens.test.ts
(app)/26
w/25
[workspace]/25
ask/1page.tsx
databases/1
[id]/1page.tsx
favorites/1page.tsx
files/1page.tsx
notifications/1page.tsx
page/4
[id]/4
[block]/1page.tsx
share/1page.tsx
layout.tsx page.tsx
search/1page.tsx
settings/10
appearance/1page.tsx
automations/3
[id]/1page.tsx
new/1page.tsx
page.tsx
billing/1page.tsx
developers/1page.tsx
members/1page.tsx
permissions/1page.tsx
teams/1page.tsx
page.tsx
shared/1page.tsx
templates/1page.tsx
trash/1page.tsx
layout.tsx page.tsx
layout.tsx
(auth)/4
login/1page.tsx
register/1page.tsx
reset-password/1page.tsx
layout.tsx
api/2
metrics/1route.ts
v1/1
health/1route.ts
f/1
[slug]/1page.tsx
health/1
ready/1route.ts
org/2
[orgId]/2
admin/2
integrations/1page.tsx
page.tsx
share/1
[id]/1page.tsx
error.tsx global-error.tsx globals.css layout.tsx not-found.tsx page.tsx providers.tsx
components/118
admin/10
org-admin/8ApiKeysTab.tsx AuditTab.tsx MembersTab.tsx OverviewTab.tsx PoliciesTab.tsx RetentionTab.tsx WebhooksTab.tsx WorkspacePicker.tsx
ScimCard.tsx SsoTabs.tsx
ai/6ai-panel.tsx ask-ai-submenu.tsx db-ai-dialog.tsx generate-page-dialog.tsx writing-actions-menu.tsx writing-diff.tsx
automations/5action-editor.tsx condition-editor.tsx lib.ts run-history.tsx trigger-editor.tsx
collaboration/6CursorLayer.tsx OfflineBanner.tsx PresenceBar.tsx README.md ReviewFailedDialog.tsx StatusChip.tsx
comments/3comment-panel.tsx comment-thread.tsx mention-input.tsx
database/27
__tests__/2cell-editor.test.tsx cell-renderer.test.tsx
AiExtractDialog.tsx AiFormulaDialog.tsx AiGenerateDialog.tsx board-view.tsx buttons-panel.tsx calendar-view.tsx cell-editor.tsx cell-renderer.tsx chart-view.tsx database-page-view.tsx database-toolbar.tsx database-view-renderer.tsx db-embedded.tsx filter-builder.tsx form-builder-view.tsx formula-editor.tsx gallery-view.tsx group-builder.tsx list-view.tsx property-editor.tsx record-header.tsx record-panel.tsx sort-builder.tsx table-view.tsx timeline-view.tsx
dialogs/7
__tests__/1move-to-dialog.test.tsx
create-dialog.tsx dialog.tsx file-permissions-dialog.tsx invite-dialog.tsx move-to-dialog.tsx share-dialog.tsx
editor/19
__tests__/3code-block-text.test.ts code-block.test.tsx expandable.test.tsx
block-card.tsx block-renderer.tsx block-save-queue.ts block-toolbar.tsx context-menu.tsx expandable.tsx history-popover.tsx inline-editor.tsx insert-dialog.tsx page-canvas.tsx page-spinner.tsx page-view.tsx selection-toolbar.tsx slash-menu.tsx template-dialog.tsx type-menu.tsx
files/4FileBlock.tsx FileBrowser.tsx FilePicker.tsx PreviewModal.tsx
form/4form-field.tsx form-renderer.tsx form-responses-view.tsx form-view.tsx
layout/8
__tests__/1page-tree-icon.test.tsx
command-palette.tsx factory-logo.tsx page-tree-node.tsx sidebar.tsx theme-provider.tsx topbar.tsx workspace-shell.tsx
mentions/3
__tests__/1mention-model.test.ts
mention-model.ts MentionPopup.tsx
search/3ask-ai-search.tsx results-list.tsx search-dialog.tsx
settings/10
api-keys/4ApiKeyCreateDialog.tsx ApiKeyRevealDialog.tsx ApiKeyTable.tsx ScopesBadge.tsx
webhooks/5CurlExamples.tsx DeliveryInspector.tsx EventExplorer.tsx OverviewTab.tsx WebhooksTab.tsx
settings-shell.tsx
ui/3confirm-dialog.tsx form.tsx toaster.tsx
hooks/21
__tests__/4realtime-frame-handler.test.ts use-blocks.test.ts use-database-options.test.ts use-workspace.test.tsx
realtime-frame-handler.ts use-ai-stream.ts use-auth.ts use-blocks.ts use-database.ts use-db-ai-stream.ts use-forms.ts use-members.ts use-mention-sources.ts use-notifications.ts use-offline-status.ts use-pages.ts use-presence-announcer.ts use-presence-toasts.ts use-presence.ts use-realtime.ts use-workspace.ts
lib/50
__tests__/21ai-database.test.ts ai-generate.test.ts ai-sse.test.ts ai-writing.test.ts api-keys.test.ts api-members.test.ts auth-refresh.test.ts auth-store.test.ts batch-queue-drop.test.ts block-content.test.ts clipboard-import.test.ts code-highlight.test.ts offline-status.test.ts presence-announcer.test.ts presence-color.test.ts presence-cursor.test.ts presence-emitter.test.ts realtime-url.test.ts search.test.ts utils.test.ts writing-diff.test.ts
files/7
__tests__/2picker.test.ts upload.test.ts
api.ts picker.ts upload-store.ts upload.ts use-file-uploads.ts
ai-database.ts ai.ts api-keys.ts api.ts auth-store.ts batch-queue.ts block-content.ts clipboard-import.ts code-highlight.ts constants.ts offline-status.ts org-admin.ts presence-announcer.ts presence-color.ts presence-cursor.ts presence-editor-views.ts presence-emitter.ts query-client.ts realtime.ts search.ts types.ts utils.ts
stores/8
__tests__/1block-patch-store.test.ts
block-patch-store.ts comment-pill-store.ts database-store.ts editor-store.ts offlineQueue.ts presence-store.ts ui-store.ts
instrumentation.ts middleware.ts
.env.example Dockerfile next-env.d.ts next.config.mjs package.json postcss.config.mjs README.md tailwind.config.ts tsconfig.json tsconfig.tsbuildinfo vitest.config.ts
worker/92
src/87
__tests__/13ai-embedding.test.ts ai-request.test.ts ai-usage-budget.test.ts audit-export.test.ts email-decision.test.ts encrypt.test.ts health-search-index-lag.test.ts mime.test.ts retention.test.ts s3-sign.test.ts search-index.test.ts smtp.test.ts webhook-sign.test.ts
health/1server.ts
lib/12
__tests__/1clamav.test.ts
clamav.ts encrypt.ts job-otel.ts mime.ts notify.ts prisma.ts redis-stream.ts redis.ts s3.ts sharp.ts smtp.ts
processors/56
automations/28
__tests__/3condition-evaluator.spec.ts executors.spec.ts run-pipeline.spec.ts
executors/17assign-user.ts call-integration.ts change-status.ts classify.ts create-notification.ts create-page.ts email-cap.ts helpers.ts integration-registry.ts permission.ts record-write.ts registry.ts run-ai-action.ts send-email.ts send-webhook.ts types.ts update-record.ts
condition-evaluator.ts dead-letter.ts log.ts matcher.ts pipeline.ts run-state.ts schedule.ts watchdog.ts
files/15
__tests__/4errors.test.ts scan-gate.test.ts status.test.ts temp.test.ts
steps/4finalize.ts metadata.ts scan.ts thumbnails.ts
cleanup.ts errors.ts generateThumbs.ts processor.ts status.ts temp.ts types.ts
search-index/4builders.ts grants.ts index.ts processor.ts
ai-embedding.ts ai.processor.ts audit-export.ts automations.processor.ts email-decision.processor.ts email.processor.ts maintenance.processor.ts retention.ts webhooks.processor.ts
config.ts events.ts index.ts logger.ts queues.ts
.env.example Dockerfile package.json README.md tsconfig.json
docs/73
api/17ai.md authentication.md automations.md blocks.md comments.md databases.md files.md forms.md openapi.yaml org-admin.md pages.md scim.md search.md sso.md versioning.md webhooks.md workspaces.md
architecture/10ai-architecture.md automation.md backend-architecture.md database-architecture.md frontend-architecture.md realtime-architecture.md search-architecture.md security-architecture.md storage.md system-architecture.md
database/2database-architecture.md redis-keys.md
development/8admin-guide.md coding-standards.md deployment.md development-guide.md files-pipeline.md perf-report.md performance.md testing.md
product/4functional-requirements.md non-functional-requirements.md product-requirements.md ux-requirements.md
requirements/1requirements-matrix.md
security/5audit-report.md files.md forms.md license-allowlist.md security-architecture.md
tasks/16phase-00-foundation.md phase-01-authentication.md phase-02-workspace.md phase-03-pages.md phase-04-editor.md phase-05-databases.md phase-06-relations.md phase-07-collaboration.md phase-08-search.md phase-09-files.md phase-10-forms.md phase-11-automation.md phase-12-ai.md phase-13-api.md phase-14-enterprise.md phase-15-production.md
ui/9ai.md automations.md design-system.md developers.md files.md forms.md org-admin.md scim.md sso.md
support-matrix.md
infrastructure/71
caddy/1Caddyfile
docker/6
init/101-extensions.sql
opensearch/1init-indices.json
.env.docker docker-compose.yml opensearch-init.sh README.md
kubernetes/40
observability/20
alertmanager/1alertmanager.yaml
grafana/8
dashboards/6ai.json api-overview.json infra.json realtime.json search.json workers-queues.json
provisioning/2
dashboards/1dashboards.yaml
datasources/1datasource.yaml
prometheus/3alerts.yaml recording-rules.yaml scrape.yaml
scripts/1sync-sources.mjs
alertmanager.yaml grafana.yaml kustomization.yaml namespace.yaml node-exporter.yaml otel-collector.yaml prometheus.yaml
postgres/7configmap.yaml cronjob-backup.yaml cronjob-opensearch-snapshot.yaml pgbouncer.yaml replica.yaml statefulset.yaml walg-iam-policy.yaml
api.yaml configmap.yaml ingress.yaml kustomization.yaml namespace.yaml networkpolicy.yaml pdb.yaml README.md realtime.yaml redis.yaml secret.example.yaml web.yaml worker.yaml
nginx/2nginx.conf README.md
observability/14
alertmanager/1alertmanager.yaml
grafana/8
dashboards/6ai.json api-overview.json infra.json realtime.json search.json workers-queues.json
provisioning/2
dashboards/1dashboards.yaml
datasources/1datasource.yaml
prometheus/3alerts.yaml recording-rules.yaml scrape.yaml
scripts/1dashboard-completeness.mjs
README.md
terraform/8compute.tf data.tf main.tf network.tf outputs.tf README.md security.tf variables.tf
packages/289
ai/24
src/20
providers/7anthropic.ts google.ts http.ts index.ts openai-compatible.ts rag.test.ts writing.test.ts
schemas/2database.ts generate.ts
adapters.test.ts config.test.ts config.ts gateway.test.ts gateway.ts index.ts tools.test.ts tools.ts types.ts usage.test.ts usage.ts
package.json README.md tsconfig.json vitest.config.ts
auth/11
src/7index.ts passwords.test.ts passwords.ts sessions.test.ts sessions.ts tokens.test.ts tokens.ts
package.json README.md tsconfig.json vitest.config.ts
collaboration/17
src/13awareness.ts codec.test.ts codec.ts index.ts lww.test.ts lww.ts mapping.ts offline.ts outbox.test.ts outbox.ts provider.test.ts provider.ts types.ts
package.json README.md tsconfig.json vitest.config.ts
config/7
src/4eslint.base.js index.ts prettier.base.json tsconfig.base.json
package.json README.md tsconfig.json
database-client/5
src/2index.test.ts index.ts
package.json README.md tsconfig.json
database-engine/33
src/29
filter/2filter.test.ts index.ts
formula/8evaluator.ts formula.test.ts functions.ts index.ts lexer.ts parser.ts types.ts validate.ts
query/6group.ts index.ts paginate.ts pivot.ts query.test.ts sort.ts
relations/2index.ts relations.test.ts
rollups/2index.ts rollups.test.ts
values/5dates.ts index.ts registry.ts types.ts values.test.ts
views/3buttons.ts index.ts views.test.ts
index.ts
package.json README.md tsconfig.json vitest.config.ts
editor/25
src/21
marks/1highlight.ts
nodes/2equation.ts mention.ts
autosave.test.ts autosave.ts clipboard.test.ts clipboard.ts codec.test.ts codec.ts context-menu.test.ts context-menu.ts diff.test.ts diff.ts factory.ts history.test.ts history.ts index.ts positions.ts slash.test.ts slash.ts types.ts
package.json README.md tsconfig.json vitest.config.ts
observability/20
src/16
__tests__/8db-redis-metrics.test.ts metrics.test.ts otel.test.ts pino-otel.test.ts prometheus.test.ts resource.test.ts scrubber.test.ts traceparent.test.ts
index.ts metrics.ts otel.ts pino-otel.ts prometheus.ts resource.ts scrubber.ts traceparent.ts
package.json README.md tsconfig.json vitest.config.ts
permissions/11
src/7index.ts levels.test.ts levels.ts resolve.test.ts resolve.ts rules.test.ts rules.ts
package.json README.md tsconfig.json vitest.config.ts
search/22
src/18chunking.test.ts chunking.ts client.test.ts client.ts embeddings.test.ts embeddings.ts hybrid.test.ts hybrid.ts index.ts indexer.test.ts indexer.ts mapping.test.ts mapping.ts queries.test.ts queries.ts rrf.test.ts rrf.ts types.ts
package.json README.md tsconfig.json vitest.config.ts
shared/61
src/57
dto/17ai.dto.ts auth.dto.test.ts auth.dto.ts block.dto.ts browser-safety.test.ts comment.dto.ts database.dto.test.ts database.dto.ts file.dto.ts formula-ast.ts index.ts notification.dto.ts page.dto.ts search.dto.ts share.dto.ts webhook.dto.ts workspace.dto.ts
events/8audit-catalog.test.ts audit-catalog.ts audit-csv.test.ts audit-csv.ts audit-scope.test.ts audit-scope.ts catalog.test.ts catalog.ts
realtime/6comment-events.ts frames.test.ts frames.ts notification-policy.ts notification-prefs.ts task-0094.test.ts
automation.test.ts automation.ts constants.ts crypto.test.ts crypto.ts env.ts errors.ts events.test.ts events.ts forms.test.ts forms.ts index.ts markdown.test.ts markdown.ts mentions.test.ts mentions.ts net.test.ts net.ts positions.test.ts positions.ts presence.test.ts presence.ts security-headers.ts webhook-delivery.test.ts webhook-delivery.ts webhook-events.ts
package.json README.md tsconfig.json vitest.config.ts
storage/16
src/12client.test.ts client.ts index.ts keys.test.ts keys.ts mime.test.ts mime.ts presign.test.ts presign.ts thumbnails.test.ts thumbnails.ts types.ts
package.json README.md tsconfig.json vitest.config.ts
ui/37
src/33
components/19avatar.tsx badge.tsx button.tsx checkbox.tsx command.tsx context-menu.tsx dialog.tsx dropdown-menu.tsx empty-state.tsx index.ts popover.tsx separator.tsx skeleton.tsx slider.tsx spinner.tsx switch.tsx tabs.tsx toast.tsx tooltip.tsx
color.ts command-filter.test.ts command-filter.ts focus.test.ts focus.ts formatters.test.ts formatters.ts index.ts theme.test.ts theme.ts toast-store.test.ts toast-store.ts tokens.test.ts tokens.ts
package.json README.md tsconfig.json vitest.config.ts
prisma/16
migrations/13
20260927000000_init/1migration.sql
20260928000000_search_documents_content_hash/1migration.sql
20260929000000_workspace_usage_storage_bytes/1migration.sql
20260930000000_form_submitted_notification_type/1migration.sql
20261001000000_ai_phase12/1migration.sql
20261002000000_webhooks_secret_encrypted_dlq/1migration.sql
20261002111436_webhook_delivery_latency/1migration.sql
20261002120000_org_admin_2fa_retention_unique/1migration.sql
20261002215124_audit_export/1migration.sql
20261003210000_perf_indexes_hot_paths/1migration.sql
20261004004500_perf_indexes_hot_paths_2/1migration.sql
migration_lock.toml README.md
schema.prisma seed.ts verify.ts
scripts/7backup-health.ts docs-completeness.mjs generate-openapi.mjs minio-init.ts opensearch-reindex.ts storage-orphans.ts verify-clean-clone.sh
tests/169
e2e/63
.auth/1user.json
fixtures/7
files/6clip.mp4 clip.wav clip.webm hero-1400.png note.docx note.txt
realtime.ts
mocks/2oidc-issuer.ts saml-idp.ts
playwright-report/3
data/2a6557bae9c2714a658968d4eb8534195c08ebda8.png e3092d07d00a16063e46385c02a559a9054fa847.webm
index.html
reports/1files-security.json
specs/34ai-database.spec.ts ai-generate.spec.ts ai-rag.spec.ts ai-security.spec.ts ai-writing.spec.ts ai.spec.ts api-keys.spec.ts appearance-theme.spec.ts auth.spec.ts automation.spec.ts collab-two-tab.spec.ts comments.spec.ts databases.spec.ts default-workspace-alias.spec.ts developers.spec.ts editor.spec.ts files.spec.ts final-flow.spec.ts forms.spec.ts oauth.spec.ts org-admin.spec.ts pages.spec.ts performance.spec.ts presence-cursors.spec.ts qa-paste-toggle.spec.ts realtime.spec.ts scim.spec.ts search-index-lag.spec.ts search.spec.ts sharing.spec.ts sso.spec.ts task-0094-comments-notifications.spec.ts webhooks.spec.ts workspace.spec.ts
test-results-final-flow/3
final-flow-Release-v1-0-fi-6c06b-w-state-carries-sequential--chromium-desktop/2test-failed-1.png trace.zip
.last-run.json
utils/4api.ts dnd.ts search-lag.ts wait.ts
.gitignore fixtures.ts global-setup.ts package.json playwright.config.ts playwright.final-flow.config.ts README.md tsconfig.json
fixtures/1
files/1make-sparse.ts
integration/60
ai-capability/2ai-app.capability.test.ts gateway.capability.test.ts
drill/2seed-drill.mjs verify-restore.mjs
fixtures/5
files/5clip.mp4 clip.wav doc.pdf hero-1400.png note.txt
helpers/3api.ts containers.ts seed.ts
realtime/11control-channel.test.ts convergence.test.ts flush-rebase-http.test.ts handshake.test.ts heartbeat-limits.test.ts lifecycle.test.ts presence.test.ts rebase.test.ts resume.test.ts rt-helpers.ts task-0094-fanout.test.ts
ai-chat.integration.test.ts ai-database.integration.test.ts ai-generate.integration.test.ts ai-rag.integration.test.ts ai-writing.integration.test.ts api-keys.integration.test.ts audit-completeness.integration.test.ts audit-export-s3.integration.test.ts auth.integration.test.ts automation-pipeline.integration.test.ts automations.integration.test.ts blocks.integration.test.ts cache-invalidation.integration.test.ts comments.integration.test.ts databases.integration.test.ts files-lifecycle.integration.test.ts files-pipeline.integration.test.ts files-security.integration.test.ts files.integration.test.ts forms-responses.integration.test.ts forms.integration.test.ts oauth.integration.test.ts openapi.contract.test.ts org-admin.integration.test.ts package.json pages.integration.test.ts permissions.integration.test.ts README.md replica-routing.integration.test.ts retention-engine.integration.test.ts scim.integration.test.ts search.integration.test.ts sso.integration.test.ts tsconfig.json vitest.config.ts webhooks.integration.test.ts workspace.integration.test.ts
performance/28
fixtures/1search-100k.ts
helpers/2seed-100k.mjs seed-1k-load.mjs
reports/7api-load-smoke.json database-load-smoke.json editor-local.json realtime-load.json search-full.json search-last.json search-reduced.json
api-load.js api.js archive.tar database-load.js database.js editor-local.mjs extract-100k-env.mjs package.json README.md realtime-1k.js realtime-load.js realtime.js run-realtime-load.sh search-search.k6.js search-summary.json seed-100k.mjs threshold-breach-demo.js verify-zero-op-loss.mjs
security/16
helpers/1app.ts
audit-report.test.ts auth-paths.test.ts deps.test.ts formula-fuzz.test.ts gitleaks-config.test.ts headers.test.ts images.test.ts oracle.ts package.json permission-fuzz.test.ts rate-limits.test.ts README.md tsconfig.json upload-abuse.test.ts vitest.config.ts
README.md
.dockerignore .env .env.bak-task0125 .env.example .eslintrc.json .gitignore .npmrc .prettierignore .prettierrc.json AGENTS.md ARCHITECTURE.md CHANGELOG.md CONTRIBUTING.md gitleaks.toml LICENSE package.json pnpm-lock.yaml pnpm-workspace.yaml PRODUCT-SPEC.md README.md ROADMAP.md SECURITY.md tsconfig.json turbo.json
authorize.tsapps/api/src/lib/authorize.tsraw← lib23,934 B← Back to the app
1/**
2 * Server-side authorization — the single place where "may I?" is decided.
3 *
4 * Effective level resolution:
5 *   1. workspace role:  OWNER → FULL_ACCESS, ADMIN → FULL_ACCESS,
6 *                       MEMBER → EDIT, GUEST → VIEW (no membership → NONE)
7 *   2. `Permission` rows (grantee × resource × level) for this workspace:
8 *        - grantee: user (direct) or team (member of that team in this workspace)
9 *        - resource scope: workspace (applies to everything), teamspace,
10 *          page, database, record, file
11 *      The most specific applicable row wins (workspace < teamspace <
12 *      database < page < record < file); ties at one specificity take the
13 *      max level. The result is maxed with the workspace-role level.
14 *
15 * Levels: NONE < VIEW < COMMENT < EDIT < FULL_ACCESS.
16 *
17 * The `prisma` parameter is a structural interface (the three delegates
18 * used) so the resolution is unit-testable with a fixture object.
19 */
20 
21import { ApiError } from "../common/errors.js";
22import { ActorContext } from "../common/actor-context.js";
23// OAuth scope rules (TASK-0129): the domain lives in modules/oauth/scopes.ts
24// (catalog + cap + the "which scope was missing" helper) — it type-imports
25// `Level` from HERE, so this value import is one-directional at runtime
26// (no cycle). Reused here, never duplicated (AGENTS rule 4).
27import { oauthScopeCap, missingOAuthScope } from "../modules/oauth/scopes.js";
28 
29export type Level = "NONE" | "VIEW" | "COMMENT" | "EDIT" | "FULL_ACCESS";
30 
31/**
32 * API-key scope rules (TASK-0127, docs/api/authentication.md §7):
33 *   READ  key → may pass only VIEW-level assertions (reads);
34 *   WRITE key → may pass up to EDIT-level assertions (mutations; COMMENT
35 *               ops are covered since the level ladder is flat there);
36 *   ADMIN key → all levels (ADMIN implies WRITE implies READ).
37 * Anything beyond the key's cap yields 403 FORBIDDEN with
38 * `details: [{reason: "api_key_scope_write"}]` (the documented public
39 * alias: **SCOPE_DENIED** — `docs/api/authentication.md` §9.1).
40 *
41 * The cap is derived from the key's SCOPES (never from the asserted
42 * resource, never from the creator's membership).
43 */
44function apiKeyScopeCap(scopes: string[]): Level {
45  if (scopes.includes("ADMIN")) return "FULL_ACCESS";
46  if (scopes.includes("WRITE")) return "EDIT";
47  return "VIEW";
48}
49 
50/**
51 * The OAuth scope-cap, re-exported from modules/oauth/scopes.ts so callers
52 * (and tests) can import it from the authorize module too.
53 */
54export { oauthScopeCap };
55 
56/**
57 * OAuth branch of {@link assertCan} (TASK-0129, docs §8.2). Runs instead of
58 * the membership path when the in-flight actor is an OAuth token
59 * (`kind: "user"` + `oauthScopes`). The cap (`oauthScopeCap`) and the
60 * "which scope was missing" detail (`missingOAuthScope`) come from
61 * modules/oauth/scopes.ts — imported, never duplicated.
62 *
63 * The target workspace comes from the `X-Factory-Workspace` header (the
64 * OAuth JWT carries no workspace claim). Two gates, in order:
65 *   1. The token's user must be a MEMBER of the target workspace — not a
66 *      member → 401 (the workspace context is invalid for this user; never a
67 *      200 on another tenant, never a membership probe leak).
68 *   2. The scope CAP must cover the operation — otherwise 403 reusing the
69 *      documented `api_key_scope_write` reason (the public alias
70 *      SCOPE_DENIED), with the needed scope in `details[0].scope`.
71 */
72async function assertCanForOAuth(
73  prisma: AuthorizePrisma,
74  actor: { userId?: string; oauthScopes?: string[] },
75  workspaceId: string,
76  need: Level,
77  resource?: ResourceScope
78): Promise<Level> {
79  const membership =
80    actor.userId && workspaceId
81      ? await prisma.workspaceMember
82          .findUnique({ where: { workspaceId_userId: { workspaceId, userId: actor.userId } } })
83          .catch(() => null)
84      : null;
85  if (!membership) {
86    throw new ApiError("UNAUTHORIZED", 401, "You are not a member of the requested workspace.", [
87      { reason: "workspace_member_required" }
88    ]);
89  }
90  const scopes = actor.oauthScopes ?? [];
91  const cap = oauthScopeCap(scopes);
92  if (LEVEL_ORDER[cap] < LEVEL_ORDER[need]) {
93    throw new ApiError("FORBIDDEN", 403, `OAuth scope does not cover ${need} access.`, [
94      { reason: "api_key_scope_write", scope: missingOAuthScope(need, scopes, resource) }
95    ]);
96  }
97  return cap;
98}
99 
100export const LEVELS: Level[] = ["NONE", "VIEW", "COMMENT", "EDIT", "FULL_ACCESS"];
101 
102export const LEVEL_ORDER: Record<Level, number> = {
103  NONE: 0,
104  VIEW: 1,
105  COMMENT: 2,
106  EDIT: 3,
107  FULL_ACCESS: 4
108};
109 
110/** Workspace role → baseline permission level. */
111export const ROLE_LEVEL: Record<string, Level> = {
112  OWNER: "FULL_ACCESS",
113  ADMIN: "FULL_ACCESS",
114  MEMBER: "EDIT",
115  GUEST: "VIEW"
116};
117 
118/** Resource specificity: higher = more specific = wins over broader grants. */
119const RESOURCE_SPECIFICITY: Record<string, number> = {
120  workspace: 0,
121  teamspace: 1,
122  database: 2,
123  page: 3,
124  record: 4,
125  file: 5
126};
127 
128export interface ResourceScope {
129  pageId?: string;
130  databaseId?: string;
131  teamId?: string;
132  recordId?: string;
133  fileId?: string;
134}
135 
136export interface EffectiveLevelInput {
137  workspaceId: string;
138  userId: string;
139  resource?: ResourceScope;
140}
141 
142/** Minimal structural type of the Prisma delegates used here (testable).
143 *
144 * NOTE (2026-09-29, TASK-0101): the argument parameters are typed as
145 * `object` — the Prisma 5.22 generated delegates take their own
146 * `*FindManyArgs`/`*FindUniqueArgs` generics, which no single structural
147 * signature can satisfy without importing the generated client (the test
148 * fixture must stay import-free). The CALLER's `where` shape is still
149 * checked by the delegate at runtime; the caller-side literals are checked
150 * by the real client when `PrismaService` is passed (the only production
151 * implementation). This is the fix for the Prisma-5.22 drift that made
152 * `PrismaService` fail to satisfy this interface in ~15 services. */
153export interface AuthorizePrisma {
154  workspaceMember: {
155    findUnique(args: object): Promise<{ id: string; role: string } | null>;
156  };
157  teamMember: {
158    findMany(args: object): Promise<{ teamId: string }[]>;
159  };
160  permission: {
161    findMany(args: object): Promise<PermissionRow[]>;
162  };
163}
164 
165export interface PermissionRow {
166  id: string;
167  workspaceId: string;
168  granteeType: string; // "user" | "team" | "role"
169  granteeId: string;
170  resourceType: string; // workspace | teamspace | page | database | record | file
171  resourceId: string;
172  level: Level;
173  inheritsFrom?: string | null;
174}
175 
176function maxLevel(a: Level, b: Level): Level {
177  return LEVEL_ORDER[a] >= LEVEL_ORDER[b] ? a : b;
178}
179 
180/**
181 * TASK-0135: optional permission-decision cache. This lib is plain (no Nest
182 * DI), so the live `CacheService` is handed in ONCE at boot by the
183 * `PermissionCacheBridge` provider (CoreModule) via {@link setPermissionCache}.
184 * When unset (tests, or `PERF_CACHE` off) decisions go straight to Postgres —
185 * the cache is a transparent accelerator, never a change in the decision.
186 *
187 * The bound function's `loader` is the live resolution; the cache layer calls
188 * it on a miss and stores the level (zod-validated on read), busting the
189 * subject's entries on `permission.changed` (TTL 60 s as the safety net).
190 */
191type GetCachedLevel = (
192  workspaceId: string,
193  userId: string,
194  scope: ResourceScope | undefined,
195  loader: () => Promise<string>
196) => Promise<{ level: string; cached: boolean }>;
197 
198let permCacheFn: GetCachedLevel | null = null;
199 
200/** Hand the live (bound) permission-cache accessor in, or `null` to disable. */
201export function setPermissionCache(fn: GetCachedLevel | null): void {
202  permCacheFn = fn;
203}
204 
205/**
206 * Resolve the effective permission level of `userId` in `workspaceId` for an
207 * optional resource scope. Never throws — returns NONE when not a member
208 * and no grant applies.
209 */
210export async function effectiveLevel(
211  prisma: AuthorizePrisma,
212  input: EffectiveLevelInput
213): Promise<Level> {
214  const { workspaceId, userId, resource } = input;
215  // TASK-0135: the decision is cached (TTL 60 s + `permission.changed` bust)
216  // when the live accessor is bound; `loader` is the live resolution. When the
217  // cache is off/unbound, go straight to Postgres (loader runs inline).
218  if (permCacheFn) {
219    const { level } = await permCacheFn(workspaceId, userId, resource, () =>
220      rawEffectiveLevel(prisma, input)
221    );
222    return level as Level;
223  }
224  return rawEffectiveLevel(prisma, input);
225}
226 
227/** The live resolution (un-cached) — the loader the permission cache calls. */
228async function rawEffectiveLevel(
229  prisma: AuthorizePrisma,
230  input: EffectiveLevelInput
231): Promise<Level> {
232  const { workspaceId, userId, resource } = input;
233 
234  const membership = await prisma.workspaceMember.findUnique({
235    where: { workspaceId_userId: { workspaceId, userId } }
236  });
237  let level: Level = membership ? ROLE_LEVEL[membership.role] ?? "NONE" : "NONE";
238 
239  // Sequential (NOT Promise.all): the permission query's team-grant filter
240  // DEPENDS on `teams`, so it cannot run in parallel. (A prior sync commit
241  // inlined `teams.map(…)` inside the `Promise.all` argument — a temporal-dead-
242  // zone `ReferenceError` that threw on EVERY `effectiveLevel` call; fixed
243  // 2026-09-28, the two queries are semantically identical.)
244  const teams = await prisma.teamMember.findMany({ where: { userId }, select: { teamId: true } });
245  const grants = await prisma.permission.findMany({
246    where: {
247      workspaceId,
248      OR: [
249        { granteeType: "user", granteeId: userId },
250        { granteeType: "team", granteeId: { in: teams.map((t) => t.teamId) } }
251      ]
252    }
253  });
254 
255  let best: { specificity: number; level: Level } | undefined;
256  for (const grant of grants) {
257    const specificity = RESOURCE_SPECIFICITY[grant.resourceType];
258    if (specificity === undefined) continue;
259    if (!appliesToResource(grant, workspaceId, resource)) continue;
260    if (!best || specificity > best.specificity || (specificity === best.specificity && LEVEL_ORDER[grant.level] > LEVEL_ORDER[best.level])) {
261      best = { specificity, level: grant.level };
262    }
263  }
264 
265  // TASK-0104 §2/§Security — explicit NONE deny (a hard stop).
266  //
267  // A grant at level "NONE" is NOT "no grant" here: when ANY resource named
268  // in the requested scope (most specific first: file → record → page →
269  // database → teamspace) carries an explicit NONE grant for this user, the
270  // effective level is a hard NONE. It overrides the role baseline, broader
271  // inheritance, and even a HIGHER grant on the same resource — an explicit
272  // deny can never be bypassed by role (AGENTS.md §27, spec §Security "Explicit
273  // deny (NONE) is a hard stop"). `grants` is already filtered by the query to
274  // grants that apply to this user (user=userId or team∈teams), so a match on
275  // resourceType+resourceId+level is sufficient.
276  //
277  // Walking the whole named chain (not just the top resource) is what makes a
278  // NONE on the containing PAGE deny its files: a file inherits the page's
279  // access, so an explicit page deny is a cap the file cannot escape. A NONE
280  // grant on a resource NOT named in the scope (a different file, a different
281  // page) never fires — it is not part of this read's inheritance chain.
282  //
283  // NOTE: `maxLevel(level, "NONE")` in the loop above is a no-op, so without
284  // this branch an explicit NONE would be silently ignored (the pre-TASK-0104
285  // behavior) — the deny is what gives NONE its teeth. No NONE grant rows
286  // existed in production before TASK-0104 (share levels are VIEW/COMMENT/
287  // EDIT), so this is a pure capability addition, not a behavior break.
288  for (const named of namedResources(resource)) {
289    if (
290      grants.some(
291        (g) => g.resourceType === named.resourceType && g.resourceId === named.resourceId && g.level === "NONE"
292      )
293    ) {
294      return "NONE";
295    }
296  }
297 
298  if (best) level = maxLevel(level, best.level);
299  return level;
300}
301 
302/**
303 * The resources named in a `ResourceScope`, ordered most → least specific by
304 * `RESOURCE_SPECIFICITY` (file > record > page > database > teamspace). Empty
305 * when the scope names nothing. Used for the explicit-NONE deny walk.
306 */
307function namedResources(resource: ResourceScope | undefined): { resourceType: string; resourceId: string }[] {
308  if (!resource) return [];
309  const named: { resourceType: string; resourceId: string }[] = [];
310  if (resource.fileId) named.push({ resourceType: "file", resourceId: resource.fileId });
311  if (resource.recordId) named.push({ resourceType: "record", resourceId: resource.recordId });
312  if (resource.pageId) named.push({ resourceType: "page", resourceId: resource.pageId });
313  if (resource.databaseId) named.push({ resourceType: "database", resourceId: resource.databaseId });
314  if (resource.teamId) named.push({ resourceType: "teamspace", resourceId: resource.teamId });
315  return named;
316}
317 
318function appliesToResource(
319  grant: Pick<PermissionRow, "resourceType" | "resourceId">,
320  workspaceId: string,
321  resource: ResourceScope | undefined
322): boolean {
323  switch (grant.resourceType) {
324    case "workspace":
325      return grant.resourceId === workspaceId;
326    case "teamspace":
327      return resource?.teamId !== undefined && resource.teamId === grant.resourceId;
328    case "page":
329      return resource?.pageId !== undefined && resource.pageId === grant.resourceId;
330    case "database":
331      return resource?.databaseId !== undefined && resource.databaseId === grant.resourceId;
332    case "record":
333      return resource?.recordId !== undefined && resource.recordId === grant.resourceId;
334    case "file":
335      return resource?.fileId !== undefined && resource.fileId === grant.resourceId;
336    default:
337      return false;
338  }
339}
340 
341/**
342 * The actor of the in-flight request (undefined = no HTTP context: workers,
343 * tests calling services directly — the legacy path, unchanged).
344 */
345function currentActor() {
346  return ActorContext.get();
347}
348 
349/**
350 * API-key branch of {@link assertCan} (TASK-0127). Runs BEFORE the
351 * membership lookup so a key in workspace A can never inherit its creator's
352 * membership in workspace B. Returns the level the operation resolves to
353 * (EDIT for WRITE/ADMIN keys, VIEW for READ keys — the levels services may
354 * subsequently grant); throws 403 on a scope mismatch.
355 */
356function assertCanForApiKey(auth: {
357  workspaceId?: string;
358  scopes?: string[];
359  apiKeyId?: string;
360  userId?: string;
361}, workspaceId: string, need: Level): Level {
362  if (auth.workspaceId !== workspaceId) {
363    // The key is bound to its own workspace (docs §7); a cross-workspace
364    // call is a FORBIDDEN — never a 200 on someone else's tenant, and
365    // never a membership probe of the key creator.
366    throw new ApiError("FORBIDDEN", 403, "API key is bound to a different workspace.", [
367      { reason: "workspace_mismatch" }
368    ]);
369  }
370  const cap = apiKeyScopeCap(auth.scopes ?? []);
371  if (LEVEL_ORDER[cap] < LEVEL_ORDER[need]) {
372    throw new ApiError(
373      "FORBIDDEN",
374      403,
375      `API key scope does not cover ${need} access.`,
376      [{ reason: "api_key_scope_write" }]
377    );
378  }
379  // The level the key "has" for this workspace — the scope cap itself.
380  // Services that branch on the returned level (e.g. admin-view flags) see
381  // the key's real capability, not an inflated one.
382  return cap;
383}
384 
385/**
386 * The effective permission level for the ACTUAL actor (API key → its scope
387 * cap in its own workspace, never the creator's grants; user → the normal
388 * {@link effectiveLevel}). For the DIRECT `effectiveLevel` call sites that
389 * compare against a level threshold themselves (comment resolve/reopen,
390 * file purge, AI context assembly) instead of going through {@link assertCan}.
391 */
392export async function actorLevel(prisma: AuthorizePrisma, input: EffectiveLevelInput): Promise<Level> {
393  const actor = currentActor();
394  if (actor?.kind === "api") {
395    if (actor.workspaceId !== input.workspaceId) return "NONE";
396    const scopes = actor.scopes ?? [];
397    if (scopes.includes("ADMIN")) return "FULL_ACCESS";
398    if (scopes.includes("WRITE")) return "EDIT";
399    return "VIEW";
400  }
401  // TASK-0129: OAuth token → its SCOPE CAP (never the user's membership).
402  // The cap is already workspace-agnostic (VIEW/EDIT), so the membership
403  // gate lives in the membership lookups, not here.
404  if (actor?.kind === "user" && actor.oauthScopes) {
405    return oauthScopeCap(actor.oauthScopes);
406  }
407  return effectiveLevel(prisma, input);
408}
409 
410/** True when the in-flight actor is an ADMIN-scoped API key of `workspaceId`. */
411export function actorIsAdminKey(workspaceId: string): boolean {
412  const actor = currentActor();
413  return actor?.kind === "api" && actor.workspaceId === workspaceId && (actor.scopes ?? []).includes("ADMIN");
414}
415 
416/**
417 * Assert the caller has at least `need` on the resource.
418 * Throws `ApiError(FORBIDDEN, 403)` with `details: [{reason: "requires_…" }]`.
419 *
420 * TASK-0127: when the in-flight actor is an API key, the decision is the
421 * key's SCOPE (and its workspace binding), not the membership of the user
422 * the caller passed as `userId` — see {@link assertCanForApiKey}.
423 */
424export async function assertCan(
425  prisma: AuthorizePrisma,
426  input: EffectiveLevelInput,
427  need: Level
428): Promise<Level> {
429  const actor = currentActor();
430  if (actor?.kind === "api") {
431    return assertCanForApiKey(actor, input.workspaceId, need);
432  }
433  // TASK-0129: an OAuth token (kind "user" + oauthScopes) is gated by its
434  // SCOPE CAP in the X-Factory-Workspace workspace, never by the user's
435  // membership — see {@link assertCanForOAuth}.
436  if (actor?.kind === "user" && actor.oauthScopes) {
437    return assertCanForOAuth(prisma, actor, input.workspaceId, need, input.resource);
438  }
439  const have = await effectiveLevel(prisma, input);
440  if (LEVEL_ORDER[have] < LEVEL_ORDER[need]) {
441    throw new ApiError("FORBIDDEN", 403, `Requires ${need} access (you have ${have}).`, [
442      { reason: `requires_${need}`, have }
443    ]);
444  }
445  return have;
446}
447 
448/**
449 * Whether the in-flight actor is an API key bound to `workspaceId` (the key
450 * is a member-equivalent of its OWN workspace; cross-workspace → false).
451 * Used by the DIRECT membership lookups that bypass {@link assertCan}
452 * (services that 404 non-members instead of 403) so an API key never
453 * probes its creator's membership (TASK-0127, docs §7).
454 */
455export function actorIsWorkspaceKey(actor: { kind?: string; workspaceId?: string } | undefined, workspaceId: string): boolean {
456  return actor?.kind === "api" && actor.workspaceId === workspaceId;
457}
458 
459/**
460 * The permission level an API key exercises for `need` in `workspaceId` —
461 * the same scope rules as {@link assertCanForApiKey} but WITHOUT throwing
462 * (for the membership-shape lookups: the result is used as the caller's
463 * "role level", not as a grant). READ → VIEW, WRITE/ADMIN → EDIT, ADMIN →
464 * FULL_ACCESS (the max the key may pass); cross-workspace → NONE.
465 */
466export function apiKeyLevelFor(
467  actor: { kind?: string; workspaceId?: string; scopes?: string[] } | undefined,
468  workspaceId: string,
469  need: Level
470): Level {
471  if (actor?.kind !== "api" || actor.workspaceId !== workspaceId) return "NONE";
472  const scopes = actor.scopes ?? [];
473  let cap: Level = "VIEW";
474  if (scopes.includes("WRITE") || scopes.includes("ADMIN")) cap = "EDIT";
475  if (scopes.includes("ADMIN")) cap = "FULL_ACCESS";
476  return LEVEL_ORDER[cap] >= LEVEL_ORDER[need] ? need : "NONE";
477}
478 
479/**
480 * Resolve the workspace membership for the ACTUAL actor (user → the user's
481 * membership; API key → a SYNTHETIC membership whose role covers the key's
482 * scope level in `workspaceId`, never the creator's real row). This is the
483 * actor-aware stand-in for a direct `workspaceMember.findUnique` at the
484 * CALLER's-own-membership sites (list-members / usage / sidebar gates);
485 * target-user lookups (is `X` a member?) keep the raw query.
486 */
487export async function actorMembership(
488  prisma: AuthorizePrisma,
489  userId: string,
490  workspaceId: string,
491  need: Level = "VIEW"
492): Promise<{ id: string; role: string } | null> {
493  const actor = currentActor();
494  if (actor?.kind === "api") {
495    if (actor.workspaceId !== workspaceId) return null;
496    const scopes = actor.scopes ?? [];
497    const cap: Level = scopes.includes("ADMIN")
498      ? "FULL_ACCESS"
499      : scopes.includes("WRITE")
500        ? "EDIT"
501        : "VIEW";
502    if (LEVEL_ORDER[cap] < LEVEL_ORDER[need]) return null; // scope too small
503    // Synthesize a role from the key's CAP (its scope, never the creator's
504    // membership row): the key acts as the workspace at that level.
505    const role = cap === "FULL_ACCESS" ? "ADMIN" : cap === "EDIT" ? "MEMBER" : "GUEST";
506    return { id: `apikey-${actor.apiKeyId ?? "unknown"}`, role };
507  }
508  // TASK-0129: an OAuth token acts as its USER's membership (it carries the
509  // user's identity) but at most its SCOPE CAP — a member with a read-only
510  // token still resolves the membership, but `need` above the cap → null.
511  if (actor?.kind === "user" && actor.oauthScopes) {
512    if (!userId) return null;
513    if (LEVEL_ORDER[oauthScopeCap(actor.oauthScopes)] < LEVEL_ORDER[need]) return null; // scope too small
514    const m = await prisma.workspaceMember.findUnique({
515      where: { workspaceId_userId: { workspaceId, userId } },
516      select: { id: true, role: true }
517    });
518    return m;
519  }
520  if (!userId) return null;
521  const m = await prisma.workspaceMember.findUnique({
522    where: { workspaceId_userId: { workspaceId, userId } },
523    select: { id: true, role: true }
524  });
525  return m;
526}
527 
528/**
529 * Assert the caller has one of the workspace roles (owner/admin gating).
530 *
531 * TASK-0127: API keys — the key's ADMIN scope is the role gate (an ADMIN
532 * key acts as the workspace admin); a READ/WRITE key is rejected with the
533 * scope reason (docs §7: "member/permission/api-key management requires
534 * ADMIN"). The key's creator membership is never consulted.
535 */
536export async function assertRole(
537  prisma: AuthorizePrisma,
538  input: { workspaceId: string; userId: string },
539  roles: string[]
540): Promise<string> {
541  const actor = currentActor();
542  if (actor?.kind === "api") {
543    if (actor.workspaceId !== input.workspaceId) {
544      throw new ApiError("FORBIDDEN", 403, "API key is bound to a different workspace.", [
545        { reason: "workspace_mismatch" }
546      ]);
547    }
548    if (!actor.scopes?.includes("ADMIN")) {
549      throw new ApiError("FORBIDDEN", 403, "This operation requires the ADMIN scope.", [
550        { reason: "api_key_scope_write" }
551      ]);
552    }
553    // The ADMIN scope maps to the workspace ADMIN role — NOT the owner.
554    // OWNER-only gates (delete workspace, transfer ownership) stay closed
555    // to every API key: an API key can never own a workspace (docs §7).
556    if (!roles.includes("ADMIN")) {
557      throw new ApiError("FORBIDDEN", 403, `Requires workspace role ${roles.join(" or ")}.`, [
558        { reason: `requires_role_${roles.join("_")}` }
559      ]);
560    }
561    return "ADMIN";
562  }
563  // TASK-0129: an OAuth token carries NO workspace role — its scope cap tops
564  // out at EDIT (there is no FULL_ACCESS scope). Every OWNER/ADMIN role gate
565  // (app registration, member management, …) is therefore closed to it.
566  if (actor?.kind === "user" && actor.oauthScopes) {
567    if (oauthScopeCap(actor.oauthScopes) !== "FULL_ACCESS") {
568      throw new ApiError("FORBIDDEN", 403, `This operation requires workspace role ${roles.join(" or ")}.`, [
569        { reason: "oauth_role_denied" }
570      ]);
571    }
572  }
573  const membership = await prisma.workspaceMember.findUnique({
574    where: { workspaceId_userId: { workspaceId: input.workspaceId, userId: input.userId } }
575  });
576  if (!membership || !roles.includes(membership.role)) {
577    throw new ApiError("FORBIDDEN", 403, `Requires workspace role ${roles.join(" or ")}.`, [
578      { reason: `requires_role_${roles.join("_")}` }
579    ]);
580  }
581  return membership.role;
582}
583