Merge pull request #3953 from ushahidi/twitter-urls-fix

fix(Twitter): urls are now formatted correctly for posts and messages

Author: theobadha

migrations/20200409232153_rewrite_twitter_urls.php

@@ -0,0 +1,63 @@
+<?php
+
+use Phinx\Migration\AbstractMigration;
+
+class RewriteTwitterUrls extends AbstractMigration
+{
+    /**
+     * Change Method.
+     *
+     * Write your reversible migrations using this method.
+     *
+     * More information on writing migrations is available here:
+     * http://docs.phinx.org/en/latest/migrations.html#the-abstractmigration-class
+     *
+     * The following commands can be used in this method and Phinx will
+     * automatically reverse them when rolling back:
+     *
+     *    createTable
+     *    renameTable
+     *    addColumn
+     *    renameColumn
+     *    addIndex
+     *    addForeignKey
+     *
+     * Remember to call "create()" or "update()" and NOT "save()" when working
+     * with the Table class.
+     */
+    public function up()
+    {
+        // phpcs:disable
+        $sql = "UPDATE posts INNER JOIN messages on messages.post_id = posts.id INNER JOIN contacts on messages.contact_id=contacts.id " .
+               "SET posts.content=" .
+               "REPLACE(posts.content, concat('https://twitter.com/statuses/', messages.data_source_message_id), " .
+               "concat('https://twitter.com/', contacts.contact, '/status/', messages.data_source_message_id)) " .
+               "WHERE `messages`.`type` = 'twitter'
+               AND messages.message=posts.content";
+        $this->execute($sql);
+        
+        $sql = "UPDATE messages INNER JOIN contacts on contacts.id = messages.contact_id " .
+                "SET messages.message = " .
+                "REPLACE(messages.message, concat('https://twitter.com/statuses/', messages.data_source_message_id), " .
+                "concat('https://twitter.com/', contacts.contact, '/status/', messages.data_source_message_id)) " .
+                "WHERE `messages`.`type` = 'twitter'";
+        $this->execute($sql);
+    }
+
+    public function down()
+    {
+        // phpcs:disable
+        $sql = "UPDATE posts INNER JOIN messages on messages.post_id = posts.id INNER JOIN contacts on messages.contact_id=contacts.id " .
+               "SET posts.content=" .
+               "REPLACE(messages.message, concat('https://twitter.com/', contacts.contact, '/status/', messages.data_source_message_id), " .
+               "concat('https://twitter.com/statuses/', messages.data_source_message_id)) " .
+               "WHERE `messages`.`type` = 'twitter' AND messages.message=posts.content";
+        $this->execute($sql);
+        $sql = "UPDATE messages INNER JOIN contacts on contacts.id = messages.contact_id " .
+                "SET messages.message = REPLACE(messages.message, " .
+                "concat('https://twitter.com/', contacts.contact, '/status/', messages.data_source_message_id), " .
+                "concat('https://twitter.com/statuses/', messages.data_source_message_id)) " .
+                "WHERE `messages`.`type` = 'twitter'";
+        $this->execute($sql);
+    }
+}