Press n or j to go to the next uncovered block, b, p or k for the previous block.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 | 139x 139x 139x 139x | import type { Document } from '../../bson'; import { MongoMissingCredentialsError } from '../../error'; import { ns } from '../../utils'; import type { HandshakeDocument } from '../connect'; import { type AuthContext, AuthProvider } from './auth_provider'; import type { MongoCredentials } from './mongo_credentials'; export class X509 extends AuthProvider { override async prepare( handshakeDoc: HandshakeDocument, authContext: AuthContext ): Promise<HandshakeDocument> { const { credentials } = authContext; if (!credentials) { throw new MongoMissingCredentialsError('AuthContext must provide credentials.'); } return { ...handshakeDoc, speculativeAuthenticate: x509AuthenticateCommand(credentials) }; } override async auth(authContext: AuthContext) { const connection = authContext.connection; const credentials = authContext.credentials; if (!credentials) { throw new MongoMissingCredentialsError('AuthContext must provide credentials.'); } const response = authContext.response; if (response?.speculativeAuthenticate) { return; } await connection.command(ns('$external.$cmd'), x509AuthenticateCommand(credentials), undefined); } } function x509AuthenticateCommand(credentials: MongoCredentials) { const command: Document = { authenticate: 1, mechanism: 'MONGODB-X509' }; if (credentials.username) { command.user = credentials.username; } return command; } |