@@ -8,16 +8,15 @@ var onComplete = load('on-complete');
8
8
9
9
// constant hooks for this file
10
10
var APIHooks = {
11
- 'init:api:addfunction:hook' : function ( name , fn ) {
11
+ 'init:api:addfunction:hook' : function ( name , fn ) {
12
12
this [ name ] = fn ;
13
- return ;
14
13
} ,
15
- 'init:api:accessapi:hook' : function ( cb ) {
14
+ 'init:api:accessapi:hook' : function ( cb ) {
16
15
return cb ( this ) ;
17
16
}
18
17
} ;
19
18
20
- function dbmigrate ( plugins , isModule , options , callback ) {
19
+ function dbmigrate ( plugins , isModule , options , callback ) {
21
20
var dotenv = require ( 'dotenv' ) ;
22
21
var setDefaultArgv = load ( 'set-default-argv' ) ;
23
22
@@ -44,10 +43,7 @@ function dbmigrate(plugins, isModule, options, callback) {
44
43
/* $lab:coverage:on$ */
45
44
46
45
if ( typeof options === 'object' ) {
47
- if ( typeof options . config === 'string' )
48
- internals . configFile = options . config ;
49
- else if ( typeof options . config === 'object' )
50
- internals . configObject = options . config ;
46
+ if ( typeof options . config === 'string' ) { internals . configFile = options . config ; } else if ( typeof options . config === 'object' ) { internals . configObject = options . config ; }
51
47
52
48
if ( typeof options . env === 'string' ) internals . currentEnv = options . env ;
53
49
@@ -65,7 +61,7 @@ function dbmigrate(plugins, isModule, options, callback) {
65
61
this . internals
66
62
) ;
67
63
68
- //delayed loading of bluebird
64
+ // delayed loading of bluebird
69
65
Promise = require ( 'bluebird' ) ;
70
66
this . internals . migrationOptions = {
71
67
dbmigrate : this . internals . dbm ,
@@ -85,7 +81,7 @@ dbmigrate.prototype = {
85
81
*
86
82
* @return boolean
87
83
*/
88
- addGlobal : function ( library ) {
84
+ addGlobal : function ( library ) {
89
85
try {
90
86
require ( library ) ;
91
87
} catch ( e ) {
@@ -100,22 +96,22 @@ dbmigrate.prototype = {
100
96
*
101
97
* @returns Promise
102
98
*/
103
- registerAPIHook : function ( callback ) {
99
+ registerAPIHook : function ( callback ) {
104
100
var plugins = this . internals . plugins ;
105
101
var self = this ;
106
102
107
103
return Promise . resolve ( Object . keys ( APIHooks ) )
108
- . each ( function ( hook ) {
104
+ . each ( function ( hook ) {
109
105
var plugin = plugins . hook ( hook ) ;
110
106
if ( ! plugin ) return ;
111
107
112
108
var APIHook = APIHooks [ hook ] . bind ( self ) ;
113
109
114
110
return Promise . resolve ( plugin )
115
- . map ( function ( plugin ) {
111
+ . map ( function ( plugin ) {
116
112
return plugin [ hook ] ( ) ;
117
113
} )
118
- . each ( function ( args ) {
114
+ . each ( function ( args ) {
119
115
return APIHook . apply ( self , args ) ;
120
116
} ) ;
121
117
} )
@@ -129,7 +125,7 @@ dbmigrate.prototype = {
129
125
*
130
126
* @return boolean
131
127
*/
132
- addConfiguration : function ( description , args , type ) {
128
+ addConfiguration : function ( description , args , type ) {
133
129
var name = args . shift ( ) ;
134
130
this . internals . argv . describe ( name , description ) ;
135
131
@@ -156,7 +152,7 @@ dbmigrate.prototype = {
156
152
/**
157
153
* Resets and sets argv to a specified new argv.
158
154
*/
159
- resetConfiguration : function ( argv ) {
155
+ resetConfiguration : function ( argv ) {
160
156
this . internals . argv = argv ;
161
157
} ,
162
158
@@ -165,7 +161,7 @@ dbmigrate.prototype = {
165
161
*
166
162
* Defaults to up all migrations if no count is given.
167
163
*/
168
- up : function ( specification , opts , callback ) {
164
+ up : function ( specification , opts , callback ) {
169
165
var executeUp = load ( 'up' ) ;
170
166
171
167
if ( arguments . length > 0 ) {
@@ -186,7 +182,7 @@ dbmigrate.prototype = {
186
182
}
187
183
188
184
return Promise . fromCallback (
189
- function ( callback ) {
185
+ function ( callback ) {
190
186
executeUp ( this . internals , this . config , callback ) ;
191
187
} . bind ( this )
192
188
) . asCallback ( callback ) ;
@@ -197,7 +193,7 @@ dbmigrate.prototype = {
197
193
*
198
194
* Defaults to up all migrations if no count is given.
199
195
*/
200
- down : function ( specification , opts , callback ) {
196
+ down : function ( specification , opts , callback ) {
201
197
var executeDown = load ( 'down' ) ;
202
198
203
199
if ( arguments . length > 0 ) {
@@ -216,7 +212,7 @@ dbmigrate.prototype = {
216
212
}
217
213
218
214
return Promise . fromCallback (
219
- function ( callback ) {
215
+ function ( callback ) {
220
216
executeDown ( this . internals , this . config , callback ) ;
221
217
} . bind ( this )
222
218
) . asCallback ( callback ) ;
@@ -227,7 +223,7 @@ dbmigrate.prototype = {
227
223
*
228
224
* Defaults to up all migrations if no count is given.
229
225
*/
230
- sync : function ( specification , opts , callback ) {
226
+ sync : function ( specification , opts , callback ) {
231
227
var executeSync = load ( 'sync' ) ;
232
228
233
229
if ( arguments . length > 0 ) {
@@ -244,7 +240,7 @@ dbmigrate.prototype = {
244
240
}
245
241
246
242
return Promise . fromCallback (
247
- function ( callback ) {
243
+ function ( callback ) {
248
244
executeSync ( this . internals , this . config , callback ) ;
249
245
} . bind ( this )
250
246
) . asCallback ( callback ) ;
@@ -253,7 +249,7 @@ dbmigrate.prototype = {
253
249
/**
254
250
* Executes down for all currently migrated migrations.
255
251
*/
256
- reset : function ( scope , callback ) {
252
+ reset : function ( scope , callback ) {
257
253
var executeDown = load ( 'down' ) ;
258
254
259
255
if ( typeof scope === 'string' ) {
@@ -265,7 +261,7 @@ dbmigrate.prototype = {
265
261
266
262
this . internals . argv . count = Number . MAX_VALUE ;
267
263
return Promise . fromCallback (
268
- function ( callback ) {
264
+ function ( callback ) {
269
265
executeDown ( this . internals , this . config , callback ) ;
270
266
} . bind ( this )
271
267
) . asCallback ( callback ) ;
@@ -274,21 +270,21 @@ dbmigrate.prototype = {
274
270
/**
275
271
* Silence the log output completely.
276
272
*/
277
- silence : function ( isSilent ) {
273
+ silence : function ( isSilent ) {
278
274
return log . silence ( isSilent ) ;
279
275
} ,
280
276
281
277
/**
282
278
* Transition migrations to the latest defined protocol.
283
279
*/
284
- transition : function ( ) {
280
+ transition : function ( ) {
285
281
transition ( this . internals ) ;
286
282
} ,
287
283
288
284
/**
289
285
* Creates a correctly formatted migration
290
286
*/
291
- create : function ( migrationName , scope , callback ) {
287
+ create : function ( migrationName , scope , callback ) {
292
288
var executeCreateMigration = load ( 'create-migration' ) ;
293
289
if ( typeof scope === 'function' ) {
294
290
callback = scope ;
@@ -299,7 +295,7 @@ dbmigrate.prototype = {
299
295
300
296
this . internals . argv . _ . push ( migrationName ) ;
301
297
return Promise . fromCallback (
302
- function ( callback ) {
298
+ function ( callback ) {
303
299
executeCreateMigration ( this . internals , this . config , callback ) ;
304
300
} . bind ( this )
305
301
) . asCallback ( callback ) ;
@@ -308,12 +304,12 @@ dbmigrate.prototype = {
308
304
/**
309
305
* Creates a database of the given dbname.
310
306
*/
311
- createDatabase : function ( dbname , callback ) {
307
+ createDatabase : function ( dbname , callback ) {
312
308
var executeDB = load ( 'db' ) ;
313
309
this . internals . argv . _ . push ( dbname ) ;
314
310
this . internals . mode = 'create' ;
315
311
return Promise . fromCallback (
316
- function ( callback ) {
312
+ function ( callback ) {
317
313
executeDB ( this . internals , this . config , callback ) ;
318
314
} . bind ( this )
319
315
) . asCallback ( callback ) ;
@@ -322,12 +318,12 @@ dbmigrate.prototype = {
322
318
/**
323
319
* Drops a database of the given dbname.
324
320
*/
325
- dropDatabase : function ( dbname , callback ) {
321
+ dropDatabase : function ( dbname , callback ) {
326
322
var executeDB = load ( 'db' ) ;
327
323
this . internals . argv . _ . push ( dbname ) ;
328
324
this . internals . mode = 'drop' ;
329
325
return Promise . fromCallback (
330
- function ( callback ) {
326
+ function ( callback ) {
331
327
executeDB ( this . internals , this . config , callback ) ;
332
328
} . bind ( this )
333
329
) . asCallback ( callback ) ;
@@ -338,30 +334,30 @@ dbmigrate.prototype = {
338
334
*
339
335
* @return value
340
336
*/
341
- setConfigParam : function ( param , value ) {
337
+ setConfigParam : function ( param , value ) {
342
338
return ( this . internals . argv [ param ] = value ) ;
343
339
} ,
344
340
345
341
/**
346
342
* Sets the callback to the default onComplete
347
343
*/
348
- setDefaultCallback : function ( ) {
344
+ setDefaultCallback : function ( ) {
349
345
this . internals . onComplete = onComplete ;
350
346
} ,
351
347
352
348
/**
353
349
* Let's the user customize the callback, which gets called after all
354
350
* migrations have been done.
355
351
*/
356
- setCustomCallback : function ( callback ) {
352
+ setCustomCallback : function ( callback ) {
357
353
this . internals . onComplete = callback ;
358
354
} ,
359
355
360
356
/**
361
357
* Seeds either the static or version controlled seeders, controlled by
362
358
* the passed mode.
363
359
*/
364
- seed : function ( mode , scope , callback ) {
360
+ seed : function ( mode , scope , callback ) {
365
361
var executeSeed = load ( 'seed' ) ;
366
362
if ( scope ) {
367
363
this . internals . migrationMode = scope ;
@@ -370,7 +366,7 @@ dbmigrate.prototype = {
370
366
371
367
this . internals . mode = mode || 'vc' ;
372
368
return Promise . fromCallback (
373
- function ( callback ) {
369
+ function ( callback ) {
374
370
executeSeed ( this . internals , this . config , callback ) ;
375
371
} . bind ( this )
376
372
) . asCallback ( callback ) ;
@@ -379,7 +375,7 @@ dbmigrate.prototype = {
379
375
/**
380
376
* Execute the down function of currently executed seeds.
381
377
*/
382
- undoSeed : function ( specification , scope , callback ) {
378
+ undoSeed : function ( specification , scope , callback ) {
383
379
var executeUndoSeed = load ( 'undo-seed' ) ;
384
380
if ( arguments . length > 0 ) {
385
381
if ( typeof specification === 'number' ) {
@@ -396,7 +392,7 @@ dbmigrate.prototype = {
396
392
}
397
393
398
394
return Promise . fromCallback (
399
- function ( callback ) {
395
+ function ( callback ) {
400
396
executeUndoSeed ( this . internals , this . config , callback ) ;
401
397
} . bind ( this )
402
398
) . asCallback ( callback ) ;
@@ -405,7 +401,7 @@ dbmigrate.prototype = {
405
401
/**
406
402
* Execute the reset function of currently executed seeds.
407
403
*/
408
- resetSeed : function ( specification , scope , callback ) {
404
+ resetSeed : function ( specification , scope , callback ) {
409
405
var executeUndoSeed = load ( 'undo-seed' ) ;
410
406
if ( arguments . length > 0 ) {
411
407
if ( typeof specification === 'number' ) {
@@ -423,7 +419,7 @@ dbmigrate.prototype = {
423
419
424
420
this . internals . argv . count = Number . MAX_VALUE ;
425
421
return Promise . fromCallback (
426
- function ( callback ) {
422
+ function ( callback ) {
427
423
executeUndoSeed ( this . internals , this . config , callback ) ;
428
424
} . bind ( this )
429
425
) . asCallback ( callback ) ;
@@ -432,7 +428,7 @@ dbmigrate.prototype = {
432
428
/**
433
429
* Executes the default routine.
434
430
*/
435
- run : function ( ) {
431
+ run : function ( ) {
436
432
load ( 'run' ) ( this . internals , this . config ) ;
437
433
}
438
434
} ;
0 commit comments