Skip to content

Commit 48aaa45

Browse files
committed
feat(api): promisify all current api methods
1 parent ad4d8f6 commit 48aaa45

File tree

1 file changed

+36
-9
lines changed

1 file changed

+36
-9
lines changed

api.js

+36-9
Original file line numberDiff line numberDiff line change
@@ -184,7 +184,10 @@ dbmigrate.prototype = {
184184
}
185185
}
186186

187-
executeUp(this.internals, this.config, callback);
187+
return Promise.fromCallback(function(callback) {
188+
189+
executeUp(this.internals, this.config, callback);
190+
}.bind(this)).asCallback(callback);
188191
},
189192

190193
/**
@@ -214,7 +217,10 @@ dbmigrate.prototype = {
214217
}
215218
}
216219

217-
executeDown(this.internals, this.config, callback);
220+
return Promise.fromCallback(function(callback) {
221+
222+
executeDown(this.internals, this.config, callback);
223+
}.bind(this)).asCallback(callback);
218224
},
219225

220226
/**
@@ -232,7 +238,10 @@ dbmigrate.prototype = {
232238
}
233239

234240
this.internals.argv.count = Number.MAX_VALUE;
235-
executeDown(this.internals, this.config, callback);
241+
return Promise.fromCallback(function(callback) {
242+
243+
executeDown(this.internals, this.config, callback);
244+
}.bind(this)).asCallback(callback);
236245
},
237246

238247
/**
@@ -257,7 +266,10 @@ dbmigrate.prototype = {
257266
}
258267

259268
this.internals.argv._.push(migrationName);
260-
executeCreateMigration(this.internals, this.config, callback);
269+
return Promise.fromCallback(function(callback) {
270+
271+
executeCreateMigration(this.internals, this.config, callback);
272+
}.bind(this)).asCallback(callback);
261273
},
262274

263275
/**
@@ -267,7 +279,10 @@ dbmigrate.prototype = {
267279

268280
this.internals.argv._.push(dbname);
269281
this.internals.mode = 'create';
270-
executeDB(this.internals, this.config, callback);
282+
return Promise.fromCallback(function(callback) {
283+
284+
executeDB(this.internals, this.config, callback);
285+
}.bind(this)).asCallback(callback);
271286
},
272287

273288
/**
@@ -277,7 +292,10 @@ dbmigrate.prototype = {
277292

278293
this.internals.argv._.push(dbname);
279294
this.internals.mode = 'drop';
280-
executeDB(this.internals, this.config, callback);
295+
return Promise.fromCallback(function(callback) {
296+
297+
executeDB(this.internals, this.config, callback);
298+
}.bind(this)).asCallback(callback);
281299
},
282300

283301
/**
@@ -320,7 +338,10 @@ dbmigrate.prototype = {
320338
}
321339

322340
this.internals.mode = mode || 'vc';
323-
executeSeed(this.internals, this.config, callback);
341+
return Promise.fromCallback(function(callback) {
342+
343+
executeSeed(this.internals, this.config, callback);
344+
}.bind(this)).asCallback(callback);
324345
},
325346

326347
/**
@@ -343,7 +364,10 @@ dbmigrate.prototype = {
343364
}
344365
}
345366

346-
executeUndoSeed(this.internals, this.config, callback);
367+
return Promise.fromCallback(function(callback) {
368+
369+
executeUndoSeed(this.internals, this.config, callback);
370+
}.bind(this)).asCallback(callback);
347371
},
348372

349373
/**
@@ -367,7 +391,10 @@ dbmigrate.prototype = {
367391
}
368392

369393
this.internals.argv.count = Number.MAX_VALUE;
370-
executeUndoSeed(this.internals, this.config, callback);
394+
return Promise.fromCallback(function(callback) {
395+
396+
executeUndoSeed(this.internals, this.config, callback);
397+
}.bind(this)).asCallback(callback);
371398
},
372399

373400
/**

0 commit comments

Comments
 (0)