diff options
| author | 2023-11-11 10:15:04 +0000 | |
|---|---|---|
| committer | 2023-11-11 10:15:04 +0000 | |
| commit | deaea100c37698893e97cf9cab159a3d220ac3cd (patch) | |
| tree | f48abc96964652d1701d91c88a00174c8f1b0196 /internal/db | |
| parent | [feature] Media attachment placeholders (#2331) (diff) | |
| download | gotosocial-deaea100c37698893e97cf9cab159a3d220ac3cd.tar.xz | |
[bugfix] support endless polls, and misskey's' method of inferring expiry in closed polls (#2349)
Diffstat (limited to 'internal/db')
| -rw-r--r-- | internal/db/bundb/basic_test.go | 2 | ||||
| -rw-r--r-- | internal/db/bundb/instance_test.go | 2 | ||||
| -rw-r--r-- | internal/db/bundb/migrations/20231110142330_small_poll_table_tweaks.go | 84 | 
3 files changed, 86 insertions, 2 deletions
| diff --git a/internal/db/bundb/basic_test.go b/internal/db/bundb/basic_test.go index 403a3888a..67973a171 100644 --- a/internal/db/bundb/basic_test.go +++ b/internal/db/bundb/basic_test.go @@ -121,7 +121,7 @@ func (suite *BasicTestSuite) TestGetAllStatuses() {  	s := []*gtsmodel.Status{}  	err := suite.db.GetAll(context.Background(), &s)  	suite.NoError(err) -	suite.Len(s, 21) +	suite.Len(s, 22)  }  func (suite *BasicTestSuite) TestGetAllNotNull() { diff --git a/internal/db/bundb/instance_test.go b/internal/db/bundb/instance_test.go index d88825a33..f2ac202ef 100644 --- a/internal/db/bundb/instance_test.go +++ b/internal/db/bundb/instance_test.go @@ -53,7 +53,7 @@ func (suite *InstanceTestSuite) TestCountInstanceStatuses() {  func (suite *InstanceTestSuite) TestCountInstanceStatusesRemote() {  	count, err := suite.db.CountInstanceStatuses(context.Background(), "fossbros-anonymous.io")  	suite.NoError(err) -	suite.Equal(2, count) +	suite.Equal(3, count)  }  func (suite *InstanceTestSuite) TestCountInstanceDomains() { diff --git a/internal/db/bundb/migrations/20231110142330_small_poll_table_tweaks.go b/internal/db/bundb/migrations/20231110142330_small_poll_table_tweaks.go new file mode 100644 index 000000000..c9f2b3d0f --- /dev/null +++ b/internal/db/bundb/migrations/20231110142330_small_poll_table_tweaks.go @@ -0,0 +1,84 @@ +// GoToSocial +// Copyright (C) GoToSocial Authors admin@gotosocial.org +// SPDX-License-Identifier: AGPL-3.0-or-later +// +// 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" + +	"github.com/uptrace/bun" +) + +func init() { +	up := func(ctx context.Context, db *bun.DB) error { +		return db.RunInTx(ctx, nil, func(ctx context.Context, tx bun.Tx) error { +			// Add new poll expiry column WITHOUT +			// the previously set NULL constraint. +			if _, err := tx.NewAddColumn(). +				Table("polls"). +				ColumnExpr("? TIMESTAMPTZ", bun.Ident("expires_at_new")). +				Exec(ctx); err != nil { +				return err +			} + +			// Copy all data from old to new, +			// this won't cause anyn issues as +			// old column is NOT NULL and it's +			// only the new column that drops +			// this constraint to allow NULL. +			if _, err := tx.NewUpdate(). +				Table("polls"). +				Column("expires_at_new"). +				Set("? = ?", bun.Ident("expires_at_new"), bun.Ident("expires_at")). +				Where("1"). // bun gets angry performing update over all rows +				Exec(ctx); err != nil { +				return err +			} + +			// Drop the old poll expiry column. +			if _, err := tx.NewDropColumn(). +				Table("polls"). +				ColumnExpr("?", bun.Ident("expires_at")). +				Exec(ctx); err != nil { +				return err +			} + +			// Rename the new expiry column +			// to the correct name (of the old). +			if _, err := tx.NewRaw( +				"ALTER TABLE ? RENAME COLUMN ? TO ?", +				bun.Ident("polls"), +				bun.Ident("expires_at_new"), +				bun.Ident("expires_at"), +			).Exec(ctx); err != nil { +				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 { +			return nil +		}) +	} + +	if err := Migrations.Register(up, down); err != nil { +		panic(err) +	} +} | 
