diff options
| author | 2023-03-02 03:06:40 -0800 | |
|---|---|---|
| committer | 2023-03-02 12:06:40 +0100 | |
| commit | e6cde25466e03ec864cd9defed96957e741b5e7c (patch) | |
| tree | 2fe1db6383efc9b788de8bb3f9926627874ccd7c /internal/db/bundb/migrations | |
| parent | [chore] move client/federator workerpools to Workers{} (#1575) (diff) | |
| download | gotosocial-e6cde25466e03ec864cd9defed96957e741b5e7c.tar.xz | |
[feature] Advertise rich text formats, support content_type field (#1370)
* Advertise rich text formats, support content_type field
* Update JSON in instance patch tests
* Replace format with content_type everywhere
* update migration to work with both pg and sqlite
* regenerate swagger docs
* update instance serialization + tests
* fix up
* learn to code tobi please, i'm begging you
---------
Co-authored-by: tsmethurst <tobi.smethurst@protonmail.com>
Diffstat (limited to 'internal/db/bundb/migrations')
| -rw-r--r-- | internal/db/bundb/migrations/20230126170719_format_to_content_type.go | 96 | 
1 files changed, 96 insertions, 0 deletions
| diff --git a/internal/db/bundb/migrations/20230126170719_format_to_content_type.go b/internal/db/bundb/migrations/20230126170719_format_to_content_type.go new file mode 100644 index 000000000..f8ffb9087 --- /dev/null +++ b/internal/db/bundb/migrations/20230126170719_format_to_content_type.go @@ -0,0 +1,96 @@ +/* +   GoToSocial +   Copyright (C) 2021-2023 GoToSocial Authors admin@gotosocial.org + +   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 <http://www.gnu.org/licenses/>. +*/ + +package migrations + +import ( +	"context" +	"strings" + +	"github.com/uptrace/bun" +	"github.com/uptrace/bun/dialect" +) + +func init() { +	up := func(ctx context.Context, db *bun.DB) error { +		return db.RunInTx(ctx, nil, func(ctx context.Context, tx bun.Tx) error { +			// Create a new column for status_content_type. +			if _, err := tx.ExecContext(ctx, "ALTER TABLE ? ADD COLUMN ? TEXT", bun.Ident("accounts"), bun.Ident("status_content_type")); err != nil && +				!(strings.Contains(err.Error(), "already exists") || strings.Contains(err.Error(), "duplicate column name") || strings.Contains(err.Error(), "SQLSTATE 42701")) { +				return err +			} + +			// Port values into this column from the old status_format column, +			// prepending 'text/' to the value to derive the mime type. +			// +			// Eg, 'plain' status_format becomes 'text/plain' status_content_type. +			q := tx. +				NewUpdate(). +				Table("accounts"). +				Where("? IS NOT NULL", bun.Ident("status_format")) + +			// We need to switch here because Postgres and SQLite +			// have different syntaxes for concatenation. +			switch tx.Dialect().Name() { +			case dialect.SQLite: +				q = q. +					Set("? = ? || ?", bun.Ident("status_content_type"), "text/", bun.Ident("status_format")) +			case dialect.PG: +				q = q. +					Set("? = CONCAT(?, ?)", bun.Ident("status_content_type"), "text/", bun.Ident("status_format")) +			default: +				panic("db conn was neither pg not sqlite") +			} + +			if _, err := q.Exec(ctx); err != nil { +				return err +			} + +			// Drop the old status_format column. +			if _, err := tx.ExecContext(ctx, "ALTER TABLE ? DROP COLUMN ?", bun.Ident("accounts"), bun.Ident("status_format")); err != nil && +				!(strings.Contains(err.Error(), "no such column") || strings.Contains(err.Error(), "does not exist") || strings.Contains(err.Error(), "SQLSTATE 42703")) { +				return err +			} + +			return nil +		}) +	} + +	down := func(ctx context.Context, db *bun.DB) error { +		return db.RunInTx(ctx, nil, func(ctx context.Context, tx bun.Tx) error { +			var err error +			_, err = db.ExecContext(ctx, "ALTER TABLE ? ADD COLUMN ? TEXT", bun.Ident("accounts"), bun.Ident("status_format")) +			if err != nil && !(strings.Contains(err.Error(), "already exists") || strings.Contains(err.Error(), "duplicate column name") || strings.Contains(err.Error(), "SQLSTATE 42701")) { +				return err +			} +			_, err = db.ExecContext(ctx, "UPDATE ? SET ? = SUBSTR(?, 6) WHERE ? IS NOT NULL", bun.Ident("accounts"), bun.Ident("status_format"), bun.Ident("status_content_type"), bun.Ident("status_content_type")) +			if err != nil { +				return err +			} +			_, err = db.ExecContext(ctx, "ALTER TABLE ? DROP COLUMN ?", bun.Ident("accounts"), bun.Ident("status_content_type")) +			if err != nil { +				return err +			} +			return nil +		}) +	} + +	if err := Migrations.Register(up, down); err != nil { +		panic(err) +	} +} | 
