var assert = require("assert");

var path = require("path");

var local = path.join.bind(path, __dirname);

describe("ThreadSafety", function() {

var NodeGit = require("../../");

var Repository = NodeGit.Repository;

var reposPath = local("../repos/workdir");

beforeEach(function() {

var test = this;

return Repository.open(reposPath)

.then(function(repo) {

test.repository = repo;

return repo.refreshIndex();

})

.then(function(index) {

test.index = index;

});

});

it("can enable and disable thread safety", function() {

var originalValue = NodeGit.getThreadSafetyStatus();

NodeGit.enableThreadSafety();

assert.equal(NodeGit.THREAD_SAFETY.ENABLED,

NodeGit.getThreadSafetyStatus());

NodeGit.setThreadSafetyStatus(NodeGit.THREAD_SAFETY.ENABLED_FOR_ASYNC_ONLY);

assert.equal(NodeGit.THREAD_SAFETY.ENABLED_FOR_ASYNC_ONLY,

NodeGit.getThreadSafetyStatus());

NodeGit.setThreadSafetyStatus(NodeGit.THREAD_SAFETY.DISABLED);

assert.equal(NodeGit.THREAD_SAFETY.DISABLED,

NodeGit.getThreadSafetyStatus());

NodeGit.setThreadSafetyStatus(originalValue);

});

it("can lock something and cleanup mutex", function() {

var diagnostics = NodeGit.getThreadSafetyDiagnostics();

var originalCount = diagnostics.storedMutexesCount;

// call a sync method to guarantee that it stores a mutex,

// and that it will clean up the mutex in a garbage collection cycle

this.repository.headDetached();

diagnostics = NodeGit.getThreadSafetyDiagnostics();

switch(NodeGit.getThreadSafetyStatus()) {

case NodeGit.THREAD_SAFETY.ENABLED:

// this is a fairly vague test - it just tests that something

// had a mutex created for it at some point (i.e., the thread safety

// code is not completely dead)

assert.ok(diagnostics.storedMutexesCount > 0);

break;

case NodeGit.THREAD_SAFETY.ENABLED_FOR_ASYNC_ONLY:

assert.equal(originalCount, diagnostics.storedMutexesCount);

break;

case NodeGit.THREAD_SAFETY.DISABLED:

assert.equal(0, diagnostics.storedMutexesCount);

}

});

});