adapter.js 1.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354
  1. const Path = require('path')
  2. class Adapter {
  3. constructor(params) {
  4. if (
  5. !process.env.SKIP_TAG_CHECK &&
  6. !process.argv.includes('create') &&
  7. !(process.argv.includes('-t') || process.argv.includes('--tags'))
  8. ) {
  9. console.error("ERROR: must pass tags using '-t' or '--tags', exiting")
  10. process.exit(1)
  11. }
  12. this.params = params || {}
  13. }
  14. getTemplatePath() {
  15. return Path.resolve(__dirname, 'template.js')
  16. }
  17. async connect() {
  18. const { waitForDb, db } = require('../../app/src/infrastructure/mongodb')
  19. await waitForDb()
  20. return { db }
  21. }
  22. disconnect() {
  23. return Promise.resolve()
  24. }
  25. async getExecutedMigrationNames() {
  26. const { db } = await this.connect()
  27. const migrations = await db.migrations
  28. .find({}, { sort: { migratedAt: 1 }, projection: { name: 1 } })
  29. .toArray()
  30. return migrations.map(migration => migration.name)
  31. }
  32. async markExecuted(name) {
  33. const { db } = await this.connect()
  34. return db.migrations.insertOne({
  35. name,
  36. migratedAt: new Date(),
  37. })
  38. }
  39. async unmarkExecuted(name) {
  40. const { db } = await this.connect()
  41. return db.migrations.deleteOne({
  42. name,
  43. })
  44. }
  45. }
  46. module.exports = Adapter