text: /**
   * Copyright (C) 2017 MongoDB Inc.
   *
   * This program is free software: you can redistribute it and/or  modify
   * it under the terms of the GNU Affero General Public License, version 3,
   * as published by the Free Software Foundation.
   *
   * This program is distributed in the hope that it will be useful,
   * but WITHOUT ANY WARRANTY; without even the implied warranty of
   * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
   * GNU Affero General Public License for more details.
   *
   * You should have received a copy of the GNU Affero General Public License
   * along with this program.  If not, see <http://www.gnu.org/licenses/>.
   *
   * As a special exception, the copyright holders give permission to link the
   * code of portions of this program with the OpenSSL library under certain
   * conditions as described in each individual source file and distribute
   * linked combinations including the program with the OpenSSL library. You
   * must comply with the GNU Affero General Public License in all respects
   * for all of the code used other than as permitted herein. If you modify
   * file(s) with this exception, you may extend this exception to your
   * version of the file(s), but you are not obligated to do so. If you do not
   * wish to do so, delete this exception statement from your version. If you
   * delete this exception statement from all source files in the program,
   * then also delete it in the license file.
   */
  
  #include "mongo/platform/basic.h"
  
  #include "mongo/db/sessions_collection_standalone.h"
  
  #include "mongo/client/query.h"
  #include "mongo/db/dbdirectclient.h"
  #include "mongo/db/operation_context.h"
  #include "mongo/rpc/get_status_from_command_result.h"
  
  namespace mongo {
  
  namespace {
  
  BSONObj lsidQuery(const LogicalSessionId& lsid) {
      return BSON(LogicalSessionRecord::kIdFieldName << lsid.toBSON());
  }
  }  // namespace
  
  Status SessionsCollectionStandalone::setupSessionsCollection(OperationContext* opCtx) {
      DBDirectClient client(opCtx);
      auto cmd = generateCreateIndexesCmd();
      BSONObj info;
      if (!client.runCommand(NamespaceString::kLogicalSessionsNamespace.db().toString(), cmd, info)) {
          return getStatusFromCommandResult(info);
      }
  
      return Status::OK();
  }
  
  Status SessionsCollectionStandalone::checkSessionsCollectionExists(OperationContext* opCtx) {
      DBDirectClient client(opCtx);
  
      auto indexes = client.getIndexSpecs(NamespaceString::kLogicalSessionsNamespace.toString());
  
      if (indexes.size() == 0u) {
          return Status{ErrorCodes::NamespaceNotFound, "config.system.sessions does not exist"};
      }
  
      auto indexExists = std::find_if(indexes.begin(), indexes.end(), [](const BSONObj& index) {
          return index.getField("name").String() == kSessionsTTLIndex;
      });
  
      if (indexExists == indexes.end()) {
          return Status{ErrorCodes::IndexNotFound,
                        "config.system.sessions does not have the required TTL index"};
      };
  
      return Status::OK();
  }
  
  Status SessionsCollectionStandalone::refreshSessions(OperationContext* opCtx,
                                                       const LogicalSessionRecordSet& sessions) {
      DBDirectClient client(opCtx);
      return doRefresh(NamespaceString::kLogicalSessionsNamespace,
                       sessions,
                       makeSendFnForBatchWrite(NamespaceString::kLogicalSessionsNamespace, &client));
  }
  
  Status SessionsCollectionStandalone::removeRecords(OperationContext* opCtx,
                                                     const LogicalSessionIdSet& sessions) {
      DBDirectClient client(opCtx);
      return doRemove(NamespaceString::kLogicalSessionsNamespace,
                      sessions,
                      makeSendFnForBatchWrite(NamespaceString::kLogicalSessionsNamespace, &client));
  }
  
  StatusWith<LogicalSessionIdSet> SessionsCollectionStandalone::findRemovedSessions(
      OperationContext* opCtx, const LogicalSessionIdSet& sessions) {
      DBDirectClient client(opCtx);
      return doFetch(NamespaceString::kLogicalSessionsNamespace,
                     sessions,
                     makeFindFnForCommand(NamespaceString::kLogicalSessionsNamespace, &client));
  }
  
  Status SessionsCollectionStandalone::removeTransactionRecords(OperationContext* opCtx,
                                                                const LogicalSessionIdSet& sessions) {
      MONGO_UNREACHABLE;
  }
  
  }  // namespace mongo
  