outline/server/migrations/20211221031430-create-pins.js

"use strict";

const { v4 } = require("uuid");

module.exports = {
  up: async (queryInterface, Sequelize) => {
    await queryInterface.createTable("pins", {
      id: {
        type: Sequelize.UUID,
        allowNull: false,
        primaryKey: true,
      },
      documentId: {
        type: Sequelize.UUID,
        allowNull: false,
        onDelete: "cascade",
        references: {
          model: "documents",
        },
      },
      collectionId: {
        type: Sequelize.UUID,
        allowNull: true,
        onDelete: "cascade",
        references: {
          model: "collections",
        },
      },
      teamId: {
        type: Sequelize.UUID,
        allowNull: false,
        onDelete: "cascade",
        references: {
          model: "teams",
        },
      },
      createdById: {
        type: Sequelize.UUID,
        allowNull: false,
        references: {
          model: "users",
        },
      },
      index: {
        type: Sequelize.STRING,
        allowNull: true,
      },
      createdAt: {
        type: Sequelize.DATE,
        allowNull: false,
      },
      updatedAt: {
        type: Sequelize.DATE,
        allowNull: false,
      },
    });
    await queryInterface.addIndex("pins", ["collectionId"]);

    const createdAt = new Date();
    const [documents] = await queryInterface.sequelize.query(
      `SELECT "id","collectionId","teamId","pinnedById" FROM documents WHERE "pinnedById" IS NOT NULL`
    );

    for (const document of documents) {
      await queryInterface.sequelize.query(
        `
        INSERT INTO pins (
          "id",
          "documentId",
          "collectionId",
          "teamId",
          "createdById",
          "createdAt",
          "updatedAt"
        )
        VALUES (
          :id,
          :documentId,
          :collectionId,
          :teamId,
          :createdById,
          :createdAt,
          :updatedAt
        )
      `,
        {
          replacements: {
            id: v4(),
            documentId: document.id,
            collectionId: document.collectionId,
            teamId: document.teamId,
            createdById: document.pinnedById,
            updatedAt: createdAt,
            createdAt,
          },
        }
      );
    }
  },
  down: async (queryInterface, Sequelize) => {
    return queryInterface.dropTable("pins");
  },
};