From the team behind Gatsby, Mastra is a framework for building AI-powered applications and agents with a modern TypeScript stack.
2266 matches across 14 categories. Click a row to expand file-level details.
| Severity | File | Line | Snippet |
|---|---|---|---|
| LOW | server-adapters/_test-utils/src/test-helpers.ts | 1190 | async function setupWorkflowRegistryMocks(workflows: Record<string, Workflow>, mastra: Mastra) { |
| LOW | server-adapters/_test-utils/src/test-helpers.ts | 1275 | function getRouteSpecificPathDefaults(route: ServerRoute): { |
| LOW | server-adapters/_test-utils/src/test-helpers.ts | 1389 | export function createStreamWithSensitiveData(format: 'v1' | 'v2' = 'v2'): ReadableStream { |
| LOW | …r-adapters/_test-utils/src/route-adapter-test-suite.ts | 27 | export function createRouteAdapterTestSuite(config: AdapterTestSuiteConfig) { |
| LOW | server-adapters/_test-utils/src/route-test-utils.ts | 106 | export function generateValidDataFromSchema(schema: z.ZodTypeAny, fieldName?: string): any { |
| LOW | server-adapters/_test-utils/src/route-test-utils.ts | 359 | export function getDefaultValidPathParams(route: ServerRoute): Record<string, any> { |
| LOW | server-adapters/_test-utils/src/route-test-utils.ts | 443 | export function getDefaultInvalidPathParams(route: ServerRoute): Array<Record<string, any>> { |
| LOW | …r-adapters/_test-utils/src/mcp-transport-test-suite.ts | 64 | export function createMCPTransportTestSuite(config: MCPTransportTestConfig) { |
| LOW | …apters/fastify/src/__tests__/stream-disconnect.test.ts | 61 | async function createRequestWithAbortSignal(requestRaw: MockRawRequest, replyRaw: MockRawReply) { |
| LOW | server-adapters/koa/src/index.ts | 865 | this.app.use(async function mastraCustomRouteDispatcher(ctx: Context, next: Next) { |
| LOW | …udflare/src/plugins/postgres-store-instance-checker.ts | 5 | export function postgresStoreInstanceChecker(): Plugin { |
| LOW | …loudflare/src/babel/postgres-store-instance-checker.ts | 23 | export function postgresStoreInstanceChecker(): PluginObj { |
| LOW | deployers/netlify/src/index.ts | 37 | function stubEdgeIncompatibleModules() { |
| LOW | auth/better-auth/src/index.ts | 21 | function mapBetterAuthUserToEEUser(user: User): EEUser { |
| LOW | auth/workos/src/fga-provider.ts | 30 | function isWorkOSResourceNotFoundError(error: any): boolean { |
| LOW | client-sdks/client-js/src/resources/agent.ts | 123 | function getClientToolObservabilityContext(toolCall: unknown): ClientToolObservabilityContext | undefined { |
| LOW | client-sdks/client-js/src/resources/agent.ts | 133 | async function executeClientToolWithObservability({ |
| LOW | …ient-sdks/client-js/src/utils/process-mastra-stream.ts | 3 | async function sharedProcessMastraStream({ |
| LOW | …ient-sdks/client-js/src/utils/process-mastra-stream.ts | 58 | export async function processMastraNetworkStream({ |
| LOW | …dks/client-js/src/utils/verify-agent-card-signature.ts | 91 | export async function verifyAgentCardSignatureIfPresent( |
| LOW | client-sdks/client-js/src/utils/index.ts | 131 | export function parseClientRequestContext(requestContext?: RequestContext | Record<string, any>) { |
| LOW | client-sdks/client-js/src/utils/index.ts | 158 | export function requestContextQueryString( |
| LOW | client-sdks/client-js/src/observability/collector.ts | 324 | export function getCurrentObservabilityCollector(): ObservabilityCollector | undefined { |
| LOW | client-sdks/ai-sdk/src/middleware.ts | 457 | export function createProcessorMiddleware(options: ProcessorMiddlewareOptions): LanguageModelV2Middleware { |
| LOW | client-sdks/ai-sdk/src/middleware.ts | 858 | function extractTextFromMastraMessage(msg: MastraDBMessage): string { |
| LOW | client-sdks/ai-sdk/src/middleware.ts | 878 | function convertMastraChunkToAISDKStreamPart(chunk: ChunkType): LanguageModelV2StreamPart | null { |
| LOW | client-sdks/ai-sdk/src/helpers.ts | 77 | function normalizeToolPayloadState(state: unknown): TransformedToolPayloadState | undefined { |
| LOW | client-sdks/ai-sdk/src/helpers.ts | 94 | function getTransformedToolPayload( |
| LOW | client-sdks/ai-sdk/src/helpers.ts | 107 | function hasTransformedToolPayload( |
| LOW | client-sdks/ai-sdk/src/transformers.ts | 161 | function createWorkflowStepDataPart(args: { |
| LOW | client-sdks/ai-sdk/src/transformers.ts | 246 | export function WorkflowStreamToAISDKTransformer({ |
| LOW | client-sdks/ai-sdk/src/transformers.ts | 323 | export function AgentNetworkToAISDKTransformer() { |
| LOW | client-sdks/ai-sdk/src/transformers.ts | 582 | function appendPendingToolCallArgs( |
| LOW | client-sdks/ai-sdk/src/convert-messages.ts | 5 | function isSystemReminderUIMessage(message: { |
| LOW | …rc/__tests__/transform-agent-cumulative-growth.test.ts | 25 | function simulateMultiStepAgentRun(numSteps: number) { |
| LOW | client-sdks/react/src/lib/ai-sdk/utils/toUIMessage.ts | 164 | function signalContentsToUserMessages(contents: unknown, metadata: MastraUIMessageMetadata): MastraUIMessage[] { |
| LOW | explorations/ralph-wiggum-loop-prototype.ts | 198 | export function createAutonomousLoopWorkflow(agent: Agent, mastra?: Mastra) { |
| LOW | explorations/longmemeval/src/cli.ts | 212 | async function loadPreparationTokenUsage( |
| LOW | …gmemeval/src/processors/observation-semantic-filter.ts | 350 | export function rebuildObservationsWithStructure( |
| LOW | …gmemeval/src/processors/observation-semantic-filter.ts | 419 | export function extractSuggestedResponseBlock(formattedContext: string): string | null { |
| LOW | …gmemeval/src/processors/observation-semantic-filter.ts | 1140 | export function createObservationSemanticFilter(config: ObservationSemanticFilterConfig): ObservationSemanticFilter { |
| LOW | explorations/longmemeval/src/commands/prepare.ts | 63 | function containsProhibitedContent(content: string): boolean { |
| LOW | explorations/longmemeval/src/commands/prepare.ts | 91 | function sanitizeProhibitedContent(content: string): string { |
| LOW | explorations/longmemeval/src/commands/reconcile.ts | 96 | function buildPatternExtractionPrompt(existingObservations: string): string { |
| LOW | explorations/longmemeval/src/commands/reconcile.ts | 167 | async function extractPatternsForQuestion( |
| LOW | explorations/longmemeval/src/commands/run.ts | 73 | function updateRateLimiterFromResponse(response: any): void { |
| LOW | explorations/longmemeval/src/commands/run.ts | 110 | async function checkRateLimitBeforeRequest(): Promise<void> { |
| LOW | workflows/temporal/src/plugin.ts | 15 | function getGeneratedWorkflowModulePath(outputDir: string): string { |
| LOW | workflows/temporal/src/plugin.ts | 19 | function getGeneratedActivitiesModulePath(outputDir: string): string { |
| LOW | workflows/temporal/src/transforms/workflows.ts | 66 | function createTemporalWorkflowHelperStatements(): t.Statement[] { |
| LOW | workflows/temporal/src/transforms/workflows.ts | 353 | function createTemporalWorkflowStatements( |
| LOW | workflows/temporal/src/transforms/workflows.ts | 405 | function getTemporalWorkflowExportFromDeclaration( |
| LOW | workflows/temporal/src/transforms/workflows.ts | 430 | function getVariableDeclarationFromStatement(statement: t.Statement): t.VariableDeclaration | null { |
| LOW | workflows/temporal/src/transforms/workflows.ts | 472 | function createWorkflowTransformState(program: t.Program, filePath: string): WorkflowTransformState { |
| LOW | workflows/temporal/src/transforms/workflows.ts | 485 | function collectWorkflowDeclarationMetadata(statement: t.Statement, state: WorkflowTransformState): void { |
| LOW | workflows/temporal/src/transforms/workflows.ts | 507 | function collectWorkflowExportMetadata(statement: t.Statement, state: WorkflowTransformState): void { |
| LOW | workflows/temporal/src/transforms/workflows.ts | 525 | function collectWorkflowTransformMetadata(program: t.Program, state: WorkflowTransformState): void { |
| LOW | workflows/temporal/src/transforms/workflows.ts | 538 | function rewriteWorkflowImportDeclaration(statement: t.ImportDeclaration, state: WorkflowTransformState): void { |
| LOW | workflows/temporal/src/transforms/workflows.ts | 565 | function getNormalizedWorkflowBindingName(name: string, state: WorkflowTransformState): string | null { |
| LOW | workflows/temporal/src/transforms/workflows.ts | 573 | function rewriteWorkflowNamedExport(statement: t.ExportNamedDeclaration, state: WorkflowTransformState): void { |
| 970 more matches not shown… | |||
| Severity | File | Line | Snippet |
|---|---|---|---|
| MEDIUM | auth/workos/src/fga-provider.ts | 136 | // ────────────────────────────────────────────────────────────── |
| MEDIUM | auth/workos/src/fga-provider.ts | 138 | // ────────────────────────────────────────────────────────────── |
| MEDIUM | auth/workos/src/fga-provider.ts | 268 | // ────────────────────────────────────────────────────────────── |
| MEDIUM | auth/workos/src/fga-provider.ts | 270 | // ────────────────────────────────────────────────────────────── |
| MEDIUM | auth/workos/src/fga-provider.ts | 408 | // ────────────────────────────────────────────────────────────── |
| MEDIUM | auth/workos/src/fga-provider.ts | 410 | // ────────────────────────────────────────────────────────────── |
| MEDIUM | docs/tests/navigation.spec.ts | 130 | // ─── Sidebar navigation tests ────────────────────────────────────────── |
| MEDIUM | docs/tests/navigation.spec.ts | 198 | // ─── Admonitions and tabs on /guides/build-your-ui/ai-sdk-ui ────────── |
| MEDIUM | docs/src/plugins/remark-model-tokens/models.ts | 13 | // ── OpenAI ──────────────────────────────────────────────── |
| MEDIUM | docs/src/plugins/remark-model-tokens/models.ts | 20 | // ── Anthropic ───────────────────────────────────────────── |
| MEDIUM | …paces/agentfs/src/filesystem/index.integration.test.ts | 40 | // ─── Basic Integration Tests ───────────────────────────────────────────────── |
| MEDIUM | …paces/agentfs/src/filesystem/index.integration.test.ts | 170 | // ─── Agent Isolation Tests ─────────────────────────────────────────────────── |
| MEDIUM | …paces/agentfs/src/filesystem/index.integration.test.ts | 240 | // ─── CompositeFilesystem Integration Tests ─────────────────────────────────── |
| MEDIUM | …paces/agentfs/src/filesystem/index.integration.test.ts | 273 | // ─── Shared Conformance Test Suite ─────────────────────────────────────────── |
| MEDIUM | mastracode/src/evals/scorers/outcome.ts | 32 | // ━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━ |
| MEDIUM | mastracode/src/evals/scorers/outcome.ts | 34 | // ━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━ |
| MEDIUM | mastracode/src/evals/scorers/outcome.ts | 75 | // ━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━ |
| MEDIUM | mastracode/src/evals/scorers/efficiency.ts | 21 | // ━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━ |
| MEDIUM | mastracode/src/evals/scorers/efficiency.ts | 23 | // ━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━ |
| MEDIUM | mastracode/src/tui/state.ts | 93 | // ── Core dependencies (set once) ────────────────────────────────────── |
| MEDIUM | mastracode/src/tui/state.ts | 102 | // ── TUI framework (set once) ────────────────────────────────────────── |
| MEDIUM | mastracode/src/tui/state.ts | 113 | // ── Agent / streaming ───────────────────────────────────────────────── |
| MEDIUM | mastracode/src/tui/state.ts | 148 | // ── Thread / conversation ───────────────────────────────────────────── |
| MEDIUM | mastracode/src/tui/state.ts | 158 | // ── Inline interaction ──────────────────────────────────────────────── |
| MEDIUM | mastracode/src/tui/state.ts | 187 | // ── Status line ─────────────────────────────────────────────────────── |
| MEDIUM | mastracode/src/tui/state.ts | 193 | // ── Observational Memory ────────────────────────────────────────────── |
| MEDIUM | mastracode/src/tui/state.ts | 201 | // ── Tasks ───────────────────────────────────────────────────────────── |
| MEDIUM | mastracode/src/tui/state.ts | 204 | // ── Goal loop ───────────────────────────────────────────────────────── |
| MEDIUM | mastracode/src/tui/state.ts | 209 | // ── Input ───────────────────────────────────────────────────────────── |
| MEDIUM | mastracode/src/tui/state.ts | 217 | // ── Dedup ──────────────────────────────────────────────────────────── |
| MEDIUM | mastracode/src/tui/state.ts | 222 | // ── Abort tracking ──────────────────────────────────────────────────── |
| MEDIUM | mastracode/src/tui/state.ts | 227 | // ── Cleanup ─────────────────────────────────────────────────────────── |
| MEDIUM | mastracode/src/tui/components/subagent-execution.ts | 18 | // ───────────────────────────────────────────────────────────────────────────── |
| MEDIUM | mastracode/src/tui/components/subagent-execution.ts | 20 | // ───────────────────────────────────────────────────────────────────────────── |
| MEDIUM | mastracode/src/tui/components/subagent-execution.ts | 30 | // ───────────────────────────────────────────────────────────────────────────── |
| MEDIUM | mastracode/src/tui/components/subagent-execution.ts | 32 | // ───────────────────────────────────────────────────────────────────────────── |
| MEDIUM | mastracode/src/tui/components/subagent-execution.ts | 77 | // ── Mutation API ────────────────────────────────────────────────────── |
| MEDIUM | mastracode/src/tui/components/subagent-execution.ts | 127 | // ── Rendering ────────────────────────────────────────────────────────── |
| MEDIUM | mastracode/src/tui/components/subagent-execution.ts | 251 | // ───────────────────────────────────────────────────────────────────────────── |
| MEDIUM | mastracode/src/tui/components/subagent-execution.ts | 253 | // ───────────────────────────────────────────────────────────────────────────── |
| MEDIUM | …rc/tui/components/__tests__/subagent-execution.test.ts | 87 | // ─── Default behavior: NO collapse ────────────────────────────────────── |
| MEDIUM | …rc/tui/components/__tests__/subagent-execution.test.ts | 126 | // ─── Opt-in collapse behavior ────────────────────────────────────────── |
| MEDIUM | examples/agent/scripts/seed-fga.ts | 68 | // ────────────────────────────────────────────────────────── |
| MEDIUM | examples/agent/scripts/seed-fga.ts | 70 | // ────────────────────────────────────────────────────────── |
| MEDIUM | examples/agent/scripts/seed-fga.ts | 89 | // ────────────────────────────────────────────────────────── |
| MEDIUM | examples/agent/scripts/seed-fga.ts | 91 | // ────────────────────────────────────────────────────────── |
| MEDIUM | examples/agent/scripts/seed-fga.ts | 123 | // ────────────────────────────────────────────────────────── |
| MEDIUM | examples/agent/scripts/seed-fga.ts | 125 | // ────────────────────────────────────────────────────────── |
| MEDIUM | examples/agent/scripts/seed-fga.ts | 147 | // ────────────────────────────────────────────────────────── |
| MEDIUM | examples/agent/scripts/seed-fga.ts | 149 | // ────────────────────────────────────────────────────────── |
| MEDIUM | examples/agent/scripts/seed-fga.ts | 187 | // ────────────────────────────────────────────────────────── |
| MEDIUM | examples/agent/scripts/seed-fga.ts | 189 | // ────────────────────────────────────────────────────────── |
| MEDIUM | examples/agent/src/mastra/mcp/external-app-server.ts | 18 | // ── ui:// app resource: a color-mixer UI ──────────────────────────────────── |
| MEDIUM | packages/core/src/auth/ee/interfaces/fga.ts | 11 | // ────────────────────────────────────────────────────────────── |
| MEDIUM | packages/core/src/auth/ee/interfaces/fga.ts | 13 | // ────────────────────────────────────────────────────────────── |
| MEDIUM | packages/core/src/auth/ee/interfaces/fga.ts | 231 | // ────────────────────────────────────────────────────────────── |
| MEDIUM | packages/core/src/auth/ee/interfaces/fga.ts | 233 | // ────────────────────────────────────────────────────────────── |
| MEDIUM | packages/core/src/auth/ee/interfaces/fga.ts | 338 | // ────────────────────────────────────────────────────────────── |
| MEDIUM | packages/core/src/auth/ee/interfaces/fga.ts | 340 | // ────────────────────────────────────────────────────────────── |
| MEDIUM | …atasets/experiment/__tests__/scorer-trajectory.test.ts | 21 | // ── Helpers ──────────────────────────────────────────────────────────────── |
| 146 more matches not shown… | |||
| Severity | File | Line | Snippet |
|---|---|---|---|
| CRITICAL | …dynamodb/src/storage/domains/background-tasks/index.ts | 228 | const res = await this.service.entities.background_task.scan.go({ pages: 'all' }); |
| CRITICAL | stores/dynamodb/src/storage/domains/memory/index.ts | 327 | messageIds.map(id => this.service.entities.message.query.primary({ entity: 'message', id }).go()), |
| CRITICAL | stores/dynamodb/src/storage/domains/memory/index.ts | 424 | const query = this.service.entities.message.query.byThread({ entity: 'message', threadId }); |
| CRITICAL | stores/dynamodb/src/storage/domains/memory/index.ts | 675 | : (await this.service.entities.thread.scan.go({ pages: 'all' })).data; |
| CRITICAL | stores/dynamodb/src/storage/domains/memory/index.ts | 788 | const query = this.service.entities.message.query.byThread({ entity: 'message', threadId }); |
| CRITICAL | stores/dynamodb/src/storage/domains/workflows/index.ts | 425 | query = this.service.entities.workflow_snapshot.query.primary({ |
| CRITICAL | stores/dynamodb/src/storage/domains/scores/index.ts | 209 | const query = this.service.entities.score.query.byScorer({ entity: 'score', scorerId }); |
| CRITICAL | stores/dynamodb/src/storage/domains/scores/index.ts | 278 | const query = this.service.entities.score.query.byRun({ entity: 'score', runId }); |
| CRITICAL | stores/dynamodb/src/storage/domains/scores/index.ts | 331 | const query = this.service.entities.score.query.byEntityData({ entity: 'score', entityId }); |
| CRITICAL | stores/dynamodb/src/storage/domains/scores/index.ts | 387 | const query = this.service.entities.score.query.bySpan({ entity: 'score', traceId, spanId }); |
| CRITICAL | stores/vectorize/src/vector/index.ts | 242 | await this.client.vectorize.indexes.metadataIndex.create(indexName, { |
| CRITICAL | stores/vectorize/src/vector/index.ts | 262 | await this.client.vectorize.indexes.metadataIndex.delete(indexName, { |
| CRITICAL | stores/vectorize/src/vector/index.ts | 281 | const res = await this.client.vectorize.indexes.metadataIndex.list(indexName, { |
| CRITICAL | …xamples/otel-bridge/hono-multi/src/integration.test.ts | 109 | return data.data.getTraceByOtelId.spans.edges.map((edge: any) => { |
| CRITICAL | workspaces/blaxel/src/sandbox/index.test.ts | 1135 | const fusermountCalls = mockSandbox.process.exec.mock.calls.filter((c: any[]) => |
| CRITICAL | workspaces/blaxel/src/sandbox/index.test.ts | 1195 | const fusermountCalls = mockSandbox.process.exec.mock.calls.filter((c: any[]) => |
| CRITICAL | workspaces/blaxel/src/sandbox/index.test.ts | 1254 | const fusermountCalls = mockSandbox.process.exec.mock.calls.filter((c: any[]) => |
| CRITICAL | workspaces/blaxel/src/sandbox/index.test.ts | 1330 | const rmCalls = mockSandbox.process.exec.mock.calls.filter( |
| CRITICAL | workspaces/blaxel/src/sandbox/index.test.ts | 1335 | const rmdirCalls = mockSandbox.process.exec.mock.calls.filter( |
| CRITICAL | workspaces/blaxel/src/sandbox/index.test.ts | 1409 | const rmCalls = mockSandbox.process.exec.mock.calls.filter( |
| CRITICAL | workspaces/blaxel/src/sandbox/index.test.ts | 1453 | const procMountsCalls = mockSandbox.process.exec.mock.calls.filter((c: any[]) => |
| CRITICAL | workspaces/blaxel/src/sandbox/index.test.ts | 1458 | const fusermountCalls = mockSandbox.process.exec.mock.calls.filter((c: any[]) => |
| CRITICAL | workspaces/blaxel/src/sandbox/index.test.ts | 1489 | const procMountsCalls = mockSandbox.process.exec.mock.calls.filter((c: any[]) => |
| CRITICAL | workspaces/blaxel/src/sandbox/index.test.ts | 1548 | const fusermountCalls = mockSandbox.process.exec.mock.calls.filter((call: any[]) => |
| CRITICAL | workspaces/daytona/src/sandbox/index.test.ts | 670 | const mountCall = mockSandbox.process.executeCommand.mock.calls.find((call: any[]) => { |
| CRITICAL | workspaces/daytona/src/sandbox/index.test.ts | 700 | mockSandbox.process.executeCommand.mock.calls.find((call: any[]) => { |
| CRITICAL | workspaces/daytona/src/sandbox/index.test.ts | 706 | const upload = mockSandbox.fs.uploadFile.mock.calls.find((call: any[]) => |
| CRITICAL | workspaces/e2b/src/sandbox/index.test.ts | 894 | mockSandbox.commands.run.mock.calls.some( |
| CRITICAL | workspaces/e2b/src/sandbox/index.test.ts | 922 | mockSandbox.commands.run.mock.calls.some( |
| CRITICAL | workspaces/e2b/src/sandbox/index.test.ts | 1072 | return mockSandbox.commands.run.mock.calls.find( |
| CRITICAL | workspaces/e2b/src/sandbox/index.test.ts | 1079 | const writeCall = mockSandbox.files.write.mock.calls.find((call: any[]) => |
| CRITICAL | workspaces/e2b/src/sandbox/index.test.ts | 1455 | const fusermountCalls = mockSandbox.commands.run.mock.calls.filter((c: any[]) => c[0].includes('fusermount')); |
| CRITICAL | workspaces/e2b/src/sandbox/index.test.ts | 1480 | const fusermountCalls = mockSandbox.commands.run.mock.calls.filter((c: any[]) => c[0].includes('fusermount')); |
| CRITICAL | workspaces/e2b/src/sandbox/index.test.ts | 1501 | const fusermountCalls = mockSandbox.commands.run.mock.calls.filter((c: any[]) => c[0].includes('fusermount')); |
| CRITICAL | workspaces/e2b/src/sandbox/index.test.ts | 1528 | const rmCalls = mockSandbox.commands.run.mock.calls.filter( |
| CRITICAL | workspaces/e2b/src/sandbox/index.test.ts | 1534 | const rmdirCalls = mockSandbox.commands.run.mock.calls.filter( |
| CRITICAL | workspaces/e2b/src/sandbox/index.test.ts | 1562 | const rmCalls = mockSandbox.commands.run.mock.calls.filter( |
| CRITICAL | workspaces/e2b/src/sandbox/index.test.ts | 1594 | const fusermountCalls = mockSandbox.commands.run.mock.calls.filter((c: any[]) => c[0].includes('fusermount')); |
| CRITICAL | workspaces/e2b/src/sandbox/index.test.ts | 1623 | const fusermountCalls = mockSandbox.commands.run.mock.calls.filter((c: any[]) => c[0].includes('fusermount')); |
| CRITICAL | workspaces/e2b/src/sandbox/index.test.ts | 1646 | const rmCalls = mockSandbox.commands.run.mock.calls.filter( |
| CRITICAL | workspaces/e2b/src/sandbox/index.test.ts | 1683 | const procMountsCalls = mockSandbox.commands.run.mock.calls.filter((c: any[]) => c[0].includes('/proc/mounts')); |
| CRITICAL | workspaces/e2b/src/sandbox/index.test.ts | 1687 | const fusermountCalls = mockSandbox.commands.run.mock.calls.filter((c: any[]) => c[0].includes('fusermount')); |
| CRITICAL | workspaces/e2b/src/sandbox/index.test.ts | 1711 | const procMountsCalls = mockSandbox.commands.run.mock.calls.filter((c: any[]) => c[0].includes('/proc/mounts')); |
| CRITICAL | workspaces/e2b/src/sandbox/index.test.ts | 1755 | const fusermountCalls = mockSandbox.commands.run.mock.calls.filter((call: any[]) => call[0].includes('fusermount')); |
| CRITICAL | packages/core/src/stream/base/output.ts | 879 | const responseMessages = self.messageList.get.response.aiV4.core(); |
| CRITICAL | packages/core/src/stream/base/output.ts | 1082 | content: self.messageList.get.response.aiV5.stepContent(), |
| CRITICAL | …/core/src/agent/message-list/utils/convert-messages.ts | 74 | return this.messageList.get.all.aiV4.ui(); |
| CRITICAL | …/core/src/agent/message-list/utils/convert-messages.ts | 76 | return this.messageList.get.all.aiV4.core(); |
| CRITICAL | …/core/src/agent/message-list/utils/convert-messages.ts | 78 | return this.messageList.get.all.aiV5.ui(); |
| CRITICAL | …/core/src/agent/message-list/utils/convert-messages.ts | 80 | return this.messageList.get.all.aiV5.model(); |
| CRITICAL | …/core/src/agent/message-list/utils/convert-messages.ts | 82 | return this.messageList.get.all.aiV6.ui(); |
| CRITICAL | …c/loop/workflows/agentic-execution/llm-mapping-step.ts | 374 | all: rest.messageList.get.all.aiV5.model(), |
| CRITICAL | …c/loop/workflows/agentic-execution/llm-mapping-step.ts | 375 | user: rest.messageList.get.input.aiV5.model(), |
| CRITICAL | …c/loop/workflows/agentic-execution/llm-mapping-step.ts | 376 | nonUser: rest.messageList.get.response.aiV5.model(), |
| CRITICAL | …c/loop/workflows/agentic-execution/llm-mapping-step.ts | 392 | all: rest.messageList.get.all.aiV5.model(), |
| CRITICAL | …c/loop/workflows/agentic-execution/llm-mapping-step.ts | 393 | user: rest.messageList.get.input.aiV5.model(), |
| CRITICAL | …c/loop/workflows/agentic-execution/llm-mapping-step.ts | 394 | nonUser: rest.messageList.get.response.aiV5.model(), |
| CRITICAL | …c/loop/workflows/agentic-execution/llm-mapping-step.ts | 470 | all: rest.messageList.get.all.aiV5.model(), |
| CRITICAL | …c/loop/workflows/agentic-execution/llm-mapping-step.ts | 471 | user: rest.messageList.get.input.aiV5.model(), |
| CRITICAL | …c/loop/workflows/agentic-execution/llm-mapping-step.ts | 472 | nonUser: rest.messageList.get.response.aiV5.model(), |
| Severity | File | Line | Snippet |
|---|---|---|---|
| LOW | …nt-sdks/react/src/lib/ai-sdk/utils/toUIMessage.test.ts | 3540 | // Step 1: Start message |
| LOW | …nt-sdks/react/src/lib/ai-sdk/utils/toUIMessage.test.ts | 3552 | // Step 2: First text stream starts - "Let me search" |
| LOW | …nt-sdks/react/src/lib/ai-sdk/utils/toUIMessage.test.ts | 3575 | // Step 3: Tool call |
| LOW | …nt-sdks/react/src/lib/ai-sdk/utils/toUIMessage.test.ts | 3591 | // Step 4: Tool result |
| LOW | …nt-sdks/react/src/lib/ai-sdk/utils/toUIMessage.test.ts | 3608 | // Step 5: Second text stream starts - "Here's what I found" |
| LOW | …nt-sdks/react/src/lib/ai-sdk/utils/toUIMessage.test.ts | 3631 | // Step 6: Finish |
| LOW | workflows/_test-utils/src/domains/foreach.ts | 269 | // Step 1: Generate items to iterate over - outputs an array |
| LOW | workflows/_test-utils/src/domains/foreach.ts | 279 | // Step 2: Transform each item (used in foreach) |
| LOW | workflows/_test-utils/src/domains/foreach.ts | 287 | // Step 3: Sum all results |
| LOW | …t/src/durable-agent/create-inngest-agentic-workflow.ts | 137 | // Step 0: Convert iteration state to LLM input format |
| LOW | …t/src/durable-agent/create-inngest-agentic-workflow.ts | 161 | // Step 1: Execute LLM |
| LOW | …t/src/durable-agent/create-inngest-agentic-workflow.ts | 163 | // Step 2: Extract tool calls as array for foreach |
| LOW | …t/src/durable-agent/create-inngest-agentic-workflow.ts | 171 | // Step 3: Execute each tool call individually (with suspend support) |
| LOW | …t/src/durable-agent/create-inngest-agentic-workflow.ts | 174 | // Step 4: Collect tool results, create observability spans, and bundle for mapping |
| LOW | …t/src/durable-agent/create-inngest-agentic-workflow.ts | 264 | // Step 5: Map tool results back to state |
| LOW | …t/src/durable-agent/create-inngest-agentic-workflow.ts | 266 | // Step 6: Check for pending background tasks |
| LOW | …t/src/durable-agent/create-inngest-agentic-workflow.ts | 268 | // Step 7: Map back to iteration state format using shared function |
| LOW | …ores/cloudflare-d1/src/storage/domains/memory/index.ts | 806 | // Step 1: Get paginated messages from the thread first (without excluding included ones) |
| LOW | …ores/cloudflare-d1/src/storage/domains/memory/index.ts | 924 | // Step 2: Add included messages with context (if any), excluding duplicates |
| LOW | stores/clickhouse/src/storage/domains/memory/index.ts | 224 | // Step 1: Get paginated messages from the thread(s) first (without excluding included ones) |
| LOW | stores/clickhouse/src/storage/domains/memory/index.ts | 375 | // Step 2: Add included messages with context (if any), excluding duplicates |
| LOW | stores/clickhouse/src/storage/db/index.ts | 302 | // Step 1: Rename old table to backup |
| LOW | stores/clickhouse/src/storage/db/index.ts | 307 | // Step 2: Create new table with correct sorting key |
| LOW | stores/clickhouse/src/storage/db/index.ts | 346 | // Step 3: Copy data from backup to new table, deduplicating by (traceId, spanId) |
| LOW | stores/clickhouse/src/storage/db/index.ts | 381 | // Step 4: Drop backup table |
| LOW | …ores/cloudflare/src/kv/storage/domains/memory/index.ts | 874 | // Step 1: Get thread messages from all specified threads (for pagination) |
| LOW | …ores/cloudflare/src/kv/storage/domains/memory/index.ts | 935 | // Step 2: Get included messages separately (not subject to pagination) |
| LOW | …ores/cloudflare/src/kv/storage/domains/memory/index.ts | 950 | // Step 3: Combine paginated + included messages, deduplicate |
| LOW | …ores/cloudflare/src/do/storage/domains/memory/index.ts | 762 | // Step 1: Get paginated messages from the thread(s) first (without excluding included ones) |
| LOW | …ores/cloudflare/src/do/storage/domains/memory/index.ts | 864 | // Step 2: Add included messages with context (if any), excluding duplicates |
| LOW | stores/lance/src/storage/domains/memory/index.ts | 403 | // Step 1: Get paginated messages from the thread first (without excluding included ones) |
| LOW | stores/lance/src/storage/domains/memory/index.ts | 438 | // Step 2: Add included messages with context (if any), excluding duplicates |
| LOW | stores/dynamodb/src/storage/domains/memory/index.ts | 423 | // Step 1: Get paginated messages from the thread first (without excluding included ones) |
| LOW | stores/dynamodb/src/storage/domains/memory/index.ts | 474 | // Step 2: Add included messages with context (if any), excluding duplicates |
| LOW | stores/mongodb/src/storage/migration.test.ts | 54 | // Step 1: Insert documents with ONLY old schema fields (simulating pre-migration data) |
| LOW | stores/mongodb/src/storage/migration.test.ts | 103 | // Step 2: Verify documents exist |
| LOW | stores/mongodb/src/storage/migration.test.ts | 107 | // Step 3: Initialize store (which creates indexes but doesn't modify document structure) |
| LOW | stores/mongodb/src/storage/migration.test.ts | 110 | // Step 4: Query via storage API - should work with old documents |
| LOW | stores/mongodb/src/storage/migration.test.ts | 128 | // Step 5: Verify new fields are null/undefined for old documents |
| LOW | stores/mongodb/src/storage/domains/memory/index.ts | 362 | // Step 1: Get paginated messages from the thread first (without excluding included ones) |
| LOW | stores/mongodb/src/storage/domains/memory/index.ts | 388 | // Step 2: Add included messages with context (if any), excluding duplicates |
| LOW | stores/mongodb/src/storage/domains/memory/index.ts | 530 | // Step 1: Get paginated messages |
| LOW | stores/mongodb/src/storage/domains/memory/index.ts | 556 | // Step 2: Add included messages with context (if any), excluding duplicates |
| LOW | stores/pg/src/storage/migration.test.ts | 1383 | // Step 3: Run the migration SQL |
| LOW | stores/pg/src/storage/migration.test.ts | 1390 | // Step 4: Verify column type is now JSONB |
| LOW | stores/pg/src/storage/migration.test.ts | 1398 | // Step 5: Verify all data was preserved |
| LOW | stores/pg/src/storage/migration.test.ts | 1558 | // Step 3: Run the migration SQL |
| LOW | stores/pg/src/storage/migration.test.ts | 1565 | // Step 4: Verify column type is now JSONB |
| LOW | stores/pg/src/storage/migration.test.ts | 1573 | // Step 5: Verify all data was preserved |
| LOW | stores/pg/src/storage/migration.test.ts | 66 | // Step 1: Create table with OLD schema (simulating existing database) |
| LOW | stores/pg/src/storage/migration.test.ts | 90 | // Step 2: Insert test data using OLD schema columns |
| LOW | stores/pg/src/storage/migration.test.ts | 195 | // Step 3: Call createTable which should trigger migration |
| LOW | stores/pg/src/storage/migration.test.ts | 198 | // Step 4: Verify new columns exist |
| LOW | stores/pg/src/storage/migration.test.ts | 224 | // Step 5: Verify original columns still exist |
| LOW | stores/pg/src/storage/migration.test.ts | 234 | // Step 6: Verify data is still queryable after migration |
| LOW | stores/pg/src/storage/migration.test.ts | 264 | // Step 7: Verify new columns have NULL values for existing data (since they didn't exist before) |
| LOW | stores/pg/src/storage/migration.test.ts | 270 | // Step 8: Verify we can insert new data with the new columns |
| LOW | stores/pg/src/storage/migration.test.ts | 305 | // Step 1: Create table with OLD schema WITHOUT timezone columns (simulating pre-Dec-23 database) |
| LOW | stores/pg/src/storage/migration.test.ts | 329 | // Step 2: Verify timezone columns do NOT exist before migration |
| LOW | stores/pg/src/storage/migration.test.ts | 338 | // Step 3: Insert test data |
| 257 more matches not shown… | |||
| Severity | File | Line | Snippet |
|---|---|---|---|
| HIGH | …de/skills/mastra-smoke-test/references/tests/errors.md | 33 | > Replace `<server-url>` with your environment URL, `<agent-id>` with an agent from your setup, and `<your-api-key>` fro |
| HIGH | …de/skills/mastra-smoke-test/references/tests/errors.md | 38 | -H "Authorization: Bearer <your-api-key>" \ |
| HIGH | …de/skills/mastra-smoke-test/references/tests/errors.md | 44 | -H "Authorization: Bearer <your-api-key>" \ |
| HIGH | …de/skills/mastra-smoke-test/references/tests/errors.md | 50 | -H "Authorization: Bearer <your-api-key>" \ |
| HIGH | stores/pinecone/README.md | 18 | apiKey: 'your-api-key', |
| HIGH | stores/pinecone/src/vector/index.ts | 40 | * apiKey: 'your-api-key', |
| HIGH | stores/pinecone/src/vector/index.ts | 46 | * apiKey: 'your-api-key', |
| HIGH | stores/pinecone/src/vector/index.ts | 53 | * apiKey: 'your-api-key', |
| HIGH | stores/turbopuffer/README.md | 18 | apiKey: 'your-api-key', |
| HIGH | …course/02-agent-tools-mcp/08-getting-zapier-mcp-url.md | 18 | ZAPIER_MCP_API_KEY=your-api-key-here |
| HIGH | observability/arize/README.md | 28 | PHOENIX_API_KEY=your-api-key |
| HIGH | observability/arize/README.md | 66 | apiKey: 'your-api-key', // Optional |
| HIGH | observability/arize/README.md | 94 | ARIZE_API_KEY=your-api-key |
| HIGH | observability/arize/README.md | 132 | apiKey: 'your-api-key', |
| HIGH | observability/arize/README.md | 164 | apiKey: "your-api-key", |
| HIGH | observability/otel-exporter/README.md | 68 | DASH0_API_KEY=your-api-key |
| HIGH | observability/otel-exporter/README.md | 98 | apiKey: 'your-api-key', |
| HIGH | observability/otel-exporter/README.md | 120 | SIGNOZ_API_KEY=your-api-key |
| HIGH | observability/otel-exporter/README.md | 150 | apiKey: 'your-api-key', |
| HIGH | observability/otel-exporter/README.md | 219 | TRACELOOP_API_KEY=your-api-key |
| HIGH | observability/otel-exporter/README.md | 249 | apiKey: 'your-api-key', |
| HIGH | observability/otel-exporter/README.md | 269 | LMNR_PROJECT_API_KEY=your-api-key |
| HIGH | observability/otel-exporter/README.md | 298 | apiKey: 'your-api-key', |
| HIGH | observability/arthur/README.md | 20 | ARTHUR_API_KEY=your-api-key |
| HIGH | observability/arthur/README.md | 56 | apiKey: 'your-api-key', |
| HIGH | observability/arthur/README.md | 71 | apiKey: 'your-api-key', |
| HIGH | observability/_examples/otel-bridge/agent-hub/README.md | 28 | OPENAI_API_KEY=your-api-key-here |
| HIGH | voice/azure/README.md | 37 | apiKey: 'your-api-key', // Optional, can use AZURE_API_KEY env var |
| HIGH | voice/azure/README.md | 42 | apiKey: 'your-api-key', // Optional, can use AZURE_API_KEY env var |
| HIGH | voice/gladia/README.md | 16 | GLADIA_API_KEY=your_api_key |
| HIGH | voice/google/README.md | 22 | GOOGLE_API_KEY=your_api_key |
| HIGH | voice/google/README.md | 65 | apiKey: 'your-api-key', // Optional, can rely on GOOGLE_API_KEY or ADC |
| HIGH | voice/google/src/index.ts | 135 | * speechModel: { apiKey: 'your-api-key' }, |
| HIGH | voice/murf/README.md | 16 | MURF_API_KEY=your_api_key |
| HIGH | voice/murf/README.md | 30 | apiKey: 'your-api-key', // Optional, can use MURF_API_KEY env var |
| HIGH | voice/speechify/README.md | 27 | apiKey: 'your-api-key', // Optional, can use SPEECHIFY_API_KEY env var |
| HIGH | voice/cloudflare/README.md | 28 | CLOUDFLARE_AI_API_KEY=your_api_key |
| HIGH | voice/cloudflare/README.md | 48 | apiKey: 'YOUR_API_KEY', |
| HIGH | voice/deepgram/README.md | 16 | DEEPGRAM_API_KEY=your_api_key |
| HIGH | voice/deepgram/README.md | 28 | apiKey: 'your-api-key', // Optional, can use DEEPGRAM_API_KEY env var |
| HIGH | voice/deepgram/README.md | 32 | apiKey: 'your-api-key', // Optional, can use DEEPGRAM_API_KEY env var |
| HIGH | voice/openai-realtime-api/README.md | 16 | OPENAI_API_KEY=your_api_key |
| HIGH | voice/openai-realtime-api/README.md | 30 | apiKey: 'your-api-key', // Optional, can use OPENAI_API_KEY env var |
| HIGH | voice/openai-realtime-api/src/index.ts | 136 | * apiKey: 'your-api-key', |
| HIGH | voice/elevenlabs/README.md | 16 | ELEVENLABS_API_KEY=your_api_key |
| HIGH | voice/elevenlabs/README.md | 28 | apiKey: 'your-api-key', // Optional, can use ELEVENLABS_API_KEY env var |
| HIGH | voice/playai/README.md | 16 | PLAYAI_API_KEY=your_api_key |
| HIGH | voice/playai/README.md | 29 | apiKey: 'your-api-key', // Optional, can use PLAYAI_API_KEY env var |
| HIGH | voice/sarvam/README.md | 16 | SARVAM_API_KEY=your_api_key |
| HIGH | voice/google-gemini-live-api/README.md | 21 | GOOGLE_API_KEY=your_api_key |
| HIGH | voice/google-gemini-live-api/README.md | 74 | apiKey: 'your-api-key', // Optional, can use GOOGLE_API_KEY env var |
| HIGH | voice/google-gemini-live-api/src/index.ts | 60 | * apiKey: 'your-api-key', |
| HIGH | voice/google-gemini-live-api/src/index.ts | 70 | * speechModel: { name: 'gemini-2.0-flash-live-001', apiKey: 'your-api-key' }, |
| HIGH | voice/google-gemini-live-api/src/index.ts | 74 | * apiKey: 'your-api-key', |
| HIGH | voice/openai/README.md | 16 | OPENAI_API_KEY=your_api_key |
| HIGH | voice/openai/README.md | 28 | apiKey: 'your-api-key', // Optional, can use OPENAI_API_KEY env var |
| HIGH | voice/openai/README.md | 32 | apiKey: 'your-api-key', // Optional, can use OPENAI_API_KEY env var |
| HIGH | voice/openai/README.md | 41 | apiKey: 'your-api-key', |
| HIGH | voice/openai/README.md | 50 | apiKey: 'your-api-key', |
| HIGH | packages/create-mastra/CHANGELOG.md | 995 | - Improve the overall flow of the `create-mastra` CLI by first asking all questions and then creating the project struct |
| 7 more matches not shown… | |||
| Severity | File | Line | Snippet |
|---|---|---|---|
| LOW | …r-adapters/_test-utils/src/route-adapter-test-suite.ts | 81 | |
| LOW | deployers/cloudflare/src/index.test.ts | 21 | |
| LOW | client-sdks/client-js/src/example.ts | 41 | |
| LOW | client-sdks/client-js/src/example.ts | 61 | // try { |
| LOW | …i-sdk/src/__tests__/add-tool-result-message-id.test.ts | 201 | // |
| LOW | …t/src/lib/ai-sdk/memory/resolveInitialMessages.test.ts | 561 | const output = (result[0].parts[0] as any).output; |
| LOW | …t/src/lib/ai-sdk/memory/resolveInitialMessages.test.ts | 581 | |
| LOW | .claude/skills/mastra-smoke-test/scripts/test-server.sh | 1 | #!/bin/bash |
| LOW | …ls/mastra-smoke-test/scripts/discover-release-scope.sh | 1 | #!/bin/bash |
| LOW | .claude/skills/builder-smoke-test/scripts/scaffold.sh | 1 | #!/usr/bin/env bash |
| LOW | .claude/skills/builder-smoke-test/scripts/scaffold.sh | 21 | # |
| LOW | .claude/skills/builder-smoke-test/scripts/preflight.sh | 1 | #!/usr/bin/env bash |
| LOW | .claude/skills/builder-smoke-test/scripts/preflight.sh | 21 | # --workos-organization-id org_... # scaffold auth-on |
| LOW | …e/skills/builder-smoke-test/scripts/seed-multi-user.sh | 1 | #!/usr/bin/env bash |
| LOW | …e/skills/builder-smoke-test/scripts/wait-for-server.sh | 1 | #!/usr/bin/env bash |
| LOW | stores/cloudflare-d1/src/storage/rest-api.test.ts | 481 | // createSampleMessage({ |
| LOW | stores/cloudflare-d1/src/storage/rest-api.test.ts | 501 | // }), |
| LOW | stores/cloudflare-d1/src/storage/rest-api.test.ts | 521 | |
| LOW | stores/cloudflare-d1/src/storage/rest-api.test.ts | 541 | // { |
| LOW | stores/cloudflare-d1/src/storage/rest-api.test.ts | 561 | // resourceId: 'cross-thread-resource', |
| LOW | stores/cloudflare-d1/src/storage/rest-api.test.ts | 581 | // resourceId: 'cross-thread-resource', |
| LOW | stores/_test-utils/src/domains/memory/threads.ts | 401 | // beforeEach(async () => { |
| LOW | stores/_test-utils/src/domains/memory/threads.ts | 421 | |
| LOW | stores/_test-utils/src/domains/memory/threads.ts | 441 | |
| LOW | …src/storage/domains/observability/v-next/index.test.ts | 4481 | // Clean up: remove TTL from all signal tables so subsequent test runs |
| LOW | stores/pg/README.md | 441 | |
| LOW | stores/pg/src/storage/domains/workflows/index.ts | 41 | // Remove null char and surrogate escape sequences. The optional extra backslash (\\\\?) |
| LOW | stores/libsql/src/vector/filter.test.ts | 761 | translator.translate({ |
| LOW | stores/libsql/src/vector/filter.test.ts | 781 | // translator.translate({ |
| LOW | stores/libsql/src/vector/filter.test.ts | 801 | // }), |
| LOW | stores/libsql/src/vector/filter.test.ts | 821 | // field: { $regex: '^exact$' }, |
| LOW | stores/libsql/src/vector/filter.test.ts | 841 | // }); |
| LOW | stores/libsql/src/vector/filter.test.ts | 861 | // nested: { |
| LOW | stores/libsql/src/vector/filter.test.ts | 881 | // expect( |
| LOW | stores/libsql/src/vector/filter.ts | 61 | |
| LOW | stores/libsql/src/vector/filter.ts | 121 | // const flags = options |
| LOW | stores/libsql/src/vector/sql-builder.ts | 261 | }, |
| LOW | stores/libsql/src/vector/sql-builder.ts | 281 | // // finalPattern = `(\\?${options})${pattern}`; |
| LOW | stores/libsql/src/vector/sql-builder.ts | 301 | // )`; |
| LOW | stores/libsql/src/vector/sql-builder.ts | 441 | }; |
| LOW | stores/mssql/README.md | 341 | |
| LOW | stores/dsql/README.md | 321 | const stats = await store.describeIndex('idx_threads_resource'); |
| LOW | observability/braintrust/src/tracing.test.ts | 2661 | // Verify trace is external |
| LOW | observability/mastra/src/exporters/default.ts | 81 | * in batches to the configured ObservabilityStorage backend with retry support. |
| LOW | workspaces/_test-utils/src/index.test.ts | 81 | return new Workspace({ filesystem, sandbox, lsp: { diagnosticTimeout: 10000 } }); |
| LOW | workspaces/files-sdk/src/filesystem/index.ts | 501 | |
| LOW | workspaces/blaxel/src/sandbox/index.integration.test.ts | 161 | }, 180000); |
| LOW | mastracode/src/index.ts | 301 | // Only these requestContext keys are stored on spans — prevents leaking |
| LOW | voice/aws-nova-sonic/src/index.ts | 701 | toolChoice: this.sessionConfig.toolChoice, |
| LOW | voice/aws-nova-sonic/src/index.ts | 1321 | // Following AWS sample: even after interruption, we keep audioContentStarted=true |
| LOW | voice/aws-nova-sonic/src/index.ts | 1381 | } else { |
| LOW | voice/google/src/index.test.ts | 261 | // return new Promise((resolve, reject) => { |
| LOW | voice/openai-realtime-api/src/index.ts | 41 | |
| LOW | examples/voice/interactive-story/next-env.d.ts | 1 | /// <reference types="next" /> |
| LOW | examples/voice/voice-memo-app/next-env.d.ts | 1 | /// <reference types="next" /> |
| LOW | examples/agent-v6/src/mastra/agents/index.ts | 41 | // return args; |
| LOW | scripts/test-migration-e2e.sh | 1 | #!/bin/bash |
| LOW | packages/core/src/background-tasks/manager.ts | 121 | // workflow on Mastra. Reversing this order races: a publish that |
| LOW | packages/core/src/background-tasks/workflow.ts | 121 | // Wrap the workflow runtime's `suspend` so we persist |
| LOW | …kages/core/src/evals/scorer-custom-gateway.e2e.test.ts | 121 | // The actual test: When we run the scorer, it should be able to resolve |
| 286 more matches not shown… | |||
| Severity | File | Line | Snippet |
|---|---|---|---|
| LOW | …adapters/express/src/__tests__/auth-middleware.test.ts | 17 | token === 'valid-token' ? { id: 'user-1', email: 'user@example.com' } : null, |
| LOW | …adapters/express/src/__tests__/auth-middleware.test.ts | 79 | email: 'user@example.com', |
| LOW | …er-adapters/hono/src/__tests__/auth-middleware.test.ts | 16 | token === 'valid-token' ? { id: 'user-1', email: 'user@example.com' } : null, |
| LOW | …adapters/fastify/src/__tests__/auth-middleware.test.ts | 16 | token === 'valid-token' ? { id: 'user-1', email: 'user@example.com' } : null, |
| LOW | …ver-adapters/koa/src/__tests__/auth-middleware.test.ts | 18 | token === 'valid-token' ? { id: 'user-1', email: 'user@example.com' } : null, |
| LOW | auth/okta/src/index.test.ts | 218 | profile: { login: 'user@example.com', email: 'user@example.com', firstName: 'Test', lastName: 'User' }, |
| LOW | auth/okta/src/index.test.ts | 227 | email: 'user@example.com', |
| LOW | client-sdks/ai-sdk/src/__tests__/custom-data.test.ts | 129 | name: 'John Doe', |
| LOW | client-sdks/ai-sdk/src/__tests__/custom-data.test.ts | 160 | expect(customDataChunk.data.user.name).toBe('John Doe'); |
| LOW | workflows/_test-utils/src/domains/structured-output.ts | 168 | phone: '555-1234', |
| LOW | stores/astra/src/vector/index.test.ts | 428 | name: 'John Doe', |
| LOW | stores/couchbase/src/vector/index.integration.test.ts | 255 | text: 'Lorem ipsum dolor sit amet, consectetur adipiscing elit. Sed do eiusmod tempor incididunt ut labore et do |
| LOW | stores/couchbase/src/vector/index.integration.test.ts | 255 | text: 'Lorem ipsum dolor sit amet, consectetur adipiscing elit. Sed do eiusmod tempor incididunt ut labore et do |
| LOW | stores/couchbase/src/vector/index.unit.test.ts | 378 | text: 'Lorem ipsum dolor sit amet, consectetur adipiscing elit. Sed do eiusmod tempor incididunt ut labore et do |
| LOW | stores/couchbase/src/vector/index.unit.test.ts | 378 | text: 'Lorem ipsum dolor sit amet, consectetur adipiscing elit. Sed do eiusmod tempor incididunt ut labore et do |
| LOW | stores/couchbase/src/vector/index.unit.test.ts | 400 | text: 'Lorem ipsum dolor sit amet, consectetur adipiscing elit. Sed do eiusmod tempor incididunt ut labore et |
| LOW | stores/couchbase/src/vector/index.unit.test.ts | 400 | text: 'Lorem ipsum dolor sit amet, consectetur adipiscing elit. Sed do eiusmod tempor incididunt ut labore et |
| LOW | stores/couchbase/src/vector/index.unit.test.ts | 403 | 'Lorem ipsum dolor sit amet, consectetur adipiscing elit. Sed do eiusmod tempor incididunt ut labore et dolore |
| LOW | stores/couchbase/src/vector/index.unit.test.ts | 403 | 'Lorem ipsum dolor sit amet, consectetur adipiscing elit. Sed do eiusmod tempor incididunt ut labore et dolore |
| LOW | stores/couchbase/src/vector/index.unit.test.ts | 485 | text: 'Lorem ipsum dolor sit amet, consectetur adipiscing elit. Sed do eiusmod tempor incididunt ut labore et |
| LOW | stores/couchbase/src/vector/index.unit.test.ts | 485 | text: 'Lorem ipsum dolor sit amet, consectetur adipiscing elit. Sed do eiusmod tempor incididunt ut labore et |
| LOW | stores/couchbase/src/vector/index.unit.test.ts | 488 | 'Lorem ipsum dolor sit amet, consectetur adipiscing elit. Sed do eiusmod tempor incididunt ut labore et dolore |
| LOW | stores/couchbase/src/vector/index.unit.test.ts | 488 | 'Lorem ipsum dolor sit amet, consectetur adipiscing elit. Sed do eiusmod tempor incididunt ut labore et dolore |
| LOW | observability/mastra/src/exporters/base.test.ts | 377 | metadata: { ...span.metadata, userName: 'John Doe', department: 'Engineering' }, |
| LOW | observability/mastra/src/exporters/base.test.ts | 389 | userName: 'John Doe', |
| LOW | …astra/src/span_processors/senstive-data-filter.test.ts | 267 | fullName: 'John Doe', |
| LOW | …astra/src/span_processors/senstive-data-filter.test.ts | 313 | content: '{ email": "test@test.com" }', |
| LOW | …astra/src/span_processors/senstive-data-filter.test.ts | 328 | expect(input.messages[0].content).toBe('{ email": "test@test.com" }'); |
| LOW | browser/agent-browser/src/__tests__/dialog.test.ts | 112 | const result = await browser.dialog({ triggerRef: '@e3', action: 'accept', text: 'John Doe' }); |
| LOW | browser/agent-browser/src/__tests__/dialog.test.ts | 114 | expect(mockDialog.accept).toHaveBeenCalledWith('John Doe'); |
| LOW | …ents/__tests__/ask-question-inline-long-labels.test.ts | 86 | 'Lorem ipsum dolor sit amet consectetur adipiscing elit sed do eiusmod tempor incididunt ut labore et dolore magna ali |
| LOW | …ents/__tests__/ask-question-inline-long-labels.test.ts | 86 | 'Lorem ipsum dolor sit amet consectetur adipiscing elit sed do eiusmod tempor incididunt ut labore et dolore magna ali |
| LOW | …/tui/components/__tests__/wrapping-select-list.test.ts | 46 | const longLabel = 'Lorem ipsum dolor sit amet consectetur adipiscing elit sed do eiusmod tempor'; |
| LOW | …/tui/components/__tests__/wrapping-select-list.test.ts | 46 | const longLabel = 'Lorem ipsum dolor sit amet consectetur adipiscing elit sed do eiusmod tempor'; |
| LOW | …/tui/components/__tests__/wrapping-select-list.test.ts | 66 | const longLabel = 'Lorem ipsum dolor sit amet consectetur adipiscing elit sed do eiusmod tempor'; |
| LOW | …/tui/components/__tests__/wrapping-select-list.test.ts | 66 | const longLabel = 'Lorem ipsum dolor sit amet consectetur adipiscing elit sed do eiusmod tempor'; |
| LOW | …/tui/components/__tests__/wrapping-select-list.test.ts | 73 | const longLabel = 'Lorem ipsum dolor sit amet consectetur adipiscing elit'; |
| LOW | …/tui/components/__tests__/wrapping-select-list.test.ts | 73 | const longLabel = 'Lorem ipsum dolor sit amet consectetur adipiscing elit'; |
| LOW | …/tui/components/__tests__/wrapping-select-list.test.ts | 96 | const longLabel = 'Lorem ipsum dolor sit amet consectetur adipiscing elit sed do eiusmod tempor'; |
| LOW | …/tui/components/__tests__/wrapping-select-list.test.ts | 96 | const longLabel = 'Lorem ipsum dolor sit amet consectetur adipiscing elit sed do eiusmod tempor'; |
| LOW | examples/agent/src/mastra/auth/simple.ts | 17 | email: 'admin@example.com', |
| LOW | examples/agent/src/mastra/auth/simple.ts | 31 | const adminEmails = ['admin@example.com', 'owner@example.com']; |
| LOW | examples/agent/src/mastra/auth/better-auth.ts | 40 | const adminEmails = ['admin@example.com', 'owner@example.com']; |
| LOW | examples/agent/src/mastra/workflows/other.ts | 121 | email: 'test@test.com', |
| LOW | …evals/src/scorers/llm/tool-call-accuracy/index.test.ts | 604 | args: { to: 'user@example.com' }, |
| LOW | …vals/src/scorers/code/content-similarity/index.test.ts | 99 | const output = [createTestMessage({ content: 'Lorem ipsum dolor sit amet', role: 'assistant', id: 'test-output' })]; |
| LOW | …vals/src/scorers/code/content-similarity/index.test.ts | 99 | const output = [createTestMessage({ content: 'Lorem ipsum dolor sit amet', role: 'assistant', id: 'test-output' })]; |
| LOW | …/evals/src/scorers/code/keyword-coverage/index.test.ts | 113 | const output = [createTestMessage({ content: 'Lorem ipsum dolor sit amet', role: 'assistant', id: 'test-output' })]; |
| LOW | …/evals/src/scorers/code/keyword-coverage/index.test.ts | 113 | const output = [createTestMessage({ content: 'Lorem ipsum dolor sit amet', role: 'assistant', id: 'test-output' })]; |
| LOW | …vals/src/scorers/code/textual-difference/index.test.ts | 75 | const output = [createTestMessage({ content: 'Lorem ipsum dolor sit amet', role: 'assistant', id: 'test-output' })]; |
| LOW | …vals/src/scorers/code/textual-difference/index.test.ts | 75 | const output = [createTestMessage({ content: 'Lorem ipsum dolor sit amet', role: 'assistant', id: 'test-output' })]; |
| LOW | …s__/core-src-agent-agent-gemini.e2e/test-36e468a1.json | 430 | "email": "test@test.com" |
| LOW | …s__/core-src-agent-agent-gemini.e2e/test-36e468a1.json | 651 | "email": "test@test.com" |
| LOW | …s__/core-src-agent-agent-gemini.e2e/test-2642b65b.json | 343 | "email": "test@test.com" |
| LOW | …s__/core-src-agent-agent-gemini.e2e/test-2642b65b.json | 523 | "email": "test@test.com" |
| LOW | …s__/core-src-agent-agent-gemini.e2e/test-7088b7e4.json | 280 | "email": "test@test.com", |
| LOW | …s__/core-src-agent-agent-gemini.e2e/test-6e44f5e0.json | 362 | "email": "test@test.com", |
| LOW | packages/core/src/tools/hitl.md | 73 | email: 'test@test.com', |
| LOW | …/core/src/tools/suspend-execute-return-types.test-d.ts | 47 | return { name: workflow.resumeData.name, email: 'test@test.com' }; |
| LOW | …/core/src/tools/suspend-execute-return-types.test-d.ts | 74 | return { name: workflow.resumeData.name, email: 'test@test.com' }; |
| 95 more matches not shown… | |||
| Severity | File | Line | Snippet |
|---|---|---|---|
| LOW | explorations/longmemeval/src/commands/investigate.ts | 901 | console.log(`\n💡 Don't forget to run: pnpm run sync-improved-om-qa\n`); |
| MEDIUM | examples/agent/src/mastra/agents/model-v2-agent.ts | 249 | * Another research agent that should NOT be used (for demonstration purposes) |
| MEDIUM | …evals/src/scorers/llm/tool-call-accuracy/index.test.ts | 329 | content: 'I cannot provide weather information without checking.', |
| LOW | …s__/core-src-agent-agent-gemini.e2e/test-c1a4b69b.json | 90 | "text": "You will be calling just *one* primitive at a time to accomplish the user task, every call to |
| LOW | …s__/core-src-agent-agent-gemini.e2e/test-c1a4b69b.json | 98 | "text": "\n You are a router in a network of specialized AI agents.\n Your job is to d |
| LOW | …s__/core-src-agent-agent-gemini.e2e/test-a7373d50.json | 63 | "text": "You will be calling just *one* primitive at a time to accomplish the user task, every call to |
| LOW | …s__/core-src-agent-agent-gemini.e2e/test-a7373d50.json | 71 | "text": "\n You are a router in a network of specialized AI agents.\n Your job is to d |
| LOW | …s__/core-src-agent-agent-gemini.e2e/test-a7373d50.json | 172 | "text": "\n You are a router in a network of specialized AI agents.\n Your job is to d |
| LOW | …s__/core-src-agent-agent-gemini.e2e/test-d4f909c5.json | 63 | "text": "You will be calling just *one* primitive at a time to accomplish the user task, every call to |
| LOW | …s__/core-src-agent-agent-gemini.e2e/test-d4f909c5.json | 71 | "text": "\n You are a router in a network of specialized AI agents.\n Your job is to d |
| LOW | …s__/core-src-agent-agent-gemini.e2e/test-d4f909c5.json | 238 | "text": "\n You are a router in a network of specialized AI agents.\n Your job is to d |
| LOW | …s__/core-src-agent-agent-gemini.e2e/test-50da5a32.json | 55 | "text": "You will be calling just *one* primitive at a time to accomplish the user task, every call to |
| LOW | …s__/core-src-agent-agent-gemini.e2e/test-50da5a32.json | 63 | "text": "\n You are a router in a network of specialized AI agents.\n Your job is to d |
| LOW | …s__/core-src-agent-agent-gemini.e2e/test-50da5a32.json | 256 | "text": "\n You are a router in a network of specialized AI agents.\n Your job is to d |
| LOW | …s__/core-src-agent-agent-gemini.e2e/test-7316c0c7.json | 55 | "text": "You will be calling just *one* primitive at a time to accomplish the user task, every call to |
| LOW | …s__/core-src-agent-agent-gemini.e2e/test-7316c0c7.json | 63 | "text": "\n You are a router in a network of specialized AI agents.\n Your job is to d |
| LOW | …s__/core-src-agent-agent-gemini.e2e/test-7316c0c7.json | 219 | "text": "\n You are a router in a network of specialized AI agents.\n Your job is to d |
| LOW | …s__/core-src-agent-agent-gemini.e2e/test-ec76f34b.json | 90 | "text": "You will be calling just *one* primitive at a time to accomplish the user task, every call to |
| LOW | …s__/core-src-agent-agent-gemini.e2e/test-ec76f34b.json | 98 | "text": "\n You are a router in a network of specialized AI agents.\n Your job is to d |
| LOW | …s__/core-src-agent-agent-gemini.e2e/test-50215a35.json | 55 | "text": "You will be calling just *one* primitive at a time to accomplish the user task, every call to |
| LOW | …s__/core-src-agent-agent-gemini.e2e/test-50215a35.json | 63 | "text": "\n You are a router in a network of specialized AI agents.\n Your job is to d |
| LOW | …s__/core-src-agent-agent-gemini.e2e/test-50215a35.json | 222 | "text": "\n You are a router in a network of specialized AI agents.\n Your job is to d |
| LOW | …s__/core-src-agent-agent-gemini.e2e/test-3ae2bed0.json | 55 | "text": "You will be calling just *one* primitive at a time to accomplish the user task, every call to |
| LOW | …s__/core-src-agent-agent-gemini.e2e/test-3ae2bed0.json | 63 | "text": "\n You are a router in a network of specialized AI agents.\n Your job is to d |
| LOW | …s__/core-src-agent-agent-gemini.e2e/test-3ae2bed0.json | 231 | "text": "\n You are a router in a network of specialized AI agents.\n Your job is to d |
| LOW | …s__/core-src-agent-agent-gemini.e2e/test-3ae2bed0.json | 302 | "text": "\n You are a router in a network of specialized AI agents.\n Your job is to d |
| LOW | …s__/core-src-agent-agent-gemini.e2e/test-45e4713b.json | 63 | "text": "You will be calling just *one* primitive at a time to accomplish the user task, every call to |
| LOW | …s__/core-src-agent-agent-gemini.e2e/test-45e4713b.json | 71 | "text": "\n You are a router in a network of specialized AI agents.\n Your job is to d |
| LOW | …s__/core-src-agent-agent-gemini.e2e/test-45e4713b.json | 238 | "text": "\n You are a router in a network of specialized AI agents.\n Your job is to d |
| LOW | …s__/core-src-agent-agent-gemini.e2e/test-99f429d7.json | 82 | "text": "You will be calling just *one* primitive at a time to accomplish the user task, every call to |
| LOW | …s__/core-src-agent-agent-gemini.e2e/test-99f429d7.json | 90 | "text": "\n You are a router in a network of specialized AI agents.\n Your job is to d |
| LOW | …s__/core-src-agent-agent-gemini.e2e/test-99f429d7.json | 191 | "text": "\n You are a router in a network of specialized AI agents.\n Your job is to d |
| LOW | packages/core/src/loop/network/index.ts | 234 | ## Available Workflows in Network (make sure to use inputs corresponding to the input schema when calling a wo |
| LOW | packages/core/src/loop/network/index.ts | 236 | ## Available Tools in Network (make sure to use inputs corresponding to the input schema when calling a tool) |
| MEDIUM | …/memory-integration-tests-src-message-ordering-v6.json | 5372 | "data: {\"candidates\": [{\"content\": {\"parts\": [{\"text\": \" Niño and La Niña. \\n\\nMy research is now c |
| MEDIUM | …s__/schema-compat-src-provider-compats-google.e2e.json | 1325 | "text": "I have successfully called the `manySchemasTool` with valid sample data satisfying all the |
| MEDIUM | …-compat-src-provider-compats-openai-reasoning.e2e.json | 1787 | "text": "The tool has been called with valid sample data. Let me know if you need anything else!" |
| MEDIUM | …ponents/MarkdownRenderer/markdown-renderer.stories.tsx | 125 | Here's a simple example: |
| Severity | File | Line | Snippet |
|---|---|---|---|
| MEDIUM | workspaces/docker/src/sandbox/process-manager.ts | 97 | // backoff would be more robust under heavy load, but overkill in practice. |
| MEDIUM | …/__recordings__/core-src-tools-provider-tools.e2e.json | 814 | "event: response.output_text.done\ndata: {\"type\":\"response.output_text.done\",\"content_index\":0,\"item_id |
| MEDIUM | …/__recordings__/core-src-tools-provider-tools.e2e.json | 815 | "event: response.content_part.done\ndata: {\"type\":\"response.content_part.done\",\"content_index\":0,\"item_ |
| MEDIUM | …/__recordings__/core-src-tools-provider-tools.e2e.json | 816 | "event: response.output_item.done\ndata: {\"type\":\"response.output_item.done\",\"item\":{\"id\":\"msg_003b24 |
| MEDIUM | …/__recordings__/core-src-tools-provider-tools.e2e.json | 819 | "data: {\"type\":\"response.completed\",\"response\":{\"id\":\"resp_003b244db9908ccb006a0aef0ea85481968f11de26 |
| MEDIUM | …/__recordings__/core-src-tools-provider-tools.e2e.json | 1769 | "event: content_block_start\ndata: {\"type\":\"content_block_start\",\"index\":1,\"content_block\":{\"type\":\ |
| MEDIUM | …/__recordings__/core-src-tools-provider-tools.e2e.json | 1769 | "event: content_block_start\ndata: {\"type\":\"content_block_start\",\"index\":1,\"content_block\":{\"type\":\ |
| MEDIUM | …ings__/core-src-tools-provider-tools-ordering.e2e.json | 364 | "event: content_block_delta\ndata: {\"type\":\"content_block_delta\",\"index\":22,\"delta\":{\"type\":\"citati |
| MEDIUM | …ings__/core-src-agent-__tests__-tool-handling.e2e.json | 923 | "text": "Here's an overview of TypeScript:\n\n### What is TypeScript?\nTypeScript is an open-source pr |
| MEDIUM | …/core-src-agent-agent-processor.e2e/test-8d6b5c23.json | 153 | "text": "Extract and structure the key information from the following text according to the specified |
| MEDIUM | packages/core/src/processors/processors/skills.test.ts | 37 | instructions: '# Testing\n\nHelp write comprehensive tests.', |
| MEDIUM | …/memory-integration-tests-src-message-ordering-v6.json | 2782 | "text": "I'll help you research weather patterns in California and create a comprehensive summary. Let |
| MEDIUM | …/memory-integration-tests-src-message-ordering-v6.json | 2922 | "text": "I'll help you research weather patterns in California and create a comprehensive summary. Let |
| MEDIUM | …/memory-integration-tests-src-message-ordering-v6.json | 3086 | "text": "I'll help you research weather patterns in California and create a comprehensive summary. Let |
| MEDIUM | …/memory-integration-tests-src-message-ordering-v6.json | 3277 | "text": "I'll help you research weather patterns in California and create a comprehensive summary. Let |
| MEDIUM | …/memory-integration-tests-src-message-ordering-v6.json | 3556 | "text": "I'll help you research weather patterns in California and create a comprehensive summary. Let |
| MEDIUM | …/memory-integration-tests-src-message-ordering-v6.json | 5156 | "ces cooler temperatures overall compared to the south.\\n* **Southern California:** Known for hotter, drier c |
| MEDIUM | …/memory-integration-tests-src-message-ordering-v6.json | 5265 | "content": "# Weather Patterns in California\n\nCalifornia is renowned for its diverse and complex |
| MEDIUM | packages/mcp/src/client/configuration.e2e.test.ts | 317 | // Adding a small delay or an explicit trigger if the fixture supported it would be more robust. |
| Severity | File | Line | Snippet |
|---|---|---|---|
| HIGH | packages/rag/src/document/document.test.ts | 723 | return False |
| HIGH | packages/rag/src/document/document.test.ts | 724 | return True |
| HIGH | packages/rag/src/document/document.test.ts | 1005 | print(i) |
| HIGH | packages/rag/src/document/document.test.ts | 1222 | print("Hello") |
| HIGH | packages/rag/src/document/document.test.ts | 2800 | print("Hello World") |
| HIGH | packages/rag/src/document/document.test.ts | 3579 | print(f"The result is {z}") |
| Severity | File | Line | Snippet |
|---|---|---|---|
| LOW | …ls/mastra-smoke-test/scripts/discover-release-scope.sh | 5 | # Usage: |
| LOW | …kills/mastra-smoke-test/scripts/check-versioning-pr.sh | 5 | # Usage: |
| LOW | .claude/skills/builder-smoke-test/scripts/scaffold.sh | 22 | # Usage: |
| LOW | .claude/skills/builder-smoke-test/scripts/preflight.sh | 14 | # Usage: |
| LOW | …e/skills/builder-smoke-test/scripts/seed-multi-user.sh | 20 | # Usage: |
| LOW | …e/skills/builder-smoke-test/scripts/wait-for-server.sh | 6 | # Usage: |
| LOW | …pg/src/storage/performance-indexes/performance-test.ts | 530 | // Example usage |
| LOW | …ql/src/storage/performance-indexes/performance-test.ts | 543 | // Example usage |
| LOW | scripts/install-example.js | 95 | // Example usage |
| LOW | scripts/ignore-example.js | 102 | // Example usage |
| LOW | scripts/generate-package-docs.ts | 291 | ## How to use |
| LOW | scripts/test-migration-e2e.sh | 11 | # Usage: |
| Severity | File | Line | Snippet |
|---|---|---|---|
| LOW | scripts/test-migration-e2e.sh | 137 | # Check if test directory exists |
| LOW | scripts/test-migration-e2e.sh | 143 | # Check if test file exists |
| LOW | .github/workflows/test-combined-stores.yml | 52 | # Check if we should include vectorize tests |
| LOW | .github/workflows/regenerate-provider-registry.yml | 76 | # Check if an automated provider registry changeset already exists |
| Severity | File | Line | Snippet |
|---|---|---|---|
| MEDIUM | …/__recordings__/core-src-tools-provider-tools.e2e.json | 1757 | "event: content_block_delta\ndata: {\"type\":\"content_block_delta\",\"index\":0,\"delta\":{\"type\":\"input_j |
| MEDIUM | .github/workflows/call-external-mastra-workflow.yml | 43 | # Create the workflow run and capture the runId |
| Severity | File | Line | Snippet |
|---|---|---|---|
| LOW | packages/core/src/_types/ai-sdk.types.d.ts | 4681 | export function getData(name: string): ValueOf<typeof data> { |
| LOW | packages/rag/src/document/document.test.ts | 3855 | function processData(data) { |
| LOW | …odemod/src/test/__fixtures__/runtime-context.output.ts | 22 | function handleRequest(requestContext: RequestContext<MyContext>) { |
| LOW | …codemod/src/test/__fixtures__/runtime-context.input.ts | 22 | function handleRequest(runtimeContext: RuntimeContext<MyContext>) { |