1 files changed, 102 insertions, 0 deletions
diff --git a/etherpad/src/etherpad/db_migrations/m0014_pne_globalpadids.js b/etherpad/src/etherpad/db_migrations/m0014_pne_globalpadids.js
new file mode 100644
index 0000000..445b32d
--- /dev/null
+++ b/etherpad/src/etherpad/db_migrations/m0014_pne_globalpadids.js
@@ -0,0 +1,102 @@
+/**
+ * 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.
+ */
+
+import("etherpad.utils.startConsoleProgressBar");
+import("etherpad.pne.pne_utils");
+import("sqlbase.sqlobj");
+import("sqlbase.sqlbase");
+import("etherpad.log");
+import("sqlbase.sqlcommon.*");
+import("etherpad.pad.padutils");
+
+function run() {
+
+  // this is a PNE-only migration
+  if (! pne_utils.isPNE()) {
+    return;
+  }
+
+  var renamesNeeded = sqlobj.selectMulti("PAD_SQLMETA", {});
+
+  if (renamesNeeded.length == 0) {
+    return;
+  }
+
+  var renamesTotal = renamesNeeded.length;
+  var renamesSoFar = 0;
+  var progressBar = startConsoleProgressBar();
+
+  renamesNeeded.forEach(function(obj) {
+    var oldPadId = String(obj.id);
+    var newPadId;
+    if (/^1\$[a-zA-Z0-9\-]+$/.test(oldPadId)) {
+      // not expecting a user pad beginning with "1$";
+      // this case is to avoid trashing dev databases
+      newPadId = oldPadId;
+    }
+    else {
+      var localPadId = padutils.makeValidLocalPadId(oldPadId);
+      newPadId = "1$"+localPadId;
+
+      // PAD_SQLMETA
+      obj.id = newPadId;
+      sqlobj.deleteRows("PAD_SQLMETA", {id:oldPadId});
+      sqlobj.insert("PAD_SQLMETA", obj);
+
+      // PAD_META
+      var meta = sqlbase.getJSON("PAD_META", oldPadId);
+      meta.padId = newPadId;
+      sqlbase.deleteJSON("PAD_META", oldPadId);
+      sqlbase.putJSON("PAD_META", newPadId, meta);
+
+      // PAD_APOOL
+      var apool = sqlbase.getJSON("PAD_APOOL", oldPadId);
+      sqlbase.deleteJSON("PAD_APOOL", oldPadId);
+      sqlbase.putJSON("PAD_APOOL", newPadId, apool);
+
+      function renamePadInStringArrayTable(arrayName) {
+        var stmnt = "UPDATE "+btquote("PAD_"+arrayName.toUpperCase()+"_META")+
+          " SET "+btquote("ID")+" = ? WHERE "+btquote("ID")+" = ?";
+        return withConnection(function(conn) {
+          var pstmnt = conn.prepareStatement(stmnt);
+          return closing(pstmnt, function() {
+            pstmnt.setString(1, newPadId);
+            pstmnt.setString(2, oldPadId);
+            pstmnt.executeUpdate();
+          });
+        });
+      }
+
+      renamePadInStringArrayTable("revs");
+      renamePadInStringArrayTable("chat");
+      renamePadInStringArrayTable("revmeta");
+      renamePadInStringArrayTable("authors");
+
+      sqlobj.insert('pro_padmeta', {
+        localPadId: localPadId,
+        title: localPadId,
+        createdDate: obj.creationTime,
+        domainId: 1 // PNE
+      });
+    }
+
+    renamesSoFar++;
+    progressBar.update(renamesSoFar/renamesTotal, renamesSoFar+"/"+renamesTotal+" pads");
+  });
+
+  progressBar.finish();
+}
+