Switch startup, config, commands and db migrations to mautrix-go systems
This commit is contained in:
@@ -5,7 +5,9 @@ import (
|
||||
"errors"
|
||||
|
||||
log "maunium.net/go/maulogger/v2"
|
||||
|
||||
"maunium.net/go/mautrix/id"
|
||||
"maunium.net/go/mautrix/util/dbutil"
|
||||
)
|
||||
|
||||
type Attachment struct {
|
||||
@@ -19,7 +21,7 @@ type Attachment struct {
|
||||
MatrixEventID id.EventID
|
||||
}
|
||||
|
||||
func (a *Attachment) Scan(row Scannable) *Attachment {
|
||||
func (a *Attachment) Scan(row dbutil.Scannable) *Attachment {
|
||||
err := row.Scan(
|
||||
&a.Channel.ChannelID, &a.Channel.Receiver,
|
||||
&a.DiscordMessageID, &a.DiscordAttachmentID,
|
||||
|
||||
@@ -1,97 +0,0 @@
|
||||
package database
|
||||
|
||||
import (
|
||||
"database/sql"
|
||||
|
||||
log "maunium.net/go/maulogger/v2"
|
||||
|
||||
"maunium.net/go/mautrix/crypto"
|
||||
"maunium.net/go/mautrix/id"
|
||||
)
|
||||
|
||||
type SQLCryptoStore struct {
|
||||
*crypto.SQLCryptoStore
|
||||
UserID id.UserID
|
||||
GhostIDFormat string
|
||||
}
|
||||
|
||||
var _ crypto.Store = (*SQLCryptoStore)(nil)
|
||||
|
||||
func NewSQLCryptoStore(db *Database, userID id.UserID, ghostIDFormat string) *SQLCryptoStore {
|
||||
return &SQLCryptoStore{
|
||||
SQLCryptoStore: crypto.NewSQLCryptoStore(db.DB, db.dialect, "", "",
|
||||
[]byte("maunium.net/go/mautrix-whatsapp"),
|
||||
&cryptoLogger{db.log.Sub("CryptoStore")}),
|
||||
UserID: userID,
|
||||
GhostIDFormat: ghostIDFormat,
|
||||
}
|
||||
}
|
||||
|
||||
func (store *SQLCryptoStore) FindDeviceID() id.DeviceID {
|
||||
var deviceID id.DeviceID
|
||||
|
||||
query := `SELECT device_id FROM crypto_account WHERE account_id=$1`
|
||||
err := store.DB.QueryRow(query, store.AccountID).Scan(&deviceID)
|
||||
if err != nil && err != sql.ErrNoRows {
|
||||
store.Log.Warn("Failed to scan device ID: %v", err)
|
||||
}
|
||||
|
||||
return deviceID
|
||||
}
|
||||
|
||||
func (store *SQLCryptoStore) GetRoomMembers(roomID id.RoomID) ([]id.UserID, error) {
|
||||
query := `
|
||||
SELECT user_id FROM mx_user_profile
|
||||
WHERE room_id=$1
|
||||
AND (membership='join' OR membership='invite')
|
||||
AND user_id<>$2
|
||||
AND user_id NOT LIKE $3
|
||||
`
|
||||
|
||||
members := []id.UserID{}
|
||||
|
||||
rows, err := store.DB.Query(query, roomID, store.UserID, store.GhostIDFormat)
|
||||
if err != nil {
|
||||
return members, err
|
||||
}
|
||||
|
||||
for rows.Next() {
|
||||
var userID id.UserID
|
||||
err := rows.Scan(&userID)
|
||||
if err != nil {
|
||||
store.Log.Warn("Failed to scan member in %s: %v", roomID, err)
|
||||
return members, err
|
||||
}
|
||||
|
||||
members = append(members, userID)
|
||||
}
|
||||
|
||||
return members, nil
|
||||
}
|
||||
|
||||
// TODO merge this with the one in the parent package
|
||||
type cryptoLogger struct {
|
||||
int log.Logger
|
||||
}
|
||||
|
||||
var levelTrace = log.Level{
|
||||
Name: "TRACE",
|
||||
Severity: -10,
|
||||
Color: -1,
|
||||
}
|
||||
|
||||
func (c *cryptoLogger) Error(message string, args ...interface{}) {
|
||||
c.int.Errorfln(message, args...)
|
||||
}
|
||||
|
||||
func (c *cryptoLogger) Warn(message string, args ...interface{}) {
|
||||
c.int.Warnfln(message, args...)
|
||||
}
|
||||
|
||||
func (c *cryptoLogger) Debug(message string, args ...interface{}) {
|
||||
c.int.Debugfln(message, args...)
|
||||
}
|
||||
|
||||
func (c *cryptoLogger) Trace(message string, args ...interface{}) {
|
||||
c.int.Logfln(levelTrace, message, args...)
|
||||
}
|
||||
@@ -1,20 +1,18 @@
|
||||
package database
|
||||
|
||||
import (
|
||||
"database/sql"
|
||||
_ "embed"
|
||||
"fmt"
|
||||
|
||||
_ "github.com/lib/pq"
|
||||
_ "github.com/mattn/go-sqlite3"
|
||||
|
||||
log "maunium.net/go/maulogger/v2"
|
||||
|
||||
"go.mau.fi/mautrix-discord/database/migrations"
|
||||
"go.mau.fi/mautrix-discord/database/upgrades"
|
||||
"maunium.net/go/mautrix/util/dbutil"
|
||||
)
|
||||
|
||||
type Database struct {
|
||||
*sql.DB
|
||||
log log.Logger
|
||||
dialect string
|
||||
*dbutil.Database
|
||||
|
||||
User *UserQuery
|
||||
Portal *PortalQuery
|
||||
@@ -26,70 +24,51 @@ type Database struct {
|
||||
Guild *GuildQuery
|
||||
}
|
||||
|
||||
func New(dbType, uri string, maxOpenConns, maxIdleConns int, baseLog log.Logger) (*Database, error) {
|
||||
conn, err := sql.Open(dbType, uri)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
//go:embed legacymigrate.sql
|
||||
var legacyMigrate string
|
||||
|
||||
func New(baseDB *dbutil.Database) *Database {
|
||||
db := &Database{Database: baseDB}
|
||||
_, err := db.Exec("SELECT id FROM version")
|
||||
if err == nil {
|
||||
baseDB.Log.Infoln("Migrating from legacy database versioning")
|
||||
_, err = db.Exec(legacyMigrate)
|
||||
if err != nil {
|
||||
panic(fmt.Errorf("failed to migrate from legacy database versioning: %v", err))
|
||||
}
|
||||
}
|
||||
|
||||
if dbType == "sqlite3" {
|
||||
conn.Exec("PRAGMA foreign_keys = ON")
|
||||
}
|
||||
|
||||
conn.SetMaxOpenConns(maxOpenConns)
|
||||
conn.SetMaxIdleConns(maxIdleConns)
|
||||
|
||||
dbLog := baseLog.Sub("Database")
|
||||
|
||||
if err := migrations.Run(conn, dbLog, dbType); err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
db := &Database{
|
||||
DB: conn,
|
||||
log: dbLog,
|
||||
dialect: dbType,
|
||||
}
|
||||
|
||||
db.UpgradeTable = upgrades.Table
|
||||
db.User = &UserQuery{
|
||||
db: db,
|
||||
log: db.log.Sub("User"),
|
||||
log: db.Log.Sub("User"),
|
||||
}
|
||||
|
||||
db.Portal = &PortalQuery{
|
||||
db: db,
|
||||
log: db.log.Sub("Portal"),
|
||||
log: db.Log.Sub("Portal"),
|
||||
}
|
||||
|
||||
db.Puppet = &PuppetQuery{
|
||||
db: db,
|
||||
log: db.log.Sub("Puppet"),
|
||||
log: db.Log.Sub("Puppet"),
|
||||
}
|
||||
|
||||
db.Message = &MessageQuery{
|
||||
db: db,
|
||||
log: db.log.Sub("Message"),
|
||||
log: db.Log.Sub("Message"),
|
||||
}
|
||||
|
||||
db.Reaction = &ReactionQuery{
|
||||
db: db,
|
||||
log: db.log.Sub("Reaction"),
|
||||
log: db.Log.Sub("Reaction"),
|
||||
}
|
||||
|
||||
db.Attachment = &AttachmentQuery{
|
||||
db: db,
|
||||
log: db.log.Sub("Attachment"),
|
||||
log: db.Log.Sub("Attachment"),
|
||||
}
|
||||
|
||||
db.Emoji = &EmojiQuery{
|
||||
db: db,
|
||||
log: db.log.Sub("Emoji"),
|
||||
log: db.Log.Sub("Emoji"),
|
||||
}
|
||||
|
||||
db.Guild = &GuildQuery{
|
||||
db: db,
|
||||
log: db.log.Sub("Guild"),
|
||||
log: db.Log.Sub("Guild"),
|
||||
}
|
||||
|
||||
return db, nil
|
||||
return db
|
||||
}
|
||||
|
||||
@@ -7,6 +7,7 @@ import (
|
||||
log "maunium.net/go/maulogger/v2"
|
||||
|
||||
"maunium.net/go/mautrix/id"
|
||||
"maunium.net/go/mautrix/util/dbutil"
|
||||
)
|
||||
|
||||
type Emoji struct {
|
||||
@@ -19,7 +20,7 @@ type Emoji struct {
|
||||
MatrixURL id.ContentURI
|
||||
}
|
||||
|
||||
func (e *Emoji) Scan(row Scannable) *Emoji {
|
||||
func (e *Emoji) Scan(row dbutil.Scannable) *Emoji {
|
||||
var matrixURL sql.NullString
|
||||
err := row.Scan(&e.DiscordID, &e.DiscordName, &matrixURL)
|
||||
|
||||
|
||||
@@ -5,6 +5,8 @@ import (
|
||||
"errors"
|
||||
|
||||
log "maunium.net/go/maulogger/v2"
|
||||
|
||||
"maunium.net/go/mautrix/util/dbutil"
|
||||
)
|
||||
|
||||
type Guild struct {
|
||||
@@ -17,7 +19,7 @@ type Guild struct {
|
||||
Bridge bool
|
||||
}
|
||||
|
||||
func (g *Guild) Scan(row Scannable) *Guild {
|
||||
func (g *Guild) Scan(row dbutil.Scannable) *Guild {
|
||||
err := row.Scan(&g.DiscordID, &g.GuildID, &g.GuildName, &g.Bridge)
|
||||
if err != nil {
|
||||
if !errors.Is(err, sql.ErrNoRows) {
|
||||
|
||||
10
database/legacymigrate.sql
Normal file
10
database/legacymigrate.sql
Normal file
@@ -0,0 +1,10 @@
|
||||
DROP TABLE version;
|
||||
CREATE TABLE version(version INTEGER PRIMARY KEY);
|
||||
INSERT INTO version VALUES (1);
|
||||
CREATE TABLE crypto_version (version INTEGER PRIMARY KEY);
|
||||
INSERT INTO crypto_version VALUES (6);
|
||||
CREATE TABLE mx_version (version INTEGER PRIMARY KEY);
|
||||
INSERT INTO mx_version VALUES (1);
|
||||
|
||||
UPDATE "user" SET id=null WHERE id='';
|
||||
ALTER TABLE "user" ADD CONSTRAINT user_id_key UNIQUE (id);
|
||||
@@ -6,7 +6,9 @@ import (
|
||||
"time"
|
||||
|
||||
log "maunium.net/go/maulogger/v2"
|
||||
|
||||
"maunium.net/go/mautrix/id"
|
||||
"maunium.net/go/mautrix/util/dbutil"
|
||||
)
|
||||
|
||||
type Message struct {
|
||||
@@ -22,7 +24,7 @@ type Message struct {
|
||||
Timestamp time.Time
|
||||
}
|
||||
|
||||
func (m *Message) Scan(row Scannable) *Message {
|
||||
func (m *Message) Scan(row dbutil.Scannable) *Message {
|
||||
var ts int64
|
||||
|
||||
err := row.Scan(&m.Channel.ChannelID, &m.Channel.Receiver, &m.DiscordID, &m.MatrixID, &m.AuthorID, &ts)
|
||||
|
||||
@@ -1,12 +0,0 @@
|
||||
CREATE TABLE attachment (
|
||||
channel_id TEXT NOT NULL,
|
||||
receiver TEXT NOT NULL,
|
||||
|
||||
discord_message_id TEXT NOT NULL,
|
||||
discord_attachment_id TEXT NOT NULL,
|
||||
|
||||
matrix_event_id TEXT NOT NULL UNIQUE,
|
||||
|
||||
PRIMARY KEY(discord_attachment_id, matrix_event_id),
|
||||
FOREIGN KEY(channel_id, receiver) REFERENCES portal(channel_id, receiver) ON DELETE CASCADE
|
||||
);
|
||||
@@ -1,5 +0,0 @@
|
||||
CREATE TABLE emoji (
|
||||
discord_id TEXT NOT NULL PRIMARY KEY,
|
||||
discord_name TEXT,
|
||||
matrix_url TEXT
|
||||
);
|
||||
@@ -1,2 +0,0 @@
|
||||
ALTER TABLE puppet ADD COLUMN custom_mxid TEXT;
|
||||
ALTER TABLE puppet ADD COLUMN access_token TEXT;
|
||||
@@ -1,2 +0,0 @@
|
||||
ALTER TABLE puppet ADD COLUMN next_batch TEXT;
|
||||
ALTER TABLE puppet ADD COLUMN enable_receipts BOOLEAN NOT NULL DEFAULT true;
|
||||
@@ -1 +0,0 @@
|
||||
ALTER TABLE "user" DROP CONSTRAINT user_id_key;
|
||||
@@ -1,18 +0,0 @@
|
||||
PRAGMA foreign_keys=off;
|
||||
|
||||
ALTER TABLE "user" RENAME TO "old_user";
|
||||
|
||||
CREATE TABLE "user" (
|
||||
mxid TEXT PRIMARY KEY,
|
||||
id TEXT,
|
||||
|
||||
management_room TEXT,
|
||||
|
||||
token TEXT
|
||||
);
|
||||
|
||||
INSERT INTO "user" SELECT mxid, id, management_room, token FROM "old_user";
|
||||
|
||||
DROP TABLE "old_user";
|
||||
|
||||
PRAGMA foreign_keys=on;
|
||||
@@ -1,7 +0,0 @@
|
||||
CREATE TABLE guild (
|
||||
discord_id TEXT NOT NULL,
|
||||
guild_id TEXT NOT NULL,
|
||||
guild_name TEXT NOT NULL,
|
||||
bridge BOOLEAN DEFAULT FALSE,
|
||||
PRIMARY KEY(discord_id, guild_id)
|
||||
);
|
||||
@@ -1,3 +0,0 @@
|
||||
-- This migration is implemented in migrations.go as it comes from
|
||||
-- maunium.net/go/mautrix/crypto/sql_store_upgrade. It runs upgrade at index 0
|
||||
-- which is described as "Add crypto store to database".
|
||||
@@ -1,3 +0,0 @@
|
||||
-- This migration is implemented in migrations.go as it comes from
|
||||
-- maunium.net/go/mautrix/crypto/sql_store_upgrade. It runs upgrade at index 1
|
||||
-- which is described as "Add account_id to crypto store".
|
||||
@@ -1,3 +0,0 @@
|
||||
-- This migration is implemented in migrations.go as it comes from
|
||||
-- maunium.net/go/mautrix/crypto/sql_store_upgrade. It runs upgrade at index 2
|
||||
-- which is described as "Add megolm withheld data to crypto store".
|
||||
@@ -1,3 +0,0 @@
|
||||
-- This migration is implemented in migrations.go as it comes from
|
||||
-- maunium.net/go/mautrix/crypto/sql_store_upgrade. It runs upgrade at index 3
|
||||
-- which is described as "Add cross-signing keys to crypto store".
|
||||
@@ -1,4 +0,0 @@
|
||||
-- This migration is implemented in migrations.go as it comes from
|
||||
-- maunium.net/go/mautrix/crypto/sql_store_upgrade. It runs upgrade at index 4
|
||||
-- which is described as "Replace VARCHAR(255) with TEXT in the crypto
|
||||
-- database".
|
||||
@@ -1,4 +0,0 @@
|
||||
-- This migration is implemented in migrations.go as it comes from
|
||||
-- maunium.net/go/mautrix/crypto/sql_store_upgrade. It runs upgrade at index 5
|
||||
-- which is described as "Split last_used into last_encrypted and
|
||||
-- last_decrypted in crypto store".
|
||||
@@ -1 +0,0 @@
|
||||
ALTER TABLE portal ADD COLUMN encrypted BOOLEAN NOT NULL DEFAULT false;
|
||||
@@ -1,120 +0,0 @@
|
||||
package migrations
|
||||
|
||||
import (
|
||||
"database/sql"
|
||||
"embed"
|
||||
|
||||
"github.com/lopezator/migrator"
|
||||
log "maunium.net/go/maulogger/v2"
|
||||
"maunium.net/go/mautrix/crypto/sql_store_upgrade"
|
||||
)
|
||||
|
||||
//go:embed *.sql
|
||||
var embeddedMigrations embed.FS
|
||||
|
||||
func migrationFromFile(description, filename string) *migrator.Migration {
|
||||
return &migrator.Migration{
|
||||
Name: description,
|
||||
Func: func(tx *sql.Tx) error {
|
||||
data, err := embeddedMigrations.ReadFile(filename)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
if _, err := tx.Exec(string(data)); err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
return nil
|
||||
},
|
||||
}
|
||||
}
|
||||
|
||||
func migrationFromFileWithDialect(dialect, description, sqliteFile, postgresFile string) *migrator.Migration {
|
||||
switch dialect {
|
||||
case "sqlite3":
|
||||
return migrationFromFile(description, sqliteFile)
|
||||
case "postgres":
|
||||
return migrationFromFile(description, postgresFile)
|
||||
default:
|
||||
return nil
|
||||
}
|
||||
}
|
||||
|
||||
func Run(db *sql.DB, baseLog log.Logger, dialect string) error {
|
||||
subLogger := baseLog.Sub("Migrations")
|
||||
logger := migrator.LoggerFunc(func(msg string, args ...interface{}) {
|
||||
subLogger.Infof(msg, args...)
|
||||
})
|
||||
|
||||
m, err := migrator.New(
|
||||
migrator.TableName("version"),
|
||||
migrator.WithLogger(logger),
|
||||
migrator.Migrations(
|
||||
migrationFromFile("Initial Schema", "01-initial.sql"),
|
||||
migrationFromFile("Attachments", "02-attachments.sql"),
|
||||
migrationFromFile("Emoji", "03-emoji.sql"),
|
||||
migrationFromFile("Custom Puppets", "04-custom-puppet.sql"),
|
||||
migrationFromFile(
|
||||
"Additional puppet fields",
|
||||
"05-additional-puppet-fields.sql",
|
||||
),
|
||||
migrationFromFileWithDialect(
|
||||
dialect,
|
||||
"Remove unique user constraint",
|
||||
"06-remove-unique-user-constraint.sqlite.sql",
|
||||
"06-remove-unique-user-constraint.postgres.sql",
|
||||
),
|
||||
migrationFromFile("Guild Bridging", "07-guilds.sql"),
|
||||
&migrator.Migration{
|
||||
Name: "Add crypto store to database",
|
||||
Func: func(tx *sql.Tx) error {
|
||||
return sql_store_upgrade.Upgrades[0](tx, dialect)
|
||||
},
|
||||
},
|
||||
&migrator.Migration{
|
||||
Name: "Add account_id to crypto store",
|
||||
Func: func(tx *sql.Tx) error {
|
||||
return sql_store_upgrade.Upgrades[1](tx, dialect)
|
||||
},
|
||||
},
|
||||
&migrator.Migration{
|
||||
Name: "Add megolm withheld data to crypto store",
|
||||
Func: func(tx *sql.Tx) error {
|
||||
return sql_store_upgrade.Upgrades[2](tx, dialect)
|
||||
},
|
||||
},
|
||||
&migrator.Migration{
|
||||
Name: "Add cross-signing keys to crypto store",
|
||||
Func: func(tx *sql.Tx) error {
|
||||
return sql_store_upgrade.Upgrades[3](tx, dialect)
|
||||
},
|
||||
},
|
||||
&migrator.Migration{
|
||||
Name: "Replace VARCHAR(255) with TEXT in the crypto database",
|
||||
Func: func(tx *sql.Tx) error {
|
||||
return sql_store_upgrade.Upgrades[4](tx, dialect)
|
||||
},
|
||||
},
|
||||
&migrator.Migration{
|
||||
Name: "Split last_used into last_encrypted and last_decrypted in crypto store",
|
||||
Func: func(tx *sql.Tx) error {
|
||||
return sql_store_upgrade.Upgrades[5](tx, dialect)
|
||||
},
|
||||
},
|
||||
migrationFromFile(
|
||||
"Add encryption column to portal table",
|
||||
"14-add-encrypted-column-to-portal-table.sql",
|
||||
),
|
||||
),
|
||||
)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
if err := m.Migrate(db); err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
return nil
|
||||
}
|
||||
@@ -6,7 +6,9 @@ import (
|
||||
"github.com/bwmarrin/discordgo"
|
||||
|
||||
log "maunium.net/go/maulogger/v2"
|
||||
|
||||
"maunium.net/go/mautrix/id"
|
||||
"maunium.net/go/mautrix/util/dbutil"
|
||||
)
|
||||
|
||||
type Portal struct {
|
||||
@@ -30,7 +32,7 @@ type Portal struct {
|
||||
FirstEventID id.EventID
|
||||
}
|
||||
|
||||
func (p *Portal) Scan(row Scannable) *Portal {
|
||||
func (p *Portal) Scan(row dbutil.Scannable) *Portal {
|
||||
var mxid, avatarURL, firstEventID sql.NullString
|
||||
var typ sql.NullInt32
|
||||
|
||||
|
||||
@@ -4,7 +4,9 @@ import (
|
||||
"database/sql"
|
||||
|
||||
log "maunium.net/go/maulogger/v2"
|
||||
|
||||
"maunium.net/go/mautrix/id"
|
||||
"maunium.net/go/mautrix/util/dbutil"
|
||||
)
|
||||
|
||||
const (
|
||||
@@ -34,7 +36,7 @@ type Puppet struct {
|
||||
EnableReceipts bool
|
||||
}
|
||||
|
||||
func (p *Puppet) Scan(row Scannable) *Puppet {
|
||||
func (p *Puppet) Scan(row dbutil.Scannable) *Puppet {
|
||||
var did, displayName, avatar, avatarURL sql.NullString
|
||||
var enablePresence sql.NullBool
|
||||
var customMXID, accessToken, nextBatch sql.NullString
|
||||
|
||||
@@ -5,7 +5,9 @@ import (
|
||||
"errors"
|
||||
|
||||
log "maunium.net/go/maulogger/v2"
|
||||
|
||||
"maunium.net/go/mautrix/id"
|
||||
"maunium.net/go/mautrix/util/dbutil"
|
||||
)
|
||||
|
||||
type Reaction struct {
|
||||
@@ -26,7 +28,7 @@ type Reaction struct {
|
||||
DiscordID string // The id or unicode of the emoji for discord
|
||||
}
|
||||
|
||||
func (r *Reaction) Scan(row Scannable) *Reaction {
|
||||
func (r *Reaction) Scan(row dbutil.Scannable) *Reaction {
|
||||
var discordID sql.NullString
|
||||
|
||||
err := row.Scan(
|
||||
|
||||
@@ -1,5 +0,0 @@
|
||||
package database
|
||||
|
||||
type Scannable interface {
|
||||
Scan(...interface{}) error
|
||||
}
|
||||
@@ -1,304 +0,0 @@
|
||||
package database
|
||||
|
||||
import (
|
||||
"database/sql"
|
||||
"encoding/json"
|
||||
"sync"
|
||||
|
||||
log "maunium.net/go/maulogger/v2"
|
||||
|
||||
"maunium.net/go/mautrix/appservice"
|
||||
"maunium.net/go/mautrix/event"
|
||||
"maunium.net/go/mautrix/id"
|
||||
)
|
||||
|
||||
type SQLStateStore struct {
|
||||
*appservice.TypingStateStore
|
||||
|
||||
db *Database
|
||||
log log.Logger
|
||||
|
||||
Typing map[id.RoomID]map[id.UserID]int64
|
||||
typingLock sync.RWMutex
|
||||
}
|
||||
|
||||
// make sure that SQLStateStore implements the appservice.StateStore interface
|
||||
var _ appservice.StateStore = (*SQLStateStore)(nil)
|
||||
|
||||
func NewSQLStateStore(db *Database) *SQLStateStore {
|
||||
return &SQLStateStore{
|
||||
TypingStateStore: appservice.NewTypingStateStore(),
|
||||
db: db,
|
||||
log: db.log.Sub("StateStore"),
|
||||
}
|
||||
}
|
||||
|
||||
func (s *SQLStateStore) IsRegistered(userID id.UserID) bool {
|
||||
var isRegistered bool
|
||||
|
||||
query := "SELECT EXISTS(SELECT 1 FROM mx_registrations WHERE user_id=$1)"
|
||||
row := s.db.QueryRow(query, userID)
|
||||
|
||||
err := row.Scan(&isRegistered)
|
||||
if err != nil {
|
||||
s.log.Warnfln("Failed to scan registration existence for %s: %v", userID, err)
|
||||
}
|
||||
|
||||
return isRegistered
|
||||
}
|
||||
|
||||
func (s *SQLStateStore) MarkRegistered(userID id.UserID) {
|
||||
query := "INSERT INTO mx_registrations (user_id) VALUES ($1)" +
|
||||
" ON CONFLICT (user_id) DO NOTHING"
|
||||
|
||||
_, err := s.db.Exec(query, userID)
|
||||
if err != nil {
|
||||
s.log.Warnfln("Failed to mark %s as registered: %v", userID, err)
|
||||
}
|
||||
}
|
||||
|
||||
func (s *SQLStateStore) IsTyping(roomID id.RoomID, userID id.UserID) bool {
|
||||
s.log.Debugln("IsTyping")
|
||||
|
||||
return false
|
||||
}
|
||||
|
||||
func (s *SQLStateStore) SetTyping(roomID id.RoomID, userID id.UserID, timeout int64) {
|
||||
s.log.Debugln("SetTyping")
|
||||
}
|
||||
|
||||
func (s *SQLStateStore) IsInRoom(roomID id.RoomID, userID id.UserID) bool {
|
||||
return s.IsMembership(roomID, userID, "join")
|
||||
}
|
||||
|
||||
func (s *SQLStateStore) IsInvited(roomID id.RoomID, userID id.UserID) bool {
|
||||
return s.IsMembership(roomID, userID, "join", "invite")
|
||||
}
|
||||
|
||||
func (s *SQLStateStore) IsMembership(roomID id.RoomID, userID id.UserID, allowedMemberships ...event.Membership) bool {
|
||||
membership := s.GetMembership(roomID, userID)
|
||||
for _, allowedMembership := range allowedMemberships {
|
||||
if allowedMembership == membership {
|
||||
return true
|
||||
}
|
||||
}
|
||||
|
||||
return false
|
||||
}
|
||||
|
||||
func (s *SQLStateStore) GetMembership(roomID id.RoomID, userID id.UserID) event.Membership {
|
||||
query := "SELECT membership FROM mx_user_profile WHERE " +
|
||||
"room_id=$1 AND user_id=$2"
|
||||
row := s.db.QueryRow(query, roomID, userID)
|
||||
|
||||
membership := event.MembershipLeave
|
||||
err := row.Scan(&membership)
|
||||
if err != nil && err != sql.ErrNoRows {
|
||||
s.log.Warnfln("Failed to scan membership of %s in %s: %v", userID, roomID, err)
|
||||
}
|
||||
|
||||
return membership
|
||||
}
|
||||
|
||||
func (s *SQLStateStore) GetMember(roomID id.RoomID, userID id.UserID) *event.MemberEventContent {
|
||||
member, ok := s.TryGetMember(roomID, userID)
|
||||
if !ok {
|
||||
member.Membership = event.MembershipLeave
|
||||
}
|
||||
|
||||
return member
|
||||
}
|
||||
|
||||
func (s *SQLStateStore) TryGetMember(roomID id.RoomID, userID id.UserID) (*event.MemberEventContent, bool) {
|
||||
query := "SELECT membership, displayname, avatar_url FROM mx_user_profile " +
|
||||
"WHERE room_id=$1 AND user_id=$2"
|
||||
row := s.db.QueryRow(query, roomID, userID)
|
||||
|
||||
var member event.MemberEventContent
|
||||
err := row.Scan(&member.Membership, &member.Displayname, &member.AvatarURL)
|
||||
if err != nil && err != sql.ErrNoRows {
|
||||
s.log.Warnfln("Failed to scan member info of %s in %s: %v", userID, roomID, err)
|
||||
}
|
||||
|
||||
return &member, err == nil
|
||||
}
|
||||
|
||||
func (s *SQLStateStore) SetMembership(roomID id.RoomID, userID id.UserID, membership event.Membership) {
|
||||
query := "INSERT INTO mx_user_profile (room_id, user_id, membership)" +
|
||||
" VALUES ($1, $2, $3) ON CONFLICT (room_id, user_id) DO UPDATE SET" +
|
||||
" membership=excluded.membership"
|
||||
|
||||
_, err := s.db.Exec(query, roomID, userID, membership)
|
||||
if err != nil {
|
||||
s.log.Warnfln("Failed to set membership of %s in %s to %s: %v", userID, roomID, membership, err)
|
||||
}
|
||||
}
|
||||
|
||||
func (s *SQLStateStore) SetMember(roomID id.RoomID, userID id.UserID, member *event.MemberEventContent) {
|
||||
query := "INSERT INTO mx_user_profile" +
|
||||
" (room_id, user_id, membership, displayname, avatar_url)" +
|
||||
" VALUES ($1, $2, $3, $4, $5) ON CONFLICT (room_id, user_id)" +
|
||||
" DO UPDATE SET membership=excluded.membership," +
|
||||
" displayname=excluded.displayname, avatar_url=excluded.avatar_url"
|
||||
_, err := s.db.Exec(query, roomID, userID, member.Membership, member.Displayname, member.AvatarURL)
|
||||
if err != nil {
|
||||
s.log.Warnfln("Failed to set membership of %s in %s to %s: %v", userID, roomID, member, err)
|
||||
}
|
||||
}
|
||||
|
||||
func (s *SQLStateStore) SetPowerLevels(roomID id.RoomID, levels *event.PowerLevelsEventContent) {
|
||||
levelsBytes, err := json.Marshal(levels)
|
||||
if err != nil {
|
||||
s.log.Errorfln("Failed to marshal power levels of %s: %v", roomID, err)
|
||||
return
|
||||
}
|
||||
|
||||
query := "INSERT INTO mx_room_state (room_id, power_levels)" +
|
||||
" VALUES ($1, $2) ON CONFLICT (room_id) DO UPDATE SET" +
|
||||
" power_levels=excluded.power_levels"
|
||||
_, err = s.db.Exec(query, roomID, levelsBytes)
|
||||
if err != nil {
|
||||
s.log.Warnfln("Failed to store power levels of %s: %v", roomID, err)
|
||||
}
|
||||
}
|
||||
|
||||
func (s *SQLStateStore) GetPowerLevels(roomID id.RoomID) *event.PowerLevelsEventContent {
|
||||
query := "SELECT power_levels FROM mx_room_state WHERE room_id=$1"
|
||||
row := s.db.QueryRow(query, roomID)
|
||||
if row == nil {
|
||||
return nil
|
||||
}
|
||||
|
||||
var data []byte
|
||||
err := row.Scan(&data)
|
||||
if err != nil {
|
||||
s.log.Errorfln("Failed to scan power levels of %s: %v", roomID, err)
|
||||
|
||||
return nil
|
||||
}
|
||||
|
||||
levels := &event.PowerLevelsEventContent{}
|
||||
err = json.Unmarshal(data, levels)
|
||||
if err != nil {
|
||||
s.log.Errorfln("Failed to parse power levels of %s: %v", roomID, err)
|
||||
|
||||
return nil
|
||||
}
|
||||
|
||||
return levels
|
||||
}
|
||||
|
||||
func (s *SQLStateStore) GetPowerLevel(roomID id.RoomID, userID id.UserID) int {
|
||||
if s.db.dialect == "postgres" {
|
||||
query := "SELECT COALESCE((power_levels->'users'->$2)::int," +
|
||||
" (power_levels->'users_default')::int, 0)" +
|
||||
" FROM mx_room_state WHERE room_id=$1"
|
||||
row := s.db.QueryRow(query, roomID, userID)
|
||||
if row == nil {
|
||||
// Power levels not in db
|
||||
return 0
|
||||
}
|
||||
|
||||
var powerLevel int
|
||||
err := row.Scan(&powerLevel)
|
||||
if err != nil {
|
||||
s.log.Errorfln("Failed to scan power level of %s in %s: %v", userID, roomID, err)
|
||||
}
|
||||
|
||||
return powerLevel
|
||||
}
|
||||
|
||||
return s.GetPowerLevels(roomID).GetUserLevel(userID)
|
||||
}
|
||||
|
||||
func (s *SQLStateStore) GetPowerLevelRequirement(roomID id.RoomID, eventType event.Type) int {
|
||||
if s.db.dialect == "postgres" {
|
||||
defaultType := "events_default"
|
||||
defaultValue := 0
|
||||
if eventType.IsState() {
|
||||
defaultType = "state_default"
|
||||
defaultValue = 50
|
||||
}
|
||||
|
||||
query := "SELECT COALESCE((power_levels->'events'->$2)::int," +
|
||||
" (power_levels->'$3')::int, $4)" +
|
||||
" FROM mx_room_state WHERE room_id=$1"
|
||||
row := s.db.QueryRow(query, roomID, eventType.Type, defaultType, defaultValue)
|
||||
if row == nil {
|
||||
// Power levels not in db
|
||||
return defaultValue
|
||||
}
|
||||
|
||||
var powerLevel int
|
||||
err := row.Scan(&powerLevel)
|
||||
if err != nil {
|
||||
s.log.Errorfln("Failed to scan power level for %s in %s: %v", eventType, roomID, err)
|
||||
}
|
||||
|
||||
return powerLevel
|
||||
}
|
||||
|
||||
return s.GetPowerLevels(roomID).GetEventLevel(eventType)
|
||||
}
|
||||
|
||||
func (s *SQLStateStore) HasPowerLevel(roomID id.RoomID, userID id.UserID, eventType event.Type) bool {
|
||||
if s.db.dialect == "postgres" {
|
||||
defaultType := "events_default"
|
||||
defaultValue := 0
|
||||
if eventType.IsState() {
|
||||
defaultType = "state_default"
|
||||
defaultValue = 50
|
||||
}
|
||||
|
||||
query := "SELECT COALESCE((power_levels->'users'->$2)::int," +
|
||||
" (power_levels->'users_default')::int, 0) >=" +
|
||||
" COALESCE((power_levels->'events'->$3)::int," +
|
||||
" (power_levels->'$4')::int, $5)" +
|
||||
" FROM mx_room_state WHERE room_id=$1"
|
||||
row := s.db.QueryRow(query, roomID, userID, eventType.Type, defaultType, defaultValue)
|
||||
if row == nil {
|
||||
// Power levels not in db
|
||||
return defaultValue == 0
|
||||
}
|
||||
|
||||
var hasPower bool
|
||||
err := row.Scan(&hasPower)
|
||||
if err != nil {
|
||||
s.log.Errorfln("Failed to scan power level for %s in %s: %v", eventType, roomID, err)
|
||||
}
|
||||
|
||||
return hasPower
|
||||
}
|
||||
|
||||
return s.GetPowerLevel(roomID, userID) >= s.GetPowerLevelRequirement(roomID, eventType)
|
||||
}
|
||||
|
||||
func (store *SQLStateStore) FindSharedRooms(userID id.UserID) []id.RoomID {
|
||||
query := `
|
||||
SELECT room_id FROM mx_user_profile
|
||||
LEFT JOIN portal ON portal.mxid=mx_user_profile.room_id
|
||||
WHERE user_id=$1 AND portal.encrypted=true
|
||||
`
|
||||
|
||||
rooms := []id.RoomID{}
|
||||
|
||||
rows, err := store.db.Query(query, userID)
|
||||
if err != nil {
|
||||
store.log.Warnfln("Failed to query shared rooms with %s: %v", userID, err)
|
||||
|
||||
return rooms
|
||||
}
|
||||
|
||||
for rows.Next() {
|
||||
var roomID id.RoomID
|
||||
|
||||
err = rows.Scan(&roomID)
|
||||
if err != nil {
|
||||
store.log.Warnfln("Failed to scan room ID: %v", err)
|
||||
} else {
|
||||
rooms = append(rooms, roomID)
|
||||
}
|
||||
}
|
||||
|
||||
return rooms
|
||||
}
|
||||
@@ -1,3 +1,5 @@
|
||||
-- v1: Initial revision
|
||||
|
||||
CREATE TABLE portal (
|
||||
channel_id TEXT,
|
||||
receiver TEXT,
|
||||
@@ -9,6 +11,8 @@ CREATE TABLE portal (
|
||||
avatar TEXT NOT NULL,
|
||||
avatar_url TEXT,
|
||||
|
||||
encrypted BOOLEAN NOT NULL DEFAULT false,
|
||||
|
||||
type INT,
|
||||
dmuser TEXT,
|
||||
|
||||
@@ -24,7 +28,12 @@ CREATE TABLE puppet (
|
||||
avatar TEXT,
|
||||
avatar_url TEXT,
|
||||
|
||||
enable_presence BOOLEAN NOT NULL DEFAULT true
|
||||
enable_presence BOOLEAN NOT NULL DEFAULT true,
|
||||
enable_receipts BOOLEAN NOT NULL DEFAULT true,
|
||||
|
||||
custom_mxid TEXT,
|
||||
access_token TEXT,
|
||||
next_batch TEXT
|
||||
);
|
||||
|
||||
CREATE TABLE "user" (
|
||||
@@ -38,12 +47,12 @@ CREATE TABLE "user" (
|
||||
|
||||
CREATE TABLE message (
|
||||
channel_id TEXT NOT NULL,
|
||||
receiver TEXT NOT NULL,
|
||||
receiver TEXT NOT NULL,
|
||||
|
||||
discord_message_id TEXT NOT NULL,
|
||||
matrix_message_id TEXT NOT NULL UNIQUE,
|
||||
matrix_message_id TEXT NOT NULL UNIQUE,
|
||||
|
||||
author_id TEXT NOT NULL,
|
||||
author_id TEXT NOT NULL,
|
||||
timestamp BIGINT NOT NULL,
|
||||
|
||||
PRIMARY KEY(discord_message_id, channel_id, receiver),
|
||||
@@ -52,10 +61,10 @@ CREATE TABLE message (
|
||||
|
||||
CREATE TABLE reaction (
|
||||
channel_id TEXT NOT NULL,
|
||||
receiver TEXT NOT NULL,
|
||||
receiver TEXT NOT NULL,
|
||||
|
||||
discord_message_id TEXT NOT NULL,
|
||||
matrix_event_id TEXT NOT NULL UNIQUE,
|
||||
matrix_event_id TEXT NOT NULL UNIQUE,
|
||||
|
||||
author_id TEXT NOT NULL,
|
||||
|
||||
@@ -68,20 +77,29 @@ CREATE TABLE reaction (
|
||||
FOREIGN KEY(channel_id, receiver) REFERENCES portal(channel_id, receiver) ON DELETE CASCADE
|
||||
);
|
||||
|
||||
CREATE TABLE mx_user_profile (
|
||||
room_id TEXT,
|
||||
user_id TEXT,
|
||||
membership TEXT NOT NULL,
|
||||
displayname TEXT,
|
||||
avatar_url TEXT,
|
||||
PRIMARY KEY (room_id, user_id)
|
||||
CREATE TABLE attachment (
|
||||
channel_id TEXT NOT NULL,
|
||||
receiver TEXT NOT NULL,
|
||||
|
||||
discord_message_id TEXT NOT NULL,
|
||||
discord_attachment_id TEXT NOT NULL,
|
||||
|
||||
matrix_event_id TEXT NOT NULL UNIQUE,
|
||||
|
||||
PRIMARY KEY(discord_attachment_id, matrix_event_id),
|
||||
FOREIGN KEY(channel_id, receiver) REFERENCES portal(channel_id, receiver) ON DELETE CASCADE
|
||||
);
|
||||
|
||||
CREATE TABLE mx_registrations (
|
||||
user_id TEXT PRIMARY KEY
|
||||
CREATE TABLE emoji (
|
||||
discord_id TEXT PRIMARY KEY,
|
||||
discord_name TEXT,
|
||||
matrix_url TEXT
|
||||
);
|
||||
|
||||
CREATE TABLE mx_room_state (
|
||||
room_id TEXT PRIMARY KEY,
|
||||
power_levels TEXT
|
||||
CREATE TABLE guild (
|
||||
discord_id TEXT NOT NULL,
|
||||
guild_id TEXT NOT NULL,
|
||||
guild_name TEXT NOT NULL,
|
||||
bridge BOOLEAN DEFAULT FALSE,
|
||||
PRIMARY KEY(discord_id, guild_id)
|
||||
);
|
||||
32
database/upgrades/upgrades.go
Normal file
32
database/upgrades/upgrades.go
Normal file
@@ -0,0 +1,32 @@
|
||||
// mautrix-discord - A Matrix-Discord puppeting bridge.
|
||||
// Copyright (C) 2022 Tulir Asokan
|
||||
//
|
||||
// This program is free software: you can redistribute it and/or modify
|
||||
// it under the terms of the GNU Affero General Public License as published by
|
||||
// the Free Software Foundation, either version 3 of the License, or
|
||||
// (at your option) any later version.
|
||||
//
|
||||
// This program is distributed in the hope that it will be useful,
|
||||
// but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
||||
// GNU Affero General Public License for more details.
|
||||
//
|
||||
// You should have received a copy of the GNU Affero General Public License
|
||||
// along with this program. If not, see <https://www.gnu.org/licenses/>.
|
||||
|
||||
package upgrades
|
||||
|
||||
import (
|
||||
"embed"
|
||||
|
||||
"maunium.net/go/mautrix/util/dbutil"
|
||||
)
|
||||
|
||||
var Table dbutil.UpgradeTable
|
||||
|
||||
//go:embed *.sql
|
||||
var rawUpgrades embed.FS
|
||||
|
||||
func init() {
|
||||
Table.RegisterFS(rawUpgrades)
|
||||
}
|
||||
@@ -4,7 +4,9 @@ import (
|
||||
"database/sql"
|
||||
|
||||
log "maunium.net/go/maulogger/v2"
|
||||
|
||||
"maunium.net/go/mautrix/id"
|
||||
"maunium.net/go/mautrix/util/dbutil"
|
||||
)
|
||||
|
||||
type User struct {
|
||||
@@ -19,10 +21,11 @@ type User struct {
|
||||
Token string
|
||||
}
|
||||
|
||||
func (u *User) Scan(row Scannable) *User {
|
||||
func (u *User) Scan(row dbutil.Scannable) *User {
|
||||
var token sql.NullString
|
||||
var discordID sql.NullString
|
||||
|
||||
err := row.Scan(&u.MXID, &u.ID, &u.ManagementRoom, &token)
|
||||
err := row.Scan(&u.MXID, &discordID, &u.ManagementRoom, &token)
|
||||
if err != nil {
|
||||
if err != sql.ErrNoRows {
|
||||
u.log.Errorln("Database scan failed:", err)
|
||||
@@ -35,6 +38,10 @@ func (u *User) Scan(row Scannable) *User {
|
||||
u.Token = token.String
|
||||
}
|
||||
|
||||
if discordID.Valid {
|
||||
u.ID = discordID.String
|
||||
}
|
||||
|
||||
return u
|
||||
}
|
||||
|
||||
@@ -44,13 +51,19 @@ func (u *User) Insert() {
|
||||
" VALUES ($1, $2, $3, $4);"
|
||||
|
||||
var token sql.NullString
|
||||
var discordID sql.NullString
|
||||
|
||||
if u.Token != "" {
|
||||
token.String = u.Token
|
||||
token.Valid = true
|
||||
}
|
||||
|
||||
_, err := u.db.Exec(query, u.MXID, u.ID, u.ManagementRoom, token)
|
||||
if u.ID != "" {
|
||||
discordID.String = u.ID
|
||||
discordID.Valid = true
|
||||
}
|
||||
|
||||
_, err := u.db.Exec(query, u.MXID, discordID, u.ManagementRoom, token)
|
||||
|
||||
if err != nil {
|
||||
u.log.Warnfln("Failed to insert %s: %v", u.MXID, err)
|
||||
@@ -63,13 +76,19 @@ func (u *User) Update() {
|
||||
" WHERE mxid=$4;"
|
||||
|
||||
var token sql.NullString
|
||||
var discordID sql.NullString
|
||||
|
||||
if u.Token != "" {
|
||||
token.String = u.Token
|
||||
token.Valid = true
|
||||
}
|
||||
|
||||
_, err := u.db.Exec(query, u.ID, u.ManagementRoom, token, u.MXID)
|
||||
if u.ID != "" {
|
||||
discordID.String = u.ID
|
||||
discordID.Valid = true
|
||||
}
|
||||
|
||||
_, err := u.db.Exec(query, discordID, u.ManagementRoom, token, u.MXID)
|
||||
|
||||
if err != nil {
|
||||
u.log.Warnfln("Failed to update %q: %v", u.MXID, err)
|
||||
|
||||
Reference in New Issue
Block a user