-
Notifications
You must be signed in to change notification settings - Fork 0
/
test.js
114 lines (95 loc) · 2.65 KB
/
test.js
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
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
var fs = require('fs')
var test = require('tape')
var mkdirp = require('mkdirp')
var rimraf = require('rimraf')
var omg = require('./')
var each = require('./each')
test('Should run migrations in the correct order', function (t) {
t.plan(8)
clearMigrations(function (err) {
t.ifError(err, 'No error clearing migrations')
var migrations = [
'0.0.0_schema',
'0.1.0_update',
'1.0.0-alpha_add-fields',
'1.0.0_final-schema-changes',
'2.0.0_two-point-oh'
]
createMigrations(shuffle(migrations.slice()), function (err) {
t.ifError(err, 'No error creating migrations')
var i = 0
omg({
dir: __dirname + '/tmp',
did: function (name, cb) {
t.equal(name, migrations[i], 'Migration name was ' + migrations[i])
i++
cb()
},
done: function (err) {
t.ifError(err, 'No error performing migrations')
t.end()
}
})
})
})
})
test('Should skip a migration if already done', function (t) {
t.plan(4)
clearMigrations(function (err) {
t.ifError(err, 'No error clearing migrations')
var migrations = [
'0.0.0_schema',
'0.1.0_update',
'1.0.0-alpha_add-fields',
'1.0.0_final-schema-changes',
'2.0.0_two-point-oh'
]
createMigrations(shuffle(migrations.slice()), function (err) {
t.ifError(err, 'No error creating migrations')
omg({
dir: __dirname + '/tmp',
should: function (name, cb) {
cb(null, name === '2.0.0_two-point-oh')
},
did: function (name, cb) {
t.equal(name, '2.0.0_two-point-oh', 'Migrated last migration only')
cb()
},
done: function (err) {
t.ifError(err, 'No error performing migrations')
t.end()
}
})
})
})
})
function clearMigrations (cb) {
rimraf(__dirname + '/tmp', cb)
}
function createMigrations (names, cb) {
mkdirp(__dirname + '/tmp', function (err) {
if (err) return cb(err)
each(names, function (name, cb) {
var timeout = randomInt(0, 1000)
var code = 'module.exports = function (cb) { setTimeout(cb, ' + timeout + ') }'
fs.writeFile(__dirname + '/tmp/' + name + '.js', code, 'utf8', cb)
}, cb)
})
}
function randomInt (min, max) {
return Math.floor(Math.random() * (max - min)) + min
}
function shuffle (array) {
var m = array.length
var t, i
// While there remain elements to shuffle…
while (m) {
// Pick a remaining element…
i = Math.floor(Math.random() * m--)
// And swap it with the current element.
t = array[m]
array[m] = array[i]
array[i] = t
}
return array
}