芝麻web文件管理V1.00

编辑当前文件:/home/freeclou/app.optimyar.com/backend/node_modules/mongodb/lib/core/auth/gssapi.js

'use strict';
const dns = require('dns');

const AuthProvider = require('./auth_provider').AuthProvider;
const retrieveKerberos = require('../utils').retrieveKerberos;
const MongoError = require('../error').MongoError;

const kGssapiClient = Symbol('GSSAPI_CLIENT');
let kerberos;

class GSSAPI extends AuthProvider {
  prepare(handshakeDoc, authContext, callback) {
    const host = authContext.options.host;
    const port = authContext.options.port;
    const credentials = authContext.credentials;
    if (!host || !port || !credentials) {
      return callback(
        new MongoError(
          `Connection must specify: ${host ? 'host' : ''}, ${port ? 'port' : ''}, ${
            credentials ? 'host' : 'credentials'
          }.`
        )
      );
    }
    if (kerberos == null) {
      try {
        kerberos = retrieveKerberos();
      } catch (e) {
        return callback(e);
      }
    }
    const username = credentials.username;
    const password = credentials.password;
    const mechanismProperties = credentials.mechanismProperties;
    const serviceName =
      mechanismProperties['gssapiservicename'] ||
      mechanismProperties['gssapiServiceName'] ||
      'mongodb';
    performGssapiCanonicalizeHostName(host, mechanismProperties, (err, host) => {
      if (err) return callback(err);
      const initOptions = {};
      if (password != null) {
        Object.assign(initOptions, { user: username, password: password });
      }
      kerberos.initializeClient(
        `${serviceName}${process.platform === 'win32' ? '/' : '@'}${host}`,
        initOptions,
        (err, client) => {
          if (err) return callback(new MongoError(err));
          if (client == null) return callback();
          this[kGssapiClient] = client;
          callback(undefined, handshakeDoc);
        }
      );
    });
  }
  auth(authContext, callback) {
    const connection = authContext.connection;
    const credentials = authContext.credentials;
    if (credentials == null) return callback(new MongoError('credentials required'));
    const username = credentials.username;
    const client = this[kGssapiClient];
    if (client == null) return callback(new MongoError('gssapi client missing'));
    function externalCommand(command, cb) {
      return connection.command('$external.$cmd', command, cb);
    }
    client.step('', (err, payload) => {
      if (err) return callback(err);
      externalCommand(saslStart(payload), (err, response) => {
        const result = response.result;
        if (err) return callback(err);
        negotiate(client, 10, result.payload, (err, payload) => {
          if (err) return callback(err);
          externalCommand(saslContinue(payload, result.conversationId), (err, response) => {
            const result = response.result;
            if (err) return callback(err);
            finalize(client, username, result.payload, (err, payload) => {
              if (err) return callback(err);
              externalCommand(
                {
                  saslContinue: 1,
                  conversationId: result.conversationId,
                  payload
                },
                (err, result) => {
                  if (err) return callback(err);
                  callback(undefined, result);
                }
              );
            });
          });
        });
      });
    });
  }
}
module.exports = GSSAPI;