> Discover all available pages from the documentation index: https://mastra.zisheng.pro/ja/llms.txt # カスタム認証 Provider カスタム認証 Provider を使用すると、組み込み Provider で対応していないアイデンティティシステム向けの認証を実装できます。`MastraAuthProvider` 基底クラスを拡張することで、任意の認証システムと統合できます。 ## 概要 認証 Provider は、受信リクエストの認証と認可を処理します。 - トークンの検証とユーザーの抽出 - ユーザー認可ロジック - パスに基づくアクセス制御(公開ルートと保護されたルート) カスタム認証 Provider は、次の用途に使用できます。 - セルフホスト型のアイデンティティシステム - カスタムトークン形式または検証ロジック - 特別な認可ルール - エンタープライズ SSO 連携 ## カスタム認証 Provider の作成 `MastraAuthProvider` クラスを拡張し、必須メソッドを実装します。 ```typescript import { MastraAuthProvider } from '@mastra/core/server' import type { MastraAuthProviderOptions } from '@mastra/core/server' import type { HonoRequest } from 'hono' // Define your user type type MyUser = { id: string email: string roles: string[] } // Define options for your provider interface MyAuthOptions extends MastraAuthProviderOptions { apiUrl?: string apiKey?: string } export class MyAuthProvider extends MastraAuthProvider { protected apiUrl: string protected apiKey: string constructor(options?: MyAuthOptions) { // Call super with a name for logging/debugging super({ name: options?.name ?? 'my-auth' }) const apiUrl = options?.apiUrl ?? process.env.MY_AUTH_API_URL const apiKey = options?.apiKey ?? process.env.MY_AUTH_API_KEY if (!apiUrl || !apiKey) { throw new Error( 'Auth API URL and API key are required. Provide them in options or set MY_AUTH_API_URL and MY_AUTH_API_KEY environment variables.', ) } this.apiUrl = apiUrl this.apiKey = apiKey // Register any custom options (authorizeUser override, public/protected paths) this.registerOptions(options) } /** * Verify the token and return the user * Return null if authentication fails */ async authenticateToken(token: string, request: HonoRequest): Promise { try { const response = await fetch(`${this.apiUrl}/verify`, { method: 'POST', headers: { 'Content-Type': 'application/json', 'X-API-Key': this.apiKey, }, body: JSON.stringify({ token }), }) if (!response.ok) { return null } const user = await response.json() return user } catch (error) { console.error('Token verification failed:', error) return null } } /** * Check if the authenticated user is authorized * Return true to allow access, false to deny */ async authorizeUser(user: MyUser, request: HonoRequest): Promise { // Basic authorization: user must exist and have an ID return !!user?.id } } ``` ## 必須メソッド ### `authenticateToken()` 受信したトークンを検証し、有効な場合はユーザーオブジェクトを、認証に失敗した場合は `null` を返します。 ```typescript async authenticateToken(token: string, request: HonoRequest): Promise ``` | パラメーター | 型 | 説明 | | --------- | ------------- | ---------------------------------------- | | `token` | `string` | `Authorization` ヘッダーから抽出された bearer token | | `request` | `HonoRequest` | 受信リクエストオブジェクト(ヘッダーや Cookie などにアクセス可能) | **戻り値**: 認証に成功した場合はユーザーオブジェクト、失敗した場合は `null`。 トークンは `Authorization: Bearer ` ヘッダーから自動的に抽出されます。その他のヘッダーや Cookie にアクセスする必要がある場合は、`request` パラメーターを使用します。 ### `authorizeUser()` 認証済みユーザーにリソースへのアクセスを許可するかどうかを判定します。 ```typescript async authorizeUser(user: TUser, request: HonoRequest): Promise | boolean ``` | パラメーター | 型 | 説明 | | --------- | ------------- | ---------------------------------- | | `user` | `TUser` | `authenticateToken` が返したユーザーオブジェクト | | `request` | `HonoRequest` | 受信リクエストオブジェクト | **戻り値**: アクセスを許可する場合は `true`、拒否する場合は `false`(403 Forbidden を返す)。 ## 設定オプション `MastraAuthProviderOptions` インターフェースでは、次のオプションを使用できます。 | オプション | 型 | 説明 | | --------------- | -------------------------------------------------------- | ------------------------- | | `name` | `string` | ログ記録やデバッグに使用する Provider 名 | | `authorizeUser` | `(user, request) => Promise \| boolean` | カスタム認可関数 | | `protected` | `(RegExp \| string \| [string, Methods \| Methods[]])[]` | 認証が必要なパス | | `public` | `(RegExp \| string \| [string, Methods \| Methods[]])[]` | 認証を省略するパス | ### パスパターン パターンマッチングを使用して、認証が必要なパスを設定します。 ```typescript const auth = new MyAuthProvider({ // Paths that require authentication protected: [ '/api/*', // Wildcard: all /api routes '/admin/*', // Wildcard: all /admin routes /^\/secure\/.*/, // Regex pattern ], // Paths that bypass authentication public: [ '/health', // Exact match '/api/status', // Exact match ['/api/webhook', 'POST'], // Only POST requests to /api/webhook ], }) ``` ## 認証 Provider の使用 カスタム認証 Provider を Mastra インスタンスに登録します。 ```typescript import { Mastra } from '@mastra/core' import { MyAuthProvider } from './my-auth-provider' export const mastra = new Mastra({ server: { auth: new MyAuthProvider({ apiUrl: process.env.MY_AUTH_API_URL, apiKey: process.env.MY_AUTH_API_KEY, }), }, }) ``` ## ヘルパーユーティリティ `@mastra/auth` パッケージは、一般的なトークン検証パターンに使用できるユーティリティを提供します。 ### JWT の検証 ```typescript import { verifyHmac, verifyJwks, decodeToken, getTokenIssuer } from '@mastra/auth' // Verify HMAC-signed JWT const payload = await verifyHmac(token, 'your-secret-key') // Verify with JWKS (for OAuth providers) const payload = await verifyJwks(token, 'https://provider.com/.well-known/jwks.json') // Decode without verification (for inspection) const decoded = await decodeToken(token) // Get the issuer from a decoded token const issuer = getTokenIssuer(decoded) ``` ### 例: JWKS ベースの Provider ```typescript import { MastraAuthProvider } from '@mastra/core/server' import type { MastraAuthProviderOptions } from '@mastra/core/server' import { verifyJwks } from '@mastra/auth' import type { JwtPayload } from '@mastra/auth' type MyUser = JwtPayload interface MyJwksAuthOptions extends MastraAuthProviderOptions { jwksUri?: string issuer?: string } export class MyJwksAuth extends MastraAuthProvider { protected jwksUri: string protected issuer: string constructor(options?: MyJwksAuthOptions) { super({ name: options?.name ?? 'my-jwks-auth' }) const jwksUri = options?.jwksUri ?? process.env.MY_JWKS_URI const issuer = options?.issuer ?? process.env.MY_AUTH_ISSUER if (!jwksUri) { throw new Error('JWKS URI is required') } this.jwksUri = jwksUri this.issuer = issuer ?? '' this.registerOptions(options) } async authenticateToken(token: string): Promise { try { const payload = await verifyJwks(token, this.jwksUri) // Optionally validate issuer if (this.issuer && payload.iss !== this.issuer) { return null } return payload } catch { return null } } async authorizeUser(user: MyUser): Promise { // Check token hasn't expired if (user.exp && user.exp * 1000 < Date.now()) { return false } return !!user.sub } } ``` ## カスタム認可ロジック カスタム `authorizeUser` 関数を指定して、デフォルトの認可を上書きします。 ```typescript const auth = new MyAuthProvider({ apiUrl: process.env.MY_AUTH_API_URL, apiKey: process.env.MY_AUTH_API_KEY, // Custom authorization: require admin role for all requests async authorizeUser(user, request) { return user.roles.includes('admin') }, }) ``` ### ロールベースの認可 ```typescript const auth = new MyAuthProvider({ async authorizeUser(user, request) { const path = request.url const method = request.method // Admin routes require admin role if (path.startsWith('/admin/')) { return user.roles.includes('admin') } // Write operations require write role if (['POST', 'PUT', 'PATCH', 'DELETE'].includes(method)) { return user.roles.includes('write') || user.roles.includes('admin') } // Read operations allowed for all authenticated users return true }, }) ``` ## カスタム認証 Provider のテスト Vitest を使用したテスト構成の例です。 ```typescript import { describe, it, expect, vi, beforeEach } from 'vitest' import { MyAuthProvider } from './my-auth-provider' // Mock fetch for API calls global.fetch = vi.fn() describe('MyAuthProvider', () => { const mockOptions = { apiUrl: 'https://auth.example.com', apiKey: 'test-api-key', } beforeEach(() => { vi.clearAllMocks() }) describe('initialization', () => { it('should initialize with provided options', () => { const auth = new MyAuthProvider(mockOptions) expect(auth).toBeInstanceOf(MyAuthProvider) }) it('should throw error when required options are missing', () => { expect(() => new MyAuthProvider({})).toThrow('Auth API URL and API key are required') }) }) describe('authenticateToken', () => { it('should return user when token is valid', async () => { const mockUser = { id: 'user123', email: 'test@example.com', roles: ['read'] } ;(fetch as any).mockResolvedValue({ ok: true, json: () => Promise.resolve(mockUser), }) const auth = new MyAuthProvider(mockOptions) const result = await auth.authenticateToken('valid-token', {} as any) expect(fetch).toHaveBeenCalledWith( 'https://auth.example.com/verify', expect.objectContaining({ method: 'POST', body: JSON.stringify({ token: 'valid-token' }), }), ) expect(result).toEqual(mockUser) }) it('should return null when token is invalid', async () => { ;(fetch as any).mockResolvedValue({ ok: false }) const auth = new MyAuthProvider(mockOptions) const result = await auth.authenticateToken('invalid-token', {} as any) expect(result).toBeNull() }) }) describe('authorizeUser', () => { it('should return true when user has valid id', async () => { const auth = new MyAuthProvider(mockOptions) const result = await auth.authorizeUser( { id: 'user123', email: 'test@example.com', roles: [] }, {} as any, ) expect(result).toBe(true) }) it('should return false when user has no id', async () => { const auth = new MyAuthProvider(mockOptions) const result = await auth.authorizeUser( { id: '', email: 'test@example.com', roles: [] }, {} as any, ) expect(result).toBe(false) }) }) describe('custom authorization', () => { it('should use custom authorizeUser when provided', async () => { const auth = new MyAuthProvider({ ...mockOptions, authorizeUser: user => user.roles.includes('admin'), }) const adminUser = { id: 'user123', email: 'admin@example.com', roles: ['admin'] } const regularUser = { id: 'user456', email: 'user@example.com', roles: ['read'] } expect(await auth.authorizeUser(adminUser, {} as any)).toBe(true) expect(await auth.authorizeUser(regularUser, {} as any)).toBe(false) }) }) describe('route configuration', () => { it('should store public routes configuration', () => { const publicRoutes = ['/health', '/api/status'] const auth = new MyAuthProvider({ ...mockOptions, public: publicRoutes, }) expect(auth.public).toEqual(publicRoutes) }) it('should store protected routes configuration', () => { const protectedRoutes = ['/api/*', '/admin/*'] const auth = new MyAuthProvider({ ...mockOptions, protected: protectedRoutes, }) expect(auth.protected).toEqual(protectedRoutes) }) }) }) ``` ## エラー処理 よくある失敗シナリオには、状況が分かるエラーメッセージを用意します。 ```typescript export class MyAuthProvider extends MastraAuthProvider { constructor(options?: MyAuthOptions) { super({ name: options?.name ?? 'my-auth' }) const apiUrl = options?.apiUrl ?? process.env.MY_AUTH_API_URL const apiKey = options?.apiKey ?? process.env.MY_AUTH_API_KEY if (!apiUrl) { throw new Error( 'Missing MY_AUTH_API_URL. Set the environment variable or pass apiUrl in options.', ) } if (!apiKey) { throw new Error( 'Missing MY_AUTH_API_KEY. Set the environment variable or pass apiKey in options.', ) } this.apiUrl = apiUrl this.apiKey = apiKey this.registerOptions(options) } async authenticateToken(token: string): Promise { if (!token || typeof token !== 'string') { return null // Immediate safe fail } try { const response = await fetch(`${this.apiUrl}/verify`, { method: 'POST', headers: { 'Content-Type': 'application/json', 'X-API-Key': this.apiKey, }, body: JSON.stringify({ token }), }) if (!response.ok) { return null } return await response.json() } catch (error) { // Log error for debugging, but don't expose details to client console.error('Auth verification error:', error) return null } } } ``` ## 組み込み Provider Mastra には、リファレンス実装として次の認証 Provider が含まれています。 - **MastraJwtAuth**: HMAC シークレットを使用したシンプルな JWT 検証(`@mastra/auth`) - **MastraAuthClerk**: Clerk 認証(`@mastra/auth-clerk`) - **MastraAuthAuth0**: Auth0 認証(`@mastra/auth-auth0`) - **MastraAuthSupabase**: Supabase 認証(`@mastra/auth-supabase`) - **MastraAuthFirebase**: Firebase 認証(`@mastra/auth-firebase`) - **MastraAuthWorkOS**: WorkOS 認証(`@mastra/auth-workos`) - **MastraAuthBetterAuth**: Better Auth 連携(`@mastra/auth-better-auth`) - **SimpleAuth**: 開発用のトークンとユーザーのマッピング(`@mastra/core/server`) 実装の詳細については、[ソースコード](https://github.com/mastra-ai/mastra/tree/main/auth)を参照してください。 ## 関連項目 - [認証の概要](https://mastra.zisheng.pro/ja/docs/server/auth): 認証の概念と設定 - [カスタム API ルート](https://mastra.zisheng.pro/ja/docs/server/custom-api-routes): カスタムエンドポイントの認証制御