.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
assistant.integration.test.tstests/integration/assistant.integration.test.tsraw← integration23,085 B← Back to the app
1/**
2 * T-172…T-175 (A-010) — AI Knowledge Assistant integration suite.
3 *
4 * Full stack (AppModule + Postgres + Redis) against the deterministic
5 * `MockProvider` (`AI_PROVIDER=mock`; the `mode:"assistant"` branch emits a
6 * deterministic tool call per `action`). All five capabilities are plain-JSON
7 * one-shots, so each test is a simple request → assert round-trip.
8 *
9 * Covers (spec §15 + SECURITY_REVIEW §4.8 — one security negative PER
10 * capability):
11 *   - extract-actions: notes → real tasks via TasksService (as the requester);
12 *     GUEST (no EDIT) → 403; empty notes → 400; hostile mock → 422, no write.
13 *   - generate-faqs: visible pages → FAQ draft page (H2/paragraph per Q/A);
14 *     a page the caller lacks VIEW on is NEVER read (dropped pre-prompt);
15 *     a non-member → 404 no-leak.
16 *   - find-duplicates: candidate pool (most-recent pages, per-page VIEW
17 *     re-check); the NONE-granted page is never in the results; forged ids
18 *     from the model are DROPPED (never fabricated into the answer).
19 *   - find-stale: backdated pool (server updatedAt filter) + per-page VIEW
20 *     re-check; the NONE-granted page is never flagged.
21 *   - suggest-metadata + apply: suggestion → normal page PATCH (EDIT
22 *     re-checked); non-member → 404; apply of a field not in the suggestion
23 *     → 400 (no smuggling); ownership-scoped 404 for a foreign suggestion.
24 *   - hidden per-call conversations (`assistant:*`) never list in the panel.
25 *   - rate limit (shared ai.calls window) → 429; budget exhaustion → 402.
26 */
27// Config must be fixed BEFORE the app boots (loadEnv + the workspace cache).
28process.env.AI_PROVIDER = "mock";
29process.env.SEARCH_VECTOR_DIMENSION = "8";
30 
31import { afterAll, beforeAll, describe, expect, it } from "vitest";
32import { createTestApp, type TestAppHandle } from "./helpers/api";
33import { addMemberViaSeam, authHeaders, createWorkspace, createUser } from "./helpers/seed";
34 
35let app: TestAppHandle;
36const RUN = `ast${Date.now().toString(36)}`;
37 
38type User = Awaited<ReturnType<typeof createUser>>;
39interface Ws {
40  workspaceId: string;
41  owner: User;
42  member: User; // GUEST (VIEW)
43  editor: User; // MEMBER (EDIT) — the faqs write-path negative
44}
45 
46// Main workspace: owner (EDIT) + member (GUEST/VIEW). `privatePage` is the
47// member's explicit-NONE page — the per-capability security negative.
48let ws: Ws;
49let notePageId = ""; // the generate-faqs source page (owner-visible)
50let privatePageId = ""; // NONE-granted to the member (drop target)
51let dupPageIds: string[] = []; // find-duplicates pool
52let stalePageIds: string[] = []; // find-stale pool (backdated)
53 
54beforeAll(async () => {
55  app = await createTestApp();
56 
57  const owner = await createUser(app.request, { name: `Assistant Owner ${RUN}` });
58  const member = await createUser(app.request, { name: `Assistant Member ${RUN}` });
59  const editor = await createUser(app.request, { name: `Assistant Editor ${RUN}` });
60  const { workspaceId } = await createWorkspace(app.request, authHeaders(owner.accessToken!), `Assistant WS ${RUN}`);
61  await addMemberViaSeam(app.request, app.internalServiceToken, workspaceId, member.email, "GUEST");
62  await addMemberViaSeam(app.request, app.internalServiceToken, workspaceId, editor.email, "MEMBER");
63  ws = { workspaceId, owner, member, editor };
64 
65  // --- generate-faqs source page (owner) with a numbered-source body ---
66  const pageRes = await app.request("POST", `/api/v1/workspaces/${workspaceId}/pages`, {
67    headers: authHeaders(owner.accessToken!),
68    body: { title: "Onboarding Guide" },
69  });
70  expect(pageRes.status).toBe(201);
71  notePageId = ((await pageRes.json()) as { id: string }).id;
72  const blockRes = await app.request("POST", `/api/v1/pages/${notePageId}/blocks`, {
73    headers: authHeaders(owner.accessToken!),
74    body: { type: "PARAGRAPH", content: { text: "Set up your account, invite the team, and configure the workspace settings." } },
75  });
76  expect(blockRes.status).toBe(201);
77 
78  // --- the member's explicit-NONE page (drop target for every retrieval) ---
79  const privRes = await app.request("POST", `/api/v1/workspaces/${workspaceId}/pages`, {
80    headers: authHeaders(owner.accessToken!),
81    body: { title: `Classified ${RUN}` },
82  });
83  privatePageId = ((await privRes.json()) as { id: string }).id;
84  await app.request("POST", `/api/v1/pages/${privatePageId}/blocks`, {
85    headers: authHeaders(owner.accessToken!),
86    body: { type: "PARAGRAPH", content: { text: `Secret fact ${RUN} that must never leak.` } },
87  });
88  await app.prisma.permission.create({
89    data: {
90      workspaceId,
91      granteeType: "user",
92      granteeId: member.userId,
93      resourceType: "page",
94      resourceId: privatePageId,
95      level: "NONE",
96    },
97  });
98  // The EDITOR (MEMBER) is also explicitly denied the private page — the
99  // generate-faqs write-path negative (a caller who CAN write but must not
100  // read this page).
101  await app.prisma.permission.create({
102    data: {
103      workspaceId,
104      granteeType: "user",
105      granteeId: editor.userId,
106      resourceType: "page",
107      resourceId: privatePageId,
108      level: "NONE",
109    },
110  });
111 
112  // --- find-duplicates pool: 4 owner pages (3 visible to the member) ---
113  for (const i of [1, 2, 3, 4]) {
114    const r = await app.request("POST", `/api/v1/workspaces/${workspaceId}/pages`, {
115      headers: authHeaders(owner.accessToken!),
116      body: { title: `Dup Pool ${RUN} p${i}` },
117    });
118    dupPageIds.push(((await r.json()) as { id: string }).id);
119    await app.request("POST", `/api/v1/pages/${dupPageIds[i - 1]}/blocks`, {
120      headers: authHeaders(owner.accessToken!),
121      body: { type: "PARAGRAPH", content: { text: `Dup body ${i} ${RUN}.` } },
122    });
123  }
124  // The 4th pool page is the NONE page for the member (shared drop target).
125  await app.prisma.permission.create({
126    data: {
127      workspaceId,
128      granteeType: "user",
129      granteeId: member.userId,
130      resourceType: "page",
131      resourceId: dupPageIds[3]!,
132      level: "NONE",
133    },
134  });
135 
136  // --- find-stale pool: 3 pages backdated > 90 days (visible to the member) ---
137  for (const i of [1, 2, 3]) {
138    const r = await app.request("POST", `/api/v1/workspaces/${workspaceId}/pages`, {
139      headers: authHeaders(owner.accessToken!),
140      body: { title: `Stale Pool ${RUN} s${i}` },
141    });
142    stalePageIds.push(((await r.json()) as { id: string }).id);
143    await app.request("POST", `/api/v1/pages/${stalePageIds[i - 1]}/blocks`, {
144      headers: authHeaders(owner.accessToken!),
145      body: { type: "PARAGRAPH", content: { text: `Stale body ${i} ${RUN}.` } },
146    });
147  }
148  await app.prisma.page.updateMany({
149    where: { id: { in: stalePageIds } },
150    data: { updatedAt: new Date(Date.now() - 200 * 86_400_000) },
151  });
152  // The private page is the OLDEST in the pool (stable order: the mock flags
153  // the FIRST visible candidates → it is only ever flagged for the owner, who
154  // can see it; for the member/editor the per-page VIEW re-check drops it).
155  await app.prisma.page.update({
156    where: { id: privatePageId },
157    data: { updatedAt: new Date(Date.now() - 250 * 86_400_000) },
158  });
159}, 180_000);
160 
161afterAll(async () => {
162  await app?.close();
163});
164 
165// ---------------------------------------------------------------------------
166// helpers
167// ---------------------------------------------------------------------------
168 
169async function call(
170  token: string,
171  path: string,
172  body: Record<string, unknown>,
173  workspaceId?: string,
174): Promise<{ status: number; json: Record<string, any> }> {
175  const res = await app.request("POST", `/api/v1/${path.replace(/^workspaces/, "workspaces")}`, {
176    headers: authHeaders(token),
177    body,
178  });
179  const text = await res.text();
180  let json: Record<string, any> = {};
181  try {
182    json = JSON.parse(text);
183  } catch {
184    json = { raw: text };
185  }
186  return { status: res.status, json };
187}
188 
189async function auditCount(action: string, workspaceId: string): Promise<number> {
190  return app.prisma.auditLog.count({ where: { workspaceId, action } });
191}
192 
193// ---------------------------------------------------------------------------
194// 1. extract-actions
195// ---------------------------------------------------------------------------
196 
197describe("assistant extract-actions (T-172)", () => {
198  it("creates real tasks from the notes' bullet lines (as the requester)", async () => {
199    const before = await auditCount("ai.assistant_extract_actions", ws.workspaceId);
200    const out = await call(ws.owner.accessToken!, `workspaces/${ws.workspaceId}/ai/assistant/extract-actions`, {
201      text: "Team sync:\n- Ship the whiteboard export\n- Review the Q3 budget\n- Update the onboarding doc\n\nNo further items.",
202    });
203    expect(out.status).toBe(200);
204    expect(out.json.tasks).toHaveLength(3);
205    expect(out.json.tasks[0].title).toBe("Ship the whiteboard export");
206    expect(out.json.tasks[1].title).toBe("Review the Q3 budget");
207    expect(out.json.tasks[2].title).toBe("Update the onboarding doc");
208 
209    // Real tasks exist (TasksService sidecar + task PAGE), status defaults to todo.
210    const rows = await app.prisma.task.findMany({
211      where: { workspaceId: ws.workspaceId, title: { in: out.json.tasks.map((t: any) => t.title) } },
212    });
213    expect(rows).toHaveLength(3);
214    for (const row of rows) {
215      expect(row.status).toBe("todo");
216      const page = await app.prisma.page.findUnique({ where: { id: row.pageId }, select: { kind: true } });
217      expect(page?.kind).toBe("task");
218    }
219 
220    // Listed in the requester's task inbox.
221    const list = await app.request("GET", `/api/v1/workspaces/${ws.workspaceId}/tasks?scope=all`, {
222      headers: authHeaders(ws.owner.accessToken!),
223    });
224    expect(list.status).toBe(200);
225    const titles = ((await list.json()) as { data: Array<{ title: string }> }).data.map((t) => t.title);
226    expect(titles).toContain("Ship the whiteboard export");
227 
228    // Audited.
229    expect(await auditCount("ai.assistant_extract_actions", ws.workspaceId)).toBe(before + 1);
230  });
231 
232  it("GUEST (no EDIT) → 403 (the capability is EDIT-gated)", async () => {
233    const out = await call(ws.member.accessToken!, `workspaces/${ws.workspaceId}/ai/assistant/extract-actions`, {
234      text: "- Do something",
235    });
236    expect(out.status).toBe(403);
237  });
238 
239  it("empty/missing notes → 400 VALIDATION_ERROR", async () => {
240    const out = await call(ws.owner.accessToken!, `workspaces/${ws.workspaceId}/ai/assistant/extract-actions`, { text: "   " });
241    expect(out.status).toBe(400);
242  });
243});
244 
245// ---------------------------------------------------------------------------
246// 2. generate-faqs
247// ---------------------------------------------------------------------------
248 
249describe("assistant generate-faqs (T-173)", () => {
250  it("builds an FAQ draft page (H2 question + paragraph answer per FAQ)", async () => {
251    const out = await call(ws.owner.accessToken!, `workspaces/${ws.workspaceId}/ai/assistant/generate-faqs`, {
252      pageIds: [notePageId],
253    });
254    expect(out.status).toBe(200);
255    expect(out.json.faqCount).toBe(1);
256    const pageId = out.json.page.id;
257 
258    const page = await app.prisma.page.findUnique({ where: { id: pageId } });
259    expect(page?.workspaceId).toBe(ws.workspaceId);
260    // Title block + 1 heading + 1 paragraph = 3 blocks.
261    const blocks = await app.prisma.block.findMany({ where: { pageId, deletedAt: null }, orderBy: { position: "asc" } });
262    expect(blocks.map((b) => b.type)).toEqual(["PARAGRAPH", "HEADING_2", "PARAGRAPH"]);
263    expect(JSON.stringify(blocks[2]!.content)).toMatch(/per \[1\]/);
264  });
265 
266  it("never reads a page the caller lacks VIEW on (the NONE page is dropped pre-prompt)", async () => {
267    // The editor (EDIT) sees notePageId but NOT privatePageId (explicit
268    // NONE) — so the write path runs, proving the drop happened at
269    // RETRIEVAL (the prompt never contained the secret).
270    const out = await call(ws.editor.accessToken!, `workspaces/${ws.workspaceId}/ai/assistant/generate-faqs`, {
271      pageIds: [notePageId, privatePageId],
272    });
273    expect(out.status).toBe(200);
274    const pageId = out.json.page.id;
275    const blocks = await app.prisma.block.findMany({ where: { pageId, deletedAt: null } });
276    const text = JSON.stringify(blocks.map((b) => b.content));
277    expect(text).not.toContain(`Secret fact ${RUN}`);
278  });
279 
280  it("non-member → 403 (the AI surface asserts the workspace first, like ai-writing)", async () => {
281    const outsider = await createUser(app.request, { name: `Assistant Outsider ${RUN}` });
282    const out = await call(outsider.accessToken!, `workspaces/${ws.workspaceId}/ai/assistant/generate-faqs`, {
283      pageIds: [notePageId],
284    });
285    expect(out.status).toBe(403);
286  });
287});
288 
289// ---------------------------------------------------------------------------
290// 3. find-duplicates
291// ---------------------------------------------------------------------------
292 
293describe("assistant find-duplicates (T-174)", () => {
294  it("groups the most-recent pages (candidate pool, permission-filtered)", async () => {
295    const out = await call(ws.owner.accessToken!, `workspaces/${ws.workspaceId}/ai/assistant/find-duplicates`, {});
296    expect(out.status).toBe(200);
297    expect(out.json.considered).toBeGreaterThanOrEqual(4);
298    // The mock groups visible candidates pairwise → at least one group.
299    expect(out.json.groups.length).toBeGreaterThanOrEqual(1);
300    const idsInGroups = out.json.groups.flatMap((g: any) => g.pages.map((p: any) => p.pageId));
301    expect(idsInGroups).toContain(dupPageIds[0]);
302  });
303 
304  it("never returns the NONE-granted page for the member (security negative)", async () => {
305    const out = await call(ws.member.accessToken!, `workspaces/${ws.workspaceId}/ai/assistant/find-duplicates`, {});
306    expect(out.status).toBe(200);
307    const idsInGroups = out.json.groups.flatMap((g: any) => g.pages.map((p: any) => p.pageId));
308    expect(idsInGroups).not.toContain(dupPageIds[3]);
309    expect(idsInGroups).not.toContain(privatePageId);
310  });
311 
312  it("drops model-emitted ids that are not in the retrieved set (no fabricated refs)", async () => {
313    const arm = await app.request("POST", `/internal/workspaces/${ws.workspaceId}/ai/mock-assistant`, {
314      headers: { Authorization: `Bearer ${app.internalServiceToken}` },
315      body: { forgeId: true },
316    });
317    expect(arm.status).toBe(200);
318    try {
319      const out = await call(ws.owner.accessToken!, `workspaces/${ws.workspaceId}/ai/assistant/find-duplicates`, {});
320      expect(out.status).toBe(200);
321      const idsInGroups = out.json.groups.flatMap((g: any) => g.pages.map((p: any) => p.pageId));
322      expect(idsInGroups).not.toContain("forged-id");
323      // The audited row records the drop.
324      const audit = await app.prisma.auditLog.findFirst({
325        where: { workspaceId: ws.workspaceId, action: "ai.assistant_duplicates_found" },
326        orderBy: { createdAt: "desc" },
327      });
328      expect(audit).toBeTruthy();
329    } finally {
330      await import("@factory/api/src/modules/ai/gateway-provider").then((m) => m.resetWorkspaceCache());
331    }
332  });
333});
334 
335// ---------------------------------------------------------------------------
336// 4. find-stale
337// ---------------------------------------------------------------------------
338 
339describe("assistant find-stale (T-174)", () => {
340  it("flags stale pages from the backdated pool (server updatedAt filter)", async () => {
341    const out = await call(ws.owner.accessToken!, `workspaces/${ws.workspaceId}/ai/assistant/find-stale`, { days: 90 });
342    expect(out.status).toBe(200);
343    // The mock flags the first two visible candidates; all 3 backdated pages
344    // are in the pool → 2 flagged, all with titles from the pool.
345    expect(out.json.considered).toBeGreaterThanOrEqual(2);
346    expect(out.json.pages.length).toBeGreaterThanOrEqual(1);
347    const flagged = new Set(out.json.pages.map((p: any) => p.pageId));
348    for (const p of out.json.pages) {
349      expect(stalePageIds).toContain(p.pageId);
350      expect(p.title.length).toBeGreaterThan(0);
351      expect(p.reason.length).toBeGreaterThan(0);
352    }
353    expect(flagged.size).toBe(out.json.pages.length);
354  });
355 
356  it("never flags the NONE-granted page for the member (security negative)", async () => {
357    // The private page is NOT backdated — but even if it were, the per-page
358    // VIEW re-check drops it before the model sees it. Assert absence.
359    const out = await call(ws.member.accessToken!, `workspaces/${ws.workspaceId}/ai/assistant/find-stale`, { days: 365 });
360    expect(out.status).toBe(200);
361    const flagged = out.json.pages.map((p: any) => p.pageId);
362    expect(flagged).not.toContain(privatePageId);
363    expect(flagged).not.toContain(dupPageIds[3]);
364  });
365});
366 
367// ---------------------------------------------------------------------------
368// 5. suggest-metadata + apply
369// ---------------------------------------------------------------------------
370 
371describe("assistant suggest-metadata + apply (T-175)", () => {
372  let suggestionId = "";
373  let suggestedTitle = "";
374 
375  it("suggests a title/description grounded in the page (suggestion only)", async () => {
376    const out = await call(ws.owner.accessToken!, `workspaces/${ws.workspaceId}/ai/assistant/suggest-metadata`, {
377      pageId: notePageId,
378    });
379    expect(out.status).toBe(200);
380    suggestionId = out.json.suggestionId;
381    suggestedTitle = out.json.suggested.title;
382    expect(suggestedTitle.length).toBeGreaterThan(0);
383    expect(out.json.current.title).toBe("Onboarding Guide");
384    // Nothing is written yet.
385    const page = await app.prisma.page.findUnique({ where: { id: notePageId }, select: { title: true } });
386    expect(page?.title).toBe("Onboarding Guide");
387    expect(await auditCount("ai.assistant_metadata_suggested", ws.workspaceId)).toBeGreaterThanOrEqual(1);
388  });
389 
390  it("applies the suggestion through the normal page PATCH (EDIT re-checked)", async () => {
391    const out = await call(ws.owner.accessToken!, `workspaces/${ws.workspaceId}/ai/assistant/apply-metadata`, {
392      suggestionId,
393      fields: { title: suggestedTitle },
394    });
395    expect(out.status).toBe(200);
396    const page = await app.prisma.page.findUnique({ where: { id: notePageId }, select: { title: true } });
397    expect(page?.title).toBe(suggestedTitle);
398    expect(await auditCount("ai.assistant_metadata_applied", ws.workspaceId)).toBeGreaterThanOrEqual(1);
399  });
400 
401  it("rejects applying a field NOT in the stored suggestion (no smuggling) → 400", async () => {
402    const out = await call(ws.owner.accessToken!, `workspaces/${ws.workspaceId}/ai/assistant/apply-metadata`, {
403      suggestionId,
404      fields: { title: "Totally different title" },
405    });
406    expect(out.status).toBe(400);
407  });
408 
409  it("non-member → 404 (no-leak, both suggest and apply)", async () => {
410    const outsider = await createUser(app.request, { name: `Assistant Outsider2 ${RUN}` });
411    const suggest = await call(outsider.accessToken!, `workspaces/${ws.workspaceId}/ai/assistant/suggest-metadata`, {
412      pageId: notePageId,
413    });
414    expect(suggest.status).toBe(404);
415    const apply = await call(outsider.accessToken!, `workspaces/${ws.workspaceId}/ai/assistant/apply-metadata`, {
416      suggestionId,
417      fields: { title: suggestedTitle },
418    });
419    expect(apply.status).toBe(404);
420  });
421});
422 
423// ---------------------------------------------------------------------------
424// hostile mock → 422, no write (extract-actions)
425// ---------------------------------------------------------------------------
426 
427describe("assistant hostile tool output", () => {
428  it("invalid tool call → retry once → 422, NO task written", async () => {
429    const wsB = await createWorkspace(app.request, authHeaders(ws.owner.accessToken!), `Assistant Hostile ${RUN}`);
430    const arm = await app.request("POST", `/internal/workspaces/${wsB.workspaceId}/ai/mock-assistant`, {
431      headers: { Authorization: `Bearer ${app.internalServiceToken}` },
432      body: { hostile: true },
433    });
434    expect(arm.status).toBe(200);
435    const out = await call(ws.owner.accessToken!, `workspaces/${wsB.workspaceId}/ai/assistant/extract-actions`, {
436      text: "- One item",
437    });
438    expect(out.status).toBe(422);
439    expect(JSON.stringify(out.json)).toMatch(/invalid/i);
440    const tasks = await app.prisma.task.count({ where: { workspaceId: wsB.workspaceId } });
441    expect(tasks).toBe(0);
442  });
443});
444 
445// ---------------------------------------------------------------------------
446// hidden conversations + rate limit + budget
447// ---------------------------------------------------------------------------
448 
449describe("assistant ledger + limits", () => {
450  it("per-call conversations (`assistant:*`) never appear in the panel list", async () => {
451    const out = await app.request("GET", `/api/v1/workspaces/${ws.workspaceId}/ai/conversations`, {
452      headers: authHeaders(ws.owner.accessToken!),
453    });
454    expect(out.status).toBe(200);
455    const { data } = (await out.json()) as { data: Array<{ title: string }> };
456    expect(data.some((c) => c.title.startsWith("assistant:"))).toBe(false);
457    // …but the rows exist (the ledger is durable).
458    const hidden = await app.prisma.aiConversation.count({
459      where: { workspaceId: ws.workspaceId, title: { startsWith: "assistant:" } },
460    });
461    expect(hidden).toBeGreaterThanOrEqual(3);
462  });
463 
464  it("shared per-user rate window → 429 ai_call_rate_limited", async () => {
465    const statuses: number[] = [];
466    let limited: Record<string, any> | null = null;
467    for (let i = 0; i < 32; i++) {
468      const out = await call(ws.owner.accessToken!, `workspaces/${ws.workspaceId}/ai/assistant/extract-actions`, {
469        text: "- rl item",
470      });
471      statuses.push(out.status);
472      if (out.status === 429) limited = out.json;
473    }
474    expect(statuses).toContain(429);
475    expect(JSON.stringify(limited)).toMatch(/ai_call_rate_limited/);
476  });
477 
478  it("budget exhaustion → 402 AI_BUDGET_EXCEEDED (pre-call JSON)", async () => {
479    // A FRESH member (fresh per-user rate window — the shared ai.calls window
480    // is per-user; the budget is per-WORKSPACE).
481    const fresh = await createUser(app.request, { name: `Assistant Budget User ${RUN}` });
482    const wsC = await createWorkspace(app.request, authHeaders(ws.owner.accessToken!), `Assistant Budget ${RUN}`);
483    await addMemberViaSeam(app.request, app.internalServiceToken, wsC.workspaceId, fresh.email, "MEMBER");
484    const set = await app.request("POST", `/internal/workspaces/${wsC.workspaceId}/ai/usage-limits`, {
485      headers: { Authorization: `Bearer ${app.internalServiceToken}` },
486      body: { aiMonthlyTokens: 1 },
487    });
488    expect(set.status).toBe(200);
489    const out = await call(fresh.accessToken!, `workspaces/${wsC.workspaceId}/ai/assistant/extract-actions`, {
490      text: "- budget item",
491    });
492    expect(out.status).toBe(402);
493    expect(JSON.stringify(out.json)).toMatch(/AI_BUDGET_EXCEEDED/);
494    const audit = await app.prisma.auditLog.findFirst({
495      where: { workspaceId: wsC.workspaceId, action: "ai.budget_exceeded" },
496    });
497    expect(audit).toBeTruthy();
498  });
499});
500