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
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
|
var test = require("tap").test
, path = require("path")
, fs = require("graceful-fs")
, crypto = require("crypto")
, rimraf = require("rimraf")
, osenv = require("osenv")
, mkdirp = require("mkdirp")
, npm = require("../../")
, locker = require("../../lib/utils/locker.js")
, lock = locker.lock
, unlock = locker.unlock
var pkg = path.join(__dirname, "/locker")
, cache = path.join(pkg, "/cache")
, tmp = path.join(pkg, "/tmp")
, nm = path.join(pkg, "/node_modules")
function cleanup () {
process.chdir(osenv.tmpdir())
rimraf.sync(pkg)
}
test("setup", function (t) {
cleanup()
mkdirp.sync(cache)
mkdirp.sync(tmp)
t.end()
})
test("locking file puts lock in correct place", function (t) {
npm.load({cache: cache, tmpdir: tmp}, function (er) {
t.ifError(er, "npm bootstrapped OK")
var n = "correct"
, c = n.replace(/[^a-zA-Z0-9]+/g, "-").replace(/^-+|-+$/g, "")
, p = path.resolve(nm, n)
, h = crypto.createHash("sha1").update(p).digest("hex")
, l = c.substr(0, 24)+"-"+h.substr(0, 16)+".lock"
, v = path.join(cache, "_locks", l)
lock(nm, n, function (er) {
t.ifError(er, "locked path")
fs.exists(v, function (found) {
t.ok(found, "lock found OK")
unlock(nm, n, function (er) {
t.ifError(er, "unlocked path")
fs.exists(v, function (found) {
t.notOk(found, "lock deleted OK")
t.end()
})
})
})
})
})
})
test("unlocking out of order errors out", function (t) {
npm.load({cache: cache, tmpdir: tmp}, function (er) {
t.ifError(er, "npm bootstrapped OK")
var n = "busted"
, c = n.replace(/[^a-zA-Z0-9]+/g, "-").replace(/^-+|-+$/g, "")
, p = path.resolve(nm, n)
, h = crypto.createHash("sha1").update(p).digest("hex")
, l = c.substr(0, 24)+"-"+h.substr(0, 16)+".lock"
, v = path.join(cache, "_locks", l)
fs.exists(v, function (found) {
t.notOk(found, "no lock to unlock")
t.throws(function () {
unlock(nm, n, function () {
t.fail("shouldn't get here")
t.end()
})
}, "blew up as expected")
t.end()
})
})
})
test("cleanup", function (t) {
cleanup()
t.end()
})
|
