From ac514b406c2288e27565ed0a84d4e1dfd70c4848 Mon Sep 17 00:00:00 2001
From: danielaloni <1danielaloni@gmail.com>
Date: Wed, 4 Jan 2023 13:19:01 +0200
Subject: [PATCH] =?UTF-8?q?=F0=9F=90=9B=20Migration=20to=20have=20the=20co?=
 =?UTF-8?q?rrect=20composite=20primary=20key=20in=20roomserver=5Fpublished?=
 =?UTF-8?q?.?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../postgres/deltas/20221027084407_published_appservice.go | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git a/roomserver/storage/postgres/deltas/20221027084407_published_appservice.go b/roomserver/storage/postgres/deltas/20221027084407_published_appservice.go
index 687ee9024..077234b6e 100644
--- a/roomserver/storage/postgres/deltas/20221027084407_published_appservice.go
+++ b/roomserver/storage/postgres/deltas/20221027084407_published_appservice.go
@@ -29,6 +29,13 @@ func UpPulishedAppservice(ctx context.Context, tx *sql.Tx) error {
 	if err != nil {
 		return fmt.Errorf("failed to execute upgrade: %w", err)
 	}
+	_, err = tx.ExecContext(ctx, `
+		ALTER TABLE roomserver_published DROP CONSTRAINT IF EXISTS roomserver_published_pkey;
+		ALTER TABLE roomserver_published ADD PRIMARY KEY (room_id, appservice_id, network_id);
+	`)
+	if err != nil {
+		return fmt.Errorf("failed to execute upgrade: %w", err)
+	}
 	return nil
 }