var baseDir = "jstests_disk_directoryper";
var baseName = "directoryperdb";
var dbpath = MongoRunner.dataPath + baseDir + "/";
var storageEngine = db.serverStatus().storageEngine.name;

// The pattern which matches the names of database files
var dbFileMatcher;
if (storageEngine == "mmapv1") {
    // Matches mmapv1 *.ns and *.0, *.1, etc files.
    dbFileMatcher = /\.(ns|\d+)$/;
} else if (storageEngine == "wiredTiger") {
    // Matches wiredTiger collection-*.wt and index-*.wt files
    dbFileMatcher = /(collection|index)-.+\.wt$/;
} else {
    assert(false, "This test must be run against mmapv1 or wiredTiger");
}

// Set up helper functions.
assertDocumentCount = function(db, count) {
    assert.eq(count,
              db[baseName].count(),
              "Expected " + count + " documents in " + db._name + "." + baseName + ". " +
                  "Found: " + tojson(db[baseName].find().toArray()));
};

checkDBFilesInDBDirectory = function(db) {
    db.adminCommand({fsync: 1});

    var dir = dbpath + db._name;
    files = listFiles(dir);
    var fileCount = 0;
    for (f in files) {
        if (files[f].isDirectory)
            continue;
        fileCount += 1;
        assert(dbFileMatcher.test(files[f].name),
               "In directory:" + dir + " found unexpected file: " + files[f].name);
    }
    assert(fileCount > 0, "Expected more than zero nondirectory files in database directory");
};

checkDBDirectoryNonexistent = function(db) {
    db.adminCommand({fsync: 1});

    var files = listFiles(dbpath);
    // Check that there are no files in the toplevel dbpath.
    for (f in files) {
        if (!files[f].isDirectory) {
            assert(!dbFileMatcher.test(files[f].name),
                   "Database file" + files[f].name +
                       " exists in dbpath after deleting all non-directoryperdb databases");
        }
    }

    // Check db directories to ensure db files in them have been destroyed.
    // mmapv1 removes the database directory, pending SERVER-1379.
    if (storageEngine == "mmapv1") {
        var files = listFiles(dbpath);
        var fileNotFound = true;
        for (f in files) {
            assert(files[f].name != db._name, "Directory " + db._name + " still exists");
        }
    } else if (storageEngine == "wiredTiger") {
        var files = listFiles(dbpath + db._name);
        assert.eq(files.length, 0, "Files left behind in database directory");
    }
};

// Start the directoryperdb instance of mongod.
var m = MongoRunner.runMongod({storageEngine: storageEngine, dbpath: dbpath, directoryperdb: ""});
// Check that the 'local' db has allocated data.
var localDb = m.getDB("local");
checkDBFilesInDBDirectory(localDb);

// Create database with directoryperdb.
var dbBase = m.getDB(baseName);
dbBase[baseName].insert({});
assertDocumentCount(dbBase, 1);
checkDBFilesInDBDirectory(dbBase);

// Drop a database created with directoryperdb.
assert.commandWorked(dbBase.runCommand({dropDatabase: 1}));
assertDocumentCount(dbBase, 0);
checkDBDirectoryNonexistent(dbBase);

// It should be impossible to create a database named "journal" with directoryperdb, as that
// directory exists. This test has been disabled until SERVER-2460 is resolved.
/*
db = m.getDB( "journal" );
assert.writeError(db[ "journal" ].insert( {} ));
*/

// Using WiredTiger, it should be impossible to create a database named "WiredTiger" with
// directoryperdb, as that file is created by the WiredTiger storageEngine.
if (storageEngine == "wiredTiger") {
    var dbW = m.getDB("WiredTiger");
    assert.writeError(dbW[baseName].insert({}));
}

// Create a database named 'a' repeated 63 times.
var dbNameAA = Array(64).join('a');
var dbAA = m.getDB(dbNameAA);
assert.writeOK(dbAA[baseName].insert({}));
assertDocumentCount(dbAA, 1);
checkDBFilesInDBDirectory(dbAA);

// Create a database named '&'.
var dbAnd = m.getDB('&');
assert.writeOK(dbAnd[baseName].insert({}));
assertDocumentCount(dbAnd, 1);
checkDBFilesInDBDirectory(dbAnd);

// Unicode directoryperdb databases do not work on Windows.
// Disabled until https://jira.mongodb.org/browse/SERVER-16725
// is resolved.
if (!_isWindows()) {
    // Create a database named '処'.
    var dbNameU = '処';
    var dbU = m.getDB(dbNameU);
    assert.writeOK(dbU[baseName].insert({}));
    assertDocumentCount(dbU, 1);
    checkDBFilesInDBDirectory(dbU);

    // Create a database named '処' repeated 21 times.
    var dbNameUU = Array(22).join('処');
    var dbUU = m.getDB(dbNameUU);
    assert.writeOK(dbUU[baseName].insert({}));
    assertDocumentCount(dbUU, 1);
    checkDBFilesInDBDirectory(dbUU);
}

print("SUCCESS directoryperdb.js");