From f8928932921e5259a0518cf7c52a6d61344b2c6c Mon Sep 17 00:00:00 2001 From: Nick Barrett Date: Fri, 17 Sep 2021 10:46:09 -0400 Subject: [PATCH] Enable the initial schema db upgrade. --- .../upgrades/2018-09-01-initial-schema.go | 328 +++++++++--------- 1 file changed, 164 insertions(+), 164 deletions(-) diff --git a/database/upgrades/2018-09-01-initial-schema.go b/database/upgrades/2018-09-01-initial-schema.go index 1cf5169..dafd93e 100644 --- a/database/upgrades/2018-09-01-initial-schema.go +++ b/database/upgrades/2018-09-01-initial-schema.go @@ -6,193 +6,193 @@ import ( func init() { upgrades[0] = upgrade{"Initial schema", func(tx *gorm.DB, ctx context) error { - // _, err := tx.Exec(`CREATE TABLE IF NOT EXISTS portal ( - // jid VARCHAR(255), - // receiver VARCHAR(255), - // mxid VARCHAR(255) UNIQUE, + _, err := tx.Exec(`CREATE TABLE IF NOT EXISTS portal ( + jid VARCHAR(255), + receiver VARCHAR(255), + mxid VARCHAR(255) UNIQUE, - // name VARCHAR(255) NOT NULL, - // topic VARCHAR(512) NOT NULL, - // avatar VARCHAR(255) NOT NULL, - // avatar_url VARCHAR(255), - // encrypted BOOLEAN NOT NULL DEFAULT false + name VARCHAR(255) NOT NULL, + topic VARCHAR(512) NOT NULL, + avatar VARCHAR(255) NOT NULL, + avatar_url VARCHAR(255), + encrypted BOOLEAN NOT NULL DEFAULT false - // PRIMARY KEY (jid, receiver) - // )`) - // if err != nil { - // return err - // } + PRIMARY KEY (jid, receiver) + )`) + if err != nil { + return err + } - // _, err = tx.Exec(`CREATE TABLE IF NOT EXISTS puppet ( - // jid VARCHAR(255) PRIMARY KEY, - // avatar VARCHAR(255), - // displayname VARCHAR(255), - // name_quality SMALLINT, - // custom_mxid VARCHAR(255), - // access_token VARCHAR(1023), - // next_batch VARCHAR(255), - // avatar_url VARCHAR(255), - // enable_presence BOOLEAN NOT NULL DEFAULT true, - // enable_receipts BOOLEAN NOT NULL DEFAULT true - // )`) - // if err != nil { - // return err - // } + _, err = tx.Exec(`CREATE TABLE IF NOT EXISTS puppet ( + jid VARCHAR(255) PRIMARY KEY, + avatar VARCHAR(255), + displayname VARCHAR(255), + name_quality SMALLINT, + custom_mxid VARCHAR(255), + access_token VARCHAR(1023), + next_batch VARCHAR(255), + avatar_url VARCHAR(255), + enable_presence BOOLEAN NOT NULL DEFAULT true, + enable_receipts BOOLEAN NOT NULL DEFAULT true + )`) + if err != nil { + return err + } - // _, err = tx.Exec(`CREATE TABLE IF NOT EXISTS "user" ( - // mxid VARCHAR(255) PRIMARY KEY, - // jid VARCHAR(255) UNIQUE, + _, err = tx.Exec(`CREATE TABLE IF NOT EXISTS "user" ( + mxid VARCHAR(255) PRIMARY KEY, + jid VARCHAR(255) UNIQUE, - // management_room VARCHAR(255), + management_room VARCHAR(255), - // client_id VARCHAR(255), - // client_token VARCHAR(255), - // server_token VARCHAR(255), - // enc_key bytea, - // mac_key bytea, - // last_connection BIGINT NOT NULL DEFAULT 0 - // )`) - // if err != nil { - // return err - // } + client_id VARCHAR(255), + client_token VARCHAR(255), + server_token VARCHAR(255), + enc_key bytea, + mac_key bytea, + last_connection BIGINT NOT NULL DEFAULT 0 + )`) + if err != nil { + return err + } - // _, err = tx.Exec(`CREATE TABLE IF NOT EXISTS "user_portal" ( - // user_jid VARCHAR(255), - // portal_jid VARCHAR(255), - // portal_receiver VARCHAR(255), - // in_community BOOLEAN NOT NULL DEFAULT FALSE, + _, err = tx.Exec(`CREATE TABLE IF NOT EXISTS "user_portal" ( + user_jid VARCHAR(255), + portal_jid VARCHAR(255), + portal_receiver VARCHAR(255), + in_community BOOLEAN NOT NULL DEFAULT FALSE, - // PRIMARY KEY (user_jid, portal_jid, portal_receiver), + PRIMARY KEY (user_jid, portal_jid, portal_receiver), - // FOREIGN KEY (user_jid) REFERENCES "user"(jid) ON DELETE CASCADE, - // FOREIGN KEY (portal_jid, portal_receiver) REFERENCES portal(jid, receiver) ON DELETE CASCADE - // )`) - // if err != nil { - // return err - // } + FOREIGN KEY (user_jid) REFERENCES "user"(jid) ON DELETE CASCADE, + FOREIGN KEY (portal_jid, portal_receiver) REFERENCES portal(jid, receiver) ON DELETE CASCADE + )`) + if err != nil { + return err + } - // _, err = tx.Exec(`CREATE TABLE IF NOT EXISTS message ( - // chat_jid VARCHAR(255), - // chat_receiver VARCHAR(255), - // jid VARCHAR(255), - // mxid VARCHAR(255) NOT NULL UNIQUE, - // sender VARCHAR(255) NOT NULL, - // content bytea NOT NULL, - // timestamp BIGINT NOT NULL DEFAULT 0, + _, err = tx.Exec(`CREATE TABLE IF NOT EXISTS message ( + chat_jid VARCHAR(255), + chat_receiver VARCHAR(255), + jid VARCHAR(255), + mxid VARCHAR(255) NOT NULL UNIQUE, + sender VARCHAR(255) NOT NULL, + content bytea NOT NULL, + timestamp BIGINT NOT NULL DEFAULT 0, - // PRIMARY KEY (chat_jid, chat_receiver, jid), - // FOREIGN KEY (chat_jid, chat_receiver) REFERENCES portal(jid, receiver) ON DELETE CASCADE - // )`) - // if err != nil { - // return err - // } + PRIMARY KEY (chat_jid, chat_receiver, jid), + FOREIGN KEY (chat_jid, chat_receiver) REFERENCES portal(jid, receiver) ON DELETE CASCADE + )`) + if err != nil { + return err + } - // _, err = tx.Exec(`CREATE TABLE IF NOT EXISTS mx_registrations ( - // user_id VARCHAR(255) PRIMARY KEY - // )`) - // if err != nil { - // return err - // } + _, err = tx.Exec(`CREATE TABLE IF NOT EXISTS mx_registrations ( + user_id VARCHAR(255) PRIMARY KEY + )`) + if err != nil { + return err + } - // _, err = tx.Exec(`CREATE TABLE IF NOT EXISTS mx_room_state ( - // room_id VARCHAR(255) PRIMARY KEY, - // power_levels TEXT - // )`) - // if err != nil { - // return err - // } + _, err = tx.Exec(`CREATE TABLE IF NOT EXISTS mx_room_state ( + room_id VARCHAR(255) PRIMARY KEY, + power_levels TEXT + )`) + if err != nil { + return err + } - // _, err = tx.Exec(`CREATE TABLE IF NOT EXISTS mx_user_profile ( - // room_id VARCHAR(255), - // user_id VARCHAR(255), - // membership VARCHAR(15) NOT NULL, - // PRIMARY KEY (room_id, user_id), - // displayname TEXT, - // avatar_url VARCHAR(255) - // )`) - // if err != nil { - // return err - // } + _, err = tx.Exec(`CREATE TABLE IF NOT EXISTS mx_user_profile ( + room_id VARCHAR(255), + user_id VARCHAR(255), + membership VARCHAR(15) NOT NULL, + PRIMARY KEY (room_id, user_id), + displayname TEXT, + avatar_url VARCHAR(255) + )`) + if err != nil { + return err + } - // _, err = tx.Exec(`CREATE TABLE IF NOT EXISTS crypto_olm_session ( - // session_id CHAR(43) PRIMARY KEY, - // sender_key CHAR(43) NOT NULL, - // session bytea NOT NULL, - // created_at timestamp NOT NULL, - // last_used timestamp NOT NULL - // )`) - // if err != nil { - // return err - // } + _, err = tx.Exec(`CREATE TABLE IF NOT EXISTS crypto_olm_session ( + session_id CHAR(43) PRIMARY KEY, + sender_key CHAR(43) NOT NULL, + session bytea NOT NULL, + created_at timestamp NOT NULL, + last_used timestamp NOT NULL + )`) + if err != nil { + return err + } - // _, err = tx.Exec(`CREATE TABLE crypto_megolm_inbound_session ( - // session_id CHAR(43) PRIMARY KEY, - // sender_key CHAR(43) NOT NULL, - // signing_key CHAR(43) NOT NULL, - // room_id VARCHAR(255) NOT NULL, - // session bytea NOT NULL, - // forwarding_chains bytea NOT NULL - // )`) - // if err != nil { - // return err - // } + _, err = tx.Exec(`CREATE TABLE crypto_megolm_inbound_session ( + session_id CHAR(43) PRIMARY KEY, + sender_key CHAR(43) NOT NULL, + signing_key CHAR(43) NOT NULL, + room_id VARCHAR(255) NOT NULL, + session bytea NOT NULL, + forwarding_chains bytea NOT NULL + )`) + if err != nil { + return err + } - // _, err = tx.Exec(`CREATE TABLE crypto_device ( - // user_id VARCHAR(255), - // device_id VARCHAR(255), - // identity_key CHAR(43) NOT NULL, - // signing_key CHAR(43) NOT NULL, - // trust SMALLINT NOT NULL, - // deleted BOOLEAN NOT NULL, - // name VARCHAR(255) NOT NULL, + _, err = tx.Exec(`CREATE TABLE crypto_device ( + user_id VARCHAR(255), + device_id VARCHAR(255), + identity_key CHAR(43) NOT NULL, + signing_key CHAR(43) NOT NULL, + trust SMALLINT NOT NULL, + deleted BOOLEAN NOT NULL, + name VARCHAR(255) NOT NULL, - // PRIMARY KEY (user_id, device_id) - // )`) + PRIMARY KEY (user_id, device_id) + )`) - // _, err = tx.Exec(`CREATE TABLE crypto_tracked_user ( - // user_id VARCHAR(255) PRIMARY KEY - // )`) - // if err != nil { - // return err - // } + _, err = tx.Exec(`CREATE TABLE crypto_tracked_user ( + user_id VARCHAR(255) PRIMARY KEY + )`) + if err != nil { + return err + } - // _, err = tx.Exec(`CREATE TABLE crypto_message_index ( - // sender_key CHAR(43), - // session_id CHAR(43), - // "index" INTEGER, - // event_id VARCHAR(255) NOT NULL, - // timestamp BIGINT NOT NULL, + _, err = tx.Exec(`CREATE TABLE crypto_message_index ( + sender_key CHAR(43), + session_id CHAR(43), + "index" INTEGER, + event_id VARCHAR(255) NOT NULL, + timestamp BIGINT NOT NULL, - // PRIMARY KEY (sender_key, session_id, "index") - // )`) - // if err != nil { - // return err - // } + PRIMARY KEY (sender_key, session_id, "index") + )`) + if err != nil { + return err + } - // _, err = tx.Exec(`CREATE TABLE crypto_account ( - // device_id VARCHAR(255) PRIMARY KEY, - // shared BOOLEAN NOT NULL, - // sync_token TEXT NOT NULL, - // account bytea NOT NULL - // )`) - // if err != nil { - // return err - // } + _, err = tx.Exec(`CREATE TABLE crypto_account ( + device_id VARCHAR(255) PRIMARY KEY, + shared BOOLEAN NOT NULL, + sync_token TEXT NOT NULL, + account bytea NOT NULL + )`) + if err != nil { + return err + } - // _, err = tx.Exec(`CREATE TABLE crypto_megolm_outbound_session ( - // room_id VARCHAR(255) PRIMARY KEY, - // session_id CHAR(43) NOT NULL UNIQUE, - // session bytea NOT NULL, - // shared BOOLEAN NOT NULL, - // max_messages INTEGER NOT NULL, - // message_count INTEGER NOT NULL, - // max_age BIGINT NOT NULL, - // created_at timestamp NOT NULL, - // last_used timestamp NOT NULL - // )`) - // if err != nil { - // return err - // } + _, err = tx.Exec(`CREATE TABLE crypto_megolm_outbound_session ( + room_id VARCHAR(255) PRIMARY KEY, + session_id CHAR(43) NOT NULL UNIQUE, + session bytea NOT NULL, + shared BOOLEAN NOT NULL, + max_messages INTEGER NOT NULL, + message_count INTEGER NOT NULL, + max_age BIGINT NOT NULL, + created_at timestamp NOT NULL, + last_used timestamp NOT NULL + )`) + if err != nil { + return err + } return nil }}