outline/server/queues/tasks/CacheIssueSourcesTask.ts

import { Integration } from "@server/models";
import { sequelize } from "@server/storage/database";
import { Hook, PluginManager } from "@server/utils/PluginManager";
import { BaseTask } from "./base/BaseTask";

type Props = {
  integrationId: string;
};

export default class CacheIssueSourcesTask extends BaseTask<Props> {
  async perform({ integrationId }: Props) {
    const integration = await Integration.findByPk(integrationId);
    if (!integration) {
      return;
    }

    const plugins = PluginManager.getHooks(Hook.IssueProvider);
    const plugin = plugins.find((p) => p.value.service === integration.service);
    if (!plugin) {
      return;
    }

    const sources = await plugin.value.fetchSources(integration);

    await sequelize.transaction(async (transaction) => {
      await integration.reload({ transaction, lock: transaction.LOCK.UPDATE });
      integration.issueSources = sources;
      await integration.save({ transaction });
    });
  }
}