From 3f6b36d96e7e718ff7fb9d98a8211448f6b0d7e9 Mon Sep 17 00:00:00 2001
From: Kegan Dougal <kegan@matrix.org>
Date: Mon, 2 Mar 2015 11:39:58 +0000
Subject: Add upgrade script

---
 scripts/upgrade_appservice_db.py | 36 ++++++++++++++++++++++++++++++++++++
 1 file changed, 36 insertions(+)
 create mode 100644 scripts/upgrade_appservice_db.py

(limited to 'scripts')

diff --git a/scripts/upgrade_appservice_db.py b/scripts/upgrade_appservice_db.py
new file mode 100644
index 0000000000..acdee56d9f
--- /dev/null
+++ b/scripts/upgrade_appservice_db.py
@@ -0,0 +1,36 @@
+import argparse
+import json
+import sqlite3
+
+
+def main(dbname):
+    con = sqlite3.connect(dbname)
+    cur = con.cursor()
+    cur.execute("SELECT id, regex FROM application_services_regex")
+    for row in cur.fetchall():
+        try:
+            print "checking %s..." % row[0]
+            json.loads(row[1])
+            print "Already in new format"
+        except ValueError:
+            # row isn't in json, make it so.
+            string_regex = row[1]
+            new_regex = json.dumps({
+                "regex": string_regex,
+                "exclusive": True
+            })
+            cur.execute(
+                "UPDATE application_services_regex SET regex=? WHERE id=?",
+                (new_regex, row[0])
+            )
+    cur.close()
+    con.commit()
+
+
+if __name__ == "__main__":
+    parser = argparse.ArgumentParser()
+
+    parser.add_argument("database")
+    args = parser.parse_args()
+
+    main(args.database)
-- 
cgit 1.5.1


From c3c01641d2d49988c59826912e4e48740ab4f32a Mon Sep 17 00:00:00 2001
From: Kegan Dougal <kegan@matrix.org>
Date: Mon, 2 Mar 2015 13:38:57 +0000
Subject: Run deltas and bump user_version in upgrade script

---
 UPGRADE.rst                      |  5 +++++
 scripts/upgrade_appservice_db.py | 28 +++++++++++++++++++++++-----
 synapse/storage/__init__.py      |  2 +-
 3 files changed, 29 insertions(+), 6 deletions(-)

(limited to 'scripts')

diff --git a/UPGRADE.rst b/UPGRADE.rst
index 4045baf4e0..8cda8d02a0 100644
--- a/UPGRADE.rst
+++ b/UPGRADE.rst
@@ -12,6 +12,11 @@ Servers which use captchas will need to add their public key to::
 This is required in order to support registration fallback (typically used on
 mobile devices).
 
+Servers which have registered application services need to upgrade their
+database as the format of stored application services has changed in Synapse.
+Run ``python upgrade_appservice_db.py <database file path>`` to convert to the
+new format.
+
 Upgrading to v0.7.0
 ===================
 
diff --git a/scripts/upgrade_appservice_db.py b/scripts/upgrade_appservice_db.py
index acdee56d9f..ae1b91c64f 100644
--- a/scripts/upgrade_appservice_db.py
+++ b/scripts/upgrade_appservice_db.py
@@ -1,17 +1,28 @@
+from synapse.storage import read_schema
 import argparse
 import json
 import sqlite3
 
 
-def main(dbname):
-    con = sqlite3.connect(dbname)
-    cur = con.cursor()
+def do_other_deltas(cursor):
+    cursor.execute("PRAGMA user_version")
+    row = cursor.fetchone()
+
+    if row and row[0]:
+        user_version = row[0]
+        # Run every version since after the current version.
+        for v in range(user_version + 1, 10):
+            print "Running delta: %d" % (v,)
+            sql_script = read_schema("delta/v%d" % (v,))
+            cursor.executescript(sql_script)
+
+
+def update_app_service_table(cur):
     cur.execute("SELECT id, regex FROM application_services_regex")
     for row in cur.fetchall():
         try:
             print "checking %s..." % row[0]
             json.loads(row[1])
-            print "Already in new format"
         except ValueError:
             # row isn't in json, make it so.
             string_regex = row[1]
@@ -23,13 +34,20 @@ def main(dbname):
                 "UPDATE application_services_regex SET regex=? WHERE id=?",
                 (new_regex, row[0])
             )
+
+
+def main(dbname):
+    con = sqlite3.connect(dbname)
+    cur = con.cursor()
+    do_other_deltas(cur)
+    update_app_service_table(cur)
+    cur.execute("PRAGMA user_version = 14")
     cur.close()
     con.commit()
 
 
 if __name__ == "__main__":
     parser = argparse.ArgumentParser()
-
     parser.add_argument("database")
     args = parser.parse_args()
 
diff --git a/synapse/storage/__init__.py b/synapse/storage/__init__.py
index d16e7b8fac..3753cd28d0 100644
--- a/synapse/storage/__init__.py
+++ b/synapse/storage/__init__.py
@@ -74,7 +74,7 @@ SCHEMAS = [
 
 # Remember to update this number every time an incompatible change is made to
 # database schema files, so the users will be informed on server restarts.
-SCHEMA_VERSION = 13
+SCHEMA_VERSION = 14
 
 dir_path = os.path.abspath(os.path.dirname(__file__))
 
-- 
cgit 1.5.1