1 files changed, 148 insertions, 0 deletions
diff --git a/etherpad/src/etherpad/db_migrations/migration_runner.js b/etherpad/src/etherpad/db_migrations/migration_runner.js
new file mode 100644
index 0000000..f4fa861
--- /dev/null
+++ b/etherpad/src/etherpad/db_migrations/migration_runner.js
@@ -0,0 +1,148 @@
+/**
+ * Copyright 2009 Google Inc.
+ * 
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS-IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+// Database migrations.
+
+import("sqlbase.sqlcommon");
+import("sqlbase.sqlobj");
+
+import("etherpad.globals.*");
+import("etherpad.utils.*");
+import("etherpad.log");
+import("etherpad.pne.pne_utils");
+
+jimport("java.lang.System.out.println");
+
+//----------------------------------------------------------------
+// 1 migration per file
+//----------------------------------------------------------------
+
+var migrations = [
+  "m0000_test",
+  "m0001_eepnet_signups_init",
+  "m0002_eepnet_signups_2",
+  "m0003_create_tests_table_v2",
+  "m0004_convert_all_tables_to_innodb",
+  "m0005_create_billing_tables",
+  "m0006_eepnet_signups_3",
+  "m0007_create_pro_tables_v4",
+  "m0008_persistent_vars",
+  "m0009_pad_tables",
+  "m0010_pad_sqlmeta",
+  "m0011_pro_users_temppass",
+  "m0012_pro_users_auto_signin",
+  "m0013_pne_padv2_upgrade",
+  "m0014_pne_globalpadids",
+  "m0015_padmeta_passwords",
+  "m0016_pne_tracking_data",
+  "m0017_pne_tracking_data_v2",
+  "m0018_eepnet_checkout_tables",
+  "m0019_padmeta_deleted",
+  "m0020_padmeta_archived",
+  "m0021_pro_padmeta_json",
+  "m0022_create_userids_table",
+  "m0023_create_usagestats_table",
+  "m0024_statistics_table",
+  "m0025_rename_pro_users_table",
+  "m0026_create_guests_table",
+  "m0027_pro_config",
+  "m0028_ondemand_beta_emails",
+  "m0029_lowercase_subdomains",
+  "m0030_fix_statistics_values",
+  "m0031_deleted_pro_users",
+  "m0032_reduce_topvalues_counts",
+  "m0033_pro_account_usage",
+  "m0034_create_recurring_billing_table",
+  "m0035_add_email_to_paymentinfo",
+  "m0036_create_missing_subscription_records",
+  "m0037_create_pro_referral_table",
+  "m0038_pad_coarse_revs",
+  "m0040_create_plugin_tables"
+];
+
+var mscope = this;
+migrations.forEach(function(m) {
+  import.call(mscope, "etherpad.db_migrations."+m);
+});
+
+//----------------------------------------------------------------
+
+function dmesg(m) {
+  if ((!isProduction()) || appjet.cache.db_migrations_print_debug) {
+    log.info(m);
+    println(m);
+  }
+}
+
+function onStartup() {
+  appjet.cache.db_migrations_print_debug = true;
+  if (!sqlcommon.doesTableExist("db_migrations")) {
+    appjet.cache.db_migrations_print_debug = false;
+    sqlobj.createTable('db_migrations', {
+      id: 'INT NOT NULL '+sqlcommon.autoIncrementClause()+' PRIMARY KEY',
+      name: 'VARCHAR(255) NOT NULL UNIQUE',
+      completed: 'TIMESTAMP'
+    });
+  }
+
+  if (pne_utils.isPNE()) { pne_utils.checkDbVersionUpgrade(); }
+  runMigrations();
+  if (pne_utils.isPNE()) { pne_utils.saveDbVersion(); }
+}
+
+function _migrationName(m) {
+  m = m.replace(/^m\d+\_/, '');
+  m = m.replace(/\_/g, '-');
+  return m;
+}
+
+function getCompletedMigrations() {
+  var completedMigrationsList = sqlobj.selectMulti('db_migrations', {}, {});
+  var completedMigrations = {};
+
+  completedMigrationsList.forEach(function(c) {
+    completedMigrations[c.name] = true;
+  });
+
+  return completedMigrations;
+}
+
+function runMigrations() {
+  var completedMigrations = getCompletedMigrations();
+
+  dmesg("Checking for database migrations...");
+  migrations.forEach(function(m) {
+    var name = _migrationName(m);
+    if (!completedMigrations[name]) {
+      sqlcommon.inTransaction(function() {
+        dmesg("performing database migration: ["+name+"]");
+        var startTime = +(new Date);
+
+        mscope[m].run();
+
+        var elapsedMs = +(new Date) - startTime;
+        dmesg("migration completed in "+elapsedMs+"ms");
+
+        sqlobj.insert('db_migrations', {
+          name: name,
+          completed: new Date()
+        });
+      });
+    }
+  });
+}
+
+