outline/server/queues/tasks/DetachDraftsFromCollectionTask.ts

import { Op } from "sequelize";
import documentMover from "@server/commands/documentMover";
import { Collection, Document, User } from "@server/models";
import { sequelize } from "@server/storage/database";
import { BaseTask } from "./base/BaseTask";
import { createContext } from "@server/context";

type Props = {
  collectionId: string;
  actorId: string;
  ip: string | null;
};

export default class DetachDraftsFromCollectionTask extends BaseTask<Props> {
  async perform(props: Props) {
    const [collection, actor] = await Promise.all([
      Collection.findByPk(props.collectionId, {
        paranoid: false,
      }),
      User.findByPk(props.actorId),
    ]);

    if (
      !actor ||
      !collection ||
      !(collection.deletedAt || collection.archivedAt)
    ) {
      return;
    }

    const documents = await Document.scope("withDrafts").findAll({
      where: {
        collectionId: props.collectionId,
        publishedAt: {
          [Op.is]: null,
        },
      },
      paranoid: false,
    });

    return sequelize.transaction(async (transaction) => {
      const ctx = createContext({
        user: actor,
        ip: props.ip,
        transaction,
      });

      for (const document of documents) {
        await documentMover(ctx, {
          document,
          collectionId: null,
        });
      }
    });
  }
}