OF-3131: Move 'subject' from history to room

distribution/src/database/openfire_db2.sql

@@ -205,7 +205,7 @@ CREATE TABLE ofMucRoom (
   logEnabled          INTEGER       NOT NULL,
   preserveHistOnDel   INTEGER       NOT NULL,
   retireOnDeletion    INTEGER       NOT NULL,
-  subject             VARCHAR(100),
+  subject             CLOB,
   rolesToBroadcast    INTEGER       NOT NULL,
   useReservedNick     INTEGER       NOT NULL,
   canChangeNick       INTEGER       NOT NULL,
@@ -403,4 +403,4 @@ INSERT INTO ofUser (username, plainPassword, name, email, creationDate, modifica
 INSERT INTO ofMucService (serviceID, subdomain, isHidden) VALUES (1, 'conference', 0);
 
 -- Do this last, as it is used by a continuous integration check to verify that the entire script was executed successfully.
-INSERT INTO ofVersion (name, version) VALUES ('openfire', 37);
+INSERT INTO ofVersion (name, version) VALUES ('openfire', 38);

distribution/src/database/openfire_hsqldb.sql

@@ -202,7 +202,7 @@ CREATE TABLE ofMucRoom (
   logEnabled          INTEGER       NOT NULL,
   retireOnDeletion    INTEGER       NOT NULL,
   preserveHistOnDel   INTEGER       NOT NULL,
-  subject             VARCHAR(100)  NULL,
+  subject             LONGVARCHAR   NULL,
   rolesToBroadcast    INTEGER       NOT NULL,
   useReservedNick     INTEGER       NOT NULL,
   canChangeNick       INTEGER       NOT NULL,
@@ -391,7 +391,7 @@ INSERT INTO ofUser (username, plainPassword, name, email, creationDate, modifica
 INSERT INTO ofMucService (serviceID, subdomain, isHidden) VALUES (1, 'conference', 0);
 
 // Do this last, as it is used by a continuous integration check to verify that the entire script was executed successfully.
-INSERT INTO ofVersion (name, version) VALUES ('openfire', 37);
+INSERT INTO ofVersion (name, version) VALUES ('openfire', 38);
 
 // The value is the size in megabytes that the .log file can reach before an automatic
 // checkpoint occurs. A checkpoint rewrites the .script file and clears the .log file

distribution/src/database/openfire_mysql.sql

@@ -192,7 +192,7 @@ CREATE TABLE ofMucRoom (
   logEnabled          TINYINT       NOT NULL,
   retireOnDeletion    TINYINT       NOT NULL,
   preserveHistOnDel   TINYINT       NOT NULL,
-  subject             VARCHAR(100)  NULL,
+  subject             TEXT          NULL,
   rolesToBroadcast    TINYINT       NOT NULL,
   useReservedNick     TINYINT       NOT NULL,
   canChangeNick       TINYINT       NOT NULL,
@@ -381,4 +381,4 @@ INSERT INTO ofUser (username, plainPassword, name, email, creationDate, modifica
 INSERT INTO ofMucService (serviceID, subdomain, isHidden) VALUES (1, 'conference', 0);
 
 # Do this last, as it is used by a continuous integration check to verify that the entire script was executed successfully.
-INSERT INTO ofVersion (name, version) VALUES ('openfire', 37);
+INSERT INTO ofVersion (name, version) VALUES ('openfire', 38);

distribution/src/database/openfire_oracle.sql

@@ -199,7 +199,7 @@ CREATE TABLE ofMucRoom(
   logEnabled          INTEGER       NOT NULL,
   retireOnDeletion    INTEGER       NOT NULL,
   preserveHistOnDel   INTEGER       NOT NULL,
-  subject             VARCHAR2(100) NULL,
+  subject             VARCHAR2(4000) NULL,
   rolesToBroadcast    INTEGER       NOT NULL,
   useReservedNick     INTEGER       NOT NULL,
   canChangeNick       INTEGER       NOT NULL,
@@ -389,6 +389,6 @@ INSERT INTO ofUser (username, plainPassword, name, email, creationDate, modifica
 INSERT INTO ofMucService (serviceID, subdomain, isHidden) VALUES (1, 'conference', 0);
 
 -- Do this last, as it is used by a continuous integration check to verify that the entire script was executed successfully.
-INSERT INTO ofVersion (name, version) VALUES ('openfire', 37);
+INSERT INTO ofVersion (name, version) VALUES ('openfire', 38);
 
 commit;

distribution/src/database/openfire_postgresql.sql

@@ -207,7 +207,7 @@ CREATE TABLE ofMucRoom (
   logEnabled          INTEGER       NOT NULL,
   retireOnDeletion    INTEGER       NOT NULL,
   preserveHistOnDel   INTEGER       NOT NULL,
-  subject             VARCHAR(100)  NULL,
+  subject             TEXT          NULL,
   rolesToBroadcast    INTEGER       NOT NULL,
   useReservedNick     INTEGER       NOT NULL,
   canChangeNick       INTEGER       NOT NULL,
@@ -397,4 +397,4 @@ INSERT INTO ofUser (username, plainPassword, name, email, creationDate, modifica
 INSERT INTO ofMucService (serviceID, subdomain, isHidden) VALUES (1, 'conference', 0);
 
 -- Do this last, as it is used by a continuous integration check to verify that the entire script was executed successfully.
-INSERT INTO ofVersion (name, version) VALUES ('openfire', 37);
+INSERT INTO ofVersion (name, version) VALUES ('openfire', 38);

distribution/src/database/openfire_sqlserver.sql

@@ -205,7 +205,7 @@ CREATE TABLE ofMucRoom (
   logEnabled          INT           NOT NULL,
   retireOnDeletion    INT           NOT NULL,
   preserveHistOnDel   INT           NOT NULL,
-  subject             NVARCHAR(100) NULL,
+  subject             NTEXT         NULL,
   rolesToBroadcast    INT           NOT NULL,
   useReservedNick     INT           NOT NULL,
   canChangeNick       INT           NOT NULL,
@@ -394,4 +394,4 @@ INSERT INTO ofUser (username, plainPassword, name, email, creationDate, modifica
 INSERT INTO ofMucService (serviceID, subdomain, isHidden) VALUES (1, 'conference', 0);
 
 /* Do this last, as it is used by a continuous integration check to verify that the entire script was executed successfully. */
-INSERT INTO ofVersion (name, version) VALUES ('openfire', 37);
+INSERT INTO ofVersion (name, version) VALUES ('openfire', 38);

distribution/src/database/openfire_sybase.sql

@@ -204,7 +204,7 @@ CREATE TABLE ofMucRoom (
   logEnabled          INT           NOT NULL,
   retireOnDeletion    INT           NOT NULL,
   preserveHistOnDel   INT           NOT NULL,
-  subject             NVARCHAR(100) NULL,
+  subject             TEXT          NULL,
   rolesToBroadcast    INT           NOT NULL,
   useReservedNick     INT           NOT NULL,
   canChangeNick       INT           NOT NULL,
@@ -394,4 +394,4 @@ INSERT INTO ofUser (username, plainPassword, name, email, creationDate, modifica
 INSERT INTO ofMucService (serviceID, subdomain, isHidden) VALUES (1, 'conference', 0)
 
 /* Do this last, as it is used by a continuous integration check to verify that the entire script was executed successfully. */
-INSERT INTO ofVersion (name, version) VALUES ('openfire', 37)
+INSERT INTO ofVersion (name, version) VALUES ('openfire', 38)

distribution/src/database/upgrade/38/openfire_db2.sql

@@ -0,0 +1,24 @@
+-- This copies the subject-defining stanza as stored in the message archive into the room's table, replacing any text
+-- based (non-stanza) subject that was stored there.
+-- In rare occasions (see OF-3131) the room can have a subject, while the history does not. In those cases, this script
+-- leaves the (non-stanza) subject in the ofMucRoom table intact (this means that the column holds a mixture of plain
+-- text and XMPP data).
+-- Note that the stanzas in ofMucConversationLog typically do not contain a timestamp (although one is provided in a
+-- separate column). If the subject that gets migrated to ofMucRoom is used as-is, the time of subject change is likely
+-- lost (until the room's subject gets changed). This is deemed an acceptable loss.
+ALTER TABLE ofMucRoom ALTER COLUMN subject SET DATA TYPE CLOB;
+
+UPDATE ofMucRoom r
+SET subject = (
+    SELECT stanza
+    FROM (
+        SELECT roomID, stanza,
+               ROW_NUMBER() OVER (PARTITION BY roomID ORDER BY logTime DESC) AS rn
+        FROM ofMucConversationLog
+        WHERE subject IS NOT NULL
+    ) l
+    WHERE l.roomID = r.roomID
+      AND l.rn = 1
+);
+
+UPDATE ofVersion SET version = 38 WHERE name = 'openfire';

distribution/src/database/upgrade/38/openfire_hsqldb.sql

@@ -0,0 +1,33 @@
+-- This copies the subject-defining stanza as stored in the message archive into the room's table, replacing any text
+-- based (non-stanza) subject that was stored there.
+-- In rare occasions (see OF-3131) the room can have a subject, while the history does not. In those cases, this script
+-- leaves the (non-stanza) subject in the ofMucRoom table intact (this means that the column holds a mixture of plain
+-- text and XMPP data).
+-- Note that the stanzas in ofMucConversationLog typically do not contain a timestamp (although one is provided in a
+-- separate column). If the subject that gets migrated to ofMucRoom is used as-is, the time of subject change is likely
+-- lost (until the room's subject gets changed). This is deemed an acceptable loss.
+ALTER TABLE ofMucRoom ALTER COLUMN subject SET DATA TYPE LONGVARCHAR;
+
+CREATE INDEX ofMucConversationLog_room_subject_time_idx
+    ON ofMucConversationLog(roomID, subject, logTime);
+
+UPDATE ofMucRoom r
+SET subject = (
+    SELECT l1.stanza
+    FROM ofMucConversationLog l1
+    JOIN (
+        SELECT roomID, MAX(logTime) AS maxTime
+        FROM ofMucConversationLog
+        WHERE subject IS NOT NULL
+        GROUP BY roomID
+    ) lm
+    ON lm.roomID = l1.roomID
+    AND lm.maxTime = l1.logTime
+    WHERE l1.roomID = r.roomID
+      AND l1.subject IS NOT NULL
+      AND l1.stanza IS NOT NULL
+);
+
+DROP INDEX ofMucConversationLog_room_subject_time_idx;
+
+UPDATE ofVersion SET version = 38 WHERE name = 'openfire';

distribution/src/database/upgrade/38/openfire_mysql.sql

@@ -0,0 +1,28 @@
+-- This copies the subject-defining stanza as stored in the message archive into the room's table, replacing any text
+-- based (non-stanza) subject that was stored there.
+-- In rare occasions (see OF-3131) the room can have a subject, while the history does not. In those cases, this script
+-- leaves the (non-stanza) subject in the ofMucRoom table intact (this means that the column holds a mixture of plain
+-- text and XMPP data).
+-- Note that the stanzas in ofMucConversationLog typically do not contain a timestamp (although one is provided in a
+-- separate column). If the subject that gets migrated to ofMucRoom is used as-is, the time of subject change is likely
+-- lost (until the room's subject gets changed). This is deemed an acceptable loss.
+ALTER TABLE ofMucRoom MODIFY subject TEXT NULL;
+
+UPDATE ofMucRoom r
+JOIN (
+    SELECT l.roomID, l.stanza
+    FROM ofMucConversationLog l
+    JOIN (
+        SELECT roomID, MAX(logTime) AS maxTime
+        FROM ofMucConversationLog
+        WHERE subject IS NOT NULL
+        GROUP BY roomID
+    ) latest
+    ON l.roomID = latest.roomID
+    AND l.logTime = latest.maxTime
+) c
+ON r.roomID = c.roomID
+SET r.subject = c.stanza
+WHERE c.stanza IS NOT NULL;
+
+UPDATE ofVersion SET version = 38 WHERE name = 'openfire';

distribution/src/database/upgrade/38/openfire_oracle.sql

@@ -0,0 +1,26 @@
+-- This copies the subject-defining stanza as stored in the message archive into the room's table, replacing any text
+-- based (non-stanza) subject that was stored there.
+-- In rare occasions (see OF-3131) the room can have a subject, while the history does not. In those cases, this script
+-- leaves the (non-stanza) subject in the ofMucRoom table intact (this means that the column holds a mixture of plain
+-- text and XMPP data).
+-- Note that the stanzas in ofMucConversationLog typically do not contain a timestamp (although one is provided in a
+-- separate column). If the subject that gets migrated to ofMucRoom is used as-is, the time of subject change is likely
+-- lost (until the room's subject gets changed). This is deemed an acceptable loss.
+ALTER TABLE ofMucRoom MODIFY subject VARCHAR2(4000);
+
+MERGE INTO ofMucRoom r
+USING (
+    SELECT roomID, stanza
+    FROM (
+        SELECT roomID, stanza,
+               ROW_NUMBER() OVER (PARTITION BY roomID ORDER BY logTime DESC) AS rn
+        FROM ofMucConversationLog
+        WHERE subject IS NOT NULL
+    ) t
+    WHERE rn = 1
+) c
+ON (r.roomID = c.roomID)
+WHEN MATCHED THEN
+  UPDATE SET r.subject = c.stanza;
+
+UPDATE ofVersion SET version = 38 WHERE name = 'openfire';

distribution/src/database/upgrade/38/openfire_postgresql.sql

@@ -0,0 +1,22 @@
+-- This copies the subject-defining stanza as stored in the message archive into the room's table, replacing any text
+-- based (non-stanza) subject that was stored there.
+-- In rare occasions (see OF-3131) the room can have a subject, while the history does not. In those cases, this script
+-- leaves the (non-stanza) subject in the ofMucRoom table intact (this means that the column holds a mixture of plain
+-- text and XMPP data).
+-- Note that the stanzas in ofMucConversationLog typically do not contain a timestamp (although one is provided in a
+-- separate column). If the subject that gets migrated to ofMucRoom is used as-is, the time of subject change is likely
+-- lost (until the room's subject gets changed). This is deemed an acceptable loss.
+ALTER TABLE ofMucRoom ALTER COLUMN subject TYPE TEXT;
+
+UPDATE ofMucRoom r
+SET subject = c.stanza
+FROM (
+    SELECT DISTINCT ON (roomID) roomID, stanza
+    FROM ofMucConversationLog
+    WHERE subject IS NOT NULL
+    ORDER BY roomID, logTime DESC
+) c
+WHERE c.roomID = r.roomID
+AND c.stanza IS NOT NULL;
+
+UPDATE ofVersion SET version = 38 WHERE name = 'openfire';

distribution/src/database/upgrade/38/openfire_sqlserver.sql

@@ -0,0 +1,25 @@
+-- This copies the subject-defining stanza as stored in the message archive into the room's table, replacing any text
+-- based (non-stanza) subject that was stored there.
+-- In rare occasions (see OF-3131) the room can have a subject, while the history does not. In those cases, this script
+-- leaves the (non-stanza) subject in the ofMucRoom table intact (this means that the column holds a mixture of plain
+-- text and XMPP data).
+-- Note that the stanzas in ofMucConversationLog typically do not contain a timestamp (although one is provided in a
+-- separate column). If the subject that gets migrated to ofMucRoom is used as-is, the time of subject change is likely
+-- lost (until the room's subject gets changed). This is deemed an acceptable loss.
+ALTER TABLE ofMucRoom ALTER COLUMN subject NTEXT NULL;
+
+WITH LatestLogs AS (
+    SELECT roomID, stanza,
+           ROW_NUMBER() OVER (PARTITION BY roomID ORDER BY logTime DESC) AS rn
+    FROM ofMucConversationLog
+    WHERE subject IS NOT NULL
+)
+UPDATE r
+SET r.subject = l.stanza
+FROM ofMucRoom r
+JOIN LatestLogs l
+  ON r.roomID = l.roomID
+WHERE l.rn = 1
+  AND l.stanza IS NOT NULL;
+
+UPDATE ofVersion SET version = 38 WHERE name = 'openfire';

distribution/src/database/upgrade/38/openfire_sybase.sql

@@ -0,0 +1,25 @@
+-- This copies the subject-defining stanza as stored in the message archive into the room's table, replacing any text
+-- based (non-stanza) subject that was stored there.
+-- In rare occasions (see OF-3131) the room can have a subject, while the history does not. In those cases, this script
+-- leaves the (non-stanza) subject in the ofMucRoom table intact (this means that the column holds a mixture of plain
+-- text and XMPP data).
+-- Note that the stanzas in ofMucConversationLog typically do not contain a timestamp (although one is provided in a
+-- separate column). If the subject that gets migrated to ofMucRoom is used as-is, the time of subject change is likely
+-- lost (until the room's subject gets changed). This is deemed an acceptable loss.
+ALTER TABLE ofMucRoom ALTER COLUMN subject TEXT NULL;
+
+WITH LatestLogs AS (
+    SELECT roomID, stanza,
+           ROW_NUMBER() OVER (PARTITION BY roomID ORDER BY logTime DESC) AS rn
+    FROM ofMucConversationLog
+    WHERE subject IS NOT NULL
+)
+UPDATE r
+SET r.subject = l.stanza
+FROM ofMucRoom r
+JOIN LatestLogs l
+  ON r.roomID = l.roomID
+WHERE l.rn = 1
+  AND l.stanza IS NOT NULL;
+
+UPDATE ofVersion SET version = 38 WHERE name = 'openfire';

xmppserver/src/main/java/org/jivesoftware/database/SchemaManager.java

@@ -68,7 +68,7 @@ public class SchemaManager {
     /**
      * Current Openfire database schema version.
      */
-    private static final int DATABASE_VERSION = 37;
+    private static final int DATABASE_VERSION = 38;
 
     /**
      * Checks the Openfire database schema to ensure that it's installed and up to date.

xmppserver/src/main/java/org/jivesoftware/openfire/muc/HistoryStrategy.java

@@ -88,7 +88,9 @@ public class HistoryStrategy implements Externalizable {
 
     /**
      * Track the latest room subject change or null if none exists yet.
+     * @deprecated Since Openfire 5.1.0, a room's subject is managed by {@link MUCRoom} directly.
      */
+    @Deprecated(forRemoval = true) // Remove in or after Openfire 5.2.0
     private Message roomSubject = null;
 
     /**
@@ -434,7 +436,9 @@ public void setContext(String subdomain, String prefix) {
      *
      * @return true if there is a message within the history of the room that has changed the
      *         room's subject.
+     * @deprecated Since Openfire 5.1.0, a room's subject is managed by {@link MUCRoom} directly.
      */
+    @Deprecated(forRemoval = true) // Remove in or after Openfire 5.2.0
     public boolean hasChangedSubject() {
         return roomSubject != null;
     }
@@ -444,7 +448,9 @@ public boolean hasChangedSubject() {
      * room's subject.
      * 
      * @return the latest room subject change or null if none exists yet.
+     * @deprecated Since Openfire 5.1.0, a room's subject is managed by {@link MUCRoom} directly.
      */
+    @Deprecated(forRemoval = true) // Remove in or after Openfire 5.2.0
     @Nullable
     public Message getChangedSubject() {
         return roomSubject;